dromara/dbswitch
1
0
Fork 0
mirror of https://gitee.com/dromara/dbswitch.git synced 2025-09-22 20:18:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

修复判断目标为MySQL变化量同步的BUG

Browse Source
This commit is contained in:
inrgihc
2021-06-02 11:40:36 +08:00
parent 99da766b37
commit d71d7a1d08
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MainService.java
View File

@@ -213,13 +213,11 @@ public class MainService {
if (!pks1.isEmpty() && !pks2.isEmpty() && pks1.containsAll(pks2) && pks2.containsAll(pks1)) { if (!pks1.isEmpty() && !pks2.isEmpty() && pks1.containsAll(pks2) && pks2.containsAll(pks1)) {
if (targetDatabaseType == DatabaseTypeEnum.MYSQL if (targetDatabaseType == DatabaseTypeEnum.MYSQL
&& !isMysqlInodbStorageEngine(properties.getTarget().getTargetSchema(), && !isMysqlInodbStorageEngine(properties.getTarget().getTargetSchema(),
tableDescription.getTableName(), writer.getDataSource())) { sourceProperties.getPrefixTable() + tableDescription.getTableName(), writer.getDataSource())) {
this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer); this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer);
} else { } else {
List<String> fields = mds.queryTableColumnName(tableDescription.getSchemaName(), List<String> fields = mds.queryTableColumnName(tableDescription.getSchemaName(), tableDescription.getTableName());
tableDescription.getTableName()); this.doIncreaseSynchronize(tableDescription, sourceProperties, sourceDataSource, writer, pks1, fields);
this.doIncreaseSynchronize(tableDescription, sourceProperties, sourceDataSource, writer, pks1,
fields);
} }
} else { } else {
this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer); this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer);