マージテーブルアーティクル間に論理レコードリレーションシップを定義する

[アーティクル]
09/25/2024

適用対象: SQL Server

このトピックでは、SQL Server で SQL Server Management Studio、Transact-SQL、またはレプリケーション管理オブジェクト (RMO) を使用して、マージテーブルアーティクル間に論理レコードリレーションシップを定義する方法について説明します。

マージレプリケーションでは、さまざまなテーブルの関連する行の間にリレーションシップを定義できます。これらの行は、同期の際にトランザクション単位として処理できます。論理レコードは、2 つのアーティクルの間に定義できます。結合フィルターリレーションシップの有無は関係ありません。詳細については、「Group Changes to Related Rows with Logical Records」 (論理レコードによる関連行への変更のグループ化) を参照してください。

Note

この機能は、 SQL Serverの将来のバージョンで削除される予定です。新規の開発作業ではこの機能を使用しないようにし、現在この機能を使用しているアプリケーションは修正することを検討してください。

このトピックの内容

作業を開始する準備:

制限事項と制約事項
マージテーブルアーティクル間に論理レコードリレーションシップを定義するために使用するもの:

SQL Server Management Studio

Transact-SQL

レプリケーション管理オブジェクト (RMO)

始める前に

制限事項と制約事項

パブリケーションに対するサブスクリプションが初期化された後に、論理レコードを追加、変更、または削除した場合は、変更を行った後で、新しいスナップショットを生成し、すべてのサブスクリプションを再初期化する必要があります。プロパティ変更の要件の詳細については、「Change Publication and Article Properties」(パブリケーションとアーティクルのプロパティの変更) をご覧ください。

SQL Server Management Studio を使用する

[結合の追加] ダイアログドロップダウンリストで論理レコードを定義します。このダイアログドロップダウンリストは、パブリケーションの新規作成ウィザードと [パブリケーションのプロパティ - <パブリケーション]> ダイアログドロップダウンリストで使用できます。ウィザードの使用およびダイアログボックスへのアクセスの詳細については、「パブリケーションの作成」および「View and Modify Publication Properties」 (パブリケーションプロパティの表示および変更) を参照してください。

[結合の追加] ダイアログボックスで論理レコードを定義できるのは、マージパブリケーションの結合フィルターに論理レコードが適用されている場合だけです。また、パブリケーションが、事前計算済みパーティションを使用するための要件を満たしている必要もあります。結合フィルターに適用されていない論理レコードを定義して、論理レコードレベルでの競合の検出と解決を設定するには、ストアドプロシージャを使用する必要があります。

論理レコードリレーションシップを定義するには

パブリケーションの新規作成ウィザードの [テーブル行のフィルター選択] ページまたは [パブリケーションのプロパティ - <パブリケーション]> ダイアログドロップダウンリストの [行のフィルター選択] ページで、[フィルター選択されたテーブル] ペイン内の行フィルターを選択します。

論理レコードリレーションシップは、行フィルターを拡張する結合フィルターに関連付けられます。したがって、先に行フィルターが定義されていないと、行フィルターを結合で拡張して論理レコードリレーションシップを適用することはできません。 1 つの結合フィルターが定義されると、この結合フィルターを別の結合フィルターを使用して拡張できます。結合フィルターの定義の詳細については、「マージアーティクル間の結合フィルターの定義および変更」を参照してください。
[追加]をクリックし、 [選択したフィルターを拡張するために結合を追加する]をクリックします。
[結合の追加] ダイアログボックスで結合フィルターを定義してから、 [論理レコード]チェックボックスをオンにします。
[パブリケーションのプロパティ - <パブリケーション]> ダイアログボックスが表示されている場合は、[OK] をクリックして保存し、ダイアログボックスを閉じます。

論理レコードリレーションシップを削除するには

論理レコードリレーションシップのみを削除するか、または論理レコードリレーションシップとそれに関連付けられている結合フィルターを削除します。

