Tworzenie publikacji

Dotyczy:SQL ServerAzure SQL Managed Instance

Ten artykuł opisuje, jak stworzyć publikację w SQL Server za pomocą SQL Server Management Studio, Transact-SQL lub Replication Management Objects (RMO).

Limity i ograniczenia

  • Nazwy publikacji i artykułów nie mogą zawierać żadnych z następujących znaków: %, , *[, ], |, ?":\/'<lub .> Jeśli obiekty w bazie danych zawierają dowolny z tych znaków i chcesz je replikować, musisz określić nazwę artykułu inną od nazwy obiektu w oknie dialogowym Właściwości artykułu — <Artykuł>, dostępnym z poziomu strony Artykuły w kreatorze.

Zabezpieczenia

Jeśli to możliwe, proś użytkowników o wprowadzenie poświadczeń uwierzytelniających podczas działania. Jeśli musisz przechowywać dane uwierzytelniające, skorzystaj z usług kryptograficznych oferowanych przez Microsoft Windows .NET Framework.

Korzystanie z programu SQL Server Management Studio

Twórz publikacje i definiuj artykuły za pomocą Nowego Czarojaka Publikacji. Po utworzeniu publikacji możesz zobaczyć i zmodyfikować właściwości publikacji w oknie dialogowym Właściwości publikacji - <Publikacja> . Aby uzyskać informacje o tworzeniu publikacji z bazy danych Oracle, zobacz Utwórz publikację z bazy Oracle.

Tworzenie publikacji i definiowanie artykułów

  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 kliknij prawym przyciskiem myszy na folder Lokalne Publikacje .

  3. Wybierz Nową publikację.

  4. Przejdź przez strony w Kreatorze nowej publikacji, aby:

    • Określ dystrybutora, jeśli dystrybucja nie została skonfigurowana na serwerze. Więcej informacji na temat konfiguracji dystrybucji można znaleźć w sekcji Configure Publishing and Distribution.

      Jeśli na stronie Dystrybutora określisz, że serwer Publisher będzie działał jako własny Dystrybutor (lokalny dystrybutor), a serwer nie jest skonfigurowany jako Dystrybutor, Kreator Nowych Publikacji skonfiguruje serwer. Na stronie folderu Snapshot określisz domyślny folder snapshot dla Dystrybutora. Folder snapshot to po prostu katalog, który wyznaczyłeś jako udostępniony; Agenci, którzy czytają z tego folderu i do niego zapisują, muszą mieć odpowiednie uprawnienia do dostępu. Aby uzyskać więcej informacji o odpowiednim zabezpieczeniu folderu, zobacz Zabezpiecz folder Snapshot.

      Jeśli określisz, że inny serwer ma działać jako Dystrybutor, musisz wprowadzić hasło na stronie Hasło administracyjne dla połączeń nawiązywanych z Publikatora do Dystrybutora. To hasło musi być zgodne z hasłem podanym podczas aktywacji Publisher u zdalnego dystrybutora.

      Aby uzyskać więcej informacji, zobacz Konfigurowanie dystrybucji.

    • Wybierz bazę publikacji.

    • Wybierz typ publikacji. Więcej informacji można znaleźć w artykule Rodzaje replikacji.

    • Określ dane i obiekty bazy danych do publikacji; opcjonalnie filtruj kolumny z artykułów tabelowych i ustaw właściwości artykułów.

    • Opcjonalnie filtruj wiersze z artykułów tabelowych. Aby uzyskać więcej informacji, zobacz Filtrowanie opublikowanych danych.

    • Ustaw harmonogram agenta Snapshot.

    • Określ dane uwierzytelniające, na których działają następujące agenty replikacyjne i nawiązują połączenia:

    • Opcjonalnie napisz scenariusz publikacji. Więcej informacji można znaleźć w artykule Replikacja skryptów.

    • Określ nazwę publikacji.

Korzystanie z Transact-SQL

Publikacje mogą być tworzone programowo za pomocą procedur przechowywanych w replikacji. Stosowane procedury przechowywane będą zależeć od rodzaju tworzonej publikacji.

