Créer un instantané d'une publication de fusion avec des filtres paramétrés

Cette rubrique explique comment créer un instantané pour une publication de fusion avec des filtres paramétrables dans SQL Server 2012 à l'aide de SQL Server Management Studio, de Transact-SQL ou d'objets RMO (Replication Management Objects).

Dans cette rubrique

• Avant de commencer :

  Recommandations

• Pour créer un instantané d'une publication de fusion avec des filtres paramétrés à l'aide de :

  SQL Server Management Studio

  Transact-SQL

  Objets RMO (Replication Management Objects)

Avant de commencer

Recommandations

• Lors de la génération d'un instantané pour une publication de fusion à l'aide de filtres paramétrables, vous devez commencer par générer un instantané standard (schéma) qui contient l'ensemble des données publiées, ainsi que les métadonnées de l'Abonné pour l'abonnement. Pour plus d'informations, consultez Créer et appliquer l'instantané initial. Après avoir créé l'instantané de schéma, vous pouvez générer l'instantané qui contient la partition des données publiées spécifique à l'Abonné.

• Si le filtrage d'un ou plusieurs articles de la publication donne des partitions qui ne se chevauchent pas et sont uniques pour chaque abonnement, les métadonnées sont nettoyées à chaque exécution de l'Agent de fusion. Cela signifie que l'instantané partitionné expire plus rapidement. Lorsque vous utilisez cette option, il est important de déterminer si des Abonnés doivent être autorisés à lancer une génération et une livraison des instantanés. Pour plus d'informations sur les options de filtrage, consultez la section « Définition des options de partition » de Instantanés des publications de fusion avec des filtres paramétrés.

[Top]

Utilisation de SQL Server Management Studio

Générez des instantanés pour les partitions dans la page Partitions de données de la boîte de dialogue Propriétés de la publication - <Publication>. Pour plus d'informations sur l'accès à cette boîte de dialogue, consultez Afficher et modifier les propriétés d'une publication. Vous pouvez permettre à des Abonnés de lancer la génération et la livraison d'instantanés et/ou de générer des instantanés.

Pour générer des instantanés pour une ou plusieurs partitions, vous devez préalablement :

1. créer une publication de fusion à l'aide de l'Assistant Nouvelle publication et spécifier un ou plusieurs filtres de lignes paramétrables dans la page Ajouter un filtre de l'Assistant. Pour plus d'informations, consultez Définir et modifier un filtre de lignes paramétrable pour un article de fusion.

2. Générez un instantané du schéma pour la publication. Par défaut, un instantané du schéma est généré lorsque vous terminez l'Assistant Nouvelle publication ; vous pouvez également générer un instantané du schéma à partir de SQL Server Management Studio.

Pour générer un instantané du schéma

1. Connectez-vous au serveur de publication dans Management Studio, puis développez le nœud du serveur.

2. Développez le dossier Réplication, puis le dossier Publications.

3. Cliquez avec le bouton droit sur la publication pour laquelle vous voulez créer un instantané, puis cliquez sur Afficher l'état de l'Agent d'instantané.

4. Dans la boîte de dialogue Afficher l'état de l'Agent d'instantané - <Publication>, cliquez sur Démarrer.

   Lorsque l'Agent d'instantané termine la génération de l'instantané, un message s'affiche, tel que « [100%] Un instantané de 17 article(s) a été généré. »

Pour permettre à des Abonnés de lancer la génération et la remise d'instantanés

1. Dans la page Partitions de données de la boîte de dialogue Propriétés de la publication - <Publication>, sélectionnez Définir automatiquement une partition et générer un instantané si nécessaire lorsqu'un nouvel abonné essaie de se synchroniser.

2. Cliquez sur OK.

Pour générer et actualiser des instantanés

1. Dans la page Partitions de données de la boîte de dialogue Propriétés de la publication - <Publication>, cliquez sur Ajouter.

2. Entrez une valeur pour la valeur HOST_NAME() et/ou SUSER_SNAME() associée à la partition pour laquelle vous voulez créer un instantané.

3. En option, spécifiez une planification pour l'actualisation des instantanés :

   1. Sélectionnez Planifier l'Agent d'instantané pour l'exécution de cette partition à l'heure ou aux heures suivantes.

   2. Acceptez la planification par défaut pour l'actualisation des instantanés, ou bien cliquez sur Modifier pour spécifier une autre planification.

4. Cliquez sur OK, ce qui vous renvoie à la boîte de dialogue Propriétés de la publication - <Publication>.

5. Sélectionnez la partition dans la grille de propriétés, puis cliquez sur Générer les instantanés sélectionnés maintenant.

6. Cliquez sur OK.

[Top]

Utilisation de Transact-SQL

Les procédures stockées et l'Agent d'instantané permettent d'effectuer les tâches suivantes :

• Vous pouvez autoriser les Abonnés à demander la génération et l'application d'un instantané lors de leur première synchronisation.

• Vous pouvez prégénérer des instantanés pour chaque partition.

• générer manuellement un instantané pour chaque Abonné.

  Remarque relative à la sécurité
  Lorsque c'est possible, vous pouvez demander aux utilisateurs de fournir les informations d'identification au moment de l'exécution. Si vous devez stocker ces informations dans un fichier de script, vous devez sécuriser ce fichier pour empêcher tout accès non autorisé.

Pour créer une publication qui permet aux Abonnés d'initialiser la génération et la remise d'instantanés