論理レコードリレーションシップのみを削除するには
1. パブリケーションの新規作成ウィザードの [行のフィルター選択] ページ、または [パブリケーションのプロパティ - <パブリケーション]> ダイアログドロップダウンリストの [行のフィルター選択] ページで、[フィルター選択されたテーブル] ペイン内の論理レコードリレーションシップに関連付けられている結合フィルターを選択し、[編集] をクリックします。
2. [結合の編集] ダイアログボックスで、 [論理レコード]チェックボックスをオフにします。
3. [OK] を選択します。
論理レコードリレーションシップとそれに関連付けられている結合フィルターを削除するには
- パブリケーションの新規作成ウィザードの [行のフィルター選択] ページまたは [パブリケーションのプロパティ - <パブリケーション]> ダイアログドロップダウンリストで、[フィルター選択されたテーブル] ペイン内のフィルターを選択し、[削除する] をクリックします。削除する結合フィルター自体が他の結合によって拡張されている場合は、それらの結合も削除されます。

Transact-SQL の使用

プログラムでレプリケーションストアドプロシージャを使用して、アーティクル間に論理レコードリレーションシップを指定できます。

論理レコードにおける競合の検出と解決の方法を変更するには

論理レコードの関連する行で発生する競合を検出し、解決するには、次の手順を実行します。
- パブリッシャー側のパブリケーションデータベースに対して、 sp_changemergearticleを実行します。 @property に logical_record_level_conflict_detection を指定し、 @value に trueを指定します。 @force_invalidate_snapshot および @force_reinit_subscription に 1を指定します。
- パブリッシャー側のパブリケーションデータベースに対して、 sp_changemergearticleを実行します。 @property に logical_record_level_conflict_resolution を指定し、 @value に trueを指定します。 @force_invalidate_snapshot および @force_reinit_subscription に 1を指定します。
標準の行レベルまたは列レベルの競合の検出と解決を使用するには、次の手順を実行します。
- パブリッシャー側のパブリケーションデータベースに対して、 sp_changemergearticleを実行します。 @property に logical_record_level_conflict_detection を指定し、 @value に falseを指定します。 @force_invalidate_snapshot および @force_reinit_subscription に 1を指定します。
- パブリッシャー側のパブリケーションデータベースに対して、 sp_changemergearticleを実行します。 @property に logical_record_level_conflict_resolution を指定し、 @value に falseを指定します。 @force_invalidate_snapshot および @force_reinit_subscription に 1を指定します。

論理レコードリレーションシップを削除するには

パブリッシャー側のパブリケーションデータベースに対して次のクエリを実行し、指定されたパブリケーションに対して定義されているすべての論理レコードリレーションシップに関する情報を返します。
```
SELECT f.* FROM sysmergesubsetfilters AS f 
INNER JOIN sysmergepublications AS p
ON f.pubid = p.pubid WHERE p.[name] = @publication;
```
結果セット内の filtername 列で削除されている論理レコードリレーションシップの名前を確認します。

Note

このクエリは、 sp_helpmergefilterと同じ情報を返します。ただし、このシステムストアドプロシージャは、結合フィルターでもある論理レコードリレーションシップに関する情報のみ返します。
パブリッシャー側のパブリケーションデータベースに対して、 sp_dropmergefilterを実行します。 @publicationを指定し、リレーションシップ内の 1 つのアーティクルの名前を @articleに、手順 1. のリレーションシップの名前を @filternameに指定します。

例 (Transact-SQL)

この例では、既存のパブリケーションで事前計算済みパーティションを有効にし、 SalesOrderHeader テーブルと SalesOrderDetail テーブルの 2 つの新しいアーティクルを含む論理レコードを作成しています。

-- Remove ON DELETE CASCADE from FK_SalesOrderDetail_SalesOrderHeader_SalesOrderID;
-- logical records cannot be used with ON DELETE CASCADE. 
IF EXISTS (SELECT * FROM sys.objects 
WHERE name = 'FK_SalesOrderDetail_SalesOrderHeader_SalesOrderID')
BEGIN
    ALTER TABLE [Sales].[SalesOrderDetail] 
    DROP CONSTRAINT [FK_SalesOrderDetail_SalesOrderHeader_SalesOrderID] 