Stwórz migawkę lub publikację transakcyjną

  1. Na serwerze Publisher, w bazie danych publikacji wykonaj polecenie sp_replicationdboption (Transact-SQL), aby włączyć publikowanie bieżącej bazy danych przy użyciu replikacji migawkowej lub transakcyjnej.

  2. W przypadku publikacji transakcyjnej ustal, czy istnieje stanowisko Log Reader Agent dla bazy danych publikacji. (Ten krok nie jest wymagany dla publikacji migawkowych.)

    • Jeśli istnieje stanowisko Log Reader Agent dla bazy publikacji, przejdź do kroku 3.

    • Jeśli nie masz pewności, czy dla opublikowanej bazy danych istnieje zadanie agenta Log Reader Agent, wykonaj polecenie sp_helplogreader_agent (Transact-SQL) u wydawcy w bazie danych publikacji.

    • Jeśli zbiór wyników jest pusty, utworz zadanie Log Reader Agent. Na Publisher wykonaj sp_addlogreader_agent (Transact-SQL). Określ poświadczenia systemu Microsoft Windows używane przez agenta dla @job_name i @password. Jeśli agent użyje uwierzytelniania SQL Server podczas łączenia z Publisher, musisz również podać wartość 0 dla @publisher_security_mode oraz dane logowania do SQL Server dla @publisher_login i @publisher_password. Przejdź do kroku 3.

  3. Na Publisher wykonaj sp_addpublication (Transact-SQL). Określ nazwę publikacji dla @publication, a dla parametru @repl_freq wartość dla snapshot publikacji migawkowej lub wartość continuous dla publikacji transakcyjnej. Określ inne opcje publikacji. To definiuje publikację.

    Note

    Nazwy publikacji nie mogą zawierać następujących znaków:

    %, *, [, ], |, :, \, ?, /, ", < lub >.

  4. Na Publisher wykonaj sp_addpublication_snapshot (Transact-SQL). Określ nazwę publikacji używaną w kroku 3 dla @publication oraz poświadczenia systemu Windows, w ramach których działa Agent migawki dla @snapshot_job_name i @password. Jeśli agent użyje uwierzytelniania SQL Server podczas łączenia z Publisher, musisz również podać wartość 0 dla @publisher_security_mode oraz dane logowania do SQL Server dla @publisher_login i publisher_password. To tworzy stanowisko Snapshot Agent dla publikacji.

    Ważna

    Podczas konfigurowania wydawcy za pomocą zdalnego dystrybutora wartości podane dla wszystkich parametrów, w tym job_login i job_password, są wysyłane do dystrybutora jako zwykły tekst. Przed wykonaniem tej procedury składowanej należy zaszyfrować połączenie między wydawcą a jego zdalnym dystrybutorem. Aby uzyskać więcej informacji, zobacz Włączanie szyfrowanych połączeń z silnikiem bazy danych (SQL Server Configuration Manager).

  5. Dodaj artykuły do publikacji. Aby uzyskać więcej informacji, zobacz Definiowanie artykułu.

  6. Uruchom zadanie Snapshot Agent, aby wygenerować początkową migawkę dla tej publikacji. Aby uzyskać więcej informacji, zobacz Tworzenie i stosowanie migawki początkowej.