1. Dans la base de données de publication sur le serveur de publication, exécutez sp_addmergepublication (Transact-SQL). Spécifiez les paramètres suivants :

   • Le nom de la publication pour @publication.

   • La valeur true pour @allow_subscriber_initiated_snapshot, qui permet aux Abonnés d'initialiser le processus d'instantané.

   • (Facultatif) Le nombre de processus d'instantané dynamique qui peuvent s'exécuter simultanément pour @max_concurrent_dynamic_snapshots. Si le nombre maximal de processus en cours d'exécution est atteint et si un Abonné essaie de générer un instantané, le processus est placé en file d'attente. Par défaut, le nombre de processus simultanés est illimité.

2. Sur le serveur de publication, exécutez sp_addpublication_snapshot (Transact-SQL). Spécifiez le nom de publication utilisé à l'étape 1 pour @publication et les informations d'identification Microsoft Windows sous lesquelles l'Agent d'instantané de réplication s'exécute pour @job_login et @password. Si l'agent doit utiliser l'authentification SQL Server lors de la connexion au serveur de publication, vous devez aussi spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion Microsoft SQL Server pour @publisher_login et @publisher_password. Un travail de l'Agent d'instantané est alors créé pour la publication. Pour plus d'informations sur la génération d'un instantané initial et la définition d'une planification personnalisée pour l'Agent d'instantané, consultez Créer et appliquer l'instantané initial.

   Remarque relative à la sécurité

   Lors de la configuration d'un serveur de publication avec un serveur de distribution distant, les valeurs fournies pour tous les paramètres, y compris job_login et job_password, sont envoyées en texte brut au serveur de distribution. Vous devez chiffrer la connexion entre le serveur de publication et son serveur de distribution distant avant d'exécuter cette procédure stockée. Pour plus d'informations, consultez Activer les connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).

3. Exécutez sp_addmergearticle (Transact-SQL) pour ajouter des articles à la publication. Cette procédure stockée doit être exécutée une fois pour chaque article de la publication. Lorsque vous utilisez des filtres paramétrables, vous devez spécifier un filtre de lignes paramétrable pour un ou plusieurs articles à l'aide du paramètre @subset_filterclause. Pour plus d'informations, consultez Définir et modifier un filtre de lignes paramétrable pour un article de fusion.

4. Si d'autres articles doivent être filtrés sur la base du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir la relation de jointure ou d'enregistrements logiques entre les articles. Cette procédure stockée doit être exécutée une fois pour chaque relation en cours de définition. Pour plus d'informations, consultez Définir et modifier un filtre de jointure entre des articles de fusion.

5. Lorsque l'Agent de fusion demande à l'instantané d'initialiser l'Abonné, l'instantané de la partition de l'abonnement demandeur est généré automatiquement.

Pour créer une publication et prégénérer ou actualiser automatiquement des instantanés

1. Exécutez sp_addmergepublication (Transact-SQL) pour créer la publication. Pour plus d'informations, consultez Créer une publication.

2. Sur le serveur de publication, exécutez sp_addpublication_snapshot (Transact-SQL). Spécifiez le nom de publication utilisé à l'étape 1 pour @publication et les informations d'identification Windows sous lesquelles l'Agent d'instantané s'exécute pour @job_login et @password. Si l'agent doit utiliser l'authentification SQL Server lors de la connexion au serveur de publication, vous devez aussi spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion SQL Server pour @publisher_login et @publisher_password. Un travail de l'Agent d'instantané est alors créé pour la publication. Pour plus d'informations sur la génération d'un instantané initial et la définition d'une planification personnalisée pour l'Agent d'instantané, consultez Créer et appliquer l'instantané initial.

   Remarque relative à la sécurité

   Lors de la configuration d'un serveur de publication avec un serveur de distribution distant, les valeurs fournies pour tous les paramètres, y compris job_login et job_password, sont envoyées en texte brut au serveur de distribution. Vous devez chiffrer la connexion entre le serveur de publication et son serveur de distribution distant avant d'exécuter cette procédure stockée. Pour plus d'informations, consultez Activer les connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).

3. Exécutez sp_addmergearticle (Transact-SQL) pour ajouter des articles à la publication. Cette procédure stockée doit être exécutée une fois pour chaque article de la publication. Lorsque vous utilisez des filtres paramétrables, vous devez spécifier un filtre de lignes paramétrable pour un article à l'aide du paramètre @subset_filterclause. Pour plus d'informations, consultez Définir et modifier un filtre de lignes paramétrable pour un article de fusion.

4. Si d'autres articles doivent être filtrés sur la base du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir la relation de jointure ou d'enregistrements logiques entre les articles. Cette procédure stockée doit être exécutée une fois pour chaque relation en cours de définition. Pour plus d'informations, consultez Définir et modifier un filtre de jointure entre des articles de fusion.

5. Dans la base de données de publication sur le serveur de publication, exécutez sp_helpmergepublication (Transact-SQL), en spécifiant la valeur de @publication définie à l'étape 1. Notez la valeur du snapshot_jobid dans le jeu de résultats.

6. Convertissez la valeur du snapshot_jobid obtenue à l'étape 5 en uniqueidentifier.

7. Dans la base de données msdb sur le serveur de publication, exécutez sp_start_job (Transact-SQL), en spécifiant la valeur convertie obtenue à l'étape 6 pour @job_id.

8. Dans la base de données de publication sur le serveur de publication, exécutez sp_addmergepartition (Transact-SQL). Spécifiez le nom de la publication définie à l'étape 1 pour @publication et la valeur utilisée pour définir la partition pour @suser_sname si SUSER_SNAME (Transact-SQL) est utilisé dans la clause de filtre ou pour @host_name si HOST_NAME (Transact-SQL) est utilisé dans la clause de filtre.

