Tworzenie subskrypcji typu pull

Dotyczy:SQL ServerAzure SQL Managed Instance

Ten temat opisuje, jak utworzyć subskrypcję pull w SQL Server, korzystając z SQL Server Management Studio, Transact-SQL lub Replication Management Objects (RMO).

Konfiguracja subskrypcji pull do replikacji P2P jest możliwa za pomocą skryptu, ale nie jest dostępna przez kreatora.

Korzystanie z programu SQL Server Management Studio

Utwórz subskrypcję pull u Publisher lub Subskrybenta, korzystając z Nowego Kreatora Subskrypcji. Korzystaj ze stron kreatora, aby:

  • Określ wydawcę i publikację.

  • Wybierz miejsce uruchamiania agentów replikacji. Aby uzyskać subskrypcję pull subskrypcji, wybierz Uruchom każdego agenta na jego Subscriber (subskrypcje pull subskrypcji) na stronie Distribution Agent Location lub na stronie Merge Agent Location, w zależności od rodzaju publikacji.

  • Określ bazy danych subskrybentów i subskrypcji.

  • Określ identyfikatory logowania i hasła używane do nawiązywania połączeń przez agentów replikacji:

    • W przypadku subskrypcji do migawek i publikacji transakcyjnych określ poświadczenia na stronie Zabezpieczenia agenta dystrybucji .

    • Aby subskrybować publikacje z replikacją scalającą, określ poświadczenia na stronie Zabezpieczenia agenta scalania.

    Aby uzyskać informacje o uprawnieniach wymaganych przez każdego agenta, zobacz Model Bezpieczeństwa Agenta Replikacyjnego.

  • Określ harmonogram synchronizacji i czas inicjowania subskrybenta.

  • Określ dodatkowe opcje łączenia publikacji: typ subskrypcji; wartości dla filtrowania parametrycznego; oraz informacje o synchronizacji przez HTTPS, jeśli publikacja jest włączona do synchronizacji sieci.

  • Określ dodatkowe opcje dla publikacji transakcyjnych, które pozwalają na aktualizację subskrypcji: czy Subskrybenci powinni natychmiast zatwierdzać zmiany w Publisher, czy wpisywać je do kolejki; dane uwierzytelniające używane do połączenia z Subskrybentem a Publisher.

  • Opcjonalnie możesz skryptować subskrypcję.

Aby utworzyć subskrypcję pull od Publisher

  1. Połącz się z programem Publisher w programie Microsoft SQL Server Management Studio, a następnie rozwiń węzeł serwera.

  2. Rozwiń folder Replikacja , a następnie rozwiń folder Publikacje lokalne .

  3. Kliknij prawym przyciskiem myszy na publikację, dla której chcesz utworzyć jedną lub więcej subskrypcji, a następnie kliknij Nowe subskrypcje.

  4. Ukończ strony w Kreatorze nowej subskrypcji.

Aby utworzyć subskrypcję pull od Subskrybenta

  1. Połącz się z subskrybentem w programie SQL Server Management Studio, a następnie rozwiń węzeł serwera.

  2. Rozwiń folder Replikacja .

  3. Kliknij prawym przyciskiem myszy folder Subskrypcje lokalne , a następnie kliknij pozycję Nowe subskrypcje.

  4. Na stronie Publikacja Kreatora nowej subskrypcji wybierz opcję <Znajdź wydawcę programu SQL Server> lub <Znajdź wydawcę programu Oracle> z listy rozwijanej Wydawca.

  5. Połącz się z wydawcą w oknie dialogowym Łączenie z serwerem .

  6. Wybierz publikację na stronie Publikacja .

  7. Ukończ strony w Kreatorze nowej subskrypcji.

Korzystanie z Transact-SQL

Subskrypcje pull mogą być tworzone programowo za pomocą procedur przechowywanych replikacji. Używane procedury składowane zależą od typu publikacji, do której należy subskrypcja.

Aby utworzyć subskrypcję pull na publikację snapshot lub transakcyjną

  1. Na Publisher sprawdź, czy publikacja obsługuje pobieranie subskrypcji, wykonując sp_helppublication (Transact-SQL).

    • Jeśli wartość allow_pull w zbiorze wyników wynosi 1, publikacja obsługuje subskrypcje pobierające.

    • Jeśli wartość allow_pull wynosi 0, wykonaj sp_changepublication (Transact-SQL), określając allow_pull dla @property i prawdziwe dla @value.

  2. Na subskrybentze wykonaj sp_addpullsubscription (Transact-SQL). Określ @publisher i @publication. Aby uzyskać informacje o aktualizacji subskrypcji, zobacz Utwórz aktualizowalną subskrypcję publikacji transakcyjnej.

  3. Na stronie Subskrybera wykonaj sp_addpullsubscription_agent (Transact-SQL). Określ następujące elementy:

    • Parametry @publisher, @publisher_db i @publication .

    • Microsoft Windows dane uwierzytelniające, pod którymi działa Distribution Agent u abonenta dla @job_login i @job_password.

      Note

      Połączenia nawiązywane za pomocą Windows Zintegrowanej Uwierzytelniania zawsze wykorzystują Windows poświadczenia określone przez @job_login i @job_password. Agent dystrybucji zawsze nawiązuje połączenie lokalne z subskrybentem przy użyciu zintegrowanego uwierzytelniania systemu Windows. Domyślnie agent łączy się z dystrybutorem za pomocą zintegrowanej uwierzytelniania Windows.

    • (Opcjonalnie) Wartość 0 dla @distributor_security_mode oraz dane logowania SQL Server dla @distributor_login i @distributor_password, jeśli musisz użyć uwierzytelniania SQL Server podczas łączenia z dystrybutorem.

    • Harmonogram zadania agenta dystrybucji dla tej subskrypcji. Aby uzyskać więcej informacji, zobacz Określanie harmonogramów synchronizacji.

  4. W Publisher wykonaj sp_addsubscription (Transact-SQL), aby zarejestrować subskrypcję pull. Określ @publication, @subscriber i @destination_db. Określ wartość ściągania dla @subscription_type.