Stwórz publikację scaloną

  1. Na serwerze Wydawcy uruchom sp_replicationdboption (Transact-SQL), aby włączyć publikowanie bieżącej bazy danych przy użyciu replikacji łączenia.

  2. Na Publikatorze, w bazie danych publikacji, wykonaj sp_addmergepublication (Transact-SQL). Określ nazwę publikacji dla @publication oraz wszelkie inne opcje publikacji. To definiuje publikację.

    Note

    Nazwy publikacji nie mogą zawierać następujących znaków:

    %, *, [, ], |, :, \, ?, /, ", < lub >.

  3. Na Publisher wykonaj sp_addpublication_snapshot (Transact-SQL). Określ nazwę publikacji używaną w kroku 2 dla @publication oraz poświadczenia systemu Windows, na których działa Agent migawki dla @snapshot_job_name i @password. Jeśli agent użyje uwierzytelniania SQL Server podczas łączenia z Publisher, musisz również podać wartość 0 dla @publisher_security_mode oraz dane logowania do SQL Server dla @publisher_login i @publisher_password. To tworzy stanowisko Snapshot Agent dla publikacji.

    Ważna

    Podczas konfigurowania wydawcy za pomocą zdalnego dystrybutora wartości podane dla wszystkich parametrów, w tym job_login i job_password, są wysyłane do dystrybutora jako zwykły tekst. Przed wykonaniem tej procedury składowanej należy zaszyfrować połączenie między wydawcą a jego zdalnym dystrybutorem. Aby uzyskać więcej informacji, zobacz Włączanie szyfrowanych połączeń z silnikiem bazy danych (SQL Server Configuration Manager).

  4. Dodaj artykuły do publikacji. Aby uzyskać więcej informacji, zobacz Definiowanie artykułu.

  5. Uruchom zadanie Snapshot Agent, aby wygenerować początkową migawkę dla tej publikacji. Aby uzyskać więcej informacji, zobacz Tworzenie i stosowanie migawki początkowej.

Przykład (Transact-SQL)

Ten przykład tworzy publikację transakcyjną. Zmienne skryptowe służą do przekazywania poświadczeń Windows niezbędnych do tworzenia zadań dla Snapshot Agent i Log Reader Agent.

-- To avoid storing the login and password in the script file, the values 
-- are passed into SQLCMD as scripting variables. 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".

DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks'; 
SET @publication = N'AdvWorksProductTran'; 
-- Windows account used to run the Log Reader and Snapshot Agents.
SET @login = $(Login); 
-- This should be passed at runtime.
SET @password = $(Password); 

-- Enable transactional or snapshot replication on the publication database.
EXEC sp_replicationdboption 
    @dbname=@publicationDB, 
    @optname=N'publish',
    @value = N'true';

-- Execute sp_addlogreader_agent to create the agent job. 
EXEC sp_addlogreader_agent 
    @job_login = @login, 
    @job_password = @password,
    -- Explicitly specify the use of Windows Integrated Authentication (default) 
    -- when connecting to the Publisher.
    @publisher_security_mode = 1;

-- Create a new transactional publication with the required properties. 
EXEC sp_addpublication 
    @publication = @publication, 
    @status = N'active',
    @allow_push = N'true',
    @allow_pull = N'true',
    @independent_agent = N'true';

-- Create a new snapshot job for the publication, using a default schedule.
EXEC sp_addpublication_snapshot 
    @publication = @publication, 
    @job_login = @login, 
    @job_password = @password,
    -- Explicitly specify the use of Windows Integrated Authentication (default) 
    -- when connecting to the Publisher.
    @publisher_security_mode = 1;
GO

Ten przykład tworzy publikację scalaną. Zmienne skryptowe służą do przekazywania poświadczeń Windows niezbędnych do utworzenia zadania dla Snapshot Agent.

-- To avoid storing the login and password in the script file, the value 
-- is passed into SQLCMD as a scripting variable. 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".

--Declarations for adding a merge publication
DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks2022'; 
SET @publication = N'AdvWorksSalesOrdersMerge'; 
SET @login = $(Login);
SET @password = $(Password);

-- Enable merge replication on the publication database, using defaults.
USE master
EXEC sp_replicationdboption 
  @dbname=@publicationDB, 
  @optname=N'merge publish',
  @value = N'true' 

-- Create a new merge publication, explicitly setting the defaults. 
USE [AdventureWorks2022]
EXEC sp_addmergepublication 
-- These parameters are optional.
  @publication = @publication,
  -- optional parameters 
  @description = N'Merge publication of AdventureWorks2022.',
  @publication_compatibility_level  = N'120RTM';

-- Create a new snapshot job for the publication.
EXEC sp_addpublication_snapshot 
  @publication = @publication, 
  @job_login = @login, 
  @job_password = @password;
GO

Używaj obiektów zarządzania replikacją (RMO)

