SQL 2012 エージェント ジョブ状態プロバイダー

Microsoft.SQLServer.2012.AgentJobStatus (DataSourceModuleType)

SQL 2012 Agent Job Status Provider

Element properties:

TypeDataSourceModuleType
IsolationAny
AccessibilityInternal
RunAsMicrosoft.SQLServer.SQLProbeAccount
OutputTypeSystem.PropertyBagData

Member Modules:

ID Module Type TypeId RunAs 
DS DataSource Microsoft.Windows.TimedScript.PropertyBagProvider Default

Overrideable Parameters:

IDParameterTypeSelectorDisplay NameDescription
IntervalSecondsint$Config/IntervalSeconds$間隔 (秒)
SyncTimestring$Config/SyncTime$同期時刻
TimeoutSecondsint$Config/TimeoutSeconds$タイムアウト (秒)

Source Code:

<DataSourceModuleType ID="Microsoft.SQLServer.2012.AgentJobStatus" Accessibility="Internal" RunAs="SQL!Microsoft.SQLServer.SQLProbeAccount">
<Configuration>
<xsd:element xmlns:xsd="http://www.w3.org/2001/XMLSchema" name="IntervalSeconds" type="xsd:integer"/>
<xsd:element xmlns:xsd="http://www.w3.org/2001/XMLSchema" name="SyncTime" type="xsd:string"/>
<xsd:element xmlns:xsd="http://www.w3.org/2001/XMLSchema" name="ConnectionString" type="xsd:string"/>
<xsd:element xmlns:xsd="http://www.w3.org/2001/XMLSchema" name="TimeoutSeconds" type="xsd:int"/>
</Configuration>
<OverrideableParameters>
<OverrideableParameter ID="IntervalSeconds" ParameterType="int" Selector="$Config/IntervalSeconds$"/>
<OverrideableParameter ID="SyncTime" ParameterType="string" Selector="$Config/SyncTime$"/>
<OverrideableParameter ID="TimeoutSeconds" ParameterType="int" Selector="$Config/TimeoutSeconds$"/>
</OverrideableParameters>
<ModuleImplementation>
<Composite>
<MemberModules>
<DataSource ID="DS" TypeID="Windows!Microsoft.Windows.TimedScript.PropertyBagProvider">
<IntervalSeconds>$Config/IntervalSeconds$</IntervalSeconds>
<SyncTime>$Config/SyncTime$</SyncTime>
<ScriptName>GetSQL2012AgentJobStatus.vbs</ScriptName>
<Arguments>$Config/ConnectionString$ $Target/Host/Host/Property[Type="SQL!Microsoft.SQLServer.DBEngine"]/TcpPort$ $Target/Host/Host/Host/Property[Type="Windows!Microsoft.Windows.Computer"]/NetworkName$ $Target/Host/Host/Property[Type="SQL!Microsoft.SQLServer.DBEngine"]/ServiceName$</Arguments>
<ScriptBody><Script>'#Include File:Initialize.vbs

Option Explicit
SetLocale("en-us")

Function Quit()
WScript.Quit()
End Function

Function IsValidObject(ByVal oObject)
IsValidObject = False

If IsObject(oObject) Then
If Not oObject Is Nothing Then
IsValidObject = True
End If
End If
End Function

Function MomCreateObject(ByVal sProgramId)
Dim oError
Set oError = New Error

On Error Resume Next
Set MomCreateObject = CreateObject(sProgramId)
oError.Save
On Error GoTo 0

If oError.Number &lt;&gt; 0 Then ThrowScriptError "Unable to create automation object '" &amp; sProgramId &amp; "'", oError
End Function
'#Include File:Error.vbs

Class Error
Private m_lNumber
Private m_sSource
Private m_sDescription
Private m_sHelpContext
Private m_sHelpFile

Public Sub Save()
m_lNumber = Err.Number
m_sSource = Err.Source
m_sDescription = Err.Description
m_sHelpContext = Err.HelpContext
m_sHelpFile = Err.HelpFile
End Sub

Public Sub Raise()
Err.Raise m_lNumber, m_sSource, m_sDescription, m_sHelpFile, m_sHelpContext
End Sub

