Поделиться через

Создание публикации

  • Статья

Область применения: SQL Server Управляемый экземпляр SQL Azure

В этой статье описывается, как создать публикацию в SQL Server с помощью SQL Server Management Studio, Transact-SQL или объектов управления репликацией (RMO).

ограничения

  • Имена публикаций и статей не могут содержать следующие символы: %, [:|"?]*\/'<или .> Если объекты в базе данных включают любой из этих символов и хотите реплицировать их, необходимо указать имя статьи, отличное от имени объекта в диалоговом окне "Свойства статьи " Статья - <статья> ", которое доступно на странице статей в мастере.

Безопасность

По возможности предлагайте пользователям вводить учетные данные системы безопасности во время выполнения приложения. Если необходимо сохранить учетные данные, используйте криптографические службы, предоставляемые microsoft Windows платформа .NET Framework.

Использование SQL Server Management Studio

Создание публикаций и определение статей осуществляется с помощью мастера создания публикаций. После создания публикации просмотрите и измените свойства публикации в диалоговом окне "Свойства публикации — <публикация> ". Дополнительные сведения о создании публикаций из базы данных Oracle вы найдете в этой статье.

Создание публикации и определение статей

  1. Подключитесь к издателю в среде Microsoft SQL Server Management Studio и раскройте узел сервера.

  2. Раскройте папку Репликация , а затем щелкните правой кнопкой мыши папку Локальные публикации .

  3. Выберите "Создать публикацию".

  4. Следуйте указаниям на страницах мастера создания публикаций, чтобы:

    • Укажите распространителя, если распределение не было настроено на сервере. Дополнительные сведения о настройке распространения см. в статье Настройка публикации и распространения.

      Если на странице распространителя сервер издателя будет выступать в качестве собственного распространителя (локальный распространитель), а сервер не настроен в качестве распространителя, мастер создания публикаций настроит сервер. Нужно будет задать для распространителя папку моментальных снимков по умолчанию на странице Папка моментальных снимков . Папка моментальных снимков — это просто каталог, назначенный для совместного использования; агенты, считывающие и записывающие данные в эту папку, должны иметь достаточные разрешения для доступа к ней. Дополнительные сведения о надлежащей защите папок см. в статье Организация безопасности папки моментальных снимков.

      Если задано, что в качестве распространителя будет функционировать другой сервер, необходимо ввести пароль на странице Административный пароль для соединений, устанавливаемых между издателем и распространителем. Пароль должен совпадать с паролем, указанным при включении издателя на удаленном распространителе.

      Дополнительные сведения см. в разделе Configure Distribution.

    • Выберите базу данных публикации.

    • Выберите тип публикации. Дополнительные сведения см. в статье Типы репликации.

    • Задайте данные и объекты базы данных для публикации. При необходимости отфильтруйте столбцы из статей таблиц и установите свойства статей.

    • Если требуется, отфильтруйте строки из статей таблиц. Дополнительные сведения см. в статье Фильтрация опубликованных данных.

    • Настройте расписание для агента моментальных снимков.

    • Задайте учетные данные, под которыми следующие агенты репликации будут запускаться и устанавливать соединения:

      • агент моментальных снимков для всех публикаций.

      • Агент чтения журналов для всех публикаций транзакций.

      • Агент чтения очередей для публикаций транзакций, которые позволяют обновлять подписки.

        Дополнительные сведения см. в разделах Replication Agent Security Model и Replication Security Best Practices.

    • При необходимости создайте скрипт для публикации. Дополнительные сведения см. в разделе Scripting Replication.

    • Задайте имя для публикации.

Использование Transact-SQL

Создание публикации может быть произведено программным путем с помощью хранимых процедур репликации. Какие именно хранимые процедуры должны для этого применяться, зависит от типа создаваемой публикации.

Создание моментального снимка или публикации транзакций

  1. На издателе в базе данных публикации выполните sp_replicationdboption (Transact-SQL), чтобы включить публикацию текущей базы данных с помощью моментального снимка или репликации транзакций.

  2. Для публикации транзакций необходимо выяснить наличие задания агента чтения журнала для базы данных публикации (Этот шаг не требуется для публикаций моментальных снимков.)

    • Если задание агента чтения журнала для указанной базы данных публикации уже существует, перейдите к шагу 3.

    • Если вы не уверены, существует ли задание агента чтения журналов для опубликованной базы данных, выполните sp_helplogreader_agent (Transact-SQL) на издателе в базе данных публикации.

    • Если результирующий набор пуст, необходимо создать задание агента чтения журнала. На издателе выполните sp_addlogreader_agent (Transact-SQL). Укажите учетные данные Microsoft Windows, в которых выполняется @job_name агент и @password. Если агент будет использовать проверку подлинности SQL Server при подключении к издателю, необходимо также указать значение 0 для @publisher_security_mode и сведения о входе SQL Server.@publisher_login @publisher_password Перейдите к шагу 3.

  3. На издателе выполните sp_addpublication (Transact-SQL). Укажите имя публикации для @publicationпараметра и @repl_freq укажите значение snapshot публикации моментального снимка или значение continuous для публикации транзакций. Укажите все остальные параметры публикации. Таким образом будет определена публикация.

    Примечание.

    Имена публикаций не могут содержать следующие символы:

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

  4. На издателе выполните процедуру sp_addpublication_snapshot (Transact-SQL). Укажите имя публикации, использовавшееся на шаге 3, в параметре @publication , а учетные данные Windows, с которыми работает агент моментальных снимков, — для параметров @snapshot_job_name @password @password. Если агент будет использовать проверку подлинности SQL Server при подключении к издателю, необходимо также указать значение 0 для @publisher_security_mode и сведения о входе SQL Server.@publisher_login publisher_password Будет создано задание агента моментальных снимков для публикации.

    Внимание

    Если издатель настраивается с удаленным распространителем, то значения, передаваемые для всех аргументов, включая job_login и job_password, передаются распространителю в формате обычного (незашифрованного) текста. Прежде чем выполнять эту хранимую процедуру, необходимо зашифровать соединение между издателем и его удаленным распространителем. Дополнительные сведения см. в статье Включение шифрования соединений в компоненте Database Engine (диспетчер конфигурации SQL Server).

  5. Добавьте статьи к публикации. Дополнительные сведения см. в статье определить статью.

  6. Запустите задание агента моментальных снимков, чтобы создать исходный моментальный снимок для этой публикации. Дополнительные сведения см. в разделе Create and Apply the Initial Snapshot.

Создание публикации слиянием

  1. На издателе выполните sp_replicationdboption (Transact-SQL), чтобы включить публикацию текущей базы данных с помощью репликации слиянием.

  2. На издателе в базе данных публикации выполните sp_addmergepublication (Transact-SQL). Укажите имя публикации в параметре @publication , а также все остальные параметры публикации. Таким образом будет определена публикация.

    Примечание.

    Имена публикаций не могут содержать следующие символы:

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

  3. На издателе выполните процедуру sp_addpublication_snapshot (Transact-SQL). Укажите имя публикации, используемое на шаге 2, для параметра @publication , а учетные данные Windows, с которыми работает агент моментальных снимков, — для параметров @snapshot_job_name @password @password. Если агент будет использовать проверку подлинности SQL Server при подключении к издателю, необходимо также указать значение 0 для @publisher_security_mode и сведения о входе SQL Server.@publisher_login @publisher_password Будет создано задание агента моментальных снимков для публикации.

    Внимание

    Если издатель настраивается с удаленным распространителем, то значения, передаваемые для всех аргументов, включая job_login и job_password, передаются распространителю в формате обычного (незашифрованного) текста. Прежде чем выполнять эту хранимую процедуру, необходимо зашифровать соединение между издателем и его удаленным распространителем. Дополнительные сведения см. в статье Включение шифрования соединений в компоненте Database Engine (диспетчер конфигурации SQL Server).

  4. Добавьте статьи к публикации. Дополнительные сведения см. в статье определить статью.

  5. Запустите задание агента моментальных снимков, чтобы создать исходный моментальный снимок для этой публикации. Дополнительные сведения см. в разделе Create and Apply the Initial Snapshot.

Пример (Transact-SQL)

В следующем примере производится создание публикации транзакций. Учетные данные Windows, необходимые для создания задания агента моментальных снимков и агента чтения журнала, передаются через переменные скрипта.

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

В следующем примере производится создание публикации слиянием. Учетные данные Windows, необходимые для создания задания агента моментальных снимков, передаются через переменные скрипта.

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

Использование объектов управления репликацией (RMO)

Публикации можно создавать программно с помощью объектов RMO. Классы RMO, с помощью которых создается публикация, зависят от типа создаваемой публикации.

Создание моментального снимка или публикации транзакций

  1. Создайте соединение с издателем с помощью класса ServerConnection .

  2. Создайте экземпляр класса ReplicationDatabase для базы данных публикации, установите в качестве значения свойства ConnectionContext экземпляр соединения ServerConnection , созданный на шаге 1, и вызовите метод LoadProperties . Если метод LoadProperties возвращает значение false, убедитесь, что база данных существует.

  3. Если свойство EnabledTransPublishing имеет значение false, то его следует заменить на true.

  4. Для публикации транзакций проверьте значение свойства LogReaderAgentExists . Если свойство имеет значение true, то задание агента чтения журнала уже есть в базе данных. Если свойство имеет значение false, выполните следующие действия.

    • Login Password Задайте и поля для предоставления LogReaderAgentProcessSecurity учетных данных для учетной записи Microsoft Windows, в которой выполняется агент чтения журналов.

      Примечание.

      Указывать свойство LogReaderAgentProcessSecurity не обязательно, если публикация создается членом предопределенной роли сервера sysadmin . В этом случае агент будет выполнять олицетворение учетную запись агента SQL Server. Дополнительные сведения см. в статье Replication Agent Security Model.

    • (необязательно) при соединении с издателем с проверкой подлинности SQL Server укажите значения свойств SqlStandardLogin и SqlStandardPassword или SecureSqlStandardPassword объекта LogReaderAgentPublisherSecurity .

    • С помощью метода CreateLogReaderAgent создайте задание агента чтения журнала для базы данных.

  5. Создайте экземпляр класса TransPublication и укажите для него следующие свойства:

    • Соединение ServerConnection , созданное на шаге 1, в качестве значения свойства ConnectionContext.

    • имя опубликованной базы данных в свойстве DatabaseName;

    • имя публикации в качестве значения свойства Name;

    • A Type (тип PublicationType) любого Transactional или Snapshot.

    • поля Login и Password свойства SnapshotGenerationAgentProcessSecurity , чтобы указать учетные данные для учетной записи Windows, с которой работает агент моментальных снимков. Эта учетная запись также используется, когда агент моментальных снимков соединяется с локальным распространителем, и для любых удаленных соединений, где применяется проверка подлинности Windows;

      Примечание.

      Указывать свойство SnapshotGenerationAgentProcessSecurity не обязательно, если публикация создается членом предопределенной роли сервера sysadmin . В этом случае агент будет выполнять олицетворение учетную запись агента SQL Server. Дополнительные сведения см. в статье Replication Agent Security Model.

    • Поля SqlStandardLogin и SqlStandardPassword или SecureSqlStandardPassword в SnapshotGenerationAgentPublisherSecurity при соединении с издателем с использованием проверки подлинности SQL Server (необязательно).

    • С помощью операторов включающего логического ИЛИ (| в Visual C# и Or в Visual Basic) и исключающего логического ИЛИ (^ в Visual C# и Xor в Visual Basic) задайте значение PublicationAttributes для свойства Attributes (необязательно).

    • Имя издателя в качестве значения PublisherName , если издатель не является издателем SQL Server (необязательно).

  6. Чтобы создать публикацию, вызовите метод Create .

    Внимание

    При настройке издателя с удаленным распространителем значения, передаваемые для всех свойств, включая SnapshotGenerationAgentProcessSecurity, отправляются распространителю в виде обычного текста. Перед вызовом метода Create следует зашифровать подключение между издателем и его удаленным распространителем. Дополнительные сведения см. в статье Включение шифрования соединений в компоненте Database Engine (диспетчер конфигурации SQL Server).

  7. Вызовите метод CreateSnapshotAgent , чтобы создать задание агента моментальных снимков для публикации.

Создание публикации слиянием

  1. Создайте соединение с издателем с помощью класса ServerConnection .

  2. Создайте экземпляр класса ReplicationDatabase для базы данных публикации, установите в качестве значения свойства ConnectionContext экземпляр соединения ServerConnection , созданный на шаге 1, и вызовите метод LoadProperties . Если метод LoadProperties возвращает значение false, убедитесь, что база данных существует.

  3. Если свойство EnabledMergePublishing имеет значение false, то его следует изменить на true и вызвать метод CommitPropertyChanges.

  4. Создайте экземпляр класса MergePublication и укажите для него следующие свойства:

    • Соединение ServerConnection , созданное на шаге 1, в качестве значения свойства ConnectionContext.

    • имя опубликованной базы данных в свойстве DatabaseName;

    • имя публикации в качестве значения свойства Name;

    • поля Login и Password свойства SnapshotGenerationAgentProcessSecurity , чтобы указать учетные данные для учетной записи Windows, с которой работает агент моментальных снимков. Эта учетная запись также используется, когда агент моментальных снимков соединяется с локальным распространителем, и для любых удаленных соединений, где применяется проверка подлинности Windows;

      Примечание.

      Указывать свойство SnapshotGenerationAgentProcessSecurity не обязательно, если публикация создается членом предопределенной роли сервера sysadmin . Дополнительные сведения см. в статье Replication Agent Security Model.

    • С помощью операторов включающего логического ИЛИ (| в Visual C# и Or в Visual Basic) и исключающего логического ИЛИ (^ в Visual C# и Xor в Visual Basic) задайте значение PublicationAttributes для свойства Attributes (необязательно).

  5. Чтобы создать публикацию, вызовите метод Create .

    Внимание

    При настройке издателя с удаленным распространителем значения, передаваемые для всех свойств, включая SnapshotGenerationAgentProcessSecurity, отправляются распространителю в виде обычного текста. Перед вызовом метода Create следует зашифровать подключение между издателем и его удаленным распространителем. Дополнительные сведения см. в статье Включение шифрования соединений в компоненте Database Engine (диспетчер конфигурации SQL Server).

  6. Вызовите метод CreateSnapshotAgent , чтобы создать задание агента моментальных снимков для публикации.

Примеры (объекты RMO)

Этот пример включает AdventureWorks базу данных для публикации транзакций, определяет задание агента чтения журналов и создает публикацию AdvWorksProductTran . Для этой публикации необходимо определить статью. Данные учетной записи Windows, необходимые для создания задания агента чтения журнала и задания агента моментальных снимков, передаются во время выполнения. Более подробные сведения по определению статей моментальных снимков и транзакций с помощью объектов RMO см. в разделе Define an Article.

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

Этот пример включает AdventureWorks базу данных для публикации слиянием и создает публикацию AdvWorksSalesOrdersMerge . Для этой публикации все равно необходимо определить статьи. Данные учетной записи Windows, необходимые для создания задания агента моментальных снимков, предоставляются во время выполнения. Более подробные сведения по определению статей публикацией слиянием с помощью объектов RMO см. в разделе Define an Article.

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

См. также