SQL 2008 Replication Component Discovery Provider

Microsoft.SQLServer.2008.ReplicationComponentDiscovery (DataSourceModuleType)

Element properties:

TypeDataSourceModuleType
IsolationAny
AccessibilityInternal
RunAsMicrosoft.SQLServer.SQLDiscoveryAccount
OutputTypeSystem.Discovery.Data

Member Modules:

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

Overrideable Parameters:

IDParameterTypeSelectorDisplay NameDescription
IntervalSecondsint$Config/IntervalSeconds$Interval Seconds
SyncTimestring$Config/SyncTime$Synchronization Time
TimeoutSecondsint$Config/TimeoutSeconds$

Source Code:

<DataSourceModuleType ID="Microsoft.SQLServer.2008.ReplicationComponentDiscovery" Accessibility="Internal" RunAs="SQL!Microsoft.SQLServer.SQLDiscoveryAccount">
<Configuration>
<xsd:element name="IntervalSeconds" type="xsd:integer"/>
<xsd:element name="SyncTime" type="xsd:string"/>
<xsd:element name="NetworkName" type="xsd:string"/>
<xsd:element name="SQLConnectionString" type="xsd:string"/>
<xsd:element name="SQLInstanceName" type="xsd:string"/>
<xsd:element 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.DiscoveryProvider">
<IntervalSeconds>$Config/IntervalSeconds$</IntervalSeconds>
<SyncTime>$Config/SyncTime$</SyncTime>
<ScriptName>DiscoverSQL2008ReplicationComponents.vbs</ScriptName>
<Arguments>$MPElement$ $Target/Id$ $Config/NetworkName$ $Config/SQLConnectionString$ $Config/SQLInstanceName$</Arguments>
<ScriptBody><Script>
'Copyright (c) Microsoft Corporation. All rights reserved.

' Parameters that should be passed to this script
' 0 MPElement ID ($MPElement$)
' 1 Target Id for ME this rule is running against ($Target/Id$)
' 2 Computer (FQDN) that SQL instance is hosted on
' 3 SQL Connection String for the instance that the DBs are being discovered on
' 4 SQL Instance that this rule is being run for

Option Explicit
SetLocale("en-us")

Const DB_EMERGENCYMODE = 32768
Const DB_LOADING = 22
Const DB_NORMAL = 0
Const DB_OFFLINE = 512
Const DB_RECOVERING = 192
Const DB_STANDBY = 1024
Const DB_SUSPECT = 256


Const SQL_DISCOVERY_CONNECT_FAILURE = -1
Const SQL_DISCOVERY_QUERY_FAILURE = -2
Const SQL_DISCOVERY_SUCCESS = 0
Const ERR_CANNOT_INSERT_NULL = 515

Dim oArgs
Set oArgs = WScript.Arguments
if oArgs.Count &lt;&gt; 5 Then
Wscript.Quit -1
End If

Dim SourceID, ManagedEntityId, TargetComputerID, InstanceName, ConnectionString

SourceID = oArgs(0)
ManagedEntityId = oArgs(1)
TargetComputerID = oArgs(2)
ConnectionString = oArgs(3)
InstanceName = oArgs(4)

Dim oAPI, oSQLDiscoveryData

Set oAPI = MOMCreateObject("MOM.ScriptAPI")
set oSQLDiscoveryData = oAPI.CreateDiscoveryData(0, SourceID, ManagedEntityId)



If DoReplicationDiscovery(TargetComputerID, InstanceName, ConnectionString, oSQLDiscoveryData) &gt;= 0 Then Call oAPI.Return(oSQLDiscoveryData)




Function DoReplicationDiscovery(ByVal sTargetComputerID, ByVal sSqlInstance, ByVal sSQLConnectionString, ByVal oSQLDiscoveryData)



Dim e
Dim oDistInstance
Dim cnADOConnection
Dim cnADOConnection2
Dim strProv
Dim oResults
Dim oResults2
Dim oRel
Dim oDatabase

Set e = New Error


Set cnADOConnection = MomCreateObject("ADODB.Connection")
cnADOConnection.Provider = "sqloledb"
cnADOConnection.ConnectionTimeout = 15
strProv = "Server=" &amp; sSQLConnectionString &amp; ";Database=master;Trusted_Connection=yes"

e.Clear
On Error Resume Next
cnADOConnection.Open strProv
e.Save
On Error Goto 0
if 0 &lt;&gt; Err.number then
'Error event in here
'g_oSQL.CreateConnectionFailureAlert sInstance, Err.number, Err.Description
DoReplicationDiscovery = SQL_DISCOVERY_CONNECT_FAILURE
Exit Function
end if