Aby utworzyć subskrypcję pull publikacji scalonej

  1. Na Publisher sprawdź, czy publikacja obsługuje pobieranie subskrypcji, wykonując sp_helpmergepublication (Transact-SQL).

    • Jeśli wartość allow_pull w zbiorze wyników wynosi 1, publikacja obsługuje subskrypcje pobierające.

    • Jeśli wartość allow_pull wynosi 0, wykonaj sp_changemergepublication (Transact-SQL), określając allow_pull dla @property i prawdziwe dla @value.

  2. Na subskrybentze wykonaj sp_addmergepullsubscription (Transact-SQL). Określ @publisher, @publisher_db, @publication oraz następujące parametry:

  3. Na stronie Subskrybenta wykonaj sp_addmergepullsubscription_agent (Transact-SQL). Określ następujące parametry:

    • @publisher, @publisher_db i @publication.

    • Windows dane uwierzytelniające, pod którymi działa Merge Agent na abonencie przez @job_login i @job_password.

      Note

      Połączenia nawiązywane za pomocą Windows Zintegrowanej Uwierzytelniania zawsze wykorzystują Windows poświadczenia określone przez @job_login i @job_password. Merge Agent zawsze nawiązuje lokalne połączenie z abonentem za pomocą Windows Integrated Authentication. Domyślnie agent łączy się z Dystrybutorem i Publisher za pomocą zintegrowanej uwierzytelniania Windows.

    • (Opcjonalnie) Wartość 0 dla @distributor_security_mode oraz dane logowania SQL Server dla @distributor_login i @distributor_password, jeśli musisz użyć uwierzytelniania SQL Server podczas łączenia z dystrybutorem.

    • (Opcjonalnie) Wartość 0 dla @publisher_security_mode oraz dane logowania SQL Server dla @publisher_login i @publisher_password, jeśli musisz użyć uwierzytelniania SQL Server podczas łączenia się z Publisher.

    • Harmonogram pracy agenta scalania dla tej subskrypcji. Więcej informacji można znaleźć w artykule Utwórz aktualizowalną subskrypcję publikacji transakcyjnej.

  4. Na Publisher wykonaj sp_addmergesubscription (Transact-SQL). Określ @publication, @subscriber, @subscriber_db oraz wartość pull dla @subscription_type. To rejestruje subskrypcję pull.

Przykłady (Transact-SQL)

Poniższy przykład tworzy subskrypcję pull do publikacji transakcyjnej. Pierwsza partia jest wykonywana u Subskrybenta, a druga u Publisher. Wartości logowania i hasła są dostarczane w czasie wykonywania przy użyciu zmiennych skryptów sqlcmd.

-- This script uses sqlcmd scripting variables. They are in the form  
-- $(MyVariable). For information about how to use scripting variables    
-- on the command line and in SQL Server Management Studio, see the   
-- "Executing Replication Scripts" section in the topic  
-- "Programming Replication Using System Stored Procedures".  
  
-- Execute this batch at the Subscriber.  
DECLARE @publication AS sysname;  
DECLARE @publisher AS sysname;  
DECLARE @publicationDB AS sysname;  
SET @publication = N'AdvWorksProductTran';  
SET @publisher = $(PubServer);  
SET @publicationDB = N'AdventureWorks';  
  
-- At the subscription database, create a pull subscription   
-- to a transactional publication.  
USE [AdventureWorksReplica]  
EXEC sp_addpullsubscription   
  @publisher = @publisher,   
  @publication = @publication,   
  @publisher_db = @publicationDB;  
  
-- Add an agent job to synchronize the pull subscription.  
EXEC sp_addpullsubscription_agent   
  @publisher = @publisher,   
  @publisher_db = @publicationDB,   
  @publication = @publication,   
  @distributor = @publisher,   
  @job_login = $(Login),   
  @job_password = $(Password);  
GO  

-- This script uses sqlcmd scripting variables. They are in the form  
-- $(MyVariable). For information about how to use scripting variables    
-- on the command line and in SQL Server Management Studio, see the   
-- "Executing Replication Scripts" section in the topic  
-- "Programming Replication Using System Stored Procedures".  
  
-- Execute this batch at the Publisher.  
DECLARE @publication AS sysname;  
DECLARE @subscriber AS sysname;  
DECLARE @subscriptionDB AS sysname;  
SET @publication = N'AdvWorksProductTran';  
SET @subscriber = $(SubServer);  
SET @subscriptionDB = N'AdventureWorksReplica';  
  
-- At the Publisher, register the subscription, using the defaults.  
EXEC sp_addsubscription   
  @publication = @publication,   
  @subscriber = @subscriber,   
  @destination_db = @subscriptionDB,   
  @subscription_type = N'pull',  
  @status = N'subscribed';  
