TransPullSubscription.SynchronizeWithJob 方法

定义

命名空间:

Microsoft.SqlServer.Replication

程序集:

Microsoft.SqlServer.Rmo.dll

启动代理作业以便同步订阅。

public:
 override void SynchronizeWithJob();

public override void SynchronizeWithJob ();

override this.SynchronizeWithJob : unit -> unit

Public Overrides Sub SynchronizeWithJob ()

示例

// Define server, publication, and database names.
String subscriberName = subscriberInstance;
String publisherName = publisherInstance;
String publicationName = "AdvWorksProductTran";
String publicationDbName = "AdventureWorks2012";
String subscriptionDbName = "AdventureWorks2012Replica";

// Create a connection to the Subscriber.
ServerConnection conn = new ServerConnection(subscriberName);

TransPullSubscription subscription;

try
{
    // Connect to the Subscriber.
    conn.Connect();

    // Define subscription properties.
    subscription = new TransPullSubscription();
    subscription.ConnectionContext = conn;
    subscription.DatabaseName = subscriptionDbName;
    subscription.PublisherName = publisherName;
    subscription.PublicationDBName = publicationDbName;
    subscription.PublicationName = publicationName;

    // If the pull subscription and the job exists, start the agent job.
    if (subscription.LoadProperties() && subscription.AgentJobId != null)
    {
        subscription.SynchronizeWithJob();
    }
    else
    {
        // Do something here if the subscription does not exist.
        throw new ApplicationException(String.Format(
            "A subscription to '{0}' does not exists on {1}",
            publicationName, subscriberName));
    }
}
catch (Exception ex)
{
    // Do appropriate error handling here.
    throw new ApplicationException("The subscription could not be synchronized.", ex);
}
finally
{
    conn.Disconnect();
}

' Define server, publication, and database names.
Dim subscriberName As String = subscriberInstance
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksProductTran"
Dim publicationDbName As String = "AdventureWorks2012"
Dim subscriptionDbName As String = "AdventureWorks2012Replica"

' Create a connection to the Subscriber.
Dim conn As ServerConnection = New ServerConnection(subscriberName)

Dim subscription As TransPullSubscription

Try
    ' Connect to the Subscriber.
    conn.Connect()

    ' Define subscription properties.
    subscription = New TransPullSubscription()
    subscription.ConnectionContext = conn
    subscription.DatabaseName = subscriptionDbName
    subscription.PublisherName = publisherName
    subscription.PublicationDBName = publicationDbName
    subscription.PublicationName = publicationName

    ' If the pull subscription and the job exists, start the agent job.
    If subscription.LoadProperties() And Not subscription.AgentJobId Is Nothing Then
        subscription.SynchronizeWithJob()
    Else
        ' Do something here if the subscription does not exist.
        Throw New ApplicationException(String.Format( _
         "A subscription to '{0}' does not exists on {1}", _
         publicationName, subscriberName))
    End If
Catch ex As Exception
    ' Do appropriate error handling here.
    Throw New ApplicationException("The subscription could not be synchronized.", ex)
Finally
    conn.Disconnect()
End Try

注解

TransSynchronizationAgent使用 属性返回SynchronizationAgent的 对象同步启动分发代理。

如果创建的请求订阅的值为 falseCreateSyncAgentByDefault，则默认值为 ，则不会为订阅创建分发代理作业，并且调用 SynchronizeWithJob 会导致异常。

StopSynchronizationJob调用 方法以停止作业（如果作业当前正在运行）。

如果 Microsoft SQL Server 代理服务未运行，则无法启动作业。 此外，如果未生成快照，则运行代理作业可能不会同步订阅。

如果已在此 实例 TransPullSubscription上设置了其他属性，请在调用 之前调用 CommitPropertyChangesSynchronizeWithJob。

方法 SynchronizeWithJob 只能由订阅服务器上的 sysadmin 固定服务器角色的成员或订阅数据库上 db_owner 固定数据库角色的成员调用。

另请参阅

• 如何同步请求订阅（RMO 编程）