Public Sub Clear()
m_lNumber = 0
m_sSource = ""
m_sDescription = ""
m_sHelpContext = ""
m_sHelpFile = ""
End Sub

Public Default Property Get Number()
Number = m_lNumber
End Property
Public Property Get Source()
Source = m_sSource
End Property
Public Property Get Description()
Description = m_sDescription
End Property
Public Property Get HelpContext()
HelpContext = m_sHelpContext
End Property
Public Property Get HelpFile()
HelpFile = m_sHelpFile
End Property
End Class

Function ThrowScriptErrorNoAbort(ByVal sMessage, ByVal oErr)
On Error Resume Next
Dim oAPITemp
Set oAPITemp = MOMCreateObject("MOM.ScriptAPI")
oAPITemp.LogScriptEvent WScript.ScriptName, 4001, 1, sMessage &amp; ". " &amp; oErr.Description
End Function

Function ThrowScriptError(Byval sMessage, ByVal oErr)
On Error Resume Next
ThrowScriptErrorNoAbort sMessage, oErr
Quit()
End Function

Sub HandleError(customMessage)
Dim localLogger
If Not (Err.number = 0) Then
Set localLogger = new ScriptLogger
localLogger.LogFormattedError(customMessage)
Wscript.Quit 0
End If
End Sub

Function HandleErrorContinue(customMessage)
Dim localLogger
HandleErrorContinue = False
If Not (Err.number = 0) Then
Set localLogger = new ScriptLogger
localLogger.LogFormattedError(customMessage)
Err.Clear
HandleErrorContinue = True
End If
End Function

'#Include File:ConnectionString.vbs

Function BuildConnectionString(strServer, strDatabase)
ON ERROR RESUME NEXT
Err.Clear

Dim dataSource
dataSource = BuildServerName(strServer, "")
BuildConnectionString = "Data Source=" &amp; EscapeConnStringValue(dataSource) &amp; ";Initial Catalog=" &amp; EscapeConnStringValue(strDatabase) &amp; ";Integrated Security=SSPI"
End Function

Function BuildConnectionStringWithPort(ByVal strServer, ByVal strDatabase, ByVal tcpPort)
ON ERROR RESUME NEXT
Err.Clear

Dim dataSource
dataSource = strServer
If ((tcpPort &lt;&gt; "0") And (tcpPort &lt;&gt; "")) Then
dataSource = dataSource &amp; "," &amp; tcpPort
End If
BuildConnectionStringWithPort = "Data Source=" &amp; EscapeConnStringValue(dataSource) &amp; ";Initial Catalog=" &amp; EscapeConnStringValue(strDatabase) &amp; ";Integrated Security=SSPI"
End Function

' This function should be used to escape Connection String keywords.
Function EscapeConnStringValue (ByVal strValue)
ON ERROR RESUME NEXT
Err.Clear

EscapeConnStringValue = """" + Replace(strValue, """", """""") + """"
End Function

Function EscapeWQLString (ByVal strValue)
ON ERROR RESUME NEXT
Err.Clear

EscapeWQLString = Replace(strValue, "'", "\'")
End Function

Function GetTcpPort (ByVal strServer)
ON ERROR RESUME NEXT
Err.Clear

Dim tcpPort
tcpPort = ""

Call BuildServerName(strServer, tcpPort)

GetTcpPort = tcpPort

End Function

Function BuildServerName(ByVal strServer, ByRef tcp)
ON ERROR RESUME NEXT
Err.Clear

Dim pathArray, instanceName, computerName, ip, serverName
Dim oWMI, oQuery

ip= ""

