マージ テーブル アーティクル間に論理レコード リレーションシップを定義する方法 (RMO プログラミング)

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

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

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

注
マージ レプリケーションを使用して、論理レコード レベルで追跡および解決する競合を指定できますが、これらのオプションは RMO を使用して設定できません。レプリケーション ストアド プロシージャを使用したこれらのオプションの設定方法については、「マージ テーブル アーティクル間に論理レコード リレーションシップを定義する方法 (レプリケーション Transact-SQL プログラミング)」を参照してください。

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

1. ServerConnection クラスを使用して、パブリッシャーへの接続を作成します。

2. MergePublication クラスのインスタンスを作成し、パブリケーションの Name プロパティと DatabaseName プロパティを設定して、手順 1. で作成した接続を ConnectionContext プロパティに設定します。

3. LoadProperties メソッドを呼び出して、オブジェクトのプロパティを取得します。このメソッドが false を返す場合、手順 2. でパブリケーション プロパティを不適切に設定したか、パブリケーションが存在していません。

4. PartitionGroupsOption プロパティが False に設定されている場合、これを True に設定します。

5. 論理レコードを構成するアーティクルが存在しない場合は、MergeArticle クラスのインスタンスを作成し、次のプロパティを設定します。

   • Name にアーティクル名を指定します。

   • PublicationName にパブリケーション名を指定します。

   • (省略可) アーティクルが行方向にフィルター選択される場合、FilterClause プロパティに行フィルター句を指定します。このプロパティを使用して、静的行フィルターまたはパラメーター化された行フィルターを指定します。詳細については、「パラメーター化された行フィルター」を参照してください。

   詳細については、「アーティクルを定義する方法 (RMO プログラミング)」を参照してください。

6. Create メソッドを呼び出します。

7. 論理レコードを構成するアーティクルごとに、手順 5. と 6. を繰り返します。

8. MergeJoinFilter クラスのインスタンスを作成して、アーティクル間の論理レコード リレーションシップを定義します。その後、次のプロパティを設定します。

   • ArticleName プロパティに論理レコード リレーションシップの子アーティクルの名前を指定します。

   • JoinArticleName プロパティに論理レコード リレーションシップの既存の親アーティクルの名前を指定します。

   • FilterName プロパティに論理レコード リレーションシップの名前を指定します。

   • リレーションシップを定義する式を JoinFilterClause プロパティに指定します。

   • LogicalRecordLink の値を FilterTypes プロパティに指定します。論理レコード リレーションシップが結合フィルターでもある場合は、このプロパティに JoinFilterAndLogicalRecordLink の値を指定します。詳細については、「論理レコードによる関連行への変更のグループ化」を参照してください。

9. リレーションシップ内の子アーティクルを表すオブジェクトに対して AddMergeJoinFilter メソッドを呼び出します。手順 8. の MergeJoinFilter オブジェクトを渡して、リレーションシップを定義します。

10. パブリケーションの他の論理レコード リレーションシップについても、手順 8. と 9. をそれぞれ実行します。

使用例

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

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

// 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 = "AdventureWorks2008R2"

' 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

関連項目

タスク

マージ テーブル アーティクル間に論理レコード リレーションシップを定義する方法 (レプリケーション Transact-SQL プログラミング)

マージ テーブル アーティクル間で論理レコード リレーションシップを定義する方法 (SQL Server Management Studio)

概念

事前計算済みパーティションによるパラメータ化されたフィルタのパフォーマンス最適化