1、修改 update group by 字段

1 files changed, 2 insertions, 1 deletions

diff --git a/nms_sync/src/com/nms/util/SyncCommon.java b/nms_sync/src/com/nms/util/SyncCommon.java
index 775fdc4..545beb8 100644
--- a/nms_sync/src/com/nms/util/SyncCommon.java
+++ b/nms_sync/src/com/nms/util/SyncCommon.java
@@ -60,6 +60,7 @@ public class SyncCommon {
 		Integer mode = tableInfo.getMode();

 		StringBuilder sbSql = new StringBuilder();

 		String colums = getColums(columns, TABLE_NAME_ALIAS);

+		String updateIds = StrKit.notBlank(tableInfo.getUpdateIds())?tableInfo.getUpdateIds():idName ;//更新主键，多个逗号分隔，如果没有配置updateIds ,默认为 idName

 		if(event == 2 && mode == 1 && ! columns.contains("*")) {//查询更新记录时 group by 找到符合条件最后一条记录

 			sbSql.append("select ").append(colums).append(",max(log.id) as tableeventlogid").append(" from ").append(tableName).append(" ").append(TABLE_NAME_ALIAS)

 				.append(" left join table_event_log log on log.target_id = ").append(TABLE_NAME_ALIAS).append(".").append(idName)

@@ -67,7 +68,7 @@ public class SyncCommon {
 			if(StrKit.notBlank(where)) {

 				sbSql.append(" and ( ").append(where).append(" )");

 			}

-			sbSql.append(" group by ").append(columns);

+			sbSql.append(" group by ").append(getColums(updateIds,TABLE_NAME_ALIAS));

 			sbSql.append(" order by ").append(" log.id ").append(" asc limit ? ");

 		}else {

 			sbSql.append("select ").append(getColums(columns, TABLE_NAME_ALIAS)).append(",log.id as tableeventlogid").append(" from ").append(tableName).append(" ").append(TABLE_NAME_ALIAS)