9. Dans la base de données de publication sur le serveur de publication, exécutez sp_adddynamicsnapshot_job (Transact-SQL). Spécifiez le nom de la publication définie à l'étape 1 pour @publication, la valeur de @suser_sname ou @host_name définie à l'étape 8 et une planification pour le travail. Le travail qui génère l'instantané paramétrable pour la partition spécifiée est ainsi créé. Pour plus d'informations, consultez Spécifier des planifications de synchronisation.

   [!REMARQUE]

   Ce travail s'exécute à l'aide du même compte Windows que le travail d'instantané initial défini à l'étape 2. Pour supprimer le travail d'instantané paramétrable et sa partition de données associée, exécutez sp_dropdynamicsnapshot_job (Transact-SQL).

10. Dans la base de données de publication sur le serveur de publication, exécutez sp_helpmergepartition (Transact-SQL) en spécifiant la valeur de @publication définie à l'étape 1 et la valeur de @suser_sname ou @host_name définie à l'étape 8. Notez la valeur du dynamic_snapshot_jobid dans le jeu de résultats.

11. Dans la base de données msdb sur le serveur de distribution, exécutez sp_start_job (Transact-SQL), en spécifiant la valeur obtenue à l'étape 9 pour @job_id. Le travail d'instantané paramétrable de la partition est alors démarré.

12. Répétez les étapes 8 à 11 pour générer un instantané partitionné pour chaque abonnement.

Pour créer une publication et créer manuellement des instantanés pour chaque partition

1. Exécutez sp_addmergepublication (Transact-SQL) pour créer la publication. Pour plus d'informations, consultez Créer une publication.

2. Sur le serveur de publication, exécutez sp_addpublication_snapshot (Transact-SQL). Spécifiez le nom de publication utilisé à l'étape 1 pour @publication et les informations d'identification Windows sous lesquelles l'Agent d'instantané s'exécute pour @job_login et @password. Si l'agent doit utiliser l'authentification SQL Server lors de la connexion au serveur de publication, vous devez aussi spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion SQL Server pour @publisher_login et @publisher_password. Un travail de l'Agent d'instantané est alors créé pour la publication. Pour plus d'informations sur la génération d'un instantané initial et la définition d'une planification personnalisée pour l'Agent d'instantané, consultez Créer et appliquer l'instantané initial.

   Remarque relative à la sécurité

   Lors de la configuration d'un serveur de publication avec un serveur de distribution distant, les valeurs fournies pour tous les paramètres, y compris job_login et job_password, sont envoyées en texte brut au serveur de distribution. Vous devez chiffrer la connexion entre le serveur de publication et son serveur de distribution distant avant d'exécuter cette procédure stockée. Pour plus d'informations, consultez Activer les connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).

3. Exécutez sp_addmergearticle (Transact-SQL) pour ajouter des articles à la publication. Cette procédure stockée doit être exécutée une fois pour chaque article de la publication. Lorsque vous utilisez des filtres paramétrables, vous devez spécifier un filtre de lignes paramétrable pour au moins un article à l'aide du paramètre @subset_filterclause. Pour plus d'informations, consultez Définir et modifier un filtre de lignes paramétrable pour un article de fusion.

4. Si d'autres articles doivent être filtrés sur la base du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir la relation de jointure ou d'enregistrements logiques entre les articles. Cette procédure stockée doit être exécutée une fois pour chaque relation en cours de définition. Pour plus d'informations, consultez Définir et modifier un filtre de jointure entre des articles de fusion.

5. Démarrez le travail d'instantané ou exécutez l'Agent d'instantané des réplications à partir de l'invite de commandes pour générer le schéma d'instantané standard et d'autres fichiers. Pour plus d'informations, consultez Créer et appliquer l'instantané initial.

6. Exécutez de nouveau l'Agent d'instantané des réplications à partir de l'invite de commandes pour générer des fichiers de copie en bloc (.bcp), en spécifiant l'emplacement de l'instantané partitionné pour - DynamicSnapshotLocation et une des propriétés suivantes ou les deux qui définissent la partition :

   • - DynamicFilterHostName - la valeur si HOST_NAME (Transact-SQL) est utilisé.

   • - DynamicFilterLogin - la valeur si SUSER_SNAME (Transact-SQL) est utilisé.

7. Répétez l'étape 6 pour générer un instantané partitionné pour chaque abonnement.

8. Exécutez l'Agent de fusion pour chaque abonnement afin d'appliquer l'instantané partitionné initial aux Abonnés, en spécifiant les propriétés suivantes :

   • -Hostname - la valeur utilisée pour définir la partition si la valeur réelle de HOST_NAME est remplacée.

   • - DynamicSnapshotLocation - l'emplacement de l'instantané dynamique pour cette partition.

[!REMARQUE]

Pour plus d'informations sur la programmation des agents de réplication, consultez Concepts des exécutables de l'agent de réplication.

Exemples (Transact-SQL)

Cet exemple crée une publication de fusion avec des filtres paramétrables dans laquelle les Abonnés initialisent le processus de génération d'instantané. Les valeurs de @job_login et @job_password sont passées à l'aide de variables de script.

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

--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;

SET @publicationdb = N'AdventureWorks2012';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';

USE [AdventureWorks2012];

-- Enable AdventureWorks2012 for merge replication.
EXEC sp_replicationdboption
  @dbname = @publicationdb,
  @optname = N'merge publish',
  @value = N'true';  

