gfwleak/nms-nmssync
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1、修改 update group by 字段

Browse Source
This commit is contained in:
fangshunjian
2019-01-13 09:55:38 +06:00
parent c88b984af2
commit 939af8aea6
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
nms_sync/src/com/nms/util/SyncCommon.java
View File

@@ -60,6 +60,7 @@ public class SyncCommon {
Integer mode = tableInfo.getMode(); Integer mode = tableInfo.getMode();
StringBuilder sbSql = new StringBuilder(); StringBuilder sbSql = new StringBuilder();
String colums = getColums(columns, TABLE_NAME_ALIAS); 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 找到符合条件最后一条记录 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) 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) .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)) { if(StrKit.notBlank(where)) {
sbSql.append(" and ( ").append(where).append(" )"); 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 ? "); sbSql.append(" order by ").append(" log.id ").append(" asc limit ? ");
}else { }else {
sbSql.append("select ").append(getColums(columns, TABLE_NAME_ALIAS)).append(",log.id as tableeventlogid").append(" from ").append(tableName).append(" ").append(TABLE_NAME_ALIAS) sbSql.append("select ").append(getColums(columns, TABLE_NAME_ALIAS)).append(",log.id as tableeventlogid").append(" from ").append(tableName).append(" ").append(TABLE_NAME_ALIAS)