GO

Poniższy przykład tworzy subskrypcję pull do publikacji scalającej. Pierwsza partia jest wykonywana u Subskrybenta, a druga u Publisher. Wartości logowania i hasła są podawane w czasie działania za pomocą zmiennych skryptowych sqlcmd .

-- This script uses sqlcmd scripting variables. They are in the form  
-- $(MyVariable). For information about how to use scripting variables    
-- on the command line and in SQL Server Management Studio, see the   
-- "Executing Replication Scripts" section in the topic  
-- "Programming Replication Using System Stored Procedures".  
  
-- Execute this batch at the Subscriber.  
DECLARE @publication AS sysname;  
DECLARE @publisher AS sysname;  
DECLARE @publicationDB AS sysname;  
DECLARE @hostname AS sysname;  
SET @publication = N'AdvWorksSalesOrdersMerge';  
SET @publisher = $(PubServer);  
SET @publicationDB = N'AdventureWorks';  
SET @hostname = N'adventure-works\david8';  
  
-- At the subscription database, create a pull subscription   
-- to a merge publication.  
USE [AdventureWorksReplica]  
EXEC sp_addmergepullsubscription   
  @publisher = @publisher,   
  @publication = @publication,   
  @publisher_db = @publicationDB;  
  
-- Add an agent job to synchronize the pull subscription.   
EXEC sp_addmergepullsubscription_agent   
  @publisher = @publisher,   
  @publisher_db = @publicationDB,   
  @publication = @publication,   
  @distributor = @publisher,   
  @job_login = $(Login),   
  @job_password = $(Password),  
  @hostname = @hostname;  
GO  

-- Execute this batch at the Publisher.  
DECLARE @myMergePub  AS sysname;  
DECLARE @mySub       AS sysname;  
DECLARE @mySubDB     AS sysname;  
  
SET @myMergePub = N'AdvWorksSalesOrdersMerge';  
SET @mySub = N'MYSUBSERVER';  
SET @mySubDB = N'AdventureWorksReplica';  
  
-- At the Publisher, register the subscription, using the defaults.  
USE [AdventureWorks]  
EXEC sp_addmergesubscription @publication = @myMergePub,   
@subscriber = @mySub, @subscriber_db = @mySubDB,   
@subscription_type = N'pull';  
GO

Korzystanie z obiektów zarządzania replikacją (RMO)

Klasy RMO używane do tworzenia subskrypcji pull zależą od rodzaju publikacji, do której należy subskrypcja.