-- Create new merge publication with Subscriber requested snapshot
-- and using the default agent schedule. 
EXEC sp_addmergepublication 
  @publication = @publication, 
  @description = N'Merge publication of AdventureWorks2012.', 
  @allow_subscriber_initiated_snapshot = N'true',
  @publication_compatibility_level = N'90RTM';

-- Create a new snapshot job for the publication, using the default schedule.
-- Pass credentials at runtime using sqlcmd scripting variables.
EXEC sp_addpublication_snapshot 
  @publication = @publication, 
  @job_login = $(login), 
  @job_password = $(password);

-- Add an article for the Employee table, 
-- which is horizontally partitioned using 
-- a parameterized row filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table1, 
  @source_owner = @schema_hr, 
  @source_object = @table1, 
  @type = N'table', 
  @description = 'contains employee information', 
  @subset_filterclause = N'[LoginID] = HOST_NAME()';

-- Add an article for the SalesPerson table, 
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table2, 
  @source_owner = @schema_sales, 
  @source_object = @table2, 
  @type = N'table', 
  @description = 'contains salesperson information';

-- Add a join filter between the two articles.
EXEC sp_addmergefilter 
  @publication = @publication, 
  @article = @table1, 
  @filtername = @filter, 
  @join_articlename = @table2, 
  @join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]', 
  @join_unique_key = 1, 
  @filter_type = 1;
GO

-- Start the agent job to generate the full snapshot for the publication.
-- The filtered data snapshot is generated automatically the first time 
-- the subscription is synchronized. 
DECLARE @publication AS sysname;
SET @publication = N'AdvWorksSalesPersonMerge';

EXEC sp_startpublication_snapshot 
  @publication = @publication;
GO

Cet exemple crée une publication à l'aide d'un filtre paramétrable dans laquelle la partition de chaque Abonné est définie en exécutant sp_addmergepartition et le travail d'instantané filtré est créé en exécutant sp_adddynamicsnapshot_job et en passant les informations de partitionnement. Les valeurs de @job_login et @job_password sont passées à l'aide de variables de script.

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

--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;

SET @publicationdb = N'AdventureWorks2012';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';

USE [AdventureWorks2012];

-- Enable AdventureWorks2012 for merge replication.
EXEC sp_replicationdboption
  @dbname = @publicationdb,
  @optname = N'merge publish',
  @value = N'true';  

-- Create new merge publication.  
EXEC sp_addmergepublication 
  @publication = @publication, 
  @description = N'Merge publication of AdventureWorks2012.', 
  @allow_subscriber_initiated_snapshot = N'false';

-- Create a new snapshot job for the publication, using the 
-- default schedule. Pass credentials at runtime using 
-- sqlcmd scripting variables.
EXEC sp_addpublication_snapshot 
  @publication = @publication, 
  @job_login = $(Login), 
  @job_password = $(password);

-- Add an article for the Employee table, 
-- which is horizontally partitioned using 
-- a parameterized row filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table1, 
  @source_owner = @schema_hr, 
  @source_object = @table1, 
  @type = N'table', 
  @description = 'contains employee information', 
  @subset_filterclause = N'[LoginID] = HOST_NAME()';

-- Add an article for the SalesPerson table, 
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table2, 
  @source_owner = @schema_sales, 
  @source_object = @table2, 
  @type = N'table', 
  @description = 'contains customer information';

-- Add a join filter between the two articles.
EXEC sp_addmergefilter 
  @publication = @publication, 
  @article = @table1, 
  @filtername = @filter, 
  @join_articlename = @table2, 
  @join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]', 
  @join_unique_key = 1, 
  @filter_type = 1;
GO

-- Start the snapshot agent job.
DECLARE @publication AS sysname;
SET @publication = N'AdvWorksSalesPersonMerge';

EXEC sp_startpublication_snapshot 
  @publication = @publication;
GO

PRINT '*** Waiting for the initial snapshot.';
GO

-- Create a temporary table to store the filtered data snapshot 
-- job information.
CREATE TABLE #temp (id int,
    job_name sysname,
    job_id uniqueidentifier,
    dynamic_filter_login sysname NULL,
    dynamic_filter_hostname sysname NULL,
    dynamic_snapshot_location nvarchar(255),
    frequency_type int, 
    frequency_interval int, 
    frequency_subday_type int,
    frequency_subday_interval int, 
    frequency_relative_interval int, 
    frequency_recurrence_factor int, 
    active_start_date int, 
    active_end_date int, 
    active_start_time int, 
    active_end_time int
)

-- Create each snapshot for a partition 
-- The initial snapshot must already be generated.
DECLARE @publication AS sysname;
DECLARE @jobname AS sysname
DECLARE @hostname AS sysname
SET @publication = N'AdvWorksSalesPersonMerge';
SET @hostname = N'adventure-works\Fernando';

WHILE NOT EXISTS(SELECT * FROM sysmergepublications 
    WHERE [name] = @publication 
    AND snapshot_ready = 1)
BEGIN
    WAITFOR DELAY '00:00:05'
END

-- Create a data partition by overriding HOST_NAME().
EXEC sp_addmergepartition 
  @publication = @publication,
  @host_name = @hostname;

-- Create the filtered data snapshot job, and use the returned 
-- information to start the job.
EXEC sp_adddynamicsnapshot_job 
  @publication = @publication,
  @host_name = @hostname;

