Share via


sp_adddynamicスナップショット_job (Transact-SQL)

適用対象: SQL ServerAzure SQL Managed Instance

パラメーター化された行フィルターを使用してパブリケーションのフィルター処理されたデータ スナップショットを生成するエージェント ジョブを作成します。 このストアド プロシージャは、パブリッシャー側のパブリケーション データベースで実行されます。 このストアド プロシージャは、サブスクライバーのジョブスナップショットフィルター処理されたデータを手動で作成するために管理者によって使用されます。

Note

フィルター処理されたデータ スナップショット ジョブを作成するには、パブリケーションの標準スナップショット ジョブが既に存在している必要があります。

詳しくは、「 パラメーター化されたフィルターを使用したパブリケーションのスナップショットの作成」をご覧ください。

Transact-SQL 構文表記規則

構文

sp_adddynamicsnapshot_job
    [ @publication = ] N'publication'
    [ , [ @suser_sname = ] N'suser_sname' ]
    [ , [ @host_name = ] N'host_name' ]
    [ , [ @dynamic_snapshot_jobname = ] N'dynamic_snapshot_jobname' OUTPUT ]
    [ , [ @dynamic_snapshot_jobid = ] 'dynamic_snapshot_jobid' OUTPUT ]
    [ , [ @frequency_type = ] frequency_type ]
    [ , [ @frequency_interval = ] frequency_interval ]
    [ , [ @frequency_subday = ] frequency_subday ]
    [ , [ @frequency_subday_interval = ] frequency_subday_interval ]
    [ , [ @frequency_relative_interval = ] frequency_relative_interval ]
    [ , [ @frequency_recurrence_factor = ] frequency_recurrence_factor ]
    [ , [ @active_start_date = ] active_start_date ]
    [ , [ @active_end_date = ] active_end_date ]
    [ , [ @active_start_time_of_day = ] active_start_time_of_day ]
    [ , [ @active_end_time_of_day = ] active_end_time_of_day ]
[ ; ]

引数

[ @publication = ] N'publication'

フィルター処理されたデータスナップショットジョブが追加されるパブリケーションの名前。 @publicationは sysname で、既定値はありません。

[ @suser_sname = ] N'suser_sname'

サブスクライバーの SU Standard EditionR_SNAME 関数の値によってフィルター処理されるサブスクリプションのフィルター処理されたデータ スナップショットを作成するときに使用される値。 @suser_snameは sysname で、既定値は NULL. この関数を使用してパブリケーションを動的にフィルター処理しない場合は、@suser_snameする必要がありますNULL

[ @host_name = ] N'host_name'

サブスクライバーのHOST_NAME関数の値によってフィルター処理されるサブスクリプションのフィルター処理されたデータ スナップショット作成するときに使用される値。 @host_nameは sysname で、既定値は NULL. この関数を使用してパブリケーションを動的にフィルター処理しない場合は、host_nameする必要がありますNULL

[ @dynamic_snapshot_jobname = ] N'dynamic_スナップショット_jobname' OUTPUT

ジョブが作成スナップショットフィルター処理されたデータの名前。 @dynamic_スナップショット_jobnameは sysname 型の OUTPUT パラメーターです。 指定した場合、@dynamic_スナップショット_jobnameディストリビューターの一意のジョブに解決する必要があります。 指定しない場合、ジョブ名は結果セットに自動的に生成されます。この名前は次のように作成されます。

'dyn_' + <name of the standard snapshot job> + <GUID>

Note

動的スナップショット ジョブの名前を生成するときに、標準のスナップショット ジョブの名前を切り捨てる場合があります。

[ @dynamic_snapshot_jobid = ] 'dynamic_スナップショット_jobid' OUTPUT

作成されたジョブスナップショットフィルター処理されたデータの識別子。 @dynamic_スナップショット_jobidは uniqueidentifierの OUTPUT パラメーターで、既定値は NULL.

[ @frequency_type = ] frequency_type

フィルター処理されたデータスナップショットジョブをスケジュールする頻度を指定します。 @frequency_typeは int であり、これらの値のいずれかになります。