Możesz tworzyć publikacje programowo za pomocą Obiektów Zarządzania Replikacją (RMO). Klasy RMO, których używasz do tworzenia publikacji, zależą od rodzaju publikacji, którą tworzysz.

Stwórz migawkę lub publikację transakcyjną

  1. Utwórz połączenie z programem Publisher przy użyciu klasy ServerConnection.

  2. Utwórz instancję klasy ReplicationDatabase dla bazy danych publikacji, ustaw właściwość ConnectionContext na instancję ServerConnection z kroku 1 i wywołaj metodę LoadProperties. Jeśli LoadProperties zwraca false, zweryfikowaj, że baza danych istnieje.

  3. Jeśli własność EnabledTransPublishing to false, ustaw ją na .true

  4. W przypadku publikacji transakcyjnej sprawdź wartość właściwości LogReaderAgentExists. Jeśli ta właściwość to true, istnieje już zadanie Log Read Agent dla tej bazy danych. Jeśli ta właściwość jest false, wykonaj następujące czynności:

  5. Stwórz instancję klasy TransPublication i ustaw następujące właściwości dla tego obiektu:

  6. Wywołaj metodę Create, aby utworzyć publikację.

    Ważna

    Podczas konfiguracji Publisher z dystrybutorem zdalnym, wartości podane dla wszystkich właściwości, w tym SnapshotGenerationAgentProcessSecurity, są przesyłane do dystrybutora jako tekst zwykły. Przed wywołaniem metody należy zaszyfrować połączenie między wydawcą a jego zdalnym dystrybutorem Create . Aby uzyskać więcej informacji, zobacz Włączanie szyfrowanych połączeń z silnikiem bazy danych (SQL Server Configuration Manager).

  7. Wywołaj metodę CreateSnapshotAgent, aby utworzyć zadanie agenta Snapshot dla publikacji.

