SQL スクリプトでは、名前または疑問符を使用してイベントパラメータを指定できます。疑問符の使用は推奨されなくなりました。名前付きパラメータを使用することをおすすめします。1 つのスクリプト内で名前と疑問符を混在させることはできません。疑問符を使用する場合、パラメータは以下に示す順に指定する必要があり、後続のパラメータが指定されていない場合のみ省略可能です (たとえば、パラメータ 2 を使用する場合は、パラメータ 1 を使用してください)。名前付きパラメータを使用する場合は、パラメータの任意のサブセットを任意の順に指定できます。

なし。

WHERE 句には、同期するプライマリキーカラムをすべて含めます。必要に応じて非プライマリキーカラムを含めることもできます。SET 句には、同期する非プライマリキーカラムをすべて含めます。

名前付きパラメータは任意の順序で使用できます。同じ名前付きパラメータを同じスクリプトで必要な回数だけ使用できます。名前付きパラメータが指定されたスクリプトでは、カラムのサブセットのみを指定できます。

たとえば、MyTable テーブルの upload_update スクリプトは、次のようの記述できます。

UPDATE MyTable
  SET column_2 = { ml r.column_2 }, column_1 = { ml r.column_1 }, ..., column_M = { ml r.column_M }
  WHERE pk_column_1 = { ml r.pk_column_1 } AND ... AND pk_column_N = { ml r.pk_column_N }

リモートデータベースのテーブルごとに、upload_update スクリプトを 1 つ指定できます。

このスクリプトは SQL で実装してください。 Java または .NET のローの処理については、ダイレクトローハンドリングを参照してください。

upload_update スクリプトを使用して競合を検出するには、以下のようにすべての非プライマリキーカラムを WHERE 句に含めます。

UPDATE table-name
SET col1 = {ml r.col1}, col2 = {ml r. col2 } ...
WHERE pk1 = {ml r.pk1} AND pk2 = {ml r.pk2} ...
   AND col1 = {ml o.col1} AND col2 ={ml o.col2} ...

この文では、col1 と col2 はプライマリキーカラムではありませんが、pk1 と pk2 はプライマリキーカラムです。非プライマリキーカラムの 2 番目のセットに渡される値は、更新ローの更新前イメージです。WHERE 句は、リモートデータベースから更新された古い値と、統合データベースの現在の値を比較します。これらの値が一致しないと更新は無視されるので、すでに統合データベースにあった値は保持されます。

このスクリプトは SQL で実装してください。 Java または .NET のローの処理については、ダイレクトローハンドリングを参照してください。

• データスクリプト
• スクリプトのパラメータ
• スクリプトの追加と削除
• upload_update スクリプトによる競合の検出
• upload_update スクリプトによる競合の解決
• upload_delete テーブルイベント
• upload_fetch テーブルイベント
• upload_insert テーブルイベント

この例は、リモートデータベース内の Customer テーブルに対する更新を処理します。このスクリプトは、統合データベース内のテーブル Customer 内の値を更新します。

CALL ml_add_table_script(
  'ver1',
  'table1',
  'upload_update',
'UPDATE Customer 
   SET name = {ml r.name}, rep_id = {ml r.rep_id} 
      WHERE cust_id = {ml o.cust_id}')

次の例は、同様の更新を実行しますが、古い (更新前イメージの) 値を使用して、競合がない場合にのみ更新が行われるようにします。競合がある場合、更新はこの「先入れ勝ち」競合解決ポリシーで無視されます。

CALL ml_add_table_script(
  'ver1',
  'table1',
  'upload_update',
'UPDATE Customer 
   SET name = {ml r.name}, rep_id = {ml r.rep_id} 
      WHERE cust_id = {ml o.cust_id}
        AND name = {ml o.name}
        AND rep_id = {ml o.rep_id}')