Value 説明
1 指定日時
2 (既定値) オンデマンド
4 毎日
8 週単位
16 月単位
32 月単位の相対
64 Autostart
128 定期的

[ @frequency_interval = ] frequency_interval

フィルター処理されたデータスナップショットジョブが実行される期間 (日単位)。 @frequency_intervalは int であり、@frequency_type値によって異なります。

@frequency_typeの @frequency_intervalへの 影響
1 (既定値) @frequency_intervalは使用されません。
4 @frequency_interval日ごと
8 @frequency_intervalは、次の 1 つ以上 (|と組み合わせたもの) です。(ビットごとの OR)(Transact-SQL)論理演算子):

1 = 日曜日
2 = 月曜日
4 = 火曜日
8 = 水曜日
16 = 木曜日
32 = 金曜日
64 = 土曜日
16 月の @frequency_interval 日。
32 @frequency_intervalは、次のいずれかのオプションです。

1 = 日曜日
2 = 月曜日
3 = 火曜日
4 = 水曜日
5 = 木曜日
6 = 金曜日
7 = 土曜日
8 = 日
9 = 平日
10 = 週末
64 @frequency_intervalは使用されません。
128 @frequency_intervalは使用されません。

[ @frequency_subday = ] frequency_subday

@frequency_subday_intervalの単位を指定します。 @frequency_subdayは int であり、これらの値のいずれかになります。

Value 説明
1 (既定値) 1 回。
2 Second
4
8 時間

[ @frequency_subday_interval = ] frequency_subday_interval

ジョブの 各実行の間に発生するfrequency_subday 期間の数。 @frequency_subday_intervalは int で、既定値は 1.

[ @frequency_relative_interval = ] frequency_relative_interval

フィルター処理されたデータの発生スナップショットジョブが毎月発生します。 このパラメーターは、@frequency_typeが (月単位の相対) に設定されている場合32使用されます。 @frequency_relative_intervalは int であり、これらの値のいずれかになります。

Value 説明
1 (既定値) First
2 Second
4 Third
8 4 番目
16 末尾

[ @frequency_recurrence_factor = ] frequency_recurrence_factor

frequency_typeで使用される 繰り返し係数。 @frequency_recurrence_factorは int で、既定値は 1.

[ @active_start_date = ] active_start_date

フィルター処理されたデータスナップショットジョブが最初にスケジュールされた日付。形式yyyyMMddは . @active_start_dateは int で、既定値は 0.

[ @active_end_date = ] active_end_date

フィルター処理されたデータスナップショットジョブのスケジュールが停止した日付。次のようにyyyyMMdd書式設定されます。 @active_end_dateは int で、既定値は 0.

[ @active_start_time_of_day = ] active_start_time_of_day

フィルター処理されたデータ スナップショット ジョブが最初にスケジュールされた時刻。次のようにHHmmss書式設定されます。 @active_start_time_of_dayは int で、既定値は 0.

[ @active_end_time_of_day = ] active_end_time_of_day

フィルター処理されたデータスナップショットジョブのスケジュールが停止した時刻。次のようにHHmmss書式設定されます。 @active_end_time_of_dayは int で、既定値は 0.

結果セット

列名 データ型 説明
id int MSdynamicスナップショットjobs システム テーブルのフィルター処理されたデータ スナップショット ジョブを識別します。
dynamic_snapshot_jobname sysname フィルター処理されたデータ スナップショット ジョブの名前。
dynamic_snapshot_jobid uniqueidentifier ディストリビューターのSQL Server エージェント ジョブを一意に識別します。

リターン コードの値

0 (成功) または 1 (失敗)。

解説

sp_adddynamicsnapshot_job は、パラメーター化されたフィルターを使用するパブリケーションのマージ レプリケーションで使用されます。

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

アクセス許可

sysadmin 固定サーバー ロールまたは固定データベース ロールdb_ownerのメンバーのみが実行sp_adddynamicsnapshot_jobできます。