resolve_conflict 表事件

在下表中，说明部分提供 SQL 数据类型。如果您使用 Java 或 .NET 编写脚本，则应该使用相应的数据类型。请参见SQL-Java 数据类型和SQL-.NET 数据类型。

在 SQL 脚本中，可以按名称或使用问号指定事件参数。不建议使用问号，建议您使用命名参数。不能在一个脚本中混合使用名称和问号。如果使用问号，则参数必须按照如下所示的顺序并且仅当没有指定任何后继参数时才是可选的（例如，如果您想使用参数 2，则必须使用参数 1）。如果使用命名参数，则可以按照任何顺序指定任意参数子集。

SQL 脚本的参数名称	说明	顺序（不建议用于 SQL）
s.remote_id	VARCHAR(128)。MobiLink 远程 ID。只有在使用命名参数时才能引用远程 ID。	不适用
s.username	VARCHAR(128)。MobiLink 用户名。	1
s.table	VARCHAR(128)。表名。	2
s.script_version	VARCHAR(128)。可选的 IN 参数，可指定 MobiLink 服务器将用于当前同步的脚本版本字符串传递到此参数。不能使用问号指定此参数。	不适用

无。

在远程数据库上更新行时，MobiLink 客户端将保存原始值的副本。客户端将数据的旧值和新值一同发送到 MobiLink 服务器。

在 MobiLink 服务器接收到更新的行时，它会将原始值与统一数据库中的当前值进行比较。使用 upload_fetch 脚本执行比较。

如果旧的上载值与统一数据库中的当前值不匹配，则该行发生冲突。MobiLink 服务器会将旧值和新值同时插入到统一数据库中，而不是更新该行。分别使用 upload_old_row_insert 和 upload_new_row_insert 脚本处理旧行和新行。

一旦插入值，MobiLink 服务器将执行 resolve_conflict 脚本。它可用于解决冲突。您可以实现您选择的任何一种方案。

每发生一次冲突该脚本执行一次。

或者，您可以不定义 resolve_conflict 脚本，而是通过将冲突解决逻辑写入 end_upload_rows 脚本或 end_upload 表脚本以面向组的方式来解决冲突。

您可以为远程数据库的每个表编写一个 resolve_conflict 脚本。

以下语句定义了适用于 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;

以下对 MobiLink 系统过程的调用在同步脚本版本 ver1 时将名为 resolveConflict 的 Java 方法注册为 resolve_conflict 表事件的脚本。

CALL ml_add_java_table_script(
   'ver1',
   'table1',
   'resolve_conflict',
   'ExamplePackage.ExampleClass.resolveConflict' )

以下是 Java 方法 resolveConflict 示例。它调用的 Java 方法将使用 MobiLink 提供的 JDBC 连接来解决冲突。

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();
	}
    }
}

以下对 MobiLink 系统过程的调用在同步脚本版本 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();
	    }
	}
    }
}

resolve_conflict 表事件

参数

缺省操作

注释

另请参见

SQL 示例

Java 示例

.NET 示例