Aby utworzyć subskrypcję pull na publikację snapshot lub transakcyjną

  1. Utwórz połączenia zarówno z subskrybentem, jak i wydawcą ServerConnection przy użyciu klasy.

  2. Utwórz wystąpienie TransPublication klasy przy użyciu połączenia programu Publisher z kroku 1. Określ Name, DatabaseName i ConnectionContext.

  3. Wywołaj metodę LoadProperties . Jeśli ta metoda zwraca wartość false, właściwości określone w kroku 2 są nieprawidłowe lub publikacja nie istnieje na serwerze.

  4. Wykonaj bitową operację logiczną AND (& w języku Visual C# i And w Visual Basic) między właściwością Attributes a AllowPull. Jeśli wynikiem jest None, ustaw Attributes na wynik bitowego logicznego OR (| w języku Visual C# i Or w Visual Basic) pomiędzy Attributes a AllowPull. Następnie zadzwoń CommitPropertyChanges , aby włączyć subskrypcje pull.

  5. Jeśli baza danych subskrypcji nie istnieje, utwórz ją przy użyciu Database klasy . Więcej informacji można znaleźć w sekcji Tworzenie, Zmiana i Usuwanie Baz Danych.

  6. Utwórz wystąpienie klasy TransPullSubscription.

  7. Ustaw następujące właściwości subskrypcji:

  8. Wywołaj metodę Create .

  9. Korzystając z instancji klasy TransPublication z kroku 2, wywołaj metodę MakePullSubscriptionWellKnown rejestracji subskrypcji pull u Publisher. Jeśli rejestracja już istnieje, występuje wyjątek.

Aby utworzyć subskrypcję pull publikacji scalonej

  1. Nawiąż połączenia zarówno z Subskrybentem, jak i Publisher, korzystając z tej klasyServerConnection.

  2. Utwórz wystąpienie MergePublication klasy przy użyciu połączenia programu Publisher z kroku 1. Określ Name, DatabaseNamei ConnectionContext.

  3. Wywołaj metodę LoadProperties . Jeśli ta metoda zwraca wartość false, właściwości określone w kroku 2 są nieprawidłowe lub publikacja nie istnieje na serwerze.

  4. Wykonaj bitową operację logiczną AND (& w języku Visual C# i And w Visual Basic) między właściwością Attributes a AllowPull. Jeśli wynikiem jest None, ustaw Attributes na wynik bitowego logicznego OR (| w języku Visual C# i Or w Visual Basic) pomiędzy Attributes a AllowPull. Następnie zadzwoń CommitPropertyChanges , aby włączyć subskrypcje pull.

  5. Jeśli baza danych subskrypcji nie istnieje, utwórz ją przy użyciu Database klasy . Więcej informacji można znaleźć w sekcji Tworzenie, Zmiana i Usuwanie Baz Danych.

  6. Utwórz wystąpienie klasy MergePullSubscription.

  7. Ustaw następujące właściwości subskrypcji:

  8. Wywołaj metodę Create .

  9. Korzystając z instancji klasy MergePublication z kroku 2, wywołaj metodę MakePullSubscriptionWellKnown rejestracji subskrypcji pull u Publisher. Jeśli rejestracja już istnieje, występuje wyjątek.

Przykład (RMO)

Ten przykład tworzy subskrypcję pull do publikacji transakcyjnej. Dane uwierzytelniające Microsoft Windows konta użyte do utworzenia zadania Distribution Agent są przekazywane w czasie działania.

// Define the Publisher, publication, and databases.  
string publicationName = "AdvWorksProductTran";  
string publisherName = publisherInstance;  
string subscriberName = subscriberInstance;  
string subscriptionDbName = "AdventureWorksReplica";  
string publicationDbName = "AdventureWorks";  
  
//Create connections to the Publisher and Subscriber.  
ServerConnection subscriberConn = new ServerConnection(subscriberName);  
ServerConnection publisherConn = new ServerConnection(publisherName);  
  
// Create the objects that we need.  
TransPublication publication;  
TransPullSubscription subscription;  
  
try  
{  
    // Connect to the Publisher and Subscriber.  
    subscriberConn.Connect();  
    publisherConn.Connect();  
  
    // Ensure that the publication exists and that   
    // it supports pull subscriptions.  
    publication = new TransPublication();  
    publication.Name = publicationName;  
    publication.DatabaseName = publicationDbName;  
    publication.ConnectionContext = publisherConn;  
  
    if (publication.IsExistingObject)  
    {  
        if ((publication.Attributes & PublicationAttributes.AllowPull) == 0)  
        {  
            publication.Attributes |= PublicationAttributes.AllowPull;  
        }  
  
        // Define the pull subscription.  
        subscription = new TransPullSubscription();  
        subscription.ConnectionContext = subscriberConn;  
        subscription.PublisherName = publisherName;  
        subscription.PublicationName = publicationName;  
        subscription.PublicationDBName = publicationDbName;  
        subscription.DatabaseName = subscriptionDbName;  
  
        // Specify the Windows login credentials for the Distribution Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin;  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword;  
  
        // Make sure that the agent job for the subscription is created.  
        subscription.CreateSyncAgentByDefault = true;  
  
        // By default, subscriptions to transactional publications are synchronized   
        // continuously, but in this case we only want to synchronize on demand.  
        subscription.AgentSchedule.FrequencyType = ScheduleFrequencyType.OnDemand;  
  
        // Create the pull subscription at the Subscriber.  
        subscription.Create();  
  
        Boolean registered = false;  
  
        // Verify that the subscription is not already registered.  
        foreach (TransSubscription existing  
            in publication.EnumSubscriptions())  
        {  
            if (existing.SubscriberName == subscriberName  
                && existing.SubscriptionDBName == subscriptionDbName)  
            {  
                registered = true;  
            }  
        }  
        if (!registered)  
        {  
            // Register the subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown(  
                subscriberName, subscriptionDbName,  
                SubscriptionSyncType.Automatic,  
                TransSubscriberType.ReadOnly);  
        }  
    }  
    else  
    {  
        // Do something here if the publication does not exist.  
        throw new ApplicationException(String.Format(  
            "The publication '{0}' does not exist on {1}.",  
            publicationName, publisherName));  
    }  
}  
catch (Exception ex)  
{  
    // Implement the appropriate error handling here.  
    throw new ApplicationException(String.Format(  
        "The subscription to {0} could not be created.", publicationName), ex);  
}  
finally  
{  
    subscriberConn.Disconnect();  
    publisherConn.Disconnect();  
}  
  

' Define the Publisher, publication, and databases.  
Dim publicationName As String = "AdvWorksProductTran"  
Dim publisherName As String = publisherInstance  
Dim subscriberName As String = subscriberInstance  
Dim subscriptionDbName As String = "AdventureWorksReplica"  
Dim publicationDbName As String = "AdventureWorks"  
  
'Create connections to the Publisher and Subscriber.  
Dim subscriberConn As ServerConnection = New ServerConnection(subscriberName)  
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)  
  
' Create the objects that we need.  
Dim publication As TransPublication  
Dim subscription As TransPullSubscription  
  