INSERT INTO #temp (id, job_name, job_id, dynamic_filter_login,
    dynamic_filter_hostname, dynamic_snapshot_location,
    frequency_type, frequency_interval, frequency_subday_type,
    frequency_subday_interval, frequency_relative_interval, 
    frequency_recurrence_factor, active_start_date, active_end_date, 
    active_start_time,active_end_time)
EXEC sp_helpdynamicsnapshot_job;

SELECT @jobname = (SELECT DISTINCT job_name FROM #temp WHERE dynamic_filter_hostname = @hostname);

EXEC msdb..sp_start_job @job_name = @jobname;
DROP TABLE #temp;
GO

Cet exemple crée une publication à l'aide d'un filtre paramétrable dans laquelle la partition de données et le travail d'instantané filtré de chaque Abonné doivent être créés en fournissant les informations de partitionnement. Un Abonné fournit des informations de partitionnement à l'aide de paramètres de ligne de commande lors de l'exécution manuelle des agents de réplication. Cet exemple suppose qu'un abonnement à la publication a également été créé.

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

--Add a new merge publication.
DECLARE @publicationdb AS sysname;
DECLARE @publication AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @filter AS sysname;
DECLARE @schema_hr AS sysname;
DECLARE @schema_sales AS sysname;

SET @publicationdb = N'AdventureWorks2012';
SET @publication = N'AdvWorksSalesPersonMerge';
SET @table1 = N'Employee';
SET @table2 = N'SalesPerson';
SET @filter = N'SalesPerson_Employee';
SET @schema_hr = N'HumanResources';
SET @schema_sales = N'Sales';

USE [AdventureWorks2012];

-- Enable AdventureWorks2012 for merge replication.
EXEC sp_replicationdboption
  @dbname = @publicationdb,
  @optname = N'merge publish',
  @value = N'true';  

-- Create new merge publication.  
EXEC sp_addmergepublication 
  @publication = @publication, 
  @description = N'Merge publication of AdventureWorks2012.', 
  @allow_subscriber_initiated_snapshot = N'false';

-- Create a new snapshot job for the publication, using the 
-- default schedule. Pass credentials at runtime using 
-- sqlcmd scripting variables.
EXEC sp_addpublication_snapshot 
  @publication = @publication, 
  @job_login = $(Login), 
  @job_password = $(Password);

-- Add an article for the Employee table, 
-- which is horizontally partitioned using 
-- a parameterized row filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table1, 
  @source_owner = @schema_hr, 
  @source_object = @table1, 
  @type = N'table', 
  @description = 'contains employee information', 
  @subset_filterclause = N'[LoginID] = HOST_NAME()';

-- Add an article for the SalesPerson table, 
-- which is partitioned based on a join filter.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table2, 
  @source_owner = @schema_sales, 
  @source_object = @table2, 
  @type = N'table', 
  @description = 'contains customer information';

-- Add a join filter between the two articles.
EXEC sp_addmergefilter 
  @publication = @publication, 
  @article = @table1, 
  @filtername = @filter, 
  @join_articlename = @table2, 
  @join_filterclause = N'[Employee].[BusinessEntityID] = [SalesPerson].[SalesPersonID]', 
  @join_unique_key = 1, 
  @filter_type = 1;
GO

REM Line breaks are added to improve readability. 
REM In a batch file, commands must be made in a single line.
REM Run the Snapshot agent from the command line to generate the standard snapshot 
REM schema and other files. 
SET DistPub=%computername%
SET PubDB=AdventureWorks2012 
SET PubName=AdvWorksSalesPersonMerge

"C:\Program Files\Microsoft SQL Server\110\COM\SNAPSHOT.EXE" -Publication %PubName%  
-Publisher %DistPub% -Distributor  %DistPub%  -PublisherDB %PubDB%  -ReplicationType 2  
-OutputVerboseLevel 1  -DistributorSecurityMode 1

PAUSE

REM Run the Snapshot agent from the command line, this time to generate 
REM the bulk copy (.bcp) data for each Subscriber partition.  
SET DistPub=%computername%
SET PubDB=AdventureWorks2012 
SET PubName=AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando

MD %SnapshotDir%

"C:\Program Files\Microsoft SQL Server\110\COM\SNAPSHOT.EXE" -Publication %PubName%  
-Publisher %DistPub%  -Distributor  %DistPub%  -PublisherDB %PubDB%  -ReplicationType 2  
-OutputVerboseLevel 1  -DistributorSecurityMode 1  -DynamicFilterHostName "adventure-works\Fernando"  
-DynamicSnapshotLocation %SnapshotDir%

PAUSE

REM Run the Merge Agent for each subscription to apply the partitioned 
REM snapshot for each Subscriber.  
SET Publisher = %computername%
SET Subscriber = %computername%
SET PubDB = AdventureWorks2012 
SET SubDB = AdventureWorks2012Replica 
SET PubName = AdvWorksSalesPersonMerge 
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando

"C:\Program Files\Microsoft SQL Server\110\COM\REPLMERG.EXE" -Publisher  %Publisher%  
-Subscriber  %Subscriber%  -Distributor %Publisher%  -PublisherDB %PubDB%  
-SubscriberDB %SubDB% -Publication %PubName%  -PublisherSecurityMode 1  -OutputVerboseLevel 3  
-Output -SubscriberSecurityMode 1  -SubscriptionType 3 -DistributorSecurityMode 1  
-Hostname "adventure-works\Fernando"  -DynamicSnapshotLocation %SnapshotDir%

PAUSE

[Top]

Utilisation d'objets RMO (Replication Management Objects)

Vous pouvez utiliser les Replication Management Objects pour générer par programme des instantanés partitionnés des manières suivantes :

• Vous pouvez autoriser les Abonnés à demander la génération et l'application d'un instantané lors de leur première synchronisation.

• Vous pouvez prégénérer des instantanés pour chaque partition.

• Vous pouvez générer manuellement un instantané pour chaque Abonné en exécutant l'Agent d'instantané.

[!REMARQUE]

Lorsque le filtrage d'un article génère des partitions qui ne se chevauchent pas et qui sont uniques pour chaque abonnement (en spécifiant une valeur de NonOverlappingSingleSubscription pour PartitionOption lors de la création d'un article de fusion), les métadonnées sont nettoyées à chaque exécution de l'Agent de fusion. Cela signifie que l'instantané partitionné expire plus rapidement. Lorsque vous optez pour cette méthode, envisagez d'autoriser les Abonnées à demander la génération d'instantanés. Pour plus d'informations, consultez la section Utilisation des options de filtrage appropriées, dans la rubrique Filtres de lignes paramétrés.

