Creazione di uno snapshot per una pubblicazione di tipo merge con filtri con parametri
Si applica a:
SQL Server
In questo argomento viene descritto come creare uno snapshot per una pubblicazione di tipo merge con i filtri con parametri in SQL Server tramite SQL Server Management Studio, Transact-SQL o Replication Management Objects (RMO).
Quando si utilizzano filtri di riga con parametri nelle pubblicazioni di tipo merge, ogni sottoscrizione con uno snapshot in due parti viene inizializzata dalla replica. Viene innanzitutto creato uno snapshot dello schema contenente tutti gli oggetti necessari alla replica e lo schema degli oggetti pubblicati, ma non i dati. Ogni sottoscrizione viene quindi inizializzata con uno snapshot che include gli oggetti e lo schema dello snapshot dello schema e i dati appartenenti alla partizione della sottoscrizione. Se più di una sottoscrizione riceve una determinata partizione, ovvero riceve lo stesso schema e gli stessi dati, lo snapshot di tale partizione viene creato una sola volta. Dallo stesso snapshot vengono inizializzate più sottoscrizioni. Per ulteriori informazioni sui filtri di riga con parametri, vedere Filtri di riga con parametri.
È possibile creare snapshot per pubblicazioni con filtri con parametri in tre modi diversi:
Pregenerare uno snapshot per ogni partizione. Questa opzione consente di controllare il momento in cui vengono generati gli snapshot.
È inoltre possibile aggiornare gli snapshot in base a una pianificazione. I nuovi Sottoscrittori che sottoscrivono una partizione per cui è stato creato uno snapshot riceveranno uno snapshot aggiornato.Consentire ai Sottoscrittori di richiedere la generazione e l'applicazione dello snapshot alla prima sincronizzazione. Questa opzione consente ai nuovi Sottoscrittori di eseguire la sincronizzazione senza l'intervento di un amministratore. Per consentire la generazione dello snapshot, è necessario che SQL Server Agent sia in esecuzione nel server di pubblicazione.
Nota
Se il filtro di uno o più articoli nella pubblicazione restituisce partizioni non sovrapposte univoche per ogni sottoscrizione, i metadati vengono eliminati a ogni esecuzione dell'agente di merge. Lo snapshot partizionato scade quindi più rapidamente. Quando si utilizza questa opzione, è consigliabile consentire ai Sottoscrittori di inizializzare la generazione e il recapito dello snapshot. Per ulteriori informazioni sulle opzioni di filtro, vedere Filtri di riga con parametri.
Generare manualmente uno snapshot per ogni Sottoscrittore con l'agente di snapshot. Il Sottoscrittore deve quindi indicare il percorso dello snapshot all'agente di merge, in modo che sia possibile recuperare e applicare lo snapshot corretto.
Nota
Questa opzione è supportata per garantire la compatibilità con le versioni precedenti e non consente le condivisioni snapshot FTP.
Il metodo più flessibile consiste nell'utilizzo di una combinazione di opzioni snapshot pregenerate e richieste dal Sottoscrittore: gli snapshot vengono pregenerati e aggiornati in base a una pianificazione, in genere durante i periodi di minore attività, ma un Sottoscrittore può generare il proprio snapshot nel caso in cui venga creata una sottoscrizione per cui è necessaria una nuova partizione.
Considerare Adventure Works, che dispone di forza lavoro mobile per la distribuzione delle scorte ai singoli negozi. Ogni venditore riceve una sottoscrizione basata sul proprio account di accesso, che consente di recuperare i dati relativi ai negozi serviti. L'amministratore decide di pregenerare gli snapshot e di aggiornarli ogni domenica. Occasionalmente viene aggiunto al sistema un nuovo utente per il quale sono necessari i dati per una partizione per cui non è disponibile alcuno snapshot. L'amministratore decide inoltre di consentire gli snapshot inizializzati dal Sottoscrittore, per evitare che si verifichi una situazione in cui un Sottoscrittore non può sottoscrivere la pubblicazione in quanto lo snapshot non è ancora disponibile. Quando il nuovo Sottoscrittore effettua la prima connessione, lo snapshot per la partizione specificata viene generato e viene applicato al Sottoscrittore. Per consentire la generazione dello snapshot, è necessario che SQL Server Agent sia in esecuzione nel server di pubblicazione.
Per creare uno snapshot per una pubblicazione con filtri con parametri, vedere Creazione di uno snapshot per una pubblicazione di tipo merge con filtri con parametri.
Impostazioni di sicurezza per l'agente snapshot
L'agente snapshot crea gli snapshot per ogni partizione. Per gli snapshot pregenerati e per quelli richiesti da un Sottoscrittore, viene eseguito l'agente e vengono effettuate le connessioni con le credenziali specificate al momento della creazione del processo dell'agente snapshot. Tale processo viene creato tramite la Creazione guidata nuova pubblicazione o sp_addpublication_snapshot. Per modificare le credenziali, utilizzare sp_changedynamicsnapshot_job. Per altre informazioni, vedere sp_changedynamicsnapshot_job (Transact-SQL).
Consigli
Quando si genera uno snapshot per una pubblicazione di tipo merge utilizzando filtri con parametri, è necessario innanzitutto generare uno snapshot (schema) standard che contiene tutti i dati pubblicati e i metadati del Sottoscrittore per la sottoscrizione. Per altre informazioni, vedere Creazione e applicazione dello snapshot iniziale. Dopo aver creato lo snapshot dello schema, è possibile generare lo snapshot che contiene la partizione dei dati pubblicati specifica del Sottoscrittore.
Se il filtro di uno o più articoli nella pubblicazione restituisce partizioni non sovrapposte univoche per ogni sottoscrizione, i metadati vengono eliminati a ogni esecuzione dell'agente di merge. Lo snapshot partizionato scade quindi più rapidamente. Quando si utilizza questa opzione, è consigliabile consentire ai Sottoscrittori di inizializzare la generazione e il recapito dello snapshot.
Utilizzo di SQL Server Management Studio
Generare snapshot per le partizioni nella pagina Partizioni dati della finestra di dialogo Proprietà pubblicazione - <Pubblicazione>. Per ulteriori informazioni sull'accesso a questa finestra di dialogo, vedere View and Modify Publication Properties. È possibile consentire ai Sottoscrittori di avviare la generazione e il recapito degli snapshot e/o di generare snapshot.
Prima di generare gli snapshot per una o più partizioni, è necessario:
Creare una pubblicazione di tipo merge mediante Creazione guidata nuova pubblicazione e specificare uno o più filtri di righe con parametri nella pagina Aggiungi filtro della procedura guidata. Per altre informazioni, vedere Definizione e modifica di un filtro di riga con parametri per un articolo di merge.
Generare uno snapshot dello schema per la pubblicazione. Per impostazione predefinita, lo snapshot dello schema viene generato quando si completa la Creazione guidata nuova pubblicazione, ma è possibile generarne uno anche mediante SQL Server Management Studio.
Per generare uno snapshot dello schema
Esegui la connessione al server di pubblicazione in Management Studio e poi espandi il nodo server.
Espandere la cartella Replica e quindi la cartella Pubblicazioni .
Fare clic con il pulsante destro del mouse sulla pubblicazione per la quale si desidera creare uno snapshot, quindi scegliere Visualizza stato agente snapshot.
Nella finestra di dialogo Visualizza stato agente snapshot - <Pubblicazione> fare clic su Avvia.
Al termine della generazione dello snapshot, verrà visualizzato un messaggio del tipo "[100%] Generato uno snapshot di 17 articoli."
Per consentire ai Sottoscrittori di avviare la generazione e il recapito di snapshot
Nella pagina Partizioni dati della finestra di dialogo Proprietà pubblicazione - <Pubblicazione> selezionare Definisci automaticamente una partizione e genera uno snapshot, se necessario, quando un nuovo Sottoscrittore cerca di eseguire la sincronizzazione.
Seleziona OK.
Per generare e aggiornare gli snapshot
Nella pagina Partizioni dati della finestra di dialogo Proprietà pubblicazione - <Pubblicazione> fare clic su Aggiungi.
Immettere un valore per le funzioni HOST_NAME() e/o SUSER_SNAME() associate alla partizione per cui si desidera creare uno snapshot.
Facoltativamente, specificare una pianificazione per l'aggiornamento degli snapshot:
Selezionare Usa la pianificazione seguente per l'esecuzione dell'agente snapshot per questa partizione.
Accettare la pianificazione predefinita per l'aggiornamento degli snapshot oppure fare clic su Cambia per specificare una pianificazione diversa.
Facendo clic su OK si torna alla finestra di dialogo Proprietà pubblicazione - <Pubblicazione>.
Selezionare la partizione nella griglia delle proprietà e quindi fare clic su Genera gli snapshot selezionati adesso.
Seleziona OK.
Utilizzo di Transact-SQL
L'utilizzo di stored procedure e dell'agente snapshot consente di eseguire le attività indicate di seguito:
Consentire ai Sottoscrittori di richiedere la generazione e l'applicazione dello snapshot alla prima sincronizzazione.
Pregenerare uno snapshot per ogni partizione.
Generare manualmente uno snapshot per ciascun Sottoscrittore.
Importante
Se possibile, richiedere agli utenti di immettere le credenziali di sicurezza in fase di esecuzione. Se è necessario archiviare le credenziali in un file script, è fondamentale proteggere il file per evitare accessi non autorizzati.
Per creare una pubblicazione che consente ai Sottoscrittori di avviare la generazione e il recapito di snapshot
Nel database di pubblicazione del server di pubblicazione eseguire sp_addmergepublication (Transact-SQL). Specificare i seguenti parametri:
Il nome della pubblicazione per @publication.
Il valore true per @allow_subscriber_initiated_snapshot, che consente ai Sottoscrittori di avviare il processo di snapshot.
(Facoltativo) Il numero di processi di snapshot dinamici che è possibile eseguire simultaneamente per @max_concurrent_dynamic_snapshots. Se è in esecuzione il numero massimo di processi e un Sottoscrittore tenta di generare uno snapshot, il processo verrà inserito in una coda. Per impostazione predefinita, non esiste nessun limite per il numero di processi simultanei.
Nel server di pubblicazione eseguire sp_addpublication_snapshot (Transact-SQL). Specificare il nome della pubblicazione utilizzato al passaggio 1 per @publication e le credenziali di Microsoft Windows utilizzate per l'agente di snapshot di replica per @job_login e @password. Se l'agente utilizza l'autenticazione di SQL Server per la connessione al server di pubblicazione, è inoltre necessario specificare il valore 0 per @publisher_security_mode e le informazioni sull'account di accesso di Microsoft SQL Server per @publisher_login e @publisher_password. Verrà creato un processo dell'agente snapshot per la pubblicazione. Per ulteriori informazioni sulla generazione di uno snapshot iniziale e sulla definizione di una pianificazione personalizzata per l'agente snapshot, vedere Create and Apply the Initial Snapshot.
Importante
Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutti i parametri, inclusi job_login e job_password, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di eseguire questa stored procedure. Per altre informazioni, vedere Abilitare le connessioni crittografate al motore di database (Gestione configurazione SQL Server).
Per aggiungere articoli alla pubblicazione, eseguire sp_addmergearticle (Transact-SQL). Questa stored procedure deve essere eseguita una sola volta per ogni articolo della pubblicazione. Quando si utilizzano filtri con parametri, è necessario specificare un filtro di riga con parametri per uno o più articoli utilizzando il parametro @subset_filterclause . Per altre informazioni, vedere Definizione e modifica di un filtro di riga con parametri per un articolo di merge.
Se il filtro di riga con parametri verrà usato per filtrare altri articoli, eseguire sp_addmergefilter (Transact-SQL) per definire le relazioni di join o tra record logici tra gli articoli. Questa stored procedure deve essere eseguita una sola volta per ogni relazione da definire. Per altre informazioni, vedere Definizione e modifica di un filtro di join tra articoli di merge.
Quando l'agente di merge richiede che il Sottoscrittore venga inizializzato dallo snapshot, lo snapshot relativo alla partizione della sottoscrizione che ha eseguito la richiesta viene generato automaticamente.
Per creare una pubblicazione e pregenerare o aggiornare automaticamente gli snapshot
Eseguire sp_addmergepublication (Transact-SQL) per creare la pubblicazione. Per altre informazioni, vedere Create a Publication.
Nel server di pubblicazione eseguire sp_addpublication_snapshot (Transact-SQL). Specificare il nome della pubblicazione utilizzato al passaggio 1 per @publication e le credenziali di Windows utilizzate per l'agente snapshot per @job_login e @password. Se l'agente utilizza l'autenticazione di SQL Server per la connessione al server di pubblicazione, è inoltre necessario specificare il valore 0 per @publisher_security_mode e le informazioni sull'account di accesso di SQL Server per @publisher_login e @publisher_password. Verrà creato un processo dell'agente snapshot per la pubblicazione. Per ulteriori informazioni sulla generazione di uno snapshot iniziale e sulla definizione di una pianificazione personalizzata per l'agente snapshot, vedere Create and Apply the Initial Snapshot.
Importante
Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutti i parametri, inclusi job_login e job_password, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di eseguire questa stored procedure. Per altre informazioni, vedere Abilitare le connessioni crittografate al motore di database (Gestione configurazione SQL Server).
Per aggiungere articoli alla pubblicazione, eseguire sp_addmergearticle (Transact-SQL). Questa stored procedure deve essere eseguita una sola volta per ogni articolo della pubblicazione. Quando si utilizzano filtri con parametri, è necessario specificare un filtro di riga con parametri per un articolo utilizzando il parametro @subset_filterclause . Per altre informazioni, vedere Definizione e modifica di un filtro di riga con parametri per un articolo di merge.
Se il filtro di riga con parametri verrà usato per filtrare altri articoli, eseguire sp_addmergefilter (Transact-SQL) per definire le relazioni di join o tra record logici tra gli articoli. Questa stored procedure deve essere eseguita una sola volta per ogni relazione da definire. Per altre informazioni, vedere Definizione e modifica di un filtro di join tra articoli di merge.
Nel database di pubblicazione del server di pubblicazione eseguire sp_helpmergepublication (Transact-SQL), specificando il valore publication dal passaggio 1. Si noti il valore di snapshot_jobid nel set di risultati.
Convertire il valore di snapshot_jobid ottenuto al passaggio 5 in uniqueidentifier.
Nel database msdb del server di pubblicazione eseguire sp_start_job (Transact-SQL) specificando il valore convertito ottenuto nel passaggio 6 per @job_id.
Nel database di pubblicazione del server di pubblicazione eseguire sp_addmergepartition (Transact-SQL). Specificare il nome della pubblicazione ottenuto nel passaggio 1 per @publication e il valore usato per definire la partizione per @suser_sname se si usa SUSER_SNAME (Transact-SQL) nella clausola di filtro oppure per @host_name se si usa HOST_NAME (Transact-SQL) nella clausola di filtro.
Nel database di pubblicazione del server di pubblicazione eseguire sp_adddynamicsnapshot_job (Transact-SQL). Specificare il nome della pubblicazione ottenuto al passaggio 1 per @publication, il valore di @suser_sname o @host_name ottenuto al passaggio 8 e una pianificazione per il processo. In tal modo verrà creato il processo che genera lo snapshot con parametri per la partizione specificata. Per altre informazioni, vedere Specify Synchronization Schedules.
Nota
Per l'esecuzione di questo processo viene utilizzato lo stesso account di Windows del processo snapshot iniziale definito al passaggio 2. Per rimuovere il processo snapshot con parametri e la partizione dati correlata, eseguire sp_dropdynamicsnapshot_job (Transact-SQL).
Nel database di pubblicazione del server di pubblicazione eseguire sp_helpmergepartition (Transact-SQL), specificando il valore di @publication ottenuto nel passaggio 1 e il valore di @suser_sname o @host_name dal passaggio 8. Si noti il valore di snapshot job nel set di risultati.
Nel database msdb del server di distribuzione eseguire sp_start_job (Transact-SQL) specificando il valore ottenuto nel passaggio 9 per @job_id. In tal modo verrà avviato il processo snapshot con parametri per la partizione.
Ripetere i passaggi da 8 a 11 per generare uno snapshot partizionato per ogni sottoscrizione.
Per creare una pubblicazione e creare manualmente gli snapshot per ogni partizione
Eseguire sp_addmergepublication (Transact-SQL) per creare la pubblicazione. Per altre informazioni, vedere Create a Publication.
Nel server di pubblicazione eseguire sp_addpublication_snapshot (Transact-SQL). Specificare il nome della pubblicazione utilizzato al passaggio 1 per @publication e le credenziali di Windows utilizzate per l'agente snapshot per @job_login e @password. Se l'agente utilizza l'autenticazione di SQL Server per la connessione al server di pubblicazione, è inoltre necessario specificare il valore 0 per @publisher_security_mode e le informazioni sull'account di accesso di SQL Server per @publisher_login e @publisher_password. Verrà creato un processo dell'agente snapshot per la pubblicazione. Per ulteriori informazioni sulla generazione di uno snapshot iniziale e sulla definizione di una pianificazione personalizzata per l'agente snapshot, vedere Create and Apply the Initial Snapshot.
Importante
Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutti i parametri, inclusi job_login e job_password, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di eseguire questa stored procedure. Per altre informazioni, vedere Abilitare le connessioni crittografate al motore di database (Gestione configurazione SQL Server).
Per aggiungere articoli alla pubblicazione, eseguire sp_addmergearticle (Transact-SQL). Questa stored procedure deve essere eseguita una sola volta per ogni articolo della pubblicazione. Quando si utilizzano filtri con parametri, è necessario specificare un filtro di riga con parametri per almeno un articolo utilizzando il parametro @subset_filterclause . Per altre informazioni, vedere Definizione e modifica di un filtro di riga con parametri per un articolo di merge.
Se il filtro di riga con parametri verrà usato per filtrare altri articoli, eseguire sp_addmergefilter (Transact-SQL) per definire le relazioni di join o tra record logici tra gli articoli. Questa stored procedure deve essere eseguita una sola volta per ogni relazione da definire. Per altre informazioni, vedere Definizione e modifica di un filtro di join tra articoli di merge.
Avviare il processo snapshot o eseguire Agente snapshot repliche dal prompt dei comandi per generare lo schema standard dello snapshot standard e gli altri file. Per altre informazioni, vedere Creazione e applicazione dello snapshot iniziale.
Eseguire nuovamente Agente snapshot repliche dal prompt dei comandi per generare file della copia bulk (estensione bcp), specificando il percorso dello snapshot partizionato per - DynamicSnapshotLocation e una o entrambe le proprietà seguenti che definiscono la partizione:
-DynamicFilterHostName - valore se viene usato HOST_NAME (Transact-SQL).
-DynamicFilterLogin - valore se viene usato SUSER_SNAME (Transact-SQL).
Ripetere il passaggio 6 per generare uno snapshot partizionato per ogni sottoscrizione.
Eseguire l'agente di merge per consentire a ogni sottoscrizione di applicare lo snapshot partizionato iniziale ai Sottoscrittori, specificando le proprietà seguenti:
-Hostname : valore utilizzato per definire la partizione se viene eseguito l'override del valore effettivo di HOST_NAME.
-DynamicSnapshotLocation : percorso dello snapshot dinamico per questa partizione.
Nota
Per altre informazioni sulla programmazione degli agenti di replica, vedere Concetti di base relativi ai file eseguibili dell'agente di replica.
Esempi (Transact-SQL)
In questo esempio viene creata una pubblicazione di tipo merge con filtri con parametri in cui i Sottoscrittori avviano il processo di generazione dello snapshot. Per passare i valori di @job_login e @job_password , vengono utilizzate variabili di scripting.
-- 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
In questo esempio viene creata una pubblicazione utilizzando un filtro con parametri in cui la partizione di ogni Sottoscrittore viene definita eseguendo sp_addmergepartition e il processo snapshot con filtro viene creato eseguendo sp_adddynamicsnapshot_job passando le informazioni sul partizionamento. Per passare i valori di @job_login e @job_password , vengono utilizzate variabili di scripting.
-- 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
In questo esempio viene creata una pubblicazione utilizzando un filtro con parametri in cui il Sottoscrittore deve disporre di una propria partizione dati e il processo snapshot con filtro viene creato fornendo le informazioni sul partizionamento. Un Sottoscrittore fornisce le informazioni sul partizionamento utilizzando i parametri della riga di comando durante l'esecuzione manuale degli agenti di replica. In questo esempio si presuppone che sia stata creata anche una sottoscrizione della pubblicazione.
-- 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
Utilizzo di RMO (Replication Management Objects)
È possibile utilizzare oggetti RMO (Replication Management Objects) per generare snapshot partizionati a livello di programmazione nelle modalità seguenti:
Consentire ai Sottoscrittori di richiedere la generazione e l'applicazione dello snapshot alla prima sincronizzazione.
Pregenerare uno snapshot per ogni partizione.
Generare manualmente uno snapshot per ogni Sottoscrittore eseguendo l'agente snapshot.
Nota
Quando il filtro di un articolo produce partizioni non sovrapposte univoche per ogni sottoscrizione (specificando un valore F:Microsoft.SqlServer.Replication.PartitionOptions.NonOverlappingSingleSubscription per P:Microsoft.SqlServer.Replication.MergeArticle.PartitionOption nel caso della creazione di un articolo di tipo merge), i metadati vengono puliti ogni volta che viene eseguito l'agente di merge. Lo snapshot partizionato scade quindi più rapidamente. Quando si utilizza questa opzione, è consigliabile consentire ai Sottoscrittori di richiedere la generazione degli snapshot. Per ulteriori informazioni, vedere la sezione relativa all'utilizzo delle opzioni di filtro appropriate nell'argomento Parameterized Row Filters.
Importante
Se possibile, richiedere agli utenti di immettere le credenziali di sicurezza in fase di esecuzione. Se devi archiviare le credenziali, utilizza i servizi di crittografia offerti da Microsoft Windows .NET Framework.
Per creare una pubblicazione che consente ai Sottoscrittori di avviare la generazione e il recapito di snapshot
Creare una connessione al server di pubblicazione tramite la classe ServerConnection .
Creare un'istanza della classe ReplicationDatabase per il database di pubblicazione, impostare la proprietà ConnectionContext sull'istanza di ServerConnection del passaggio 1, quindi chiamare il metodo LoadProperties . If LoadProperties restituisce false, verificare che il database esista.
If EnabledMergePublishing è false, impostarla su true e chiamare CommitPropertyChanges.
Creare un'istanza della classe MergePublication e impostare le proprietà seguenti per questo oggetto:
Oggetto ServerConnection indicato nel passaggio 1 per ConnectionContext.
Nome del database pubblicato per DatabaseName.
Nome per la pubblicazione per Name.
Numero massimo di processi di snapshot dinamici da eseguire per MaxConcurrentDynamicSnapshots. Poiché le richieste di snapshot avviate dal Sottoscrittore possono verificarsi in qualsiasi momento, questa proprietà limita il numero di processi dell'agente snapshot che possono essere eseguiti simultaneamente quando più Sottoscrittori richiedono il rispettivo snapshot partizionato contemporaneamente. Quando è in esecuzione il numero massimo di processi, le richieste aggiuntive di snapshot partizionati vengono inserite nella coda fino al completamento di uno dei processi.
Utilizzare l'operatore logico OR bit per bit (| in Visual C# e Or in Visual Basic) per aggiungere il valore AllowSubscriberInitiatedSnapshot a Attributes.
Campi Login e Password di SnapshotGenerationAgentProcessSecurity per fornire le credenziali per l'account di Microsoft Windows con cui verrà eseguito il processo dell'agente snapshot.
Nota
È consigliabile impostare SnapshotGenerationAgentProcessSecurity quando la pubblicazione viene creata da un membro del ruolo predefinito del server sysadmin . Per altre informazioni, vedere Modello di sicurezza dell'agente di replica.
Chiamare il metodo Create per creare la pubblicazione.
Importante
Quando si configura un server di pubblicazione con un server di distribuzione remoto, i valori specificati per tutte le proprietà, inclusa SnapshotGenerationAgentProcessSecurity, vengono inviati al server di distribuzione come testo normale. È consigliabile crittografare la connessione tra il server di pubblicazione e il server di distribuzione remoto prima di chiamare il metodo Create. Per altre informazioni, vedere Abilitare le connessioni crittografate al motore di database (Gestione configurazione SQL Server).
Utilizzare la proprietà MergeArticle per aggiungere articoli alla pubblicazione. Specificare la proprietà FilterClause per almeno un articolo che definisce il filtro con parametri. (Facoltativo) Creare oggetti MergeJoinFilter che definiscono i filtri join tra gli articoli. Per altre informazioni, vedere definire un articolo.
Se il valore di SnapshotAgentExists è false, chiamare CreateSnapshotAgent per creare il processo dell'agente snapshot iniziale per questa pubblicazione.
Chiamare il metodo StartSnapshotGenerationAgentJob dell'oggetto MergePublication creato nel passaggio 4. In questo modo viene avviato il processo dell'agente che genera lo snapshot iniziale. Per ulteriori informazioni sulla generazione di uno snapshot iniziale e sulla definizione di una pianificazione personalizzata per l'agente snapshot, vedere Create and Apply the Initial Snapshot.
(Facoltativo) Verificare la presenza di un valore true per la proprietà SnapshotAvailable per determinare quando lo snapshot iniziale è pronto per l'utilizzo.
La prima volta che l'agente di merge per un Sottoscrittore si connette, verrà generato automaticamente uno snapshot partizionato.
Per creare una pubblicazione e pregenerare o aggiornare automaticamente gli snapshot
Utilizzare un'istanza della classe MergePublication per definire una pubblicazione di tipo merge. Per altre informazioni, vedere Create a Publication.
Utilizzare la proprietà MergeArticle per aggiungere articoli alla pubblicazione. Specificare la proprietà FilterClause per almeno un articolo che definisce il filtro con parametri, quindi creare eventuali oggetti MergeJoinFilter che definiscono filtri join tra gli articoli. Per altre informazioni, vedere definire un articolo.
Se il valore di SnapshotAgentExists è false, chiamare CreateSnapshotAgent per creare il processo dell'agente snapshot per questa pubblicazione.
Chiamare il metodo StartSnapshotGenerationAgentJob dell'oggetto MergePublication creato nel passaggio 1. Questo metodo avvia il processo dell'agente che genera lo snapshot iniziale. Per ulteriori informazioni sulla generazione di uno snapshot iniziale e sulla definizione di una pianificazione personalizzata per l'agente snapshot, vedere Creazione e applicazione dello snapshot iniziale.
(Facoltativo) Verificare la presenza di un valore true per la proprietà SnapshotAvailable per determinare quando lo snapshot iniziale è pronto per l'utilizzo.
Creare un'istanza della classe MergePartition e impostare i criteri di filtro con parametri per il Sottoscrittore utilizzando una o entrambe le proprietà seguenti:
Se la partizione del Sottoscrittore è definita dal risultato di SUSER_SNAME (Transact-SQL), usare DynamicFilterLogin.
Se la partizione del Sottoscrittore è definita dal risultato di HOST_NAME (Transact-SQL) o da un overload di questa funzione, usare DynamicFilterHostName.
Creare un'istanza della classe MergeDynamicSnapshotJob e impostare la stessa proprietà indicata nel passaggio 6.
Utilizzare la classe ReplicationAgentSchedule per definire una pianificazione per la generazione dello snapshot filtrato per la partizione del Sottoscrittore.
Utilizzando l'istanza di MergePublication indicata nel passaggio 1, chiamare AddMergePartition. Passare l'oggetto MergePartition indicato nel passaggio 6.
Utilizzando l'istanza di MergePublication indicata nel passaggio 1, chiamare il metodo AddMergeDynamicSnapshotJob . Passare l'oggetto MergeDynamicSnapshotJob indicato nel passaggio 7 e l'oggetto ReplicationAgentSchedule indicato nel passaggio 8.
Chiamare EnumMergeDynamicSnapshotJobse individuare l'oggetto MergeDynamicSnapshotJob per il processo di snapshot partizionato appena aggiunto nella matrice restituita.
Ottenere la proprietà Name per il processo.
Creare una connessione al server di distribuzione tramite la classe ServerConnection .
Creare un'istanza della classe Server SMO (SQL Server Management Objects) passando l'oggetto ServerConnection indicato nel passaggio 13.
Creare un'istanza della classe Job passando la proprietà JobServer dell'oggetto Server indicato nel passaggio 14 e il nome del processo indicato nel passaggio 12.
Chiamare il metodo Start per avviare il processo di snapshot partizionato.
Ripetere i passaggi da 6 a 16 per ogni Sottoscrittore.
Per creare una pubblicazione e creare manualmente gli snapshot per ogni partizione
Utilizzare un'istanza della classe MergePublication per definire una pubblicazione di tipo merge. Per altre informazioni, vedere Create a Publication.
Utilizzare la proprietà MergeArticle per aggiungere articoli alla pubblicazione. Specificare la proprietà FilterClause per almeno un articolo che definisce il filtro con parametri, quindi creare eventuali oggetti MergeJoinFilter che definiscono i filtri join tra gli articoli. Per altre informazioni, vedere definire un articolo.
Generare lo snapshot iniziale. Per altre informazioni, vedere Creazione e applicazione dello snapshot iniziale.
Creare un'istanza della classe SnapshotGenerationAgent e impostare le seguenti proprietà obbligatorie:
Publisher : nome del server di pubblicazione
PublisherDatabase : nome del database di pubblicazione
Publication : nome della pubblicazione
Distributor : nome del server di distribuzione
PublisherSecurityMode : valore di Integrated per usare l'autenticazione integrata di Windows o valore di Standard per usare l'autenticazione di SQL Server.
DistributorSecurityMode : valore di Integrated per usare l'autenticazione integrata di Windows o valore di Standard per usare l'autenticazione di SQL Server.
Impostare un valore di Merge per ReplicationType.
Impostare una o più delle seguenti proprietà per definire i parametri di partizionamento:
Se la partizione del Sottoscrittore è definita dal risultato di SUSER_SNAME (Transact-SQL), usare DynamicFilterLogin.
Se la partizione del Sottoscrittore è definita dal risultato di HOST_NAME (Transact-SQL) o da un overload di questa funzione, usare DynamicFilterHostName.
Chiamare il metodo GenerateSnapshot .
Ripetere i passaggi da 4 a 7 per ogni Sottoscrittore.
Esempi (RMO)
In questo esempio viene creata una pubblicazione di tipo merge che consente ai Sottoscrittori di richiedere la generazione di snapshot.
// 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
In questo esempio vengono creati manualmente la partizione del Sottoscrittore e lo snapshot filtrato per una pubblicazione di tipo merge con filtri di riga con parametri.
// 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
In questo esempio viene avviato manualmente l'agente snapshot per generare lo snapshot di dati filtrati per un Sottoscrittore in una pubblicazione di tipo merge con filtri di riga con parametri.
// 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
Vedi anche
Filtri di riga con parametri
Replication System Stored Procedures Concepts
Procedure consigliate per la sicurezza della replica
Commenti e suggerimenti
Presto disponibile: Nel corso del 2024 verranno gradualmente disattivati i problemi di GitHub come meccanismo di feedback per il contenuto e ciò verrà sostituito con un nuovo sistema di feedback. Per altre informazioni, vedere https://aka.ms/ContentUserFeedback.
Invia e visualizza il feedback per