Try  
    ' Connect to the Publisher and Subscriber.  
    subscriberConn.Connect()  
    publisherConn.Connect()  
  
    ' Ensure that the publication exists and that   
    ' it supports pull subscriptions.  
    publication = New TransPublication()  
    publication.Name = publicationName  
    publication.DatabaseName = publicationDbName  
    publication.ConnectionContext = publisherConn  
  
    If publication.IsExistingObject Then  
        If (publication.Attributes And PublicationAttributes.AllowPull) = 0 Then  
            publication.Attributes = publication.Attributes _  
            Or PublicationAttributes.AllowPull  
        End If  
  
        ' Define the pull subscription.  
        subscription = New TransPullSubscription()  
        subscription.ConnectionContext = subscriberConn  
        subscription.PublisherName = publisherName  
        subscription.PublicationName = publicationName  
        subscription.PublicationDBName = publicationDbName  
        subscription.DatabaseName = subscriptionDbName  
        subscription.Description = "Pull subscription to " + publicationDbName _  
        + " on " + subscriberName + "."  
  
        ' Specify the Windows login credentials for the Distribution Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword  
  
        ' Make sure that the agent job for the subscription is created.  
        subscription.CreateSyncAgentByDefault = True  
  
        ' By default, subscriptions to transactional publications are synchronized   
        ' continuously, but in this case we only want to synchronize on demand.  
        subscription.AgentSchedule.FrequencyType = ScheduleFrequencyType.OnDemand  
  
        ' Create the pull subscription at the Subscriber.  
        subscription.Create()  
  
        Dim registered As Boolean = False  
  
        ' Verify that the subscription is not already registered.  
        For Each existing As TransSubscription In publication.EnumSubscriptions()  
            If existing.SubscriberName = subscriberName And _  
                existing.SubscriptionDBName = subscriptionDbName Then  
                registered = True  
            End If  
        Next existing  
        If Not registered Then  
            ' Register the subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown( _  
             subscriberName, subscriptionDbName, _  
             SubscriptionSyncType.Automatic, _  
             TransSubscriberType.ReadOnly)  
        End If  
    Else  
        ' Do something here if the publication does not exist.  
        Throw New ApplicationException(String.Format( _  
         "The publication '{0}' does not exist on {1}.", _  
         publicationName, publisherName))  
    End If  
Catch ex As Exception  
    ' Implement the appropriate error handling here.  
    Throw New ApplicationException(String.Format( _  
        "The subscription to {0} could not be created.", publicationName), ex)  
Finally  
    subscriberConn.Disconnect()  
    publisherConn.Disconnect()  
End Try

Ten przykład tworzy subskrypcję pull do publikacji merge. Poświadczenia do konta Windows używane do utworzenia zadania Merge Agent są przekazywane w czasie działania.

// Define the Publisher, publication, and databases.  
string publicationName = "AdvWorksSalesOrdersMerge";  
string publisherName = publisherInstance;  
string subscriberName = subscriberInstance;  
string subscriptionDbName = "AdventureWorksReplica";  
string publicationDbName = "AdventureWorks";  
string hostname = @"adventure-works\garrett1";  
  
//Create connections to the Publisher and Subscriber.  
ServerConnection subscriberConn = new ServerConnection(subscriberName);  
ServerConnection publisherConn = new ServerConnection(publisherName);  
  
// Create the objects that we need.  
MergePublication publication;  
MergePullSubscription subscription;  
  
try  
{  
    // Connect to the Subscriber.  
    subscriberConn.Connect();  
  
    // Ensure that the publication exists and that   
    // it supports pull subscriptions.  
    publication = new MergePublication();  
    publication.Name = publicationName;  
    publication.DatabaseName = publicationDbName;  
    publication.ConnectionContext = publisherConn;  
  
    if (publication.LoadProperties())  
    {  
        if ((publication.Attributes & PublicationAttributes.AllowPull) == 0)  
        {  
            publication.Attributes |= PublicationAttributes.AllowPull;  
        }  
  
        // Define the pull subscription.  
        subscription = new MergePullSubscription();  
        subscription.ConnectionContext = subscriberConn;  
        subscription.PublisherName = publisherName;  
        subscription.PublicationName = publicationName;  
        subscription.PublicationDBName = publicationDbName;  
        subscription.DatabaseName = subscriptionDbName;  
        subscription.HostName = hostname;  
  
        // Specify the Windows login credentials for the Merge Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin;  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword;  
  
        // Make sure that the agent job for the subscription is created.  
        subscription.CreateSyncAgentByDefault = true;  
  
        // Create the pull subscription at the Subscriber.  
        subscription.Create();  
  
        Boolean registered = false;  
  
        // Verify that the subscription is not already registered.  
        foreach (MergeSubscription existing  
            in publication.EnumSubscriptions())  
        {  
            if (existing.SubscriberName == subscriberName  
                && existing.SubscriptionDBName == subscriptionDbName  
                && existing.SubscriptionType == SubscriptionOption.Pull)  
            {  
                registered = true;  
            }  
        }  
        if (!registered)  
        {  
            // Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown(  
                subscriberName, subscriptionDbName,  
                SubscriptionSyncType.Automatic,  
                MergeSubscriberType.Local, 0);  
        }  
    }  
    else  
    {  
        // Do something here if the publication does not exist.  
        throw new ApplicationException(String.Format(  
            "The publication '{0}' does not exist on {1}.",  
            publicationName, publisherName));  
    }  
}  
catch (Exception ex)  
{  
    // Implement the appropriate error handling here.  
    throw new ApplicationException(String.Format(  
        "The subscription to {0} could not be created.", publicationName), ex);  
}  
finally  
{  
    subscriberConn.Disconnect();  
    publisherConn.Disconnect();  
}  
  

' Define the Publisher, publication, and databases.  
Dim publicationName As String = "AdvWorksSalesOrdersMerge"  
Dim publisherName As String = publisherInstance  
Dim subscriberName As String = subscriberInstance  
Dim subscriptionDbName As String = "AdventureWorksReplica"  
Dim publicationDbName As String = "AdventureWorks"  
Dim hostname As String = "adventure-works\garrett1"  
  
'Create connections to the Publisher and Subscriber.  
Dim subscriberConn As ServerConnection = New ServerConnection(subscriberName)  
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)  
  