Remarque relative à la sécurité
Si possible, demandez aux utilisateurs de fournir les informations d'identification de sécurité au moment de l'exécution. Si vous devez stocker des informations d'identification, utilisez les Services de chiffrement fournis par Microsoft Windows .NET Framework.

Pour créer une publication qui permet aux Abonnés d'initialiser la génération et la remise d'instantanés

1. Créez une connexion au serveur de publication en utilisant la classe ServerConnection.

2. Créez une instance de la classe ReplicationDatabase pour la base de données de publication, définissez la propriété ConnectionContext sur l'instance de ServerConnection définie à l'étape 1 et appelez la méthode LoadProperties. Si LoadProperties retourne false, confirmez que la base de données existe.

3. Si la propriété EnabledMergePublishing a la valeur false, affectez-lui la valeur true et appelez CommitPropertyChanges.

4. Créez une instance de la classe MergePublication et définissez les propriétés suivantes pour cet objet :

   • La classe ServerConnection créée à l'étape 1 pour la propriété ConnectionContext.

   • Le nom de la base de données publiée pour DatabaseName.

   • Un nom pour la publication pour Name.

   • Le nombre maximal de travaux d'instantané dynamique à exécuter pour MaxConcurrentDynamicSnapshots. Comme des demandes d'instantané initialisées par l'Abonné peuvent se produire à tout moment, cette propriété limite le nombre des travaux de l'Agent d'instantané qui peuvent s'exécuter simultanément lorsque plusieurs Abonnés demandent leur instantané partitionné au même moment. Lorsque le nombre maximal de travaux s'exécute, des demandes d'instantanés partitionnés supplémentaires sont mises en file d'attente jusqu'à ce que l'un des travaux en cours d'exécution se termine.

   • Utilisez l'opérateur logique OR (| dans Visual c# et Or dans Visual Basic) pour ajouter la valeur AllowSubscriberInitiatedSnapshot à Attributes.

   • Les champs Login et Password de SnapshotGenerationAgentProcessSecurity pour fournir les informations d'identification pour le compte Microsoft Windows sous lequel le travail de l'Agent d'instantané s'exécute.

     [!REMARQUE]

     La définition de SnapshotGenerationAgentProcessSecurity est recommandée lorsque la publication est créée par un membre du rôle serveur fixe sysadmin. Pour plus d'informations, consultez Modèle de sécurité de l'Agent de réplication.

5. Appelez la méthode Create pour créer la publication.

   Remarque relative à la sécurité

   Lors de la configuration d'un serveur de publication avec un serveur de distribution distant, les valeurs fournies pour toutes les propriétés, y compris SnapshotGenerationAgentProcessSecurity, sont envoyées sous forme de texte brut au serveur de distribution. Vous devez chiffrer la connexion entre le serveur de publication et son serveur de distribution distant avant d'appeler la méthode Create. Pour plus d'informations, consultez Activer les connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).

6. Utilisez la propriété MergeArticle pour ajouter des articles à la publication. Spécifiez la propriété FilterClause pour au moins un article qui définit le filtre paramétrable. (Facultatif) Créez des objets MergeJoinFilter qui définissent des filtres de jointure entre les articles. Pour plus d'informations, consultez Définir un article.

7. Si SnapshotAgentExists a la valeur false, appelez CreateSnapshotAgent pour créer le travail de l'Agent d'instantané initial pour cette publication.

8. Appelez la méthode StartSnapshotGenerationAgentJob de l'objet MergePublication créé à l'étape 4. Cela démarre le travail de l'agent qui génère l'instantané initial. Pour plus d'informations sur la génération d'un instantané initial et la définition d'une planification personnalisée pour l'Agent d'instantané, consultez Créer et appliquer l'instantané initial.

9. (Facultatif) Cherchez une valeur true pour la propriété SnapshotAvailable afin de déterminer quand l'instantané initial est prêt à être utilisé.

10. Lorsque l'Agent de fusion pour un Abonné se connecte pour la première fois, un instantané partitionné est généré automatiquement.

Pour créer une publication et prégénérer ou actualiser automatiquement des instantanés

1. Utilisez une instance de la classe MergePublication pour définir une publication de fusion. Pour plus d'informations, consultez Créer une publication.

2. Utilisez la propriété MergeArticle pour ajouter des articles à la publication. Spécifiez la propriété FilterClause pour au moins un article qui définit le filtre paramétrable et créez tous les objets MergeJoinFilter qui définissent les filtres de jointure entre les articles. Pour plus d'informations, consultez Définir un article.

3. Si SnapshotAgentExists a la valeur false, appelez CreateSnapshotAgent pour créer le travail de l'Agent d'instantané pour cette publication.