pathArray = Split(strServer, "\")
computerName = pathArray(0)
instanceName = "MSSQLSERVER"
if (pathArray.Count &gt; 1) Then
instanceName = pathArray(1)
End If

serverName = strServer

Set oWMI = GetObject("winmgmts:\\" &amp; computerName &amp; "\root\Microsoft\SqlServer\" &amp; SQL_WMI_NAMESPACE)
Set oQuery = oWMI.ExecQuery("SELECT * FROM ServerNetworkProtocolProperty WHERE ProtocolName = 'Tcp' AND InstanceName = '"&amp; EscapeWQLString(instanceName) &amp;"' AND PropertyName = 'ListenOnAllIPs'")

If oQuery.Count &gt;0 Then
Dim isListenAll
Set isListenAll = oQuery.ItemIndex(0)
If(isListenAll.PropertyNumVal = 1) Then
Set oQuery = oWMI.ExecQuery("SELECT * FROM ServerNetworkProtocolProperty WHERE ProtocolName = 'Tcp' AND InstanceName = '"&amp; EscapeWQLString(instanceName) &amp;"' AND IPAddressName = 'IPAll' AND (PropertyName = 'TcpPort' OR PropertyName = 'TcpDynamicPorts') AND PropertyStrVal &lt;&gt; ''")

If (oQuery.Count &gt; 0) Then
tcp = oQuery.ItemIndex(0).PropertyStrVal

If ((tcp &lt;&gt; "0") And (tcp &lt;&gt; "")) Then
serverName = serverName &amp; "," &amp; tcp
Else tcp = ""
End If
End If
Else
Set oQuery = oWMI.ExecQuery("SELECT * FROM ServerNetworkProtocolProperty WHERE ProtocolName = 'Tcp' AND InstanceName = '"&amp; EscapeWQLString(instanceName) &amp;"' AND IPAddressName &lt;&gt; '' AND PropertyName = 'Enabled' AND PropertyNumVal = 1")
If (oQuery.Count &gt; 0) Then
Dim ipAddressName
ipAddressName = oQuery.ItemIndex(0).IPAddressName
Set oQuery = oWMI.ExecQuery("SELECT * FROM ServerNetworkProtocolProperty WHERE ProtocolName = 'Tcp' AND InstanceName = '"&amp; EscapeWQLString(instanceName) &amp;"' AND IPAddressName = '"&amp; EscapeWQLString(ipAddressName) &amp;"' AND (PropertyName = 'TcpPort' OR PropertyName = 'TcpDynamicPorts') AND PropertyStrVal &lt;&gt; ''")
If (oQuery.Count &gt; 0) Then
tcp = oQuery.ItemIndex(0).PropertyStrVal
End If
Set oQuery = oWMI.ExecQuery("SELECT * FROM ServerNetworkProtocolProperty WHERE ProtocolName = 'Tcp' AND InstanceName = '"&amp; EscapeWQLString(instanceName) &amp;"' AND IPAddressName = '"&amp; EscapeWQLString(ipAddressName) &amp;"' AND PropertyName = 'IpAddress' AND PropertyStrVal &lt;&gt; ''")
If (oQuery.Count &gt; 0) Then
ip = oQuery.ItemIndex(0).PropertyStrVal
End If
If ip &lt;&gt; "" Then
serverName = ip
End If
If ((tcp &lt;&gt; "0") And (tcp &lt;&gt; "")) Then
serverName = servername &amp; "," &amp; tcp
Else tcp = ""
End If
End If
End If
End If
On Error Goto 0
BuildServerName = serverName
End Function'#Include File:GetSQL2012AgentJobStatus.vbs
'Copyright (c) Microsoft Corporation. All rights reserved.

Const SQL_MONITORING_CONNECT_FAILURE = -1
Const SQL_MONITORING_QUERY_FAILURE = -2
Const SQL_MONITORING_SUCCESS = 0

Dim SCRIPT_SQL

SCRIPT_SQL = "SET NOCOUNT ON" &amp; VbCrLf &amp;_
"DECLARE @job_activity TABLE (" &amp; VbCrLf &amp;_
"[session_id] [int] NOT NULL," &amp; VbCrLf &amp;_
"[job_id] [uniqueidentifier] NOT NULL," &amp; VbCrLf &amp;_
"[job_name] [sysname] COLLATE SQL_Latin1_General_CP1_CS_AS NOT NULL," &amp; VbCrLf &amp;_
"[run_requested_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[run_requested_source] [sysname] COLLATE SQL_Latin1_General_CP1_CS_AS NULL," &amp; VbCrLf &amp;_
"[queued_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[start_execution_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[last_executed_step_id] [int] NULL," &amp; VbCrLf &amp;_
"[last_exectued_step_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[stop_execution_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[next_scheduled_run_date] [datetime] NULL," &amp; VbCrLf &amp;_
"[job_history_id] [int] NULL," &amp; VbCrLf &amp;_
"[message] [nvarchar](1024) COLLATE SQL_Latin1_General_CP1_CS_AS NULL," &amp; VbCrLf &amp;_
"[run_status] [int] NULL," &amp; VbCrLf &amp;_
"[operator_id_emailed] [int] NULL," &amp; VbCrLf &amp;_
"[operator_id_netsent] [int] NULL," &amp; VbCrLf &amp;_
"[operator_id_paged] [int] NULL," &amp; VbCrLf &amp;_
"[execution_time_minutes] [int] NULL )" &amp; VbCrLf &amp;_
"INSERT INTO @job_activity" &amp; VbCrLf &amp;_
"([session_id]" &amp; VbCrLf &amp;_
",[job_id]" &amp; VbCrLf &amp;_
",[job_name]" &amp; VbCrLf &amp;_
",[run_requested_date]" &amp; VbCrLf &amp;_
",[run_requested_source]" &amp; VbCrLf &amp;_
",[queued_date]" &amp; VbCrLf &amp;_
",[start_execution_date]" &amp; VbCrLf &amp;_
",[last_executed_step_id]" &amp; VbCrLf &amp;_
",[last_exectued_step_date]" &amp; VbCrLf &amp;_
",[stop_execution_date]" &amp; VbCrLf &amp;_
",[next_scheduled_run_date]" &amp; VbCrLf &amp;_
",[job_history_id]" &amp; VbCrLf &amp;_
",[message]" &amp; VbCrLf &amp;_
",[run_status]" &amp; VbCrLf &amp;_
",[operator_id_emailed]" &amp; VbCrLf &amp;_
",[operator_id_netsent]" &amp; VbCrLf &amp;_
",[operator_id_paged])" &amp; VbCrLf &amp;_
"EXECUTE [msdb].[dbo].[sp_help_jobactivity]" &amp; VbCrLf &amp;_
"SELECT" &amp; VbCrLf &amp;_
"[ja].[job_id]" &amp; VbCrLf &amp;_
",[ja].[job_name]" &amp; VbCrLf &amp;_
",[originating_server]" &amp; VbCrLf &amp;_
",[message]" &amp; VbCrLf &amp;_
",[run_status]" &amp; VbCrLf &amp;_
", [execution_time_minutes] = case" &amp; VbCrLf &amp;_
" -- Has not finished a run" &amp; VbCrLf &amp;_
" When [start_execution_date] is not null And [stop_execution_date] is null" &amp; VbCrLf &amp;_
" Then DATEDIFF(minute, [start_execution_date], GETDATE())" &amp; VbCrLf &amp;_
" -- Has finished that run, but we still need to time for monitor state" &amp; VbCrLf &amp;_
" When [start_execution_date] is not null and [stop_execution_date] is not null" &amp; VbCrLf &amp;_
" Then DATEDIFF(minute, [start_execution_date], [stop_execution_date])" &amp; VbCrLf &amp;_
" else null" &amp; VbCrLf &amp;_
"End" &amp; VbCrLf &amp;_
" " &amp; VbCrLf &amp;_
"FROM @job_activity [ja]" &amp; VbCrLf &amp;_
"JOIN [msdb].[dbo].[sysjobs_view] [sjv] ON [sjv].[job_id] = [ja].[job_id]"



'Start of Main
'-----------------------------------------------------------------------------------------------
call Main()

Sub Main()

Dim objParameters, sConnectionString, sTcpPort, Computer, Service
Dim oAPI, oBag

Set objParameters = WScript.Arguments

If objParameters.Count &lt;&gt; 4 Then
Quit()
End If

sConnectionString= objParameters(0)
sTcpPort = objParameters(1)
Computer = objParameters(2)
Service = objParameters(3)

Set objParameters = Nothing

Set oAPI = MOMCreateObject("MOM.ScriptAPI")
Set oBag = oAPI.CreatePropertyBag()

Dim state
state = GetServiceState(Computer, Service)
if (state &lt;&gt; "Running") And (state &lt;&gt; "Unknown") Then
Call oAPI.Return(oBag)
Quit()
End If

If GetJobStatus(oBag, sConnectionString, sTcpPort) = 0 Then
Call oAPI.Return(oBag)
Else
Call oAPI.Return(oBag)
Quit()
End If

End Sub
'End of Main

'-----------------------------------------------------------------------------------------------
'The function returns service or "Unknown" state
'Input:
' server - compute name
' service - system service name
'Output:
' service state or "Unknown" state
Function GetServiceState( sTargetComputer, sServiceName)
On Error Resume Next

Dim sNamespace, sQuery, oWMI, objClasses, sState
sNamespace = "winmgmts://" &amp; sTargetComputer &amp; "/root/cimv2"
sQuery = "SELECT State FROM Win32_Service where Name = """ &amp; EscapeWQLString(sServiceName) &amp; """"

Set oWMI = GetObject(sNamespace)
Set objClasses = oWMI.ExecQuery(sQuery)

if objClasses.Count &gt;= 1 Then
sState = objClasses.ItemIndex(0).Properties_.Item("State")
End If

If Err.number &lt;&gt; 0 Or objClasses.Count = 0 Then
sState = "Unknown"
End If

Err.Clear
GetServiceState = sState
End Function
'End of Main
'-----------------------------------------------------------------------------------------------

Function GetJobStatus (ByRef oBag, ByVal sConnectionString, ByVal sTcpPort)


Dim cnADOConnection
Dim strProv
Dim rsSQLJobs
Dim bFail
Dim nDuration
Dim jobID
Dim lastStatus
Dim lastMessage


'on error resume next

Set cnADOConnection = MomCreateObject("ADODB.Connection")
cnADOConnection.Provider = "sqloledb"
cnADOConnection.ConnectionTimeout = 30


strProv = BuildConnectionStringWithPort(sConnectionString, "msdb", sTcpPort)
Err.Clear
cnADOConnection.Open strProv
if 0 &lt;&gt; Err.number then
Err.Clear
strProv = BuildConnectionString(sConnectionString, "msdb")
cnADOConnection.Open strProv
if 0 &lt;&gt; Err.number then
GetJobStatus = SQL_MONITORING_CONNECT_FAILURE
Exit Function
End If
end if


Err.Clear
Set rsSQLJobs = cnADOConnection.Execute(SCRIPT_SQL)
If 0 &lt;&gt; Err.number Then
GetJobStatus = SQL_MONITORING_QUERY_FAILURE
Exit Function
End If

If 0 = rsSQLJobs.State Then
' No records returned, recordset is likely closed.
Exit Function
End If

Do
bFail = True
Err.Clear
if rsSQLJobs.EOF then
if 0 &lt;&gt; Err.number then Exit Do
bFail = False
Exit Do
End If
If 0 &lt;&gt; Err.number Then Exit Do
jobID = rsSQLJobs("job_id").Value
lastStatus = rsSQLJobs("run_status").Value
lastMessage = rsSQLJobs("message").Value
nDuration = Int(rsSQLJobs("execution_time_minutes").Value)
If (IsNull(nDuration)) Then nDuration = -1
If (IsNull(lastStatus)) Then lastStatus = -1
If (IsNull(lastMessage)) Then lastMessage = ""
Call oBag.AddValue(jobID &amp; "-Duration",CDbl(nDuration))
Call oBag.AddValue(jobID &amp; "-LastStatus", CInt(lastStatus))
Call oBag.AddValue(jobID &amp; "-LastMessage", CStr(lastMessage))

Err.Clear
rsSQLJobs.MoveNext
If 0 &lt;&gt; Err.number then Exit Do
Loop



If bFail Then
' Throw
End if

Set cnADOConnection = Nothing
Set rsSQLJobs = Nothing


GetJobStatus = SQL_MONITORING_SUCCESS

End Function</Script></ScriptBody>
<TimeoutSeconds>$Config/TimeoutSeconds$</TimeoutSeconds>
</DataSource>
</MemberModules>
<Composition>
<Node ID="DS"/>
</Composition>
</Composite>
</ModuleImplementation>
<OutputType>System!System.PropertyBagData</OutputType>
</DataSourceModuleType>