e.Clear
On Error Resume Next
Set oResults = cnADOConnection.Execute("sp_get_distributor")
e.Save
On Error Goto 0


if 0 &lt;&gt; e.number then
'Error event in here
DoReplicationDiscovery = SQL_DISCOVERY_QUERY_FAILURE
Exit Function
end if

' First create the distributor object if it exists in this instance
If oResults(0) = True Then
Set oDistInstance = oSQLDiscoveryData.CreateClassInstance("$MPElement[Name='Microsoft.SQLServer.2008.Distributor']$")
With oDistInstance
.AddProperty "$MPElement[Name='Windows!Microsoft.Windows.Computer']/PrincipalName$", TargetComputerID
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.ServerRole']/InstanceName$", sSqlInstance
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/DistributionServer$", oResults(1)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/DistributionDBInstalled$", CBool(oResults(2))
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/IsDistributionPublisher$", CBool(oResults(3))
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/HasRemoteDistributionPublisher$", CBool(oResults(4))
.AddProperty "$MPElement[Name='System!System.Entity']/DisplayName$", oResults(1)
End With

e.Clear
On Error Resume Next
Set oResults = cnADOConnection.Execute("sp_helpdistributor")
e.Save
On Error Goto 0

With oDistInstance
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/DistributionDB$", oResults(1)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/Directory$", oResults(2)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Distributor']/Account$", oResults(3)
End With

On Error Resume Next
Set oResults2 = cnADOConnection.Execute("select name from sys.databases where is_distributor = 1")
e.Save
On Error Goto 0

If oResults2.Fields.Count &gt; 0 Then
Do While Not oResults2.EOF
Set oRel = oSQLDiscoveryData.CreateRelationshipInstance("$MPElement[Name='Microsoft.SQLServer.2008.DistributorContainsDatabase']$")
Set oDatabase = oSQLDiscoveryData.CreateClassInstance("$MPElement[Name='Microsoft.SQLServer.2008.Database']$")

With oDatabase
.AddProperty "$MPElement[Name='Windows!Microsoft.Windows.Computer']/PrincipalName$", TargetComputerID
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.ServerRole']/InstanceName$", sSqlInstance
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Database']/DatabaseName$", oResults2(0)
End With
Call oSQLDiscoveryData.AddInstance(oDatabase)
oRel.Source = oDistInstance
oRel.Target = oDatabase
Call oSQLDiscoveryData.AddInstance(oRel)
oResults2.MoveNext
Loop
End If


Call oSQLDiscoveryData.AddInstance(oDistInstance)

End If



' Create the publisher and subscriber objects
On Error Resume Next
Set oResults = cnADOConnection.Execute("sp_helpdistpublisher")
e.Save
On Error Goto 0
If oResults.Fields.Count &gt; 0 Then
Do while Not oResults.EOF
Set oDistInstance = oSQLDiscoveryData.CreateClassInstance("$MPElement[Name='Microsoft.SQLServer.2008.Publisher']$")
With oDistInstance
.AddProperty "$MPElement[Name='Windows!Microsoft.Windows.Computer']/PrincipalName$", TargetComputerID
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.ServerRole']/InstanceName$", sSqlInstance
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Publisher']/Name$", oResults(0)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Publisher']/DistributionDB$", oResults(1)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Publisher']/PublisherType$", OResults(9)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Publisher']/DataSource$", OResults(10)
.AddProperty "$MPElement[Name='SQL!Microsoft.SQLServer.Publisher']/WorkingDirectory$", OResults(6)
.AddProperty "$MPElement[Name='System!System.Entity']/DisplayName$", oResults(0)
End With
Call oSQLDiscoveryData.AddInstance(oDistInstance)
oResults.MoveNext
Loop
End If

cnADOConnection.Close()
DoReplicationDiscovery = 0

End Function

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 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

'******************************************************************************
Function ThrowScriptErrorNoAbort(ByVal sMessage, ByVal oErr)
On Error Resume Next
Dim oAPITemp
Set oAPITemp = MOMCreateObject("MOM.ScriptAPI")
oAPITemp.LogScriptEvent "DiscoverSQL2008ReplicationComponents.vbs", 4001, 1, sMessage &amp; ". " &amp; oErr.m_sDescription
End Function

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

Function ConvertSizeStringToNumber(sSizeString)
' Remove the KB and return a valid double
sSizeString = Replace(sSizeString, " KB", "")
ConvertSizeStringToNumber = CDbl(sSizeString)
End Function

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