特定のテーブルの競合を解決する処理を定義します。
次の表の説明では、SQL データ型を示します。Java または .NET でスクリプトを作成する場合、適切な対応するデータ型を使用します。 SQL データ型と Java データ型とSQL データ型と .NET データ型を参照してください。
SQL スクリプトでは、名前または疑問符を使用してイベントパラメータを指定できます。疑問符の使用は推奨されなくなりました。名前付きパラメータを使用することをおすすめします。1 つのスクリプト内で名前と疑問符を混在させることはできません。疑問符を使用する場合、パラメータは以下に示す順に指定する必要があり、後続のパラメータが指定されていない場合のみ省略可能です (たとえば、パラメータ 2 を使用する場合は、パラメータ 1 を使用してください)。名前付きパラメータを使用する場合は、パラメータの任意のサブセットを任意の順に指定できます。
SQL スクリプトのパラメータ名 | 説明 | 順序 (SQL では非推奨) |
---|---|---|
s.remote_id | VARCHAR(128)。Mobile Link リモート ID。名前付きパラメータを使用している場合のみ、リモート ID を参照できます。 | 適用外 |
s.username |
VARCHAR(128)。Mobile Link ユーザ名。 |
1 |
s.table |
VARCHAR(128)。テーブル名。 |
2 |
s.script_version | VARCHAR(128)。Mobile Link サーバが現在の同期に使用しているスクリプトバージョン文字列をこのパラメータに渡すことを指定する、オプションの IN パラメータ。このパラメータの指定に疑問符を使用することはできません。 | 適用外 |
なし。
リモートデータベースでローが更新されると、Mobile Link クライアントは元の値のコピーを保存します。クライアントは、Mobile Link サーバに古い値と新しい値の両方を送信します。
Mobile Link サーバは更新されたローを受信すると、元の値と統合データベース内の現在の値を比較します。比較は、upload_fetch スクリプトを使用して行われます。
アップロードされた古い値が統合データベース内の現在の値と一致しない場合は、そのローに競合が発生します。ローを更新する代わりに、Mobile Link サーバは古い値と新しい値の両方を統合データベースに挿入します。古いローと新しいローは、それぞれスクリプト upload_old_row_insert と upload_new_row_insert を使用して処理されます。
値が挿入されると、Mobile Link サーバは resolve_conflict スクリプトを実行します。ここで、競合を解決できます。どのスキームでも選択して実装できます。
このスクリプトは競合ごとに 1 回実行されます。
別の方法として、resolve_conflict スクリプトを定義する代わりに、end_upload_rows スクリプトまたは end_upload テーブルスクリプトで競合解決論理を使用して、集合指向型の方法で競合を解決することもできます。
リモートデータベースのテーブルごとに、resolve_conflict スクリプトを 1 つ指定できます。
次の文は、Oracle インストール環境用の CustDB サンプルアプリケーションに適した resolve_conflict スクリプトを定義します。このスクリプトは、ストアドプロシージャ ULResolveOrderConflict を呼び出します。
exec ml_add_table_script( 'custdb', 'ULOrder', 'resolve_conflict', 'begin ULResolveOrderConflict(); end; ') CREATE OR REPLACE PROCEDURE ULResolveOrderConflict() AS new_order_id integer; new_status varchar(20); new_notes varchar(50); BEGIN -- approval overrides denial SELECT order_id, status, notes INTO new_order_id, new_status, new_notes FROM ULNewOrder WHERE syncuser_id = SyncUserID; IF new_status = 'Approved' THEN UPDATE ULOrder o SET o.status = new_status, o.notes = new_notes WHERE o.order_id = new_order_id; END IF; DELETE FROM ULOldOrder; DELETE FROM ULNewOrder; END; |
次の Mobile Link システムプロシージャコールは、スクリプトバージョン ver1 を同期するときに、resolveConflict という Java メソッドを resolve_conflict テーブルイベント用のスクリプトとして登録します。
CALL ml_add_java_table_script( 'ver1', 'table1', 'resolve_conflict', 'ExamplePackage.ExampleClass.resolveConflict' ) |
次に示すのは、サンプルの Java メソッド resolveConflict です。このメソッドは、競合を解決するために Mobile Link が提供する JDBC 接続を使用する Java メソッドを呼び出します。
package ExamplePackage; import java.sql.*; import ianywhere.ml.script.*; public class ExampleClass { DBConnectionContext _cc; public ExampleClass( DBConnectionContext cc ) { _cc = cc; } public void resolveConflict( String user, String table ) throws java.sql.SQLException { if( table == "Order" ) { // Insert error information in a table, Connection conn = _cc.getConnection(); String conflictTable = "New" + table; PreparedStatement stmt = conn.prepareStatement( "SELECT order_id, new_status, new_notes " + "FROM " + conflictTable + "WHERE rid = " + _cc.getRemoteID() ); ResultSet rs = stmt.executeQuery(); PreparedStatement updt = conn.prepareStatement( "UPDATE ULOrder SET status = ?, notes = ? WHERE order_id = ?" ); while( rs.next() ) { if( rs.getString( 2 ) == "Approved" ) { updt.setString( 1, rs.getString( 2 ) ); updt.setString( 2, rs.getString( 3 ) ); updt.setInt( 3, rs.getInt( 1 ) ); } } updt.close(); stmt.close(); } } } |
次の Mobile Link システムプロシージャコールは、スクリプトバージョン ver1 を同期するときに、ResolveConflict という .NET メソッドを resolve_conflict テーブルイベント用のスクリプトとして登録します。
CALL ml_add_dnet_table_script( 'ver1', 'table1', 'resolve_conflict', 'TestScripts.Test.ResolveConflict' ) |
次に示すのは、サンプルの .NET メソッド ResolveConflict です。このメソッドは、競合を解決する .NET メソッドを呼び出します。
using System; using iAnywhere.MobiLink.Script; namespace TestScripts { public class Test { DBConnectionContext _cc; public Test( DBConnectionContext cc ) { _cc = cc; } public void ResolveConflict( string user, string table ) { if( table == "Order" ) { // Insert error information in a table, DBConnection conn = _cc.GetConnection(); String conflictTable = "New" + table; DBCommand cmd = conn.CreateCommand(); cmd.CommandText = "SELECT order_id, new_status, new_notes " + "FROM " + conflictTable + "WHERE rid = " + _cc.GetRemoteID(); DBRowReader dr = cmd.ExecuteReader(); DBCommand updt = conn.CreateCommand(); updt.CommandText = "UPDATE ULOrder SET status = ?, notes = ? WHERE order_id = ?"; object[] row; while( (row = dr.NextRow() ) != null ) { if( row.[1].Equals( "Approved" ) ) { updt.Parameters[0] = row[1]; updt.Parameters[1] = row[2]; updt.Parameters[2] = row[0]; } } updt.Close(); cmd.Close(); conn.Close(); } } } } |
![]() |
DocCommentXchange で意見交換できます
|
Copyright © 2013, SAP AG or an SAP affiliate company. - SAP Sybase SQL Anywhere 16.0 |