' Create the objects that we need.  
Dim publication As MergePublication  
Dim subscription As MergePullSubscription  
  
Try  
    ' Connect to the Subscriber.  
    subscriberConn.Connect()  
  
    ' Ensure that the publication exists and that   
    ' it supports pull subscriptions.  
    publication = New MergePublication()  
    publication.Name = publicationName  
    publication.DatabaseName = publicationDbName  
    publication.ConnectionContext = publisherConn  
  
    If publication.LoadProperties() Then  
        If (publication.Attributes And PublicationAttributes.AllowPull) = 0 Then  
            publication.Attributes = publication.Attributes _  
            Or PublicationAttributes.AllowPull  
        End If  
  
        ' Define the pull subscription.  
        subscription = New MergePullSubscription()  
        subscription.ConnectionContext = subscriberConn  
        subscription.PublisherName = publisherName  
        subscription.PublicationName = publicationName  
        subscription.PublicationDBName = publicationDbName  
        subscription.DatabaseName = subscriptionDbName  
        subscription.HostName = hostname  
  
        ' Specify the Windows login credentials for the Merge Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword  
  
        ' Make sure that the agent job for the subscription is created.  
        subscription.CreateSyncAgentByDefault = True  
  
        ' Create the pull subscription at the Subscriber.  
        subscription.Create()  
  
        Dim registered As Boolean = False  
  
        ' Verify that the subscription is not already registered.  
        For Each existing As MergeSubscription In _  
        publication.EnumSubscriptions()  
            If existing.SubscriberName = subscriberName Then  
                registered = True  
            End If  
        Next  
        If Not registered Then  
            ' Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown( _  
             subscriberName, subscriptionDbName, _  
             SubscriptionSyncType.Automatic, _  
             MergeSubscriberType.Local, 0)  
        End If  
    Else  
        ' Do something here if the publication does not exist.  
        Throw New ApplicationException(String.Format( _  
         "The publication '{0}' does not exist on {1}.", _  
         publicationName, publisherName))  
    End If  
Catch ex As Exception  
    ' Implement the appropriate error handling here.  
    Throw New ApplicationException(String.Format( _  
        "The subscription to {0} could not be created.", publicationName), ex)  
Finally  
    subscriberConn.Disconnect()  
    publisherConn.Disconnect()  
End Try

Ten przykład tworzy subskrypcję pull do publikacji merge bez tworzenia powiązanego zadania agenta i metadanych subskrypcji w MSsubscription_properties. Poświadczenia do konta Windows używane do utworzenia zadania Merge Agent są przekazywane w czasie działania.

// Define the Publisher, publication, and databases.  
string publicationName = "AdvWorksSalesOrdersMerge";  
string publisherName = publisherInstance;  
string subscriberName = subscriberInstance;  
string subscriptionDbName = "AdventureWorksReplica";  
string publicationDbName = "AdventureWorks";  
  
//Create connections to the Publisher and Subscriber.  
ServerConnection subscriberConn = new ServerConnection(subscriberName);  
ServerConnection publisherConn = new ServerConnection(publisherName);  
  
// Create the objects that we need.  
MergePublication publication;  
MergePullSubscription subscription;  
  
try  
{  
    // Connect to the Subscriber.  
    subscriberConn.Connect();  
  
    // Ensure that the publication exists and that   
    // it supports pull subscriptions.  
    publication = new MergePublication();  
    publication.Name = publicationName;  
    publication.DatabaseName = publicationDbName;  
    publication.ConnectionContext = publisherConn;  
  
    if (publication.LoadProperties())  
    {  
        if ((publication.Attributes & PublicationAttributes.AllowPull) == 0)  
        {  
            publication.Attributes |= PublicationAttributes.AllowPull;  
        }  
  
        // Define the pull subscription.  
        subscription = new MergePullSubscription();  
        subscription.ConnectionContext = subscriberConn;  
        subscription.PublisherName = publisherName;  
        subscription.PublicationName = publicationName;  
        subscription.PublicationDBName = publicationDbName;  
        subscription.DatabaseName = subscriptionDbName;  
  
        // Specify that an agent job not be created for this subscription. The  
        // subscription can only be synchronized by running the Merge Agent directly.  
        // Subscription metadata stored in MSsubscription_properties will not  
        // be available and must be specified at run time.  
        subscription.CreateSyncAgentByDefault = false;  
  
        // Create the pull subscription at the Subscriber.  
        subscription.Create();  
  
        Boolean registered = false;  
  
        // Verify that the subscription is not already registered.  
        foreach (MergeSubscription existing  
            in publication.EnumSubscriptions())  
        {  
            if (existing.SubscriberName == subscriberName  
                && existing.SubscriptionDBName == subscriptionDbName  
                && existing.SubscriptionType == SubscriptionOption.Pull)  
            {  
                registered = true;  
            }  
        }  
        if (!registered)  
        {  
            // Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown(  
                subscriberName, subscriptionDbName,  
                SubscriptionSyncType.Automatic,  
                MergeSubscriberType.Local, 0);  
        }  
    }  
    else  
    {  
        // Do something here if the publication does not exist.  
        throw new ApplicationException(String.Format(  
            "The publication '{0}' does not exist on {1}.",  
            publicationName, publisherName));  
    }  
}  
catch (Exception ex)  
{  
    // Implement the appropriate error handling here.  
    throw new ApplicationException(String.Format(  
        "The subscription to {0} could not be created.", publicationName), ex);  
}  
finally  
{  
    subscriberConn.Disconnect();  
    publisherConn.Disconnect();  
}  