END

ALTER TABLE [Sales].[SalesOrderDetail]  
WITH CHECK ADD CONSTRAINT [FK_SalesOrderDetail_SalesOrderHeader_SalesOrderID] 
FOREIGN KEY([SalesOrderID])
REFERENCES [Sales].[SalesOrderHeader] ([SalesOrderID])
GO

DECLARE @publication    AS sysname;
DECLARE @table1 AS sysname;
DECLARE @table2 AS sysname;
DECLARE @table3 AS sysname;
DECLARE @salesschema AS sysname;
DECLARE @hrschema AS sysname;
DECLARE @filterclause AS nvarchar(1000);
DECLARE @partitionoption AS bit;
SET @publication = N'AdvWorksSalesOrdersMerge'; 
SET @table1 = N'SalesOrderDetail'; 
SET @table2 = N'SalesOrderHeader'; 
SET @salesschema = N'Sales';
SET @hrschema = N'HumanResources';
SET @filterclause = N'Employee.LoginID = HOST_NAME()';

-- Ensure that the publication uses precomputed partitions.
SET @partitionoption = (SELECT [use_partition_groups] FROM sysmergepublications 
    WHERE [name] = @publication);
IF @partitionoption <> 1
BEGIN
    EXEC sp_changemergepublication 
        @publication = @publication, 
        @property = N'use_partition_groups', 
        @value = 'true',
        @force_invalidate_snapshot = 1;
END  

-- Add a filtered article for the Employee table.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table1, 
  @source_object = @table1, 
  @type = N'table', 
  @source_owner = @hrschema,
  @schema_option = 0x0004CF1,
  @description = N'article for the Employee table',
  @subset_filterclause = @filterclause;

-- Add an article for the SalesOrderHeader table.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table2, 
  @source_object = @table2, 
  @type = N'table', 
  @source_owner = @salesschema,
  @schema_option = 0x0034EF1,
  @description = N'article for the SalesOrderHeader table';

-- Add an article for the SalesOrderDetail table.
EXEC sp_addmergearticle 
  @publication = @publication, 
  @article = @table3, 
  @source_object = @table3, 
  @source_owner = @salesschema,
  @description = 'article for the SalesOrderDetail table', 
  @identityrangemanagementoption = N'auto', 
  @pub_identity_range = 100000, 
  @identity_range = 100, 
  @threshold = 80;

-- Add a merge join filter between Employee and SalesOrderHeader.
EXEC sp_addmergefilter 
  @publication = @publication, 
  @article = @table2, 
  @filtername = N'SalesOrderHeader_Employee', 
  @join_articlename = @table1, 
  @join_filterclause = N'Employee.EmployeeID = SalesOrderHeader.SalesPersonID', 
  @join_unique_key = 1, 
  @filter_type = 1, 
  @force_invalidate_snapshot = 1, 
  @force_reinit_subscription = 1;

-- Create a logical record relationship that is also a merge join 
-- filter between SalesOrderHeader and SalesOrderDetail.
EXEC sp_addmergefilter 
  @publication = @publication, 
  @article = @table3, 
  @filtername = N'LogicalRecord_SalesOrderHeader_SalesOrderDetail', 
  @join_articlename = @table2, 
  @join_filterclause = N'[SalesOrderHeader].[SalesOrderID] = [SalesOrderDetail].[SalesOrderID]', 
  @join_unique_key = 1, 
  @filter_type = 3, 
  @force_invalidate_snapshot = 1, 
  @force_reinit_subscription = 1;
GO

レプリケーション管理オブジェクト (RMO) の使用

Note

マージレプリケーションを使用して、論理レコードレベルで追跡および解決する競合を指定できますが、これらのオプションは RMO を使用して設定できません。

例 (RMO)

