BizTalk Serverを使用して通知メッセージを処理して Oracle Database の特定のタスクを完了する
Oracle データベース アダプターを使用して、Oracle データベース テーブルの変更に関する通知を受け取ることができます。 ただし、アダプターは、一部のレコードが特定のデータベース テーブルに挿入、更新、または削除されたことを示す通知のみを送信します。 これらのレコードの後処理は、クライアント アプリケーション自体で処理する必要があります。 このトピックでは、Oracle データベースから受信した通知の種類に基づいて、テーブル内のレコードを処理する方法に関するシナリオベースの説明を示します。
通知を受信した後に後続のアクションを実行するシナリオ
アダプター クライアントが特定の通知後タスクを実行する必要があるいくつかのシナリオを次に示します。
シナリオ 1. アダプター クライアントが Oracle データベースから受け取る通知の種類に基づいて特定のタスクを実行する必要があるシナリオを考えてみましょう。 たとえば、テーブル "B" にレコードが挿入されている場合、クライアント アプリケーションはテーブル "A" のレコードを更新する必要があります。 同様に、テーブル "B" からレコードが削除された場合、クライアント アプリケーションはテーブル "A" からレコードを削除する必要があります。
このシナリオでは、受信した通知メッセージから、アダプター クライアントは通知の種類を抽出して、通知が挿入操作用か削除操作用かを決定する必要があります。 通知の種類が確認されたら、アダプター クライアントは後続のアクションを実行して、関連するテーブルを挿入または更新する必要があります。
シナリオ 2. テーブルへの変更に関する通知メッセージを受信する受信場所がダウンするシナリオを考えてみましょう。 受信場所がダウンしている間は、一部のレコードがテーブルに追加されます。 ただし、これらのレコードの場合、アダプター クライアントは通知を受信しません。 受信場所がバックアップされると、アダプターは特定のメッセージを送信してクライアントに通知し、クライアント アプリケーションは、受信場所がダウンしている間にデータベース テーブルに挿入されたすべてのレコードを検索する必要があります。
このシナリオでは、受信した通知メッセージから、アダプター クライアントは、通知がデータベース テーブルに対する変更の場合か、開始する受信場所に対する通知であるかに関する情報を抽出する必要があります。 通知が受信場所を開始する場合、アダプター クライアントは、受信場所がダウンしている間に挿入、更新、または削除された可能性のあるレコードを処理するロジックを実装する必要があります。
Note
Oracle Database アダプターで通知機能を使用する方法について理解を深めるために一覧表示されているシナリオの例を次に示します。 ただし、受信した通知の種類を抽出するために必要なタスクの基本的なセットは、すべてのシナリオで似ています。 このトピックでは、通知メッセージから通知の種類を抽出する方法について説明します。
このトピックでは、通知メッセージの受信方法について説明します
このトピックでは、通知メッセージを処理して後続のタスクを実行する方法を示すために、アダプター クライアントが BizTalk アプリケーションを使用して ACCOUNTACTIVITY テーブルへの変更に関する通知メッセージを受信する基本的なシナリオを検討します。 通知を受信すると、クライアントは受信した通知の種類をフィルター処理し、後続のアクションを実行します。 非常に基本的なシナリオを示すために、アダプター クライアントが受信した通知の種類に基づいて通知メッセージを別のフォルダーにコピーすることを検討します。 そのため、次のようになります。
通知メッセージが挿入操作または更新操作の場合、アダプター クライアントはメッセージを C:\TestLocation\UpsertNotification フォルダーにコピーします。
通知メッセージが Delete などの他の操作の場合、アダプター クライアントはメッセージを C:\TestLocation\OtherNotificaiton フォルダーにコピーします。
BizTalk アプリケーションの一部としてこれを実現するには、オーケストレーションに次のものが含まれている必要があります。
通知メッセージを受信する一方向の受信ポート。
受信した通知メッセージの種類に関する情報を抽出する xpath クエリを含む式図形。
オーケストレーションにデシジョン ブロックを含める決定図形。 この決定ブロックでは、アプリケーションは、受信した通知メッセージに基づいて、後続の操作を実行する対象を決定します。
最終的に通知メッセージを受信する 2 つの一方向送信ポート。
Oracle データベース バインド プロパティを使用した通知の構成
次の表は、Oracle データベースからの通知の受信を構成するために使用する Oracle Database アダプター バインド プロパティをまとめたものです。 BizTalk Server管理コンソールで受信ポートを構成するときに、これらのバインド プロパティを指定する必要があります。
Note
Notification 操作のスキーマを生成するときに、必須ではない場合でも、これらのバインド プロパティを指定することもできます。 その場合、アダプター サービス アドインを使用してメタデータ生成の一部として生成されるポート バインド ファイルには、バインド プロパティに指定した値も含まれます。 このバインド ファイルは、後で BizTalk Server 管理コンソールにインポートして、バインド プロパティが既に設定されている WCF-custom または WCF-OracleDB 受信ポートを作成できます。 バインド ファイルを使用して WCF カスタムまたは WCF-OracleDB ポートを作成する方法の詳細については、「ポート バインド ファイルを 使用して Oracle Database への物理ポート バインドを構成する」を参照してください。
| Binding プロパティ | 説明 |
|---|---|
| InboundOperationType | 実行する受信操作を指定します。 通知メッセージを受信するには、これを [通知] に設定します。 |
| NotificationPort | Oracle データベースからのデータベース変更通知をリッスンするために ODP.NET 開く必要があるポート番号を指定します。 |
| NotificationStatement | クエリ通知の登録に使用する SELECT ステートメントを指定します。 アダプターは、指定された SELECT ステートメントの結果セットが変更された場合にのみ通知メッセージを取得します。 |
| NotifyOnListenerStart | リスナーの起動時にアダプターがアダプター クライアントに通知を送信するかどうかを指定します。 |
これらのプロパティの詳細については、「バインド プロパティの 操作」を参照してください。 Oracle データベース アダプターを使用して Oracle データベースから通知を受信する方法の詳細については、詳細を参照してください。
Oracle データベースから通知メッセージを受信する方法
BizTalk Serverを使用して Oracle データベース アダプターを使用して Oracle データベースに対して操作を実行するには、「Oracle Database を使用して BizTalk アプリケーションを開発するための構成要素」で説明されている手順に従います。 通知メッセージを受信するようにアダプターを構成するには、次のタスクを実行します。
BizTalk プロジェクトを作成し、 通知 受信操作のスキーマを生成します。 必要に応じて、 InboundOperationType、 NotificationPort、および NotificationStatement バインド プロパティの値を指定できます。
Oracle データベースから通知を受信するためのメッセージを BizTalk プロジェクトに作成します。
前のセクションで説明したように、オーケストレーションを作成します。
BizTalk プロジェクトをビルドして展開します。
物理送受信ポートを作成して BizTalk アプリケーションを構成します。
Note
通知メッセージの受信などの受信操作の場合は、一方向の WCF-Custom または受信ポートのみを構成 WCF-OracleDB 必要があります。 双方向の受信ポートは、受信操作ではサポートされていません。
BizTalk アプリケーションを起動します。
このトピックでは、これらのタスクを実行する手順について説明します。
スキーマの生成
Notification 受信操作のスキーマを生成する必要があります。 スキーマの生成方法の詳細については、「 Visual Studio での Oracle Database 操作のメタデータの取得 」を参照してください。 スキーマを生成するときは、次のタスクを実行します。 デザイン時にバインド プロパティを指定しない場合は、最初の手順をスキップします。
スキーマの生成中に、 InboundOperationType、 NotificationPort、および NotificationStatement バインド プロパティの値を指定します。 このバインド プロパティの詳細については、「バインド プロパティ の操作」を参照してください。 バインド プロパティを指定する方法については、「 Oracle Database のバインド プロパティを構成する」を参照してください。
コントラクトの種類を [サービス (受信操作)] として選択します。
通知操作のスキーマを生成します。
メッセージとメッセージの種類の定義
前に生成したスキーマでは、オーケストレーション内のメッセージに必要な "型" について説明します。 通常、メッセージは変数であり、対応するスキーマによって定義される型です。 スキーマが生成されたら、BizTalk プロジェクトのオーケストレーション ビューからメッセージにリンクする必要があります。
このトピックでは、Oracle データベースから通知を受信するメッセージを 1 つ作成する必要があります。
メッセージを作成し、スキーマにリンクするには、次の手順を実行します。
メッセージを作成し、スキーマにリンクするには
BizTalk プロジェクトにオーケストレーションを追加します。 ソリューション エクスプローラーから BizTalk プロジェクト名を右クリックし、[追加] をポイントして、[新しい項目] をクリックします。 BizTalk オーケストレーションの名前を入力し、[ 追加] をクリックします。
BizTalk プロジェクトがまだ開いていない場合は、オーケストレーション ビュー ウィンドウを開きます。 [ 表示] をクリックし、[ その他のウィンドウ] をポイントして、[ オーケストレーション ビュー] をクリックします。
オーケストレーション ビューで、[メッセージ] を右クリックし、[新しいメッセージ] をクリックします。
新しく作成したメッセージを右クリックし、[ プロパティ ウィンドウ] を選択します。
Message_1の [プロパティ] ウィンドウで、次の操作を行います。
プロパティ 目的 識別子 「 NotifyReceive.メッセージ型 ドロップダウン リストから [ スキーマ] を展開し、[ Process_Notification.OracleDBBinding.Notification] を選択します。 ここで、Process_Notification は BizTalk プロジェクトの名前です。 OracleDBBinding は、 通知 操作用に生成されるスキーマです。
オーケストレーションの設定
Oracle データベースから通知メッセージを受信し、受信した通知の種類に基づいてタスクを実行するためにBizTalk Serverを使用するには、BizTalk オーケストレーションを作成する必要があります。 このオーケストレーションでは、アダプターは NotificationStatement バインディング プロパティに指定された SELECT ステートメントに基づいて通知メッセージを受信します。 Expression 図形内で指定された xpath クエリは、通知の種類 ( NotificationType など) を変数に抽出します。 [決定] 図形では、この変数の値を使用して受信した通知の種類を決定し、後続の操作を実行するための適切な "パス" を取得します。 前のセクションで説明したように、オーケストレーションは受信した通知メッセージの種類に基づいて次の操作を実行します。
通知メッセージが挿入操作または更新操作の場合、アダプター クライアントはメッセージを C:\TestLocation\UpsertNotification フォルダーにコピーします。
通知メッセージが他の操作 (Delete など) の場合、アダプター クライアントはメッセージを C:\TestLocation\OtherNotificaiton フォルダーにコピーします。
そのため、オーケストレーションには次のものが含まれている必要があります。
通知メッセージを受信する一方向の受信ポート。
受信した通知の種類を抽出する xpath クエリを含む式図形。
オーケストレーションにデシジョン ブロックを含める Decide 図形。 この決定ブロックでは、アプリケーションは、受信した通知メッセージに基づいて、実行する後続の操作を決定します。
最終的に通知メッセージを受信する 2 つの一方向送信ポート。
図形を受け取ります。
サンプル オーケストレーションは次のようになります。
を実行するオーケストレーション
メッセージ図形の追加
メッセージ図形ごとに次のプロパティを指定してください。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 図形 | 図形の種類 | プロパティ |
|---|---|---|
| ReceiveNotification | 受信 | - 名前を ReceiveNotification に設定する - アクティブ化を True に設定する |
式図形の追加
オーケストレーションに式図形を含める目的は、受信した通知メッセージの種類を抽出する xpath クエリを使用することです。 xpath クエリを作成する前に、通知メッセージの形式を見てみましょう。 一般的な通知メッセージは次のようになります。
<?xml version="1.0" encoding="utf-8" ?>
<Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/">
<Details>
<NotificationDetails>
<ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName>
<Info>1</Info>
<QueryId>0</QueryId>
</NotificationDetails>
</Details>
<Info>Insert</Info>
<ResourceNames>
<string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string>
</ResourceNames>
<Source>Data</Source>
<Type>Change</Type>
</Notification>
ご覧のように、通知の種類に関する情報は、親<Notification>タグ内の <info> タグ内で使用できます。 そのため、この式の図形の一部として、次の操作を行う必要があります。
タグ内の値を含む変数を
<Info>作成し、その型を System.String に設定します。 変数の作成の詳細については、「 オーケストレーションでの変数の使用」を参照してください。このトピックでは、変数に NotificationType という名前を 付けます。
xpath クエリを作成して、Info> タグから値を<抽出します。 xpath クエリは次のようになります。
NotificationType = xpath(NotifyReceive,"string(/*[local-name()='Notification']/*[local-name()='Info']/text())");この xpath クエリでは、 NotifyReceive は通知メッセージを受信するために作成したメッセージです。 関数内の抜粋は、
stringクエリがタグ内<Info>の値を抽出する必要があることを示しています。これはタグ内<Notification>にあります。 最後に、クエリによって抽出された値が NotificaitonType 変数に割り当てられます。
決定図形の追加
Decide 図形を追加する目的は、オーケストレーションにデシジョン ブロックを含めて、受信した通知メッセージの種類に基づいて後続の操作を実行するかを決定することです。 この決定は、 NotificationType 変数の値に基づいて行われます。 このトピックでは、オーケストレーションによって、受信した通知メッセージの種類に基づいて決定が行われます。 そのため、Rule 図形の条件は次のように指定されます。
NotificationType.Equals("Insert") | NotificationType.Equals("Update")
この条件は、 NotificaitonType 変数の値が Insert または Update の場合、オーケストレーションが 1 つのタスク セットを実行することを示唆しています。 NotificationType 変数の値がそれ以外の場合、オーケストレーションは他の一連のタスクを実行します。
前のセクションで説明したように、簡単な方法を示すために、オーケストレーションは通知メッセージの種類に基づいてメッセージを別のフォルダーにコピーします。 そのため、Rule ブロックと Else ブロック内で Send 図形を追加して、メッセージを別のポートに送信する必要があります。 このトピックでは、Rule ブロックの Send 図形に SendUpsertNotification 、Else ブロックの Send 図形に SendOtherNotification という名前を付けます。
ポートの追加
次に、次の論理ポートをオーケストレーションに追加する必要があります。
Oracle データベースから通知メッセージを受信するための一方向受信ポート。
挿入および更新操作の通知メッセージを特定のフォルダーに送信するための一方向送信ポート。
他の操作の通知メッセージを特定のフォルダーに送信する一方向送信ポート。
論理ポートごとに次のプロパティを指定してください。 [ポート] 列に表示される名前は、オーケストレーションに表示されるポートの名前です。
| Port | プロパティ |
|---|---|
| OracleNotifyPort | - 識別子を OracleNotifyPort に設定する - 型を OracleNotifyPortType に設定する - 通信パターンを一方向に設定する - 通信方向を受信に設定する |
| NotificationUpsertPort | - 識別子を NotificationUpsertPort に設定する - [種類] を NotificationUpsertPortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する |
| OtherNotificationPort | - 識別子を OtherNotificationPort に設定する - 型を OtherNotificationPortType に設定する - 通信パターンを一方向に設定する - [通信の方向] を [送信] に設定する |
アクション 図形のメッセージを指定し、ポートに接続する
次の表では、アクション図形のメッセージを指定し、メッセージをポートにリンクするために設定するプロパティとその値を指定します。 [図形] 列に表示される名前は、前述のオーケストレーションに表示されるメッセージ図形の名前です。
| 図形 | プロパティ |
|---|---|
| ReceiveNotification | - Message を NotifyReceive に設定する - 操作を OracleNotifyPort.Notify.Request に設定する |
| SendUpsertNotification | - Message を NotifyReceive に設定する - 操作を NotificationUpsertPort.Upsert.Request に設定する |
| SendOtherNotification | - メッセージを選択に設定する - 操作を OtherNotificationPort.Other.Request に設定する |
これらのプロパティを指定すると、メッセージの図形とポートが接続され、オーケストレーションが完了します。
BizTalk ソリューションをビルドし、BizTalk Serverに展開する必要があります。 詳細については、「オーケストレーションの ビルドと実行」を参照してください。
BizTalk アプリケーションの構成
BizTalk プロジェクトを展開すると、前に作成したオーケストレーションが、BizTalk Server管理コンソールの [オーケストレーション] ウィンドウの下に一覧表示されます。 アプリケーションを構成するには、BizTalk Server管理コンソールを使用する必要があります。 チュートリアルについては、「 チュートリアル: 基本的な BizTalk アプリケーションの展開」を参照してください。
アプリケーションの構成には、次の作業が含まれます。
アプリケーションのホストの選択。
オーケストレーションで作成したポートを、BizTalk Server管理コンソールの物理ポートにマッピングします。 このオーケストレーションでは、次の操作を行う必要があります。
物理 WCF-Custom または一方向の受信ポート WCF-OracleDB 定義します。 このポートは、Oracle データベースからの通知をリッスンします。 受信ポートを作成する方法については、「 Oracle データベース アダプターへの物理ポート バインドを手動で構成する」を参照してください。 受信ポートには、次のバインド プロパティを指定してください。
重要
デザイン時にバインド プロパティを指定した場合は、この手順を実行する必要はありません。 このような場合は、アダプター サービスアドインによって作成されたバインド ファイルをインポートすることで、必要なバインド プロパティを設定して、WCF カスタムまたは WCF-OracleDB 受信ポートを作成できます。 詳細については、「ポート バインド ファイルを使用した物理ポート バインドの構成」を参照してください。
Binding プロパティ 値 InboundOperationType これを [通知] に設定します。 NotificationPort Oracle データベースからのデータベース変更通知をリッスンするために ODP.NET 開く必要があるポート番号を指定します。 これを、Windows ファイアウォールの例外リストに追加する必要があるのと同じポート番号に設定します。 Windows ファイアウォールの例外の一覧にポートを追加する方法については、「」を参照してください https://go.microsoft.com/fwlink/?LinkID=196959。
大事な： これを既定値 -1 に設定した場合は、通知メッセージを受信するために Windows ファイアウォールを完全に無効にする必要があります。NotificationStatement これを次のように設定します。
SELECT TID,ACCOUNT,PROCESSED FROM SCOTT.ACCOUNTACTIVITY WHERE PROCESSED = ‘n’
メモ： テーブル名とスキーマ名を指定する必要があります。 たとえば、「SCOTT.ACCOUNTACTIVITY」のように入力します。NotifyOnListenerStart これを True に設定 します。 さまざまなバインド プロパティの詳細については、「バインド プロパティ の操作」を参照してください。
Note
Oracle Database アダプターを使用して受信操作を実行するときに、トランザクション分離レベルとトランザクション タイムアウトを構成することをお勧めします。 これを行うには、WCF-Custom または受信ポートの構成中にサービスの動作 WCF-OracleDB 追加します。 サービスの動作を追加する方法については、「 Oracle Database でトランザクション分離レベルとトランザクション タイムアウトを構成する」を参照してください。
ハード ディスク上の場所と、BizTalk オーケストレーションが挿入および更新操作のために Oracle データベースから通知メッセージを削除する対応するファイル ポートを定義します。 このポートを構成して、C:\TestLocation\UpsertNotification フォルダーに通知メッセージをドロップします。
ハード ディスク上の場所と、BizTalk オーケストレーションが他のすべての操作のために Oracle データベースから通知メッセージを削除する対応するファイル ポートを定義します。 このポートを構成して、フォルダー C:\TestLocation\OtherNotification に通知メッセージをドロップします。
アプリケーションの起動
Oracle データベースから通知メッセージを受信し、後続の Select 操作と Update 操作を実行するには、BizTalk アプリケーションを起動する必要があります。 BizTalk アプリケーションを起動する手順については、「オーケストレーションを 開始する方法」を参照してください。
この段階で、次のことを確認します。
WCF-Custom または WCF-OracleDB Oracle データベースから通知メッセージを受信する一方向の受信ポートが実行されています。
Oracle データベースからメッセージを受信する 2 つの FILE 送信ポートが実行されています。
操作の BizTalk オーケストレーションが実行されています。
操作の実行
BizTalk オーケストレーションを開始すると、次の一連のアクションが実行されます。
NotifyOnListenerStart バインド プロパティが True に設定されているため、次のメッセージが表示されます。
<?xml version="1.0" encoding="utf-8" ?> <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/"> <Info>ListenerStarted</Info> <Source>OracleDBBinding</Source> <Type>Startup</Type> </Notification>タグの
<Info>値は "ListnerStarted" であることに注意してください。 そのため、このメッセージは C:\TestLocation\OtherNotification フォルダーで受信されます。ACCOUNTACTIVITY テーブルにレコードを挿入します。 次のような通知メッセージが表示されます。
<?xml version="1.0" encoding="utf-8" ?> <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/"> <Details> <NotificationDetails> <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName> <Info>1</Info> <QueryId>0</QueryId> </NotificationDetails> </Details> <Info>Insert</Info> <ResourceNames> <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string> </ResourceNames> <Source>Data</Source> <Type>Change</Type> </Notification>タグの
<Info>値は "Insert" であることに注意してください。 そのため、このメッセージは C:\TestLocation\UpsertNotification フォルダーで受信されます。ACCOUNTACTIVITY テーブルのレコードを更新します。 次のような通知メッセージが表示されます。
<?xml version="1.0" encoding="utf-8" ?> <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/"> <Details> <NotificationDetails> <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName> <Info>32</Info> <QueryId>0</QueryId> </NotificationDetails> </Details> <Info>Update</Info> <ResourceNames> <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string> </ResourceNames> <Source>Data</Source> <Type>Change</Type> </Notification>タグの
<Info>値は "Update" であることに注意してください。 そのため、このメッセージは C:\TestLocation\UpsertNotification フォルダーで受信されます。ACCOUNTACTIVITY テーブルからレコードを削除します。 次のような通知メッセージが表示されます。
<?xml version="1.0" encoding="utf-8" ?> <Notification xmlns="http://Microsoft.LobServices.OracleDB/2007/03/Notification/"> <Details> <NotificationDetails> <ResourceName>SCOTT.ACCOUNTACTIVITY</ResourceName> <Info>16</Info> <QueryId>0</QueryId> </NotificationDetails> </Details> <Info>Delete</Info> <ResourceNames> <string xmlns="http://schemas.microsoft.com/2003/10/Serialization/Arrays">SCOTT.ACCOUNTACTIVITY</string> </ResourceNames> <Source>Data</Source> <Type>Change</Type> </Notification>タグの
<Info>値は "Delete" であることに注意してください。 そのため、このメッセージは C:\TestLocation\OtherNotification フォルダーで受信されます。
ベスト プラクティス
BizTalk プロジェクトを展開して構成したら、構成設定をバインド ファイルと呼ばれる XML ファイルにエクスポートできます。 バインド ファイルを生成したら、ファイルから構成設定をインポートして、同じオーケストレーションの送信ポートと受信ポートを作成する必要がないようにすることができます。 バインド ファイルの詳細については、「 Oracle データベース アダプターのバインドを再利用する」を参照してください。
通知メッセージを受信した後の複雑な操作の実行
わかりやすく、理解を深めるために、このトピックのオーケストレーションでは、通知の種類に基づいて異なるフォルダーにメッセージをコピーします。 ただし、実際のシナリオでは、より複雑な操作を実行する必要がある場合があります。 このトピックで説明されているように、同様の手順を実行し、それらを基にして必要な操作を実行できます。 たとえば、ACCOUNTACTIVITY テーブルに対する挿入操作の通知メッセージが表示された場合は、オーケストレーションを変更して別のテーブルにレコードを挿入できます。 このような場合は、[決定] 図形内で適切な変更を行うことができます。