Stwórz publikację scaloną

  1. Utwórz połączenie z programem Publisher przy użyciu klasy ServerConnection.

  2. Utwórz instancję klasy ReplicationDatabase dla bazy danych publikacji, ustaw właściwość ConnectionContext na instancję ServerConnection z kroku 1 i wywołaj metodę LoadProperties. Jeśli LoadProperties zwraca false, zweryfikowaj, że baza danych istnieje.

  3. Jeśli właściwość EnabledMergePublishing ma wartość false, ustaw ją na true i wywołaj CommitPropertyChanges.

  4. Stwórz instancję klasy MergePublication i ustaw następujące właściwości dla tego obiektu:

    • ServerConnection z kroku 1 dla ConnectionContext.

    • Nazwa opublikowanej bazy danych dla DatabaseName.

    • Nazwa publikacji dla Name.

    • Pola LoginSnapshotGenerationAgentProcessSecurity i Password , aby podać dane uwierzytelniające dla konta Windows, pod którym działa Snapshot Agent. To konto jest również używane, gdy Snapshot Agent nawiązuje połączenia z lokalnym dystrybutorem oraz do zdalnych połączeń podczas uwierzytelniania Windows.

      Note

      Ustawienie SnapshotGenerationAgentProcessSecurity nie jest wymagane, gdy publikacja jest tworzona przez członka roli stałego administratora systemu . Aby uzyskać więcej informacji, zobacz model zabezpieczeń agenta replikacji .

    • (Opcjonalnie) Użyj operatora logicznego OR (|w Visual C# i Or Visual Basic) oraz wyłącznego operatora logicznego OR (^w Visual C# i Xor Visual Basic) do ustawienia PublicationAttributes wartości dla tej Attributes właściwości.

  5. Wywołaj metodę Create, aby utworzyć publikację.

    Ważna

    Podczas konfiguracji Publisher z dystrybutorem zdalnym, wartości podane dla wszystkich właściwości, w tym SnapshotGenerationAgentProcessSecurity, są przesyłane do dystrybutora jako tekst zwykły. Przed wywołaniem metody należy zaszyfrować połączenie między wydawcą a jego zdalnym dystrybutorem Create . Aby uzyskać więcej informacji, zobacz Włączanie szyfrowanych połączeń z silnikiem bazy danych (SQL Server Configuration Manager).

  6. Wywołaj metodę CreateSnapshotAgent, aby utworzyć zadanie Agenta migawki dla publikacji.

Przykłady (RMO)

Ten przykład umożliwia publikację transakcyjną bazy danych AdventureWorks , definiuje zadanie Log Reader Agent i tworzy publikację AdvWorksProductTran . Artykuł musi być zdefiniowany dla tej publikacji. Poświadczenia konta Windows potrzebne do utworzenia zadania Log Reader Agent oraz zadania Snapshot Agent są przekazywane w czasie działania. Aby dowiedzieć się, jak używać RMO do definiowania artykułów migawkowych i transakcyjnych, zobacz Definiuj artykuł.

// Set the Publisher, publication database, and publication names.
string publicationName = "AdvWorksProductTran";
string publicationDbName = "AdventureWorks2022";
string publisherName = publisherInstance;

ReplicationDatabase publicationDb;
TransPublication publication;

// Create a connection to the Publisher using Windows Authentication.
ServerConnection conn;
conn = new ServerConnection(publisherName);


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

    // Enable the AdventureWorks2022 database for transactional publishing.
    publicationDb = new ReplicationDatabase(publicationDbName, conn);

    // If the database exists and is not already enabled, 
    // enable it for transactional publishing.
    if (publicationDb.LoadProperties())
    {
        if (!publicationDb.EnabledTransPublishing)
        {
            publicationDb.EnabledTransPublishing = true;
        }

        // If the Log Reader Agent does not exist, create it.
        if (!publicationDb.LogReaderAgentExists)
        {
            // Specify the Windows account under which the agent job runs.
            // This account will be used for the local connection to the 
            // Distributor and all agent connections that use Windows Authentication.
            publicationDb.LogReaderAgentProcessSecurity.Login = winLogin;
            publicationDb.LogReaderAgentProcessSecurity.Password = winPassword;

            // Explicitly set authentication mode for the Publisher connection
            // to the default value of Windows Authentication.
            publicationDb.LogReaderAgentPublisherSecurity.WindowsAuthentication = true;

            // Create the Log Reader Agent job.
            publicationDb.CreateLogReaderAgent();
        }
    }
    else
    {
        throw new ApplicationException(String.Format(
            "The {0} database does not exist at {1}.",
            publicationDb, publisherName));
    }

    // Set the required properties for the transactional publication.
    publication = new TransPublication();
    publication.ConnectionContext = conn;
    publication.Name = publicationName;
    publication.DatabaseName = publicationDbName;

    // Specify a transactional publication (the default).
    publication.Type = PublicationType.Transactional;

    // Activate the publication so that we can add subscriptions.
    publication.Status = State.Active;

    // Enable push and pull subscriptions and independent Distribition Agents.
    publication.Attributes |= PublicationAttributes.AllowPull;
    publication.Attributes |= PublicationAttributes.AllowPush;
    publication.Attributes |= PublicationAttributes.IndependentAgent;

    // Specify the Windows account under which the Snapshot Agent job runs.
    // This account will be used for the local connection to the 
    // Distributor and all agent connections that use Windows Authentication.
    publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin;
    publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword;

    // Explicitly set the security mode for the Publisher connection
    // Windows Authentication (the default).
    publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = true;

    if (!publication.IsExistingObject)
    {
        // Create the transactional publication.
        publication.Create();

        // Create a Snapshot Agent job for the publication.
        publication.CreateSnapshotAgent();
    }
    else
    {
        throw new ApplicationException(String.Format(
            "The {0} publication already exists.", publicationName));
    }
}

catch (Exception ex)
{
    // Implement custom application error handling here.
    throw new ApplicationException(String.Format(
        "The publication {0} could not be created.", publicationName), ex);
}
finally
{
    conn.Disconnect();
}

' Set the Publisher, publication database, and publication names.
Dim publicationName As String = "AdvWorksProductTran"
Dim publicationDbName As String = "AdventureWorks2022"
Dim publisherName As String = publisherInstance

