DistributionPublisher Clase

Referencia

Definición

Espacio de nombres:: Microsoft.SqlServer.Replication

Ensamblado:: Microsoft.SqlServer.Rmo.dll

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Representa la información sobre un publicador registrado en el distribuidor actualmente conectado.

public ref class DistributionPublisher sealed : Microsoft::SqlServer::Replication::ReplicationObject

public sealed class DistributionPublisher : Microsoft.SqlServer.Replication.ReplicationObject

type DistributionPublisher = class
    inherit ReplicationObject

Public NotInheritable Class DistributionPublisher
Inherits ReplicationObject

Herencia: Object

ReplicationObject
DistributionPublisher

Ejemplos

En este ejemplo se muestra cómo se usa un DistributionPublisher objeto para habilitar la publicación.

// Set the server and database names
string distributionDbName = "distribution";
string publisherName = publisherInstance;
string publicationDbName = "AdventureWorks2012";

DistributionDatabase distributionDb;
ReplicationServer distributor;
DistributionPublisher publisher;
ReplicationDatabase publicationDb;

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

try
{
    // Connect to the server acting as the Distributor 
    // and local Publisher.
    conn.Connect();

    // Define the distribution database at the Distributor,
    // but do not create it now.
    distributionDb = new DistributionDatabase(distributionDbName, conn);
    distributionDb.MaxDistributionRetention = 96;
    distributionDb.HistoryRetention = 120;

    // Set the Distributor properties and install the Distributor.
    // This also creates the specified distribution database.
    distributor = new ReplicationServer(conn);
    distributor.InstallDistributor((string)null, distributionDb);

    // Set the Publisher properties and install the Publisher.
    publisher = new DistributionPublisher(publisherName, conn);
    publisher.DistributionDatabase = distributionDb.Name;
    publisher.WorkingDirectory = @"\\" + publisherName + @"\repldata";
    publisher.PublisherSecurity.WindowsAuthentication = true;
    publisher.Create();

    // Enable AdventureWorks2012 as a publication database.
    publicationDb = new ReplicationDatabase(publicationDbName, conn);

    publicationDb.EnabledTransPublishing = true;
    publicationDb.EnabledMergePublishing = true;
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("An error occured when installing distribution and publishing.", ex);
}
finally
{
    conn.Disconnect();
}

' Set the server and database names
Dim distributionDbName As String = "distribution"
Dim publisherName As String = publisherInstance
Dim publicationDbName As String = "AdventureWorks2012"

Dim distributionDb As DistributionDatabase
Dim distributor As ReplicationServer
Dim publisher As DistributionPublisher
Dim publicationDb As ReplicationDatabase

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

Try
    ' Connect to the server acting as the Distributor 
    ' and local Publisher.
    conn.Connect()

    ' Define the distribution database at the Distributor,
    ' but do not create it now.
    distributionDb = New DistributionDatabase(distributionDbName, conn)
    distributionDb.MaxDistributionRetention = 96
    distributionDb.HistoryRetention = 120

    ' Set the Distributor properties and install the Distributor.
    ' This also creates the specified distribution database.
    distributor = New ReplicationServer(conn)
    distributor.InstallDistributor((CType(Nothing, String)), distributionDb)

    ' Set the Publisher properties and install the Publisher.
    publisher = New DistributionPublisher(publisherName, conn)
    publisher.DistributionDatabase = distributionDb.Name
    publisher.WorkingDirectory = "\\" + publisherName + "\repldata"
    publisher.PublisherSecurity.WindowsAuthentication = True
    publisher.Create()

    ' Enable AdventureWorks2012 as a publication database.
    publicationDb = New ReplicationDatabase(publicationDbName, conn)

    publicationDb.EnabledTransPublishing = True
    publicationDb.EnabledMergePublishing = True

Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("An error occured when installing distribution and publishing.", ex)

Finally
    conn.Disconnect()

End Try

En este ejemplo se muestra cómo se usa un DistributionPublisher objeto para deshabilitar la publicación en el distribuidor.

// Set the Distributor and publication database names.
// Publisher and Distributor are on the same server instance.
string publisherName = publisherInstance;
string distributorName = publisherInstance;
string distributionDbName = "distribution";
string publicationDbName = "AdventureWorks2012";

// Create connections to the Publisher and Distributor
// using Windows Authentication.
ServerConnection publisherConn = new ServerConnection(publisherName);
ServerConnection distributorConn = new ServerConnection(distributorName);

// Create the objects we need.
ReplicationServer distributor =
    new ReplicationServer(distributorConn);
DistributionPublisher publisher;
DistributionDatabase distributionDb =
    new DistributionDatabase(distributionDbName, distributorConn);
ReplicationDatabase publicationDb;
publicationDb = new ReplicationDatabase(publicationDbName, publisherConn);