' Define the Publisher, publication, and databases.  
Dim publicationName As String = "AdvWorksSalesOrdersMerge"  
Dim publisherName As String = publisherInstance  
Dim subscriberName As String = subscriberInstance  
Dim subscriptionDbName As String = "AdventureWorksReplica"  
Dim publicationDbName As String = "AdventureWorks"  
  
'Create connections to the Publisher and Subscriber.  
Dim subscriberConn As ServerConnection = New ServerConnection(subscriberName)  
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)  
  
' Create the objects that we need.  
Dim publication As MergePublication  
Dim subscription As MergePullSubscription  
  
Try  
    ' Connect to the Subscriber.  
    subscriberConn.Connect()  
  
    ' Ensure that the publication exists and that   
    ' it supports pull subscriptions.  
    publication = New MergePublication()  
    publication.Name = publicationName  
    publication.DatabaseName = publicationDbName  
    publication.ConnectionContext = publisherConn  
  
    If publication.LoadProperties() Then  
        If (publication.Attributes And PublicationAttributes.AllowPull) = 0 Then  
            publication.Attributes = publication.Attributes _  
            Or PublicationAttributes.AllowPull  
        End If  
  
        ' Define the pull subscription.  
        subscription = New MergePullSubscription()  
        subscription.ConnectionContext = subscriberConn  
        subscription.PublisherName = publisherName  
        subscription.PublicationName = publicationName  
        subscription.PublicationDBName = publicationDbName  
        subscription.DatabaseName = subscriptionDbName  
  
        ' Specify that an agent job not be created for this subscription. The  
        ' subscription can only be synchronized by running the Merge Agent directly.  
        ' Subscription metadata stored in MSsubscription_properties will not  
        ' be available and must be specified at run time.  
        subscription.CreateSyncAgentByDefault = False  
  
        ' Create the pull subscription at the Subscriber.  
        subscription.Create()  
  
        Dim registered As Boolean = False  
  
        ' Verify that the subscription is not already registered.  
        For Each existing As MergeSubscription In _  
        publication.EnumSubscriptions()  
            If existing.SubscriberName = subscriberName Then  
                registered = True  
            End If  
        Next  
        If Not registered Then  
            ' Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown( _  
             subscriberName, subscriptionDbName, _  
             SubscriptionSyncType.Automatic, _  
             MergeSubscriberType.Local, 0)  
        End If  
    Else  
        ' Do something here if the publication does not exist.  
        Throw New ApplicationException(String.Format( _  
         "The publication '{0}' does not exist on {1}.", _  
         publicationName, publisherName))  
    End If  
Catch ex As Exception  
    ' Implement the appropriate error handling here.  
    Throw New ApplicationException(String.Format( _  
     "The subscription to {0} could not be created.", publicationName), ex)  
Finally  
    subscriberConn.Disconnect()  
    publisherConn.Disconnect()  
End Try

Ten przykład tworzy subskrypcję pull do publikacji scalającej, którą można synchronizować przez Internet za pomocą synchronizacji webowej. Poświadczenia do konta Windows używane do utworzenia zadania Merge Agent są przekazywane w czasie działania. Więcej informacji można znaleźć w sekcji Konfiguruj synchronizację sieci.

// Define the Publisher, publication, and databases.  
string publicationName = "AdvWorksSalesOrdersMerge";  
string publisherName = publisherInstance;  
string subscriberName = subscriberInstance;  
string subscriptionDbName = "AdventureWorksReplica";  
string publicationDbName = "AdventureWorks";  
string hostname = @"adventure-works\garrett1";  
string webSyncUrl = "https://" + publisherInstance + "/WebSync/replisapi.dll";  
  
//Create connections to the Publisher and Subscriber.  
ServerConnection subscriberConn = new ServerConnection(subscriberName);  
ServerConnection publisherConn = new ServerConnection(publisherName);  
  
// Create the objects that we need.  
MergePublication publication;  
MergePullSubscription subscription;  
  