この例では、 SalesOrderHeader テーブルと SalesOrderDetail テーブルの 2 つの新しいアーティクルを含む論理レコードを作成しています。

           // Define the Publisher and publication names.
           string publisherName = publisherInstance;
           string publicationName = "AdvWorksSalesOrdersMerge";
           string publicationDbName = "AdventureWorks2022";

           // Specify article names.
           string articleName1 = "SalesOrderHeader";
           string articleName2 = "SalesOrderDetail";
           
           // Specify logical record information.
           string lrName = "SalesOrderHeader_SalesOrderDetail";
           string lrClause = "[SalesOrderHeader].[SalesOrderID] = "
               + "[SalesOrderDetail].[SalesOrderID]";

           string schema = "Sales";

           MergeArticle article1 = new MergeArticle();
           MergeArticle article2 = new MergeArticle();
           MergeJoinFilter lr = new MergeJoinFilter();
           MergePublication publication = new MergePublication();

           // Create a connection to the Publisher.
           ServerConnection conn = new ServerConnection(publisherName);

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

               // Verify that the publication uses precomputed partitions.
               publication.Name = publicationName;
               publication.DatabaseName = publicationDbName;
               publication.ConnectionContext = conn;

               // If we can't get the properties for this merge publication, then throw an application exception.
               if (publication.LoadProperties())
               {
                   // If precomputed partitions is disabled, enable it.
                   if (publication.PartitionGroupsOption == PartitionGroupsOption.False)
                   {
                       publication.PartitionGroupsOption = PartitionGroupsOption.True;
                   }
               }
               else
               {
                   throw new ApplicationException(String.Format(
                       "Settings could not be retrieved for the publication. " +
                       "Ensure that the publication {0} exists on {1}.",
                       publicationName, publisherName));
               }

               // Set the required properties for the PurchaseOrderHeader article.
               article1.ConnectionContext = conn;
               article1.Name = articleName1;
               article1.DatabaseName = publicationDbName;
               article1.SourceObjectName = articleName1;
               article1.SourceObjectOwner = schema;
               article1.PublicationName = publicationName;
               article1.Type = ArticleOptions.TableBased;

               // Set the required properties for the SalesOrderDetail article.
               article2.ConnectionContext = conn;
               article2.Name = articleName2;
               article2.DatabaseName = publicationDbName;
               article2.SourceObjectName = articleName2;
               article2.SourceObjectOwner = schema;
               article2.PublicationName = publicationName;
               article2.Type = ArticleOptions.TableBased;

               if (!article1.IsExistingObject) article1.Create();
               if (!article2.IsExistingObject) article2.Create();

               // Define a logical record relationship between 
               // PurchaseOrderHeader and PurchaseOrderDetail. 

               // Parent article.
               lr.JoinArticleName = articleName1;
               
               // Child article.
               lr.ArticleName = articleName2;
               lr.FilterName = lrName;
               lr.JoinUniqueKey = true;
               lr.FilterTypes = FilterTypes.LogicalRecordLink;
               lr.JoinFilterClause = lrClause;

               // Add the logical record definition to the parent article.
               article1.AddMergeJoinFilter(lr);
           }
           catch (Exception ex)
           {
               // Do error handling here and rollback the transaction.
               throw new ApplicationException(
                   "The filtered articles could not be created", ex);
           }
           finally
           {
               conn.Disconnect();
           }

' Define the Publisher and publication names.
Dim publisherName As String = publisherInstance
Dim publicationName As String = "AdvWorksSalesOrdersMerge"
Dim publicationDbName As String = "AdventureWorks2022"

' Specify article names.
Dim articleName1 As String = "SalesOrderHeader"
Dim articleName2 As String = "SalesOrderDetail"

' Specify logical record information.
Dim lrName As String = "SalesOrderHeader_SalesOrderDetail"
Dim lrClause As String = "[SalesOrderHeader].[SalesOrderID] = " _
        & "[SalesOrderDetail].[SalesOrderID]"

Dim schema As String = "Sales"