try
{
    // Connect to the Publisher and Distributor.
    publisherConn.Connect();
    distributorConn.Connect();

    // Disable all publishing on the AdventureWorks2012 database.
    if (publicationDb.LoadProperties())
    {
        if (publicationDb.EnabledMergePublishing)
        {
            publicationDb.EnabledMergePublishing = false;
        }
        else if (publicationDb.EnabledTransPublishing)
        {
            publicationDb.EnabledTransPublishing = false;
        }
    }
    else
    {
        throw new ApplicationException(
            String.Format("The {0} database does not exist.", publicationDbName));
    }

    // We cannot uninstall the Publisher if there are still Subscribers.
    if (distributor.RegisteredSubscribers.Count == 0)
    {
        // Uninstall the Publisher, if it exists.
        publisher = new DistributionPublisher(publisherName, distributorConn);
        if (publisher.LoadProperties())
        {
            publisher.Remove(false);
        }
        else
        {
            // Do something here if the Publisher does not exist.
            throw new ApplicationException(String.Format(
                "{0} is not a Publisher for {1}.", publisherName, distributorName));
        }

        // Drop the distribution database.
        if (distributionDb.LoadProperties())
        {
            distributionDb.Remove();
        }
        else
        {
            // Do something here if the distribition DB does not exist.
            throw new ApplicationException(String.Format(
                "The distribution database '{0}' does not exist on {1}.",
                distributionDbName, distributorName));
        }

        // Uninstall the Distributor, if it exists.
        if (distributor.LoadProperties())
        {
            // Passing a value of false means that the Publisher 
            // and distribution databases must already be uninstalled,
            // and that no local databases be enabled for publishing.
            distributor.UninstallDistributor(false);
        }
        else
        {
            //Do something here if the distributor does not exist.
            throw new ApplicationException(String.Format(
                "The Distributor '{0}' does not exist.", distributorName));
        }
    }
    else
    {
        throw new ApplicationException("You must first delete all subscriptions.");
    }
}
catch (Exception ex)
{
    // Implement appropriate error handling here.
    throw new ApplicationException("The Publisher and Distributor could not be uninstalled", ex);
}
finally
{
    publisherConn.Disconnect();
    distributorConn.Disconnect();
}

' Set the Distributor and publication database names.
' Publisher and Distributor are on the same server instance.
Dim publisherName As String = publisherInstance
Dim distributorName As String = subscriberInstance
Dim distributionDbName As String = "distribution"
Dim publicationDbName As String = "AdventureWorks2012"

' Create connections to the Publisher and Distributor
' using Windows Authentication.
Dim publisherConn As ServerConnection = New ServerConnection(publisherName)
Dim distributorConn As ServerConnection = New ServerConnection(distributorName)

' Create the objects we need.
Dim distributor As ReplicationServer
distributor = New ReplicationServer(distributorConn)
Dim publisher As DistributionPublisher
Dim distributionDb As DistributionDatabase
distributionDb = New DistributionDatabase(distributionDbName, distributorConn)
Dim publicationDb As ReplicationDatabase
publicationDb = New ReplicationDatabase(publicationDbName, publisherConn)

Try
    ' Connect to the Publisher and Distributor.
    publisherConn.Connect()
    distributorConn.Connect()

    ' Disable all publishing on the AdventureWorks2012 database.
    If publicationDb.LoadProperties() Then
        If publicationDb.EnabledMergePublishing Then
            publicationDb.EnabledMergePublishing = False
        ElseIf publicationDb.EnabledTransPublishing Then
            publicationDb.EnabledTransPublishing = False
        End If
    Else
        Throw New ApplicationException( _
            String.Format("The {0} database does not exist.", publicationDbName))
    End If

    ' We cannot uninstall the Publisher if there are still Subscribers.
    If distributor.RegisteredSubscribers.Count = 0 Then
        ' Uninstall the Publisher, if it exists.
        publisher = New DistributionPublisher(publisherName, distributorConn)
        If publisher.LoadProperties() Then
            publisher.Remove(False)
        Else
            ' Do something here if the Publisher does not exist.
            Throw New ApplicationException(String.Format( _
                "{0} is not a Publisher for {1}.", publisherName, distributorName))
        End If

        ' Drop the distribution database.
        If distributionDb.LoadProperties() Then
            distributionDb.Remove()
        Else
            ' Do something here if the distribition DB does not exist.
            Throw New ApplicationException(String.Format( _
             "The distribution database '{0}' does not exist on {1}.", _
             distributionDbName, distributorName))
        End If

        ' Uninstall the Distributor, if it exists.
        If distributor.LoadProperties() Then
            ' Passing a value of false means that the Publisher 
            ' and distribution databases must already be uninstalled,
            ' and that no local databases be enabled for publishing.
            distributor.UninstallDistributor(False)
        Else
            'Do something here if the distributor does not exist.
            Throw New ApplicationException(String.Format( _
                "The Distributor '{0}' does not exist.", distributorName))
        End If
    Else
        Throw New ApplicationException("You must first delete all subscriptions.")
    End If

Catch ex As Exception
    ' Implement appropriate error handling here.
    Throw New ApplicationException("The Publisher and Distributor could not be uninstalled", ex)

