トランザクション パブリケーションに対するサブスクリプションの更新を有効にする方法 (レプリケーション Transact-SQL プログラミング)
.gif "注意") 注 |
|---|
この機能は、将来のバージョンの Microsoft SQL Server では削除される予定です。新しい開発作業では、この機能の使用を避け、現在この機能を使用しているアプリケーションは修正するようにしてください。 |
レプリケーション ストアド プロシージャを使用してプログラムからトランザクション パブリケーションを作成するときに、即時更新サブスクリプションまたはキュー更新サブスクリプションを有効にできます。
.gif "セキュリティに関する注意") セキュリティに関する注意 |
|---|
可能であれば、実行時にセキュリティ資格情報の入力を求めるメッセージを表示します。スクリプト ファイルに資格情報を格納する必要がある場合、不正なアクセスを防ぐために、ファイルをセキュリティ保護する必要があります。 |
即時更新サブスクリプションをサポートするパブリケーションを作成するには
必要に応じて、パブリケーション データベース用のログ リーダー エージェント ジョブを作成します。
パブリケーション データベース用のログ リーダー エージェント ジョブが既に存在する場合、手順 2. に進みます。
パブリッシュされたデータベース用のログ リーダー エージェント ジョブが存在するかどうかわからない場合は、パブリッシャ側のパブリケーション データベースに対して sp_helplogreader_agent (Transact-SQL) を実行します。結果セットが空の場合、ログ リーダー エージェント ジョブを作成する必要があります。
パブリッシャで、sp_addlogreader_agent (Transact-SQL) を実行します。エージェントの実行に使用される Microsoft Windows 資格情報を @job_name と @password に指定します。エージェントがパブリッシャに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に 0 を指定し、@publisher_login と @publisher_password に Microsoft SQL Server ログイン情報を指定する必要があります。
パラメータ @allow_sync_tran に true を指定して、sp_addpublication (Transact-SQL) を実行します。
パブリッシャで、sp_addpublication_snapshot (Transact-SQL) を実行します。手順 2. で使用したパブリケーション名を @publication に指定し、スナップショット エージェントを実行するときに使用される Windows 資格情報を @job_name と @password に指定します。エージェントがパブリッシャに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に 0 を指定し、@publisher_login と @publisher_password に SQL Server ログイン情報を指定する必要があります。これにより、パブリケーション用のスナップショット エージェント ジョブが作成されます。
パブリケーションにアーティクルを追加します。詳細については、「アーティクルを定義する方法 (レプリケーション Transact-SQL プログラミング)」を参照してください。
サブスクライバで、このパブリケーションに対する更新サブスクリプションを作成します。詳細については、「トランザクション パブリケーションに対して更新可能なサブスクリプションを作成する方法 (レプリケーション Transact-SQL プログラミング)」を参照してください。
キュー更新サブスクリプションをサポートするパブリケーションを作成するには
必要に応じて、パブリケーション データベース用のログ リーダー エージェント ジョブを作成します。
パブリケーション データベース用のログ リーダー エージェント ジョブが既に存在する場合、手順 2. に進みます。
パブリッシュされたデータベース用のログ リーダー エージェント ジョブが存在するかどうかわからない場合は、パブリッシャ側のパブリケーション データベースに対して sp_helplogreader_agent (Transact-SQL) を実行します。結果セットが空の場合、ログ リーダー エージェント ジョブを作成する必要があります。
パブリッシャで、sp_addlogreader_agent (Transact-SQL) を実行します。エージェントの実行に使用される Windows 資格情報を @job_name と @password に指定します。エージェントがパブリッシャに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に 0 を指定し、@publisher_login と @publisher_password に SQL Server ログイン情報を指定する必要があります。
必要に応じて、ディストリビュータ用のキュー リーダー エージェント ジョブを作成します。
ディストリビューション データベース用のキュー リーダー エージェント ジョブが既に存在する場合、手順 3. に進みます。
ディストリビューション データベース用のキュー リーダー エージェント ジョブが存在するかどうかわからない場合は、ディストリビュータ側のディストリビューション データベースに対して sp_helpqreader_agent (Transact-SQL) を実行します。結果セットが空の場合、キュー リーダー エージェント ジョブを作成する必要があります。
ディストリビュータで、sp_addqreader_agent (Transact-SQL) を実行します。エージェントの実行に使用される Windows 資格情報を @job_name と @password に指定します。これらの資格情報は、キュー リーダー エージェントがパブリッシャとサブスクライバに接続するときに使用されます。詳細については、「レプリケーション エージェントのセキュリティ モデル」を参照してください。
パラメータ @allow_queued_tran に true を指定し、@conflict_policy に pub wins、sub reinit、または sub wins を指定して、sp_addpublication (Transact-SQL) を実行します。
パブリッシャで、sp_addpublication_snapshot (Transact-SQL) を実行します。手順 3. で使用したパブリケーション名を @publication に指定し、スナップショット エージェントを実行するときに使用される Windows 資格情報を @snapshot_job_name と @password に指定します。エージェントがパブリッシャに接続する際に SQL Server 認証を使用する場合、さらに @publisher_security_mode に 0 を指定し、@publisher_login と @publisher_password に SQL Server ログイン情報を指定する必要があります。これにより、パブリケーション用のスナップショット エージェント ジョブが作成されます。
パブリケーションにアーティクルを追加します。詳細については、「アーティクルを定義する方法 (レプリケーション Transact-SQL プログラミング)」を参照してください。
サブスクライバで、このパブリケーションに対する更新サブスクリプションを作成します。詳細については、「トランザクション パブリケーションに対して更新可能なサブスクリプションを作成する方法 (レプリケーション Transact-SQL プログラミング)」を参照してください。
キュー更新サブスクリプションが可能なパブリケーションの競合ポリシーを変更するには
- パブリッシャ側のパブリケーション データベースに対して、sp_changepublication (Transact-SQL) を実行します。@property に conflict_policy を指定し、pub wins、sub reinit、または sub wins のいずれかの競合ポリシー モードを @value に指定します。
使用例
この例では、即時更新プル サブスクリプションとキュー更新プル サブスクリプションの両方がサポートされるパブリケーションを作成します。
-- To avoid storing the login and password in the script file, the values
-- are passed into SQLCMD as scripting variables. 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".
--Declarations for adding a transactional publication
DECLARE @publicationDB AS sysname;
DECLARE @publication AS sysname;
DECLARE @login AS sysname;
DECLARE @password AS sysname;
SET @publicationDB = N'AdventureWorks2008R2';
SET @publication = N'AdvWorksProductTran';
SET @login = $(Login);
SET @password = $(Password);
USE [AdventureWorks2008R2]
-- Enable transactional replication on the publication database.
EXEC sp_replicationdboption
@dbname=@publicationDB,
@optname=N'publish',
@value = N'true';
-- Execute sp_addlogreader_agent to create the agent job.
EXEC sp_addlogreader_agent
@job_login = @login,
@job_password = @password,
-- Explicitly specify the use of Windows Integrated Authentication (default)
-- when connecting to the Publisher.
@publisher_security_mode = 1;
-- Create a transactional publication that supports immediate updating,
-- queued updating, and pull subscriptions.
EXEC sp_addpublication
@publication = @publication,
@status = N'active',
@allow_sync_tran = N'true',
@allow_queued_tran = N'true',
@allow_pull = N'true',
@independent_agent = N'true',
-- Explicitly declare the related default properties
@conflict_policy = N'pub wins';
-- Create a new snapshot job for the publication, using a default schedule.
EXEC sp_addpublication_snapshot
@publication = @publication,
@job_login = @login,
@job_password = @password,
-- Explicitly specify the use of Windows Integrated Authentication (default)
-- when connecting to the Publisher.
@publisher_security_mode = 1;
GO
--Declarations for adding an article.
DECLARE @publication AS sysname;
DECLARE @article AS sysname;
DECLARE @owner AS sysname;
SET @publication = N'AdvWorksProductTran';
SET @article = N'Product';
SET @owner = N'Production';
-- Add a horizontally and vertically filtered article for the Product table.
USE [AdventureWorks2008R2]
EXEC sp_addarticle
@publication = @publication,
@article = @article,
@source_table = @article,
@vertical_partition = N'false',
@type = N'logbased',
@source_owner = @owner,
@destination_owner = @owner;
GO