Procedura: Creazione di una pubblicazione (programmazione RMO)

È possibile creare pubblicazioni a livello di programmazione tramite gli oggetti RMO (Replication Management Objects). Le classi RMO utilizzate per creare una pubblicazione dipendono dal tipo di pubblicazione creata.

Nota sulla sicurezza
Se possibile, richiedere agli utenti di immettere le credenziali di protezione in fase di esecuzione. Se è necessario archiviare le credenziali, utilizzare i servizi di crittografia offerti da Microsoft Windows .NET Framework.

Per creare una pubblicazione snapshot o transazionale

1. Creare una connessione al server di pubblicazione tramite la classe ServerConnection.

2. Creare un'istanza della classe ReplicationDatabase per il database di pubblicazione, impostare la proprietà ConnectionContext sull'istanza di ServerConnection del passaggio 1, quindi chiamare il metodo LoadProperties. Se LoadProperties restituisce false, verificare che il database esista.

3. Se la proprietà EnabledTransPublishing è impostata su false, impostarla su true.

4. Per una pubblicazione transazionale, verificare il valore della proprietà LogReaderAgentExists. Se questa proprietà è impostata su true, per il database esiste già un processo dell'agente di lettura log. Se questa proprietà è impostata su false, eseguire le operazioni seguenti:

   • Impostare i campi Login e Password o SecurePassword di LogReaderAgentProcessSecurity in modo da fornire le credenziali dell'account Microsoft utilizzato per l'esecuzione dell'agente di lettura log.

     Nota

     Non è necessario impostare LogReaderAgentProcessSecurity quando la pubblicazione viene creata da un membro del ruolo predefinito del server sysadmin. In questo caso l'agente rappresenterà l'account di SQL Server Agent. Per ulteriori informazioni, vedere Modello di sicurezza dell'agente di replica.

   • (Facoltativo) Impostare i campi SqlStandardLogin e SqlStandardPassword o SecureSqlStandardPassword di LogReaderAgentPublisherSecurity quando si utilizza l'autenticazione di SQL Server per la connessione al server di pubblicazione.

   • Chiamare il metodo CreateLogReaderAgent per creare il processo dell'agente di lettura log per il database.