Finally
    publisherConn.Disconnect()
    distributorConn.Disconnect()

End Try

Comentarios

La DistributionPublisher clase requiere una conexión al distribuidor que usa el publicador.

Seguridad para subprocesos

Los miembros estáticos públicos (Shared en Microsoft Visual Basic) de este tipo son seguros para las operaciones multiproceso. No se garantiza que los miembros de instancia sean seguros para subprocesos.

Constructores

DistributionPublisher()	Crea una nueva instancia de la clase DistributionPublisher.
DistributionPublisher(String, ServerConnection)	Crea una instancia de la clase DistributionPublisher, con el nombre del publicador y con una conexión al distribuidor utilizado por el publicador.

Propiedades

CachePropertyChanges	Obtiene o establece si los cambios realizados en las propiedades de replicación se almacenan en memoria caché o se aplican inmediatamente. (Heredado de ReplicationObject)
ConnectionContext	Obtiene o establece la conexión a una instancia de Microsoft SQL Server. (Heredado de ReplicationObject)
DistributionDatabase	Obtiene o establece el nombre de la base de datos de distribución utilizada por el publicador.
DistributionPublications	Obtiene las publicaciones que existen en el publicador.
HeterogeneousLogReaderAgentExists	Obtiene un valor que indica si el trabajo del Agente de registro del LOG existe para el publicador que no es SQL Server.
HeterogeneousLogReaderAgentProcessSecurity	Obtiene el contexto de seguridad usado por el Agente de registro del LOG para un publicador que no es de SQL Server.
IsExistingObject	Obtiene si el objeto existe en el servidor. (Heredado de ReplicationObject)
Name	Obtiene o establece el nombre de la instancia del publicador de Microsoft SQL Server.
PublisherSecurity	Obtiene el contexto de seguridad utilizado por el agente de replicación para la conexión al publicador.
PublisherType	Obtiene o establece el tipo de publicador.
RegisteredSubscribers	Obtiene los suscriptores que están suscritos a publicaciones en el publicador.
SqlServerName	Obtiene el nombre de la instancia de Microsoft SQL Server a la que está conectado este objeto. (Heredado de ReplicationObject)
Status	Obtiene el estado del publicador.
ThirdParty	Obtiene o establece un valor que indica si el publicador no es de SQL Server.
TransPublications	Obtiene las publicaciones transaccionales en el publicador.
TrustedDistributorConnection	Obtiene o establece un valor que indica si la conexión de distribuidor es de confianza.
UserData	Obtiene o establece una propiedad de un objeto que permite a los usuarios adjuntar sus propios datos al objeto. (Heredado de ReplicationObject)
WorkingDirectory	Obtiene o establece el nombre del directorio de trabajo utilizado para almacenar archivos de datos y de esquema para la publicación.

Métodos

CheckValidCreation()	Comprueba la creación de replicación válida. (Heredado de ReplicationObject)
CheckValidDefinition(Boolean)	Indica si la definición es válida. (Heredado de ReplicationObject)
CommitPropertyChanges()	Envía todas las instrucciones de cambio de propiedad almacenadas en caché a la instancia de Microsoft SQL Server. (Heredado de ReplicationObject)
Create()	Registra el publicador con las propiedades especificadas en el distribuidor.
CreateHeterogeneousLogReaderAgent()	Crea un trabajo del Agente de registro del LOG para un publicador que no es de SQL Server.
Decouple()	Desacopla del servidor el objeto de replicación al que se hace referencia. (Heredado de ReplicationObject)
EnumDistributionPublications()	Devuelve la información almacenada en el distribuidor sobre las publicaciones en este publicador.
EnumRegisteredSubscribers()	Devuelve la información almacenada en el distribuidor sobre los suscriptores de este publicador.
EnumTransPublications()	Devuelve la información del distribuidor sobre las publicaciones transaccionales de este publicador.
GetChangeCommand(StringBuilder, String, String)	Devuelve el comando de cambio de la replicación. (Heredado de ReplicationObject)
GetCreateCommand(StringBuilder, Boolean, ScriptOptions)	Devuelve el comando de creación de la replicación. (Heredado de ReplicationObject)
GetDropCommand(StringBuilder, Boolean)	Devuelve el comando drop de la replicación. (Heredado de ReplicationObject)
InternalRefresh(Boolean)	Inicia una actualización interna de la replicación. (Heredado de ReplicationObject)
Load()	Carga las propiedades de un objeto existente desde el servidor. (Heredado de ReplicationObject)
LoadProperties()	Carga las propiedades de un objeto existente desde el servidor. (Heredado de ReplicationObject)
Refresh()	Vuelve a cargar las propiedades del objeto. (Heredado de ReplicationObject)
Remove(Boolean)	Quita el registro de este publicador del distribuidor actualmente conectado.
Script(ScriptOptions)	Genera un script de Transact-SQL que se puede usar para instalar o desinstalar el publicador.

Se aplica a

Consulte también

sp_changelogreader_agent (Transact-SQL)gure Publishing and Distribution (RMO Programming)

Compartir a través de