Créer un instantané d'une publication de fusion avec des filtres paramétrés
S’applique à :
SQL Server
Cette rubrique explique comment créer une instantané pour une publication de fusion avec des filtres paramétrables dans SQL Server à l’aide de SQL Server Management Studio, Transact-SQL ou Replication Management Objects (RMO).
Lorsque vous utilisez des filtres de lignes paramétrés dans les publications de fusion, la réplication initialise chaque abonnement avec un instantané en deux parties. Un instantané est d'abord créée. Il contient tous les objets nécessaires à la publication ainsi que le schéma des objets publiés mais pas les données. Ensuite, chaque abonnement est initialisé avec un instantané qui comprend les objets et le schéma provenant de l'instantané du schéma ainsi que les données appartenant à la partition de l'abonnement. Si plusieurs abonnements reçoivent une partition donnée (en d'autres termes, s'ils reçoivent les mêmes schéma et données), l'instantané de cette partition n'est créé qu'une seule fois ; plusieurs abonnements sont initialisés à l'aide du même instantané. Pour plus d'informations sur les filtres de lignes paramétrés, consultez Parameterized Row Filters.
Pour créer des instantanés de publication avec des filtres paramétrés, trois méthodes sont possibles :
Vous pouvez prégénérer des instantanés pour chaque partition. Cette option vous permet de contrôler le moment où les instantanés sont générés.
Vous pouvez également choisir d'actualiser les instantanés selon une planification définie. Les nouveaux Abonnés à une partition dont vous avez créé un instantané reçoivent un instantané à jour.Vous pouvez autoriser les Abonnés à demander la génération et l’application d’un instantané lors de leur première synchronisation. L’utilisation de cette option permet aux nouveaux Abonnés de se synchroniser sans nécessiter d’intervention d’un administrateur (SQL Server Agent doit s’exécuter sur le serveur de publication pour permettre à la instantané d’être générée).
Remarque
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 optez pour cette méthode, envisagez d'autoriser les Abonnées à initialiser la génération et la remise d'instantané. Pour plus d'informations sur les options de filtrage, consultez Parameterized Row Filters.
Vous pouvez générer manuellement un instantané pour chaque Abonné avec l’Agent d’instantané. L'Abonné doit alors fournir l'emplacement de l'instantané à l'Agent de fusion afin qu'il puisse extraire et appliquer l'instantané approprié.
Remarque
Cette option est prise en charge pour assurer la compatibilité descendante et n'autorise pas les partages d'instantanés FTP.
L'approche la plus souple est celle qui consiste à combiner les options d'instantané prégénéré et d'instantané demandé par l'Abonné : les instantanés sont prégénérés et actualisés à intervalles planifiés (généralement pendant les heures creuses), mais un Abonné peut générer son propre instantané en cas de création d'un abonnement nécessitant une nouvelle partition.
Considérez Adventure Works, qui a une force de travail mobile qui livre l’inventaire à des magasins individuels. Chaque commercial reçoit un abonnement basé sur son nom de connexion, lequel extrait les données relatives aux magasins dont le commercial est responsable. L'administrateur choisit de prégénérer des instantanés et de les actualiser tous les dimanches. De temps à autre, un nouvel utilisateur est ajouté au système et a besoin de données pour une partition dont il n'existe aucun instantané disponible. L'administrateur décide par ailleurs d'autoriser les instantanés initialisés par l'Abonné pour éviter que ce dernier se retrouve dans une situation où il est incapable de s'abonner à la publication car aucun instantané n'est disponible. Lorsque le nouvel Abonné se connecte pour la première fois, le instantané est généré pour la partition spécifiée et appliqué à l’Abonné (SQL Server Agent doit s’exécuter sur le serveur de publication pour autoriser la instantané à générer).
Pour créer un instantané d'une publication avec des filtres paramétrés, consultez Créer un instantané d'une publication de fusion avec des filtres paramétrés.
Paramètres de sécurité de l'Agent d'instantané
L'Agent d'instantané crée des instantanés de chaque partition. Pour les instantanés prégénérés et ceux demandés par un Abonné, l'Agent s'exécute et se connecte avec les informations d'identification spécifiées au moment de la création du travail de l'Agent d'instantané pour la publication (ce travail est créé par l'Assistant Nouvelle publication ou par sp_addpublication_snapshot). Pour modifier les informations d'identification, utilisez sp_changedynamicsnapshot_job. Pour plus d’informations, consultez sp_changedynamicinstantané_job (Transact-SQL).
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, voir Create and Apply the Initial Snapshot. 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 optez pour cette méthode, envisagez d'autoriser les Abonnées à initialiser la génération et la remise d'instantané.
Utilisation de SQL Server Management Studio
Générez des instantané pour les partitions sur la page Partitions de données de la boîte de dialogue Propriétés de publication - <Publication>. Pour plus d'informations sur l'accès à cette boîte de dialogue, consultez Afficher et modifier les propriétés d’un serveur de 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 :
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, voir Définir et modifier un filtre de lignes paramétrable pour un article de fusion.
Générez un instantané du schéma pour la publication. Par défaut, un instantané de schéma est généré lorsque vous terminez l’Assistant Nouvelle publication. Vous pouvez également générer un schéma instantané à partir de SQL Server Management Studio.
Pour générer un instantané du schéma
Connecter au serveur de publication dans Management Studio, puis développez le nœud du serveur.
Développez le dossier Réplication , puis le dossier Publications .
Cliquez avec le bouton droit sur la réplication pour laquelle vous souhaitez créer un instantané, puis cliquez sur Afficher l'état de l'Agent d'instantané.
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 comme celui-ci s'affiche : « [100 %] Un instantané de 17 article(s) a été généré ».
Pour permettre aux Abonnés d'initier la génération et la remise d'instantanés
Dans la page Partitions de données de la boîte de dialogue Propriétés de publication - <Publication>, sélectionnez Définir automatiquement une partition et générer une instantané si nécessaire lorsqu’un nouvel Abonné tente de se synchroniser.
Cliquez sur OK.
Pour générer et actualiser des instantanés
Dans la page Partitions de données de la boîte de dialogue Propriétés de publication - <Publication> , cliquez sur Ajouter.
Entrez une valeur pour la valeur HOST_NAME() et/ou SUSER_SNAME() associée à la partition pour laquelle vous voulez créer un instantané.
En option, spécifiez une planification pour l'actualisation des instantanés :
Sélectionnez Planifier l'Agent d'instantané pour l'exécution de cette partition à l'heure ou aux heures suivantes.
Acceptez la planification par défaut pour l'actualisation des instantanés, ou cliquez sur Modifier pour spécifier une autre planification.
Cliquez sur OK, qui vous renvoie à la boîte de dialogue Propriétés de publication - <Publication>.
Sélectionnez la partition dans la grille de propriétés, puis cliquez sur Générer les instantanés sélectionnés maintenant.
Cliquez sur OK.
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é.
Important
Lorsque c'est possible, demande aux utilisateurs de fournir les informations d'identification au moment de l'exécution. Si vous devez enregistrer les informations d'identification dans un fichier de script, vous devez sécuriser le fichier pour empêcher un 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
Sur le serveur de publication sur la base de données 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é.
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’Agentd’instantané de réplication s’exécute pour @job_login et @password. Si l’agent utilise l’authentification SQL Server lors de la connexion au serveur de publication, vous devez également spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion Microsoft SQL Server pour @publisher_login et @publisher_password. Il s'ensuit la création d'un travail de l'Agent d'instantané 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 Create and Apply the Initial Snapshot.
Important
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 des connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).
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, voir Définir et modifier un filtre de lignes paramétrable pour un article de fusion.
Si d’autres articles seront filtrés en fonction du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir les relations de jointure ou d’enregistrement logique 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, voir Définir et modifier un filtre de jointure entre des articles de fusion.
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
Exécutez sp_addmergepublication (Transact-SQL) pour créer la publication. Pour plus d’informations, voir Create a Publication.
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 utilise l’authentification SQL Server lors de la connexion au serveur de publication, vous devez également spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion SQL Server pour @publisher_login et @publisher_password. Il s'ensuit la création d'un travail de l'Agent d'instantané 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 Create and Apply the Initial Snapshot.
Important
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 des connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).
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, voir Définir et modifier un filtre de lignes paramétrable pour un article de fusion.
Si d’autres articles seront filtrés en fonction du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir les relations de jointure ou d’enregistrement logique 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, voir Définir et modifier un filtre de jointure entre des articles de fusion.
Sur le serveur de publication sur la base de données de publication, exécutez sp_helpmergepublication (Transact-SQL), en spécifiant la valeur de @publication de l’étape 1. Notez la valeur du snapshot_jobid dans le jeu de résultats.
Convertissez la valeur du snapshot_jobid obtenue à l'étape 5 en uniqueidentifier.
Sur le serveur de publication sur la base de données msdb , exécutez sp_start_job (Transact-SQL), en spécifiant la valeur convertie obtenue à l’étape 6 pour @job_id.
Sur le serveur de publication de la base de données de publication, exécutez sp_addmergepartition (Transact-SQL). Spécifiez le nom de la publication de 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.
Sur l’éditeur de la base de données de publication, exécutez sp_adddynamicinstantané_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 de instantané paramétré et sa partition de données associée, exécutez sp_dropdynamicinstantané_job (Transact-SQL).
Sur le serveur de publication sur la base de données de publication, exécutez sp_helpmergepartition (Transact-SQL), en spécifiant la valeur de @publication de l’étape 1 et la valeur de @suser_sname ou de @host_name de l’étape 8. Notez la valeur du dynamic_snapshot_jobid dans le jeu de résultats.
Sur le serveur de distribution sur la base de données msdb , 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é.
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
Exécutez sp_addmergepublication (Transact-SQL) pour créer la publication. Pour plus d’informations, voir Create a Publication.
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 utilise l’authentification SQL Server lors de la connexion au serveur de publication, vous devez également spécifier la valeur 0 pour @publisher_security_mode et les informations de connexion SQL Server pour @publisher_login et @publisher_password. Il s'ensuit la création d'un travail de l'Agent d'instantané 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 Create and Apply the Initial Snapshot.
Important
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 des connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).
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, voir Définir et modifier un filtre de lignes paramétrable pour un article de fusion.
Si d’autres articles seront filtrés en fonction du filtre de lignes paramétrable, exécutez sp_addmergefilter (Transact-SQL) pour définir les relations de jointure ou d’enregistrement logique 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, voir Définir et modifier un filtre de jointure entre des articles de fusion.
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, voir Create and Apply the Initial Snapshot.
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 : valeur si HOST_NAME (Transact-SQL) est utilisé.
-DynamicFilterLogin : valeur si SUSER_SNAME (Transact-SQL) est utilisé.
Répétez l'étape 6 pour générer un instantané partitionné pour chaque abonnement.
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'AdventureWorks2022';
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 [AdventureWorks2022];
-- Enable AdventureWorks2022 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 AdventureWorks2022.',
@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'AdventureWorks2022';
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 [AdventureWorks2022];
-- Enable AdventureWorks2022 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 AdventureWorks2022.',
@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'AdventureWorks2022';
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 [AdventureWorks2022];
-- Enable AdventureWorks2022 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 AdventureWorks2022.',
@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=AdventureWorks2022
SET PubName=AdvWorksSalesPersonMerge
"C:\Program Files\Microsoft SQL Server\120\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=AdventureWorks2022
SET PubName=AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando
MD %SnapshotDir%
"C:\Program Files\Microsoft SQL Server\120\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 = AdventureWorks2022
SET SubDB = AdventureWorks2022Replica
SET PubName = AdvWorksSalesPersonMerge
SET SnapshotDir=\\%DistPub%\repldata\unc\fernando
"C:\Program Files\Microsoft SQL Server\120\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
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 F:Microsoft.SqlServer.Replication.PartitionOptions.NonOverlappingSingleSubscription pour P:Microsoft.SqlServer.Replication.MergeArticle.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 Parameterized Row Filters.
Important
Lorsque c'est possible, demande aux utilisateurs de fournir les informations d'identification 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
Créez une connexion au serveur de publication en utilisant la classe ServerConnection .
Créez une instance de la classe ReplicationDatabase pour la base de données de publication, affectez à la propriété ConnectionContext l'instance de ServerConnection créée à l'étape 1, puis appelez la méthode LoadProperties . If LoadProperties retourne false, confirmez que la base de données existe.
If EnabledMergePublishing a la valeur false, affectez-lui la valeur true et appelez CommitPropertyChanges.
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.
Le nom de 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 OR logique de bits (| dans Visual C# et Or dans Visual Basic) pour ajouter la valeur AllowSubscriberInitiatedSnapshot à Attributes.
Password Champs Login et informations d’identification SnapshotGenerationAgentProcessSecurity 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, voir Replication Agent Security Model.
Appelez la méthode Create pour créer la publication.
Important
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 des connexions chiffrées dans le moteur de base de données (Gestionnaire de configuration SQL Server).
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.
Si SnapshotAgentExists a la valeur false, appelez CreateSnapshotAgent pour créer le travail de l'Agent d'instantané initial pour cette publication.
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 Create and Apply the Initial Snapshot.
(Facultatif) Cherchez une valeur true pour la propriété SnapshotAvailable afin de déterminer quand l'instantané initial est prêt à être utilisé.
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
Utilisez une instance de la classe MergePublication pour définir une publication de fusion. Pour plus d’informations, voir Create a Publication.
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.
Si SnapshotAgentExists a la valeur false, appelez CreateSnapshotAgent pour créer le travail de l'Agent d'instantané pour cette publication.
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.
Cherchez une valeur true pour la propriété SnapshotAvailable afin de déterminer quand l'instantané initial est prêt à être utilisé.
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 d’une surcharge de cette fonction, utilisez DynamicFilterHostName.
Créez une instance de la classe MergeDynamicSnapshotJob et définissez la même propriété qu'à l'étape 6.
Utilisez la classe ReplicationAgentSchedule pour définir une planification pour générer l'instantané filtré pour la partition de l'Abonné.
Utilisez l'instance de MergePublication de l'étape 1 pour appeler AddMergePartition. Passez l'objet MergePartition créé à l'étape 6.
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.
Appelez EnumMergeDynamicSnapshotJobset localisez l'objet MergeDynamicSnapshotJob correspondant au travail d'instantané partitionné nouvellement ajouté dans le tableau retourné.
Obtenez la propriété Name pour le travail.
Créez une connexion au serveur de distribution en utilisant la classe ServerConnection .
Créez une instance de la classe Server SMO (SQL Server Management Objects), en passant l'objet ServerConnection créé à l'étape 13.
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.
Appelez la méthode Start pour démarrer le travail d'instantané partitionné.
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
Utilisez une instance de la classe MergePublication pour définir une publication de fusion. Pour plus d’informations, voir Create a Publication.
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.
Générez l'instantané initial. Pour plus d’informations, voir Create and Apply the Initial Snapshot.
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 – valeur Integrated pour utiliser l'authentification intégrée de Windows ou valeur Standard pour utiliser l'authentification SQL Server.
DistributorSecurityMode – valeur Integrated pour utiliser l'authentification intégrée de Windows ou valeur Standard pour utiliser l'authentification SQL Server.
Spécifiez la valeur Merge pour ReplicationType.
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 d’une surcharge de cette fonction, utilisez DynamicFilterHostName.
Appelez la méthode GenerateSnapshot .
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 = "AdventureWorks2022";
ReplicationDatabase publicationDb;
MergePublication publication;
// Create a connection to the Publisher.
ServerConnection conn = new ServerConnection(publisherName);
try
{
// Connect to the Publisher.
conn.Connect();
// Enable the database for merge publication.
publicationDb = new ReplicationDatabase(publicationDbName, conn);
if (publicationDb.LoadProperties())
{
if (!publicationDb.EnabledMergePublishing)
{
publicationDb.EnabledMergePublishing = true;
}
}
else
{
// Do something here if the database does not exist.
throw new ApplicationException(String.Format(
"The {0} database does not exist on {1}.",
publicationDb, publisherName));
}
// Set the required properties for the merge publication.
publication = new MergePublication();
publication.ConnectionContext = conn;
publication.Name = publicationName;
publication.DatabaseName = publicationDbName;
// Enable precomputed partitions.
publication.PartitionGroupsOption = PartitionGroupsOption.True;
// Specify the Windows account under which the Snapshot Agent job runs.
// This account will be used for the local connection to the
// Distributor and all agent connections that use Windows Authentication.
publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin;
publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword;
// Explicitly set the security mode for the Publisher connection
// Windows Authentication (the default).
publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = true;
// Enable Subscribers to request snapshot generation and filtering.
publication.Attributes |= PublicationAttributes.AllowSubscriberInitiatedSnapshot;
publication.Attributes |= PublicationAttributes.DynamicFilters;
// Enable pull and push subscriptions.
publication.Attributes |= PublicationAttributes.AllowPull;
publication.Attributes |= PublicationAttributes.AllowPush;
if (!publication.IsExistingObject)
{
// Create the merge publication.
publication.Create();
// Create a Snapshot Agent job for the publication.
publication.CreateSnapshotAgent();
}
else
{
throw new ApplicationException(String.Format(
"The {0} publication already exists.", publicationName));
}
}
catch (Exception ex)
{
// Implement custom application error handling here.
throw new ApplicationException(String.Format(
"The publication {0} could not be created.", publicationName), ex);
}
finally
{
conn.Disconnect();
}
' Set the Publisher, publication database, and publication names.
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"
Dim publicationDb As ReplicationDatabase
Dim publication As MergePublication
' Create a connection to the Publisher.
Dim conn As ServerConnection = New ServerConnection(publisherName)
Try
' Connect to the Publisher.
conn.Connect()
' Enable the database for merge publication.
publicationDb = New ReplicationDatabase(publicationDbName, conn)
If publicationDb.LoadProperties() Then
If Not publicationDb.EnabledMergePublishing Then
publicationDb.EnabledMergePublishing = True
End If
Else
' Do something here if the database does not exist.
Throw New ApplicationException(String.Format( _
"The {0} database does not exist on {1}.", _
publicationDb, publisherName))
End If
' Set the required properties for the merge publication.
publication = New MergePublication()
publication.ConnectionContext = conn
publication.Name = publicationName
publication.DatabaseName = publicationDbName
' Enable precomputed partitions.
publication.PartitionGroupsOption = PartitionGroupsOption.True
' Specify the Windows account under which the Snapshot Agent job runs.
' This account will be used for the local connection to the
' Distributor and all agent connections that use Windows Authentication.
publication.SnapshotGenerationAgentProcessSecurity.Login = winLogin
publication.SnapshotGenerationAgentProcessSecurity.Password = winPassword
' Explicitly set the security mode for the Publisher connection
' Windows Authentication (the default).
publication.SnapshotGenerationAgentPublisherSecurity.WindowsAuthentication = True
' Enable Subscribers to request snapshot generation and filtering.
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowSubscriberInitiatedSnapshot
publication.Attributes = publication.Attributes Or _
PublicationAttributes.DynamicFilters
' Enable pull and push subscriptions
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowPull
publication.Attributes = publication.Attributes Or _
PublicationAttributes.AllowPush
If Not publication.IsExistingObject Then
' Create the merge publication.
publication.Create()
' Create a Snapshot Agent job for the publication.
publication.CreateSnapshotAgent()
Else
Throw New ApplicationException(String.Format( _
"The {0} publication already exists.", publicationName))
End If
Catch ex As Exception
' Implement custom application error handling here.
Throw New ApplicationException(String.Format( _
"The publication {0} could not be created.", publicationName), ex)
Finally
conn.Disconnect()
End Try
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 = "AdventureWorks2022";
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 = "AdventureWorks2022"
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 = "AdventureWorks2022";
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 = "AdventureWorks2022"
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
Voir aussi
Filtres de lignes paramétrés
Concepts liés aux procédures stockées système de réplication
Bonnes pratiques en matière de sécurité de la réplication
Commentaires
Bientôt disponible : Tout au long de 2024, nous allons supprimer progressivement GitHub Issues comme mécanisme de commentaires pour le contenu et le remplacer par un nouveau système de commentaires. Pour plus d’informations, consultez https://aka.ms/ContentUserFeedback.
Envoyer et afficher des commentaires pour