5. Creare un'istanza della classe TransPublication e impostare le proprietà seguenti per questo oggetto:

   • Oggetto ServerConnection ottenuto al passaggio 1 per ConnectionContext.

   • Nome del database pubblicato per DatabaseName.

   • Nome per la pubblicazione per Name.

   • Valore PublicationType di Transactional o Snapshot.

   • Campi Login e Password di SnapshotGenerationAgentProcessSecurity per fornire le credenziali per l'account di Windows con cui verrà eseguito il processo dell'agente snapshot. Questo account viene utilizzato anche quando l'agente snapshot stabilisce connessioni al server di distribuzione locale e per qualsiasi connessione remota quando si utilizza l'autenticazione di Windows.

     Nota

     Non è necessario impostare SnapshotGenerationAgentProcessSecurity quando la pubblicazione viene creata da un membro del ruolo predefinito del server sysadmin. In questo caso l'agente rappresenterà l'account di SQL Server Agent. Per ulteriori informazioni, vedere Modello di sicurezza dell'agente di replica.

   • (Facoltativo) Campi SqlStandardLogin e SqlStandardPassword o SecureSqlStandardPassword di SnapshotGenerationAgentPublisherSecurity quando si utilizza l'autenticazione di SQL Server per la connessione al server di pubblicazione.

   • (Facoltativo) Utilizzare l'operatore logico OR inclusivo (| in Visual C# e Or in Visual Basic) e l'operatore logico OR esclusivo (^ in Visual C# e Xor in Visual Basic) per impostare i valori di PublicationAttributes per la proprietà Attributes.

   • (Facoltativo) Nome del server di pubblicazione per PublisherName quando il server di pubblicazione non è non SQL Server.

6. Chiamare il metodo Create per creare la pubblicazione.

   Nota sulla sicurezza

   Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutte le proprietà, inclusa SnapshotGenerationAgentProcessSecurity, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di chiamare il metodo Create. Per ulteriori informazioni, vedere Crittografia delle connessioni a SQL Server.

7. Chiamare il metodo CreateSnapshotAgent per creare il processo dell'agente snapshot per la pubblicazione.

Per creare una pubblicazione di tipo merge

1. Creare una connessione al server di pubblicazione tramite la classe ServerConnection.

2. Creare un'istanza della classe ReplicationDatabase per il database di pubblicazione, impostare la proprietà ConnectionContext sull'istanza di ServerConnection del passaggio 1, quindi chiamare il metodo LoadProperties. Se LoadProperties restituisce false, verificare che il database esista.

3. Se la proprietà EnabledMergePublishing è false, impostarla su true e chiamare CommitPropertyChanges.

4. Creare un'istanza della classe MergePublication e impostare le proprietà seguenti per questo oggetto:

   • Oggetto ServerConnection ottenuto al passaggio 1 per ConnectionContext.

   • Nome del database pubblicato per DatabaseName.

   • Nome per la pubblicazione per Name.

   • Campi Login e Password di SnapshotGenerationAgentProcessSecurity per fornire le credenziali per l'account di Windows con cui verrà eseguito il processo dell'agente snapshot. Questo account viene utilizzato anche quando l'agente snapshot stabilisce connessioni al server di distribuzione locale e per qualsiasi connessione remota quando si utilizza l'autenticazione di Windows.

     Nota

     Non è necessario impostare SnapshotGenerationAgentProcessSecurity quando la pubblicazione viene creata da un membro del ruolo predefinito del server sysadmin. Per ulteriori informazioni, vedere Modello di sicurezza dell'agente di replica.

   • (Facoltativo) Utilizzare l'operatore logico OR inclusivo (| in Visual C# e Or in Visual Basic) e l'operatore logico OR esclusivo (^ in Visual C# e Xor in Visual Basic) per impostare i valori di PublicationAttributes per la proprietà Attributes.

5. Chiamare il metodo Create per creare la pubblicazione.

   Nota sulla sicurezza

   Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutte le proprietà, inclusa SnapshotGenerationAgentProcessSecurity, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di chiamare il metodo Create. Per ulteriori informazioni, vedere Crittografia delle connessioni a SQL Server.

6. Chiamare il metodo CreateSnapshotAgent per creare il processo dell'agente snapshot per la pubblicazione.

Esempio

In questo esempio il database AdventureWorks viene attivato per la pubblicazione transazionale, viene definito un processo dell'agente di lettura log e viene creata la pubblicazione AdvWorksProductTran. Per questa pubblicazione è necessario definire un articolo. Le credenziali dell'account di Windows necessarie per creare il processo dell'agente di lettura log e il processo dell'agente snapshot vengono passate in fase di esecuzione. Per informazioni sull'utilizzo di oggetti RMO per definire articoli snapshot e transazionali, vedere Procedura: Definizione di un articolo (programmazione RMO).

            // Set the Publisher, publication database, and publication names.
            string publicationName = "AdvWorksProductTran";
            string publicationDbName = "AdventureWorks2008R2";
            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 AdventureWorks 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 = "AdventureWorks2008R2"
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 AdventureWorks 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

In questo esempio il database AdventureWorks viene attivato per la pubblicazione di tipo merge e viene creata la pubblicazione AdvWorksSalesOrdersMerge. Per questa pubblicazione è ancora necessario definire gli articoli. Le credenziali dell'account di Windows necessarie per creare il processo dell'agente snapshot vengono passate in fase di esecuzione. Per informazioni sull'utilizzo di oggetti RMO per definire articoli di merge, vedere Procedura: Definizione di un articolo (programmazione RMO).

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

            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 = "AdventureWorks2008R2"

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

Vedere anche

Attivitá

Procedura: Creazione di una pubblicazione (programmazione Transact-SQL della replica)

Concetti

Pubblicazione di dati e oggetti di database

Concetti di base relativi a RMO (Replication Management Objects)