4. Appelez la méthode StartSnapshotGenerationAgentJob de l'objet MergePublication créé à l'étape 1. Cette méthode démarre le travail de l'agent qui génère l'instantané initial. Pour plus d'informations sur la génération d'un instantané initial et la définition d'une planification personnalisée pour l'Agent d'instantané, consultez Créer et appliquer l'instantané initial.

5. Cherchez une valeur true pour la propriété SnapshotAvailable afin de déterminer quand l'instantané initial est prêt à être utilisé.

6. Créez une instance de la classe MergePartition et définissez les critères de filtrage paramétrable pour l'Abonné en utilisant une des propriétés suivantes, ou les deux :

   • Si la partition de l'Abonné est définie par le résultat de SUSER_SNAME (Transact-SQL), utilisez DynamicFilterLogin.

   • Si la partition de l'Abonné est définie par le résultat de HOST_NAME (Transact-SQL) ou une surcharge de cette fonction, utilisez DynamicFilterHostName.

7. Créez une instance de la classe MergeDynamicSnapshotJob et définissez la même propriété qu'à l'étape 6.

8. Utilisez la classe ReplicationAgentSchedule pour définir une planification pour générer l'instantané filtré pour la partition de l'Abonné.

9. Utilisez l'instance de MergePublication de l'étape 1 pour appeler AddMergePartition. Passez l'objet MergePartition créé à l'étape 6.

10. Utilisez l'instance de MergePublication de l'étape 1 pour appeler la méthode AddMergeDynamicSnapshotJob. Passez l'objet MergeDynamicSnapshotJob créé à l'étape 7 et l'objet ReplicationAgentSchedule créé à l'étape 8.

11. Appelez EnumMergeDynamicSnapshotJobs et localisez l'objet MergeDynamicSnapshotJob correspondant au travail d'instantané partitionné nouvellement ajouté dans le tableau retourné.

12. Obtenez la propriété Name pour le travail.

13. Créez une connexion au serveur de distribution en utilisant la classe ServerConnection.

14. Créez une instance de la classe Server SMO (SQL Server Management Objects), en passant l'objet ServerConnection créé à l'étape 13.

15. Créez une instance de la classe Job, en passant la propriété JobServer de l'objet Server créé à l'étape 14 et le nom du travail obtenu à l'étape 12.

16. Appelez la méthode Start pour démarrer le travail d'instantané partitionné.

17. Répétez les étapes 6 à 16 pour chaque Abonné.

Pour créer une publication et créer manuellement des instantanés pour chaque partition

1. Utilisez une instance de la classe MergePublication pour définir une publication de fusion. Pour plus d'informations, consultez Créer une publication.

2. Utilisez la propriété MergeArticle pour ajouter des articles à la publication. Spécifiez la propriété FilterClause pour au moins un article qui définit le filtre paramétrable et créez tous les objets MergeJoinFilter qui définissent les filtres de jointure entre les articles. Pour plus d'informations, consultez Définir un article.

3. Générez l'instantané initial. Pour plus d'informations, consultez Créer et appliquer l'instantané initial.

4. Créez une instance de la classe SnapshotGenerationAgent et définissez les propriétés requises suivantes :

   • Publisher – nom du serveur de publication

   • PublisherDatabase – nom de la base de données de publication

   • Publication – nom de la publication

   • Distributor – nom du serveur de distribution

   • PublisherSecurityMode – une valeur de Integrated pour utiliser l'authentification intégrée Windows ou une valeur de Standard pour utiliser l'authentification SQL Server.

   • DistributorSecurityMode – une valeur de Integrated pour utiliser l'authentification intégrée Windows ou une valeur de Standard pour utiliser l'authentification SQL Server.

5. Définissez une valeur de Merge pour ReplicationType.

6. Définissez une ou plusieurs des propriétés suivantes pour définir les paramètres de partitionnement :

   • Si la partition de l'Abonné est définie par le résultat de SUSER_SNAME (Transact-SQL), utilisez DynamicFilterLogin.

   • Si la partition de l'Abonné est définie par le résultat de HOST_NAME (Transact-SQL) ou une surcharge de cette fonction, utilisez DynamicFilterHostName.

7. Appelez la méthode GenerateSnapshot.

8. Répétez les étapes 4 à 7 pour chaque Abonné.

Exemples (RMO)

Cet exemple crée une publication de fusion qui permet aux Abonnés de demander la génération d'instantanés.

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

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

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