Dim article1 As MergeArticle = New MergeArticle()
Dim article2 As MergeArticle = New MergeArticle()
Dim lr As MergeJoinFilter = New MergeJoinFilter()
Dim publication As MergePublication = New MergePublication()

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

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

    ' Verify that the publication uses precomputed partitions.
    publication.Name = publicationName
    publication.DatabaseName = publicationDbName
    publication.ConnectionContext = conn

    ' If we can't get the properties for this merge publication, then throw an application exception.
    If publication.LoadProperties() Then
        ' If precomputed partitions is disabled, enable it.
        If publication.PartitionGroupsOption = PartitionGroupsOption.False Then
            publication.PartitionGroupsOption = PartitionGroupsOption.True
        End If
    Else
        Throw New ApplicationException(String.Format( _
            "Settings could not be retrieved for the publication. " _
            & "Ensure that the publication {0} exists on {1}.", _
            publicationName, publisherName))
    End If

    ' Set the required properties for the SalesOrderHeader article.
    article1.ConnectionContext = conn
    article1.Name = articleName1
    article1.DatabaseName = publicationDbName
    article1.SourceObjectName = articleName1
    article1.SourceObjectOwner = schema
    article1.PublicationName = publicationName
    article1.Type = ArticleOptions.TableBased

    ' Set the required properties for the SalesOrderDetail article.
    article2.ConnectionContext = conn
    article2.Name = articleName2
    article2.DatabaseName = publicationDbName
    article2.SourceObjectName = articleName2
    article2.SourceObjectOwner = schema
    article2.PublicationName = publicationName
    article2.Type = ArticleOptions.TableBased

    If Not article1.IsExistingObject Then
        article1.Create()
    End If
    If Not article2.IsExistingObject Then
        article2.Create()
    End If

    ' Define a logical record relationship between 
    ' SalesOrderHeader and SalesOrderDetail. 

    ' Parent article.
    lr.JoinArticleName = articleName1
    ' Child article.
    lr.ArticleName = articleName2
    lr.FilterName = lrName
    lr.JoinUniqueKey = True
    lr.FilterTypes = FilterTypes.LogicalRecordLink
    lr.JoinFilterClause = lrClause

    ' Add the logical record definition to the parent article.
    article1.AddMergeJoinFilter(lr)
Catch ex As Exception
    ' Do error handling here and rollback the transaction.
    Throw New ApplicationException( _
            "The filtered articles could not be created", ex)
Finally
    conn.Disconnect()
End Try

次の方法で共有

マージテーブルアーティクル間に論理レコードリレーションシップを定義する

始める前に

制限事項と制約事項

SQL Server Management Studio を使用する

論理レコードリレーションシップを定義するには

論理レコードリレーションシップを削除するには

Transact-SQL の使用

関連する結合フィルターを使用せずに論理レコードリレーションシップを定義するには

論理レコードにおける競合の検出と解決の方法を変更するには

論理レコードリレーションシップを削除するには

例 (Transact-SQL)

レプリケーション管理オブジェクト (RMO) の使用

関連する結合フィルターを使用せずに論理レコードリレーションシップを定義するには

例 (RMO)

フィードバック

その他のリソース

次の方法で共有

マージ テーブル アーティクル間に論理レコード リレーションシップを定義する

始める前に

制限事項と制約事項

SQL Server Management Studio を使用する

論理レコード リレーションシップを定義するには

論理レコード リレーションシップを削除するには

Transact-SQL の使用

関連する結合フィルターを使用せずに論理レコード リレーションシップを定義するには

論理レコードにおける競合の検出と解決の方法を変更するには

論理レコード リレーションシップを削除するには

例 (Transact-SQL)

レプリケーション管理オブジェクト (RMO) の使用

関連する結合フィルターを使用せずに論理レコード リレーションシップを定義するには

例 (RMO)

関連するコンテンツ

フィードバック

その他のリソース

マージテーブルアーティクル間に論理レコードリレーションシップを定義する

論理レコードリレーションシップを定義するには

論理レコードリレーションシップを削除するには

関連する結合フィルターを使用せずに論理レコードリレーションシップを定義するには

論理レコードリレーションシップを削除するには

関連する結合フィルターを使用せずに論理レコードリレーションシップを定義するには