try  
{  
    // Connect to the Subscriber.  
    subscriberConn.Connect();  
  
    // Ensure that the publication exists and that   
    // it supports pull subscriptions and Web synchronization.  
    publication = new MergePublication();  
    publication.Name = publicationName;  
    publication.DatabaseName = publicationDbName;  
    publication.ConnectionContext = publisherConn;  
  
    if (publication.LoadProperties())  
    {  
        if ((publication.Attributes & PublicationAttributes.AllowPull) == 0)  
        {  
            publication.Attributes |= PublicationAttributes.AllowPull;  
        }  
        if ((publication.Attributes & PublicationAttributes.AllowWebSynchronization) == 0)  
        {  
            publication.Attributes |= PublicationAttributes.AllowWebSynchronization;  
        }  
  
        // Define the pull subscription.  
        subscription = new MergePullSubscription();  
        subscription.ConnectionContext = subscriberConn;  
        subscription.PublisherName = publisherName;  
        subscription.PublicationName = publicationName;  
        subscription.PublicationDBName = publicationDbName;  
        subscription.DatabaseName = subscriptionDbName;  
        subscription.HostName = hostname;  
  
        // Specify the Windows login credentials for the Merge Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin;  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword;  
  
        // Enable Web synchronization.  
        subscription.UseWebSynchronization = true;  
        subscription.InternetUrl = webSyncUrl;  
  
        // Specify the same Windows credentials to use when connecting to the  
        // Web server using HTTPS Basic Authentication.  
        subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication;  
        subscription.InternetLogin = winLogin;  
        subscription.InternetPassword = winPassword;  
  
        // Ensure that we create a job for this subscription.  
        subscription.CreateSyncAgentByDefault = true;  
  
        // Create the pull subscription at the Subscriber.  
        subscription.Create();  
  
        Boolean registered = false;  
  
        // Verify that the subscription is not already registered.  
        foreach (MergeSubscription existing  
            in publication.EnumSubscriptions())  
        {  
            if (existing.SubscriberName == subscriberName  
                && existing.SubscriptionDBName == subscriptionDbName  
                && existing.SubscriptionType == SubscriptionOption.Pull)  
            {  
                registered = true;  
            }  
        }  
        if (!registered)  
        {  
            // Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown(  
                subscriberName, subscriptionDbName,  
                SubscriptionSyncType.Automatic,  
                MergeSubscriberType.Local, 0);  
        }  
    }  
    else  
    {  
        // Do something here if the publication does not exist.  
        throw new ApplicationException(String.Format(  
            "The publication '{0}' does not exist on {1}.",  
            publicationName, publisherName));  
    }  
}  
catch (Exception ex)  
{  
    // Implement the appropriate error handling here.  
    throw new ApplicationException(String.Format(  
        "The subscription to {0} could not be created.", publicationName), ex);  
}  
finally  
{  
    subscriberConn.Disconnect();  
    publisherConn.Disconnect();  
}  

' Define the Publisher, publication, and databases.  
Dim publicationName As String = "AdvWorksSalesOrdersMerge"  
Dim publisherName As String = publisherInstance  
Dim subscriberName As String = subscriberInstance  
Dim subscriptionDbName As String = "AdventureWorksReplica"  
Dim publicationDbName As String = "AdventureWorks"  
Dim hostname As String = "adventure-works\garrett1"  
Dim webSyncUrl As String = "https://" + publisherInstance + "/WebSync/replisapi.dll"  
  
'Create connections to the Publisher and Subscriber.  
Dim subscriberConn As ServerConnection = New ServerConnection(subscriberName)  
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)  
  
' Create the objects that we need.  
Dim publication As MergePublication  
Dim subscription As MergePullSubscription  
  
Try  
    ' Connect to the Subscriber.  
    subscriberConn.Connect()  
  
    ' Ensure that the publication exists and that   
    ' it supports pull subscriptions and Web synchronization.  
    publication = New MergePublication()  
    publication.Name = publicationName  
    publication.DatabaseName = publicationDbName  
    publication.ConnectionContext = publisherConn  
  
    If publication.LoadProperties() Then  
        If (publication.Attributes And PublicationAttributes.AllowPull) = 0 Then  
            publication.Attributes = publication.Attributes _  
            Or PublicationAttributes.AllowPull  
        End If  
        If (publication.Attributes And PublicationAttributes.AllowWebSynchronization) = 0 Then  
            publication.Attributes = publication.Attributes _  
            Or PublicationAttributes.AllowWebSynchronization  
        End If  
  
        ' Define the pull subscription.  
        subscription = New MergePullSubscription()  
        subscription.ConnectionContext = subscriberConn  
        subscription.PublisherName = publisherName  
        subscription.PublicationName = publicationName  
        subscription.PublicationDBName = publicationDbName  
        subscription.DatabaseName = subscriptionDbName  
        subscription.HostName = hostname  
        subscription.CreateSyncAgentByDefault = True  
  
        ' Specify the Windows login credentials for the Merge Agent job.  
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin  
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword  
  
        ' Enable Web synchronization.  
        subscription.UseWebSynchronization = True  
        subscription.InternetUrl = webSyncUrl  
  
        ' Specify the same Windows credentials to use when connecting to the  
        ' Web server using HTTPS Basic Authentication.  
        subscription.InternetSecurityMode = AuthenticationMethod.BasicAuthentication  
        subscription.InternetLogin = winLogin  
        subscription.InternetPassword = winPassword  
  
        ' Create the pull subscription at the Subscriber.  
        subscription.Create()  
  
        Dim registered As Boolean = False  
  
        ' Verify that the subscription is not already registered.  
        For Each existing As MergeSubscription In _  
        publication.EnumSubscriptions()  
            If existing.SubscriberName = subscriberName Then  
                registered = True  
            End If  
        Next  
        If Not registered Then  
            ' Register the local subscription with the Publisher.  
            publication.MakePullSubscriptionWellKnown( _  
             subscriberName, subscriptionDbName, _  
             SubscriptionSyncType.Automatic, _  
             MergeSubscriberType.Local, 0)  
        End If  
    Else  
        ' Do something here if the publication does not exist.  
        Throw New ApplicationException(String.Format( _  
         "The publication '{0}' does not exist on {1}.", _  
         publicationName, publisherName))  
    End If  
Catch ex As Exception  
    ' Implement the appropriate error handling here.  
    Throw New ApplicationException(String.Format( _  
     "The subscription to {0} could not be created.", publicationName), ex)  
Finally  
    subscriberConn.Disconnect()  
    publisherConn.Disconnect()  
End Try

Treści powiązane

  • Last updated on