Cet exemple crée manuellement la partition de l'Abonné et l'instantané filtré pour une publication de fusion avec des filtres de lignes paramétrables.

          // Define the server, database, and publication names
            string publisherName = publisherInstance;
            string publicationName = "AdvWorksSalesOrdersMerge";
            string publicationDbName = "AdventureWorks2012";
            string distributorName = publisherInstance;

            MergePublication publication;
            MergePartition partition;
            MergeDynamicSnapshotJob snapshotAgentJob;
            ReplicationAgentSchedule schedule;
            
            // Create a connection to the Publisher.
            ServerConnection publisherConn = new ServerConnection(publisherName);

            // Create a connection to the Distributor to start the Snapshot Agent.
            ServerConnection distributorConn = new ServerConnection(distributorName);

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

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


                // If we can't get the properties for this merge publication, 
                // then throw an application exception.
                if (publication.LoadProperties() || publication.SnapshotAvailable)
                {
                    // Set a weekly schedule for the filtered data snapshot.
                    schedule = new ReplicationAgentSchedule();
                    schedule.FrequencyType = ScheduleFrequencyType.Weekly;
                    schedule.FrequencyRecurrenceFactor = 1;
                    schedule.FrequencyInterval = Convert.ToInt32(0x001);

                    // Set the value of Hostname that defines the data partition. 
                    partition = new MergePartition();
                    partition.DynamicFilterHostName = hostname;
                    snapshotAgentJob = new MergeDynamicSnapshotJob();
                    snapshotAgentJob.DynamicFilterHostName = hostname;

                    // Create the partition for the publication with the defined schedule.
                    publication.AddMergePartition(partition);
                    publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule);
                }
                else
                {
                    throw new ApplicationException(String.Format(
                        "Settings could not be retrieved for the publication, " +
                        " or the initial snapshot has not been generated. " +
                        "Ensure that the publication {0} exists on {1} and " +
                        "that the Snapshot Agent has run successfully.",
                        publicationName, publisherName));
                }
            }
            catch (Exception ex)
            {
                // Do error handling here.
                throw new ApplicationException(string.Format(
                    "The partition for '{0}' in the {1} publication could not be created.",
                    hostname, publicationName), ex);
            }
            finally
            {
                publisherConn.Disconnect();
                if (distributorConn.IsOpen) distributorConn.Disconnect();
            }

' Define the server, database, and publication names
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2012"
Dim distributorName As String = publisherInstance

Dim publication As MergePublication
Dim partition As MergePartition
Dim snapshotAgentJob As MergeDynamicSnapshotJob
Dim schedule As ReplicationAgentSchedule

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

' Create a connection to the Distributor to start the Snapshot Agent.
Dim distributorConn As ServerConnection = New ServerConnection(distributorName)

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

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


    ' If we can't get the properties for this merge publication, 
    ' then throw an application exception.
    If (publication.LoadProperties() Or publication.SnapshotAvailable) Then
        ' Set a weekly schedule for the filtered data snapshot.
        schedule = New ReplicationAgentSchedule()
        schedule.FrequencyType = ScheduleFrequencyType.Weekly
        schedule.FrequencyRecurrenceFactor = 1
        schedule.FrequencyInterval = Convert.ToInt32("0x001", 16)

        ' Set the value of Hostname that defines the data partition. 
        partition = New MergePartition()
        partition.DynamicFilterHostName = hostname
        snapshotAgentJob = New MergeDynamicSnapshotJob()
        snapshotAgentJob.DynamicFilterHostName = hostname

        ' Create the partition for the publication with the defined schedule.
        publication.AddMergePartition(partition)
        publication.AddMergeDynamicSnapshotJob(snapshotAgentJob, schedule)
    Else
        Throw New ApplicationException(String.Format( _
         "Settings could not be retrieved for the publication, " + _
         " or the initial snapshot has not been generated. " + _
         "Ensure that the publication {0} exists on {1} and " + _
         "that the Snapshot Agent has run successfully.", _
         publicationName, publisherName))
    End If
Catch ex As Exception
    ' Do error handling here.
    Throw New ApplicationException(String.Format( _
     "The partition for '{0}' in the {1} publication could not be created.", _
     hostname, publicationName), ex)
Finally
    publisherConn.Disconnect()
    If distributorConn.IsOpen Then
        distributorConn.Disconnect()
    End If
End Try

Cet exemple lance manuellement l'Agent d'instantané pour qu'il génère l'instantané des données filtrées pour un Abonné à une publication de fusion avec des filtres de lignes paramétrables.

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

            SnapshotGenerationAgent agent;

            try
            {
                // Set the required properties for Snapshot Agent.
                agent = new SnapshotGenerationAgent();
                agent.Distributor = distributorName;
                agent.DistributorSecurityMode = SecurityMode.Integrated;
                agent.Publisher = publisherName;
                agent.PublisherSecurityMode = SecurityMode.Integrated;
                agent.Publication = publicationName;
                agent.PublisherDatabase = publicationDbName;
                agent.ReplicationType = ReplicationType.Merge;

                // Specify the partition information to generate a 
                // filtered snapshot based on Hostname.
                agent.DynamicFilterHostName = hostname;

                // Start the agent synchronously.
                agent.GenerateSnapshot();
            }
            catch (Exception ex)
            {
                // Implement custom application error handling here.
                throw new ApplicationException(String.Format(
                    "A snapshot could not be generated for the {0} publication."
                    , publicationName), ex);
            }

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

Dim agent As SnapshotGenerationAgent

Try
    ' Set the required properties for Snapshot Agent.
    agent = New SnapshotGenerationAgent()
    agent.Distributor = distributorName
    agent.DistributorSecurityMode = SecurityMode.Integrated
    agent.Publisher = publisherName
    agent.PublisherSecurityMode = SecurityMode.Integrated
    agent.Publication = publicationName
    agent.PublisherDatabase = publicationDbName
    agent.ReplicationType = ReplicationType.Merge

    ' Specify the partition information to generate a 
    ' filtered snapshot based on Hostname.
    agent.DynamicFilterHostName = hostname

    ' Start the agent synchronously.
    agent.GenerateSnapshot()
Catch ex As Exception
    ' Implement custom application error handling here.
    Throw New ApplicationException(String.Format( _
     "A snapshot could not be generated for the {0} publication." _
     , publicationName), ex)
End Try

[Top]

Voir aussi

Concepts

Filtres de lignes paramétrés

Concepts liés aux procédures stockées système de réplication

Instantanés des publications de fusion avec des filtres paramétrés

Méthodes préconisées en matière de sécurité de réplication