방법: 밀어넣기 구독 만들기(RMO Programming)

RMO(복제 관리 개체)를 사용하여 프로그래밍 방식으로 밀어넣기 구독을 만들 수 있습니다. _밀어넣기 구독을 만들 때 사용하는 RMO 클래스는 구독을 만드는 게시 유형에 따라 달라집니다.

보안 정보
가능하면 런타임에 사용자에게 자격 증명을 입력하라는 메시지를 표시하십시오. 자격 증명을 저장해야 하는 경우 Microsoft Windows .NET Framework에서 제공하는 암호화 서비스를 사용합니다.

스냅숏 또는 트랜잭션 게시에 밀어넣기 구독을 만들려면

1. ServerConnection 클래스를 사용하여 게시자 연결을 만듭니다.

2. 1단계에서 만든 게시자 연결을 사용하여 TransPublication 클래스의 인스턴스를 만듭니다. Name, DatabaseName 및 ConnectionContext를 지정합니다.

3. LoadProperties 메서드를 호출합니다. 이 메서드가 false를 반환하는 경우 2단계에서 지정한 속성이 올바르지 않거나 서버에 게시가 없습니다.

4. Attributes 속성과 AllowPush 사이에서 비트 논리 AND(Visual C#의 & 및 Visual Basic의 And)를 수행합니다. 결과가 None이면 Attributes와 AllowPush 사이의 비트 논리 OR(Visual C#의 | 및 Visual Basic의 Or)의 결과에 대해 Attributes를 설정합니다. 그런 다음 CommitPropertyChanges를 호출하여 밀어넣기 구독을 설정합니다.

5. 구독 데이터베이스가 없는 경우 Database 클래스를 사용하여 만듭니다. 자세한 내용은 데이터베이스 생성, 변경 및 제거을 참조하십시오.

6. TransSubscription 클래스의 인스턴스를 만듭니다.

7. 다음 구독 속성을 설정합니다.

   • ConnectionContext에 대해 1단계에서 만든 게시자에 대한 ServerConnection

   • SubscriptionDBName에 대한 구독 데이터베이스 이름

   • SubscriberName에 대한 구독자 이름

   • DatabaseName에 대한 게시 데이터베이스 이름

   • PublicationName에 대한 게시 이름

   • 배포자에서 배포 에이전트가 실행되는 Microsoft Windows 계정에 대한 자격 증명을 제공하는 SynchronizationAgentProcessSecurity의 Login 필드와 Password 또는 SecurePassword 필드. 이 계정은 Windows 인증을 사용하여 배포자에 대한 로컬 연결 및 원격 연결을 만드는 데 사용됩니다.

     [!참고]

     sysadmin 고정 서버 역할의 멤버가 구독을 만들 때 SynchronizationAgentProcessSecurity를 설정할 필요는 없지만 설정해 두는 것이 좋습니다. 이 경우 에이전트는 SQL Server 에이전트 계정을 가장합니다. 자세한 내용은 복제 에이전트 보안 모델을 참조하십시오.

   • (옵션) 구독을 동기화하는 데 사용되는 에이전트 작업을 만드는 CreateSyncAgentByDefault에 true 값(기본값). false를 지정한 경우 구독은 프로그래밍 방식으로만 동기화할 수 있습니다.

   • (옵션) _SQL Server 인증을 사용하여 구독자에 연결할 때 SubscriberSecurity의 SqlStandardLogin 필드와 SqlStandardPassword 또는 SecureSqlStandardPassword 필드

8. Create 메서드를 호출합니다.

   보안 정보
   원격 배포자가 있는 게시자에서 밀어넣기 구독을 만드는 경우 SynchronizationAgentProcessSecurity를 비롯한 모든 속성에 제공된 값이 일반 텍스트로 배포자에게 보내집니다. 이 Create 메서드를 호출하기 전에 게시자와 해당 원격 배포자 간 연결을 암호화해야 합니다. 자세한 내용은 SQL Server 연결 암호화를 참조하십시오.

병합 게시에 밀어넣기 구독을 만들려면

1. ServerConnection 클래스를 사용하여 게시자 연결을 만듭니다.

2. 1단계에서 만든 게시자 연결을 사용하여 MergePublication 클래스의 인스턴스를 만듭니다. Name, DatabaseName 및 ConnectionContext를 지정합니다.

3. LoadProperties 메서드를 호출합니다. 이 메서드가 false를 반환하는 경우 2단계에서 지정한 속성이 올바르지 않거나 서버에 게시가 없습니다.

4. Attributes 속성과 AllowPush 사이에서 비트 논리 AND(Visual C#의 & 및 Visual Basic의 And)를 수행합니다. 결과가 None이면 Attributes와 AllowPush 사이의 비트 논리 OR(Visual C#의 | 및 Visual Basic의 Or)의 결과에 대해 Attributes를 설정합니다. 그런 다음 CommitPropertyChanges를 호출하여 밀어넣기 구독을 설정합니다.

5. 구독 데이터베이스가 없는 경우 Database 클래스를 사용하여 만듭니다. 자세한 내용은 데이터베이스 생성, 변경 및 제거를 참조하십시오.

6. MergeSubscription 클래스의 인스턴스를 만듭니다.

7. 다음 구독 속성을 설정합니다.

   • ConnectionContext에 대해 1단계에서 만든 게시자에 대한 ServerConnection

   • SubscriptionDBName에 대한 구독 데이터베이스 이름

   • SubscriberName에 대한 구독자 이름

   • DatabaseName에 대한 게시 데이터베이스 이름

   • PublicationName에 대한 게시 이름

   • 배포자에서 병합 에이전트가 실행되는 Microsoft Windows 계정에 대한 자격 증명을 제공하는 SynchronizationAgentProcessSecurity의 Login 필드와 Password 또는 SecurePassword 필드. 이 계정은 Windows 인증을 사용하여 배포자에 대한 로컬 연결 및 원격 연결을 만드는 데 사용됩니다.

     [!참고]

     sysadmin 고정 서버 역할의 멤버가 구독을 만들 때 SynchronizationAgentProcessSecurity를 설정할 필요는 없지만 설정해 두는 것이 좋습니다. 이 경우 에이전트는 SQL Server 에이전트 계정을 가장합니다. 자세한 내용은 복제 에이전트 보안 모델을 참조하십시오.

   • (옵션) 구독을 동기화하는 데 사용되는 에이전트 작업을 만드는 CreateSyncAgentByDefault에 true 값(기본값). false를 지정한 경우 구독은 프로그래밍 방식으로만 동기화할 수 있습니다.

   • (옵션) SQL Server 인증을 사용하여 구독자에 연결할 때 SubscriberSecurity의 SqlStandardLogin 필드와 SqlStandardPassword 또는 SecureSqlStandardPassword 필드

   • (옵션) SQL Server 인증을 사용하여 게시자에 연결할 때 PublisherSecurity의 SqlStandardLogin 필드와 SqlStandardPassword 또는 SecureSqlStandardPassword 필드

8. Create 메서드를 호출합니다.

   보안 정보
   원격 배포자가 있는 게시자에서 밀어넣기 구독을 만드는 경우 SynchronizationAgentProcessSecurity를 비롯한 모든 속성에 제공된 값이 일반 텍스트로 배포자에게 보내집니다. 이 Create 메서드를 호출하기 전에 게시자와 해당 원격 배포자 간 연결을 암호화해야 합니다. 자세한 내용은 SQL Server 연결 암호화를 참조하십시오.

예

다음은 트랜잭션 게시에 _새 밀어넣기 구독을 만드는 예입니다. 배포 에이전트 작업을 실행하는 데 사용되는 Windows 계정 자격 증명은 런타임에 전달됩니다.

           // Define the Publisher, publication, and databases.
            string publicationName = "AdvWorksProductTran";
            string publisherName = publisherInstance;
            string subscriberName = subscriberInstance;
            string subscriptionDbName = "AdventureWorksReplica";
            string publicationDbName = "AdventureWorks";

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

            // Create the objects that we need.
            TransPublication publication;
            TransSubscription subscription;

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

                // Ensure that the publication exists and that 
                // it supports push subscriptions.
                publication = new TransPublication();
                publication.Name = publicationName;
                publication.DatabaseName = publicationDbName;
                publication.ConnectionContext = conn;

                if (publication.IsExistingObject)
                {
                    if ((publication.Attributes & PublicationAttributes.AllowPush) == 0)
                    {
                        publication.Attributes |= PublicationAttributes.AllowPush;
                    }

                    // Define the push subscription.
                    subscription = new TransSubscription();
                    subscription.ConnectionContext = conn;
                    subscription.SubscriberName = subscriberName;
                    subscription.PublicationName = publicationName;
                    subscription.DatabaseName = publicationDbName;
                    subscription.SubscriptionDBName = subscriptionDbName;

                    // Specify the Windows login credentials for the Distribution Agent job.
                    subscription.SynchronizationAgentProcessSecurity.Login = winLogin;
                    subscription.SynchronizationAgentProcessSecurity.Password = winPassword;

                    // 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 push subscription.
                    subscription.Create();
                }
                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
            {
                conn.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 a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(subscriberName)

' Create the objects that we need.
Dim publication As TransPublication
Dim subscription As TransSubscription

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

    ' Ensure that the publication exists and that 
    ' it supports push subscriptions.
    publication = New TransPublication()
    publication.Name = publicationName
    publication.DatabaseName = publicationDbName
    publication.ConnectionContext = conn

    If publication.IsExistingObject Then
        If (publication.Attributes And PublicationAttributes.AllowPush) = 0 Then
            publication.Attributes = publication.Attributes _
            Or PublicationAttributes.AllowPush
        End If

        ' Define the push subscription.
        subscription = New TransSubscription()
        subscription.ConnectionContext = conn
        subscription.SubscriberName = subscriberName
        subscription.PublicationName = publicationName
        subscription.DatabaseName = publicationDbName
        subscription.SubscriptionDBName = subscriptionDbName

        ' Specify the Windows login credentials for the Distribution Agent job.
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword

        ' 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 push subscription.
        subscription.Create()
    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
    conn.Disconnect()
End Try

다음은 병합 게시에 새 밀어넣기 구독을 만드는 예입니다. 병합 에이전트 작업을 실행하는 데 사용되는 Windows 계정 자격 증명은 런타임에 전달됩니다.

          // 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 a connection to the Publisher.
            ServerConnection conn = new ServerConnection(subscriberName);

            // Create the objects that we need.
            MergePublication publication;
            MergeSubscription subscription;

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

                // Ensure that the publication exists and that 
                // it supports push subscriptions.
                publication = new MergePublication();
                publication.Name = publicationName;
                publication.DatabaseName = publicationDbName;
                publication.ConnectionContext = conn;

                if (publication.IsExistingObject)
                {
                    if ((publication.Attributes & PublicationAttributes.AllowPush) == 0)
                    {
                        publication.Attributes |= PublicationAttributes.AllowPush;
                    }

                    // Define the push subscription.
                    subscription = new MergeSubscription();
                    subscription.ConnectionContext = conn;
                    subscription.SubscriberName = subscriberName;
                    subscription.PublicationName = publicationName;
                    subscription.DatabaseName = publicationDbName;
                    subscription.SubscriptionDBName = subscriptionDbName;
                    subscription.HostName = hostname;

                    // Set a schedule to synchronize the subscription every 2 hours
                    // during weekdays from 6am to 10pm.
                    subscription.AgentSchedule.FrequencyType = ScheduleFrequencyType.Weekly;
                    subscription.AgentSchedule.FrequencyInterval = Convert.ToInt32(0x003E);
                    subscription.AgentSchedule.FrequencyRecurrenceFactor = 1;
                    subscription.AgentSchedule.FrequencySubDay = ScheduleFrequencySubDay.Hour;
                    subscription.AgentSchedule.FrequencySubDayInterval = 2;
                    subscription.AgentSchedule.ActiveStartDate = 20051108;
                    subscription.AgentSchedule.ActiveEndDate = 20071231;
                    subscription.AgentSchedule.ActiveStartTime = 060000;
                    subscription.AgentSchedule.ActiveEndTime = 100000;

                    // Specify the Windows login credentials for the Merge Agent job.
                    subscription.SynchronizationAgentProcessSecurity.Login = winLogin;
                    subscription.SynchronizationAgentProcessSecurity.Password = winPassword;

                    // Create the push subscription.
                    subscription.Create();
                }
                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
            {
                conn.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 a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(subscriberName)

' Create the objects that we need.
Dim publication As MergePublication
Dim subscription As MergeSubscription

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

    ' Ensure that the publication exists and that 
    ' it supports push subscriptions.
    publication = New MergePublication()
    publication.Name = publicationName
    publication.DatabaseName = publicationDbName
    publication.ConnectionContext = conn

    If publication.IsExistingObject Then
        If (publication.Attributes And PublicationAttributes.AllowPush) = 0 Then
            publication.Attributes = publication.Attributes _
            Or PublicationAttributes.AllowPush
        End If

        ' Define the push subscription.
        subscription = New MergeSubscription()
        subscription.ConnectionContext = conn
        subscription.SubscriberName = subscriberName
        subscription.PublicationName = publicationName
        subscription.DatabaseName = publicationDbName
        subscription.SubscriptionDBName = subscriptionDbName
        subscription.HostName = hostname

        ' Set a schedule to synchronize the subscription every 2 hours
        ' during weekdays from 6am to 10pm.
        subscription.AgentSchedule.FrequencyType = ScheduleFrequencyType.Weekly
        subscription.AgentSchedule.FrequencyInterval = Convert.ToInt32("0x003E", 16)
        subscription.AgentSchedule.FrequencyRecurrenceFactor = 1
        subscription.AgentSchedule.FrequencySubDay = ScheduleFrequencySubDay.Hour
        subscription.AgentSchedule.FrequencySubDayInterval = 2
        subscription.AgentSchedule.ActiveStartDate = 20051108
        subscription.AgentSchedule.ActiveEndDate = 20071231
        subscription.AgentSchedule.ActiveStartTime = 60000
        subscription.AgentSchedule.ActiveEndTime = 100000

        ' Specify the Windows login credentials for the Merge Agent job.
        subscription.SynchronizationAgentProcessSecurity.Login = winLogin
        subscription.SynchronizationAgentProcessSecurity.Password = winPassword

        ' Create the push subscription.
        subscription.Create()
    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
    conn.Disconnect()
End Try

참고 항목

태스크

방법: 게시 만들기(RMO 프로그래밍)

방법: 밀어넣기 구독 만들기(Replication Transact-SQL Programming)

방법: 밀어넣기 구독 동기화(RMO Programming)

개념

복제 관리 개체 개념

게시 구독