Dim publicationDb As ReplicationDatabase
Dim publication As TransPublication

' Create a connection to the Publisher using Windows Authentication.
Dim conn As ServerConnection
conn = New ServerConnection(publisherName)

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

    ' Enable the AdventureWorks2022 database for transactional publishing.
    publicationDb = New ReplicationDatabase(publicationDbName, conn)

    ' If the database exists and is not already enabled, 
    ' enable it for transactional publishing.
    If publicationDb.LoadProperties() Then
        If Not publicationDb.EnabledTransPublishing Then
            publicationDb.EnabledTransPublishing = True
        End If

        ' If the Log Reader Agent does not exist, create it.
        If Not publicationDb.LogReaderAgentExists Then
            ' Specify the Windows account under which the agent job runs.
            ' This account will be used for the local connection to the 
            ' Distributor and all agent connections that use Windows Authentication.
            publicationDb.LogReaderAgentProcessSecurity.Login = winLogin
            publicationDb.LogReaderAgentProcessSecurity.Password = winPassword

            ' Explicitly set authentication mode for the Publisher connection
            ' to the default value of Windows Authentication.
            publicationDb.LogReaderAgentPublisherSecurity.WindowsAuthentication = True

            ' Create the Log Reader Agent job.
            publicationDb.CreateLogReaderAgent()
        End If
    Else
        Throw New ApplicationException(String.Format( _
         "The {0} database does not exist at {1}.", _
         publicationDb, publisherName))
    End If

    ' Set the required properties for the transactional publication.
    publication = New TransPublication()
    publication.ConnectionContext = conn
    publication.Name = publicationName
    publication.DatabaseName = publicationDbName

    ' Specify a transactional publication (the default).
    publication.Type = PublicationType.Transactional

    'Enable push and pull subscriptions and independent Distribition Agents.
    publication.Attributes = _
    publication.Attributes Or PublicationAttributes.AllowPull
    publication.Attributes = _
    publication.Attributes Or PublicationAttributes.AllowPush
    publication.Attributes = _
    publication.Attributes Or PublicationAttributes.IndependentAgent

    ' Activate the publication so that we can add subscriptions.
    publication.Status = State.Active

    ' Specify the Windows account under which the Snapshot Agent job runs.
    ' This account will be used for the local connection to the 
    ' Distributor and all agent connections that use Windows Authentication.
    publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin
    publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword

    ' Explicitly set the security mode for the Publisher connection
    ' Windows Authentication (the default).
    publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = True

    If Not publication.IsExistingObject Then
        ' Create the transactional publication.
        publication.Create()

        ' Create a Snapshot Agent job for the publication.
        publication.CreateSnapshotAgent()
    Else
        Throw New ApplicationException(String.Format( _
            "The {0} publication already exists.", publicationName))
    End If
Catch ex As Exception
    ' Implement custom application error handling here.
    Throw New ApplicationException(String.Format( _
        "The publication {0} could not be created.", publicationName), ex)
Finally
    conn.Disconnect()
End Try

Ten przykład umożliwia publikację w bazie AdventureWorks danych poprzez scalanie i tworzy publikację AdvWorksSalesOrdersMerge . Artykuły muszą być nadal zdefiniowane dla tej publikacji. Poświadczenia konta systemu Windows wymagane do utworzenia zadania Snapshot Agent są przekazywane w czasie wykonywania. Aby dowiedzieć się, jak używać RMO do definiowania artykułów scalanych, zobacz Definiuj artykuł.

// Set the Publisher, publication database, and publication names.
string publisherName = publisherInstance;
string publicationName = "AdvWorksSalesOrdersMerge";
string publicationDbName = "AdventureWorks2022";

ReplicationDatabase publicationDb;
MergePublication publication;

// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);

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

    // Enable the database for merge publication.				
    publicationDb = new ReplicationDatabase(publicationDbName, conn);
    if (publicationDb.LoadProperties())
    {
        if (!publicationDb.EnabledMergePublishing)
        {
            publicationDb.EnabledMergePublishing = true;
        }
    }
    else
    {
        // Do something here if the database does not exist. 
        throw new ApplicationException(String.Format(
            "The {0} database does not exist on {1}.",
            publicationDb, publisherName));
    }

    // Set the required properties for the merge publication.
    publication = new MergePublication();
    publication.ConnectionContext = conn;
    publication.Name = publicationName;
    publication.DatabaseName = publicationDbName;

    // Enable precomputed partitions.
    publication.PartitionGroupsOption = PartitionGroupsOption.True;

    // Specify the Windows account under which the Snapshot Agent job runs.
    // This account will be used for the local connection to the 
    // Distributor and all agent connections that use Windows Authentication.
    publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin;
    publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword;

    // Explicitly set the security mode for the Publisher connection
    // Windows Authentication (the default).
    publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = true;

    // Enable Subscribers to request snapshot generation and filtering.
    publication.Attributes |= PublicationAttributes.AllowSubscriberInitiatedSnapshot;
    publication.Attributes |= PublicationAttributes.DynamicFilters;

    // Enable pull and push subscriptions.
    publication.Attributes |= PublicationAttributes.AllowPull;
    publication.Attributes |= PublicationAttributes.AllowPush;

    if (!publication.IsExistingObject)
    {
        // Create the merge publication.
        publication.Create();
        
        // Create a Snapshot Agent job for the publication.
        publication.CreateSnapshotAgent();
    }
    else
    {
        throw new ApplicationException(String.Format(
            "The {0} publication already exists.", publicationName));
    }
}

catch (Exception ex)
{
    // Implement custom application error handling here.
    throw new ApplicationException(String.Format(
        "The publication {0} could not be created.", publicationName), ex);
}
finally
{
    conn.Disconnect();
}

' Set the Publisher, publication database, and publication names.
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"

Dim publicationDb As ReplicationDatabase
Dim publication As MergePublication

' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)

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

    ' Enable the database for merge publication.				
    publicationDb = New ReplicationDatabase(publicationDbName, conn)
    If publicationDb.LoadProperties() Then
        If Not publicationDb.EnabledMergePublishing Then
            publicationDb.EnabledMergePublishing = True
        End If
    Else
        ' Do something here if the database does not exist. 
        Throw New ApplicationException(String.Format( _
         "The {0} database does not exist on {1}.", _
         publicationDb, publisherName))
    End If

    ' Set the required properties for the merge publication.
    publication = New MergePublication()
    publication.ConnectionContext = conn
    publication.Name = publicationName
    publication.DatabaseName = publicationDbName

    ' Enable precomputed partitions.
    publication.PartitionGroupsOption = PartitionGroupsOption.True

    ' Specify the Windows account under which the Snapshot Agent job runs.
    ' This account will be used for the local connection to the 
    ' Distributor and all agent connections that use Windows Authentication.
    publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin
    publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword

    ' Explicitly set the security mode for the Publisher connection
    ' Windows Authentication (the default).
    publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = True

    ' Enable Subscribers to request snapshot generation and filtering.
    publication.Attributes = publication.Attributes Or _
        PublicationAttributes.AllowSubscriberInitiatedSnapshot
    publication.Attributes = publication.Attributes Or _
        PublicationAttributes.DynamicFilters

    ' Enable pull and push subscriptions
    publication.Attributes = publication.Attributes Or _
        PublicationAttributes.AllowPull
    publication.Attributes = publication.Attributes Or _
        PublicationAttributes.AllowPush

    If Not publication.IsExistingObject Then
        ' Create the merge publication.
        publication.Create()

        ' Create a Snapshot Agent job for the publication.
        publication.CreateSnapshotAgent()
    Else
        Throw New ApplicationException(String.Format( _
            "The {0} publication already exists.", publicationName))
    End If
Catch ex As Exception
    ' Implement custom application error handling here.
    Throw New ApplicationException(String.Format( _
        "The publication {0} could not be created.", publicationName), ex)
Finally
    conn.Disconnect()
End Try

Treści powiązane

  • Last updated on