From d71d7a1d08bdbe470f505304bcad57831d618bf5 Mon Sep 17 00:00:00 2001 From: inrgihc Date: Wed, 2 Jun 2021 11:40:36 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=88=A4=E6=96=AD=E7=9B=AE?= =?UTF-8?q?=E6=A0=87=E4=B8=BAMySQL=E5=8F=98=E5=8C=96=E9=87=8F=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E7=9A=84BUG?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/gitee/dbswitch/data/service/MainService.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MainService.java b/dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MainService.java index 93d65dd4..943126ab 100644 --- a/dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MainService.java +++ b/dbswitch-data/src/main/java/com/gitee/dbswitch/data/service/MainService.java @@ -213,13 +213,11 @@ public class MainService { if (!pks1.isEmpty() && !pks2.isEmpty() && pks1.containsAll(pks2) && pks2.containsAll(pks1)) { if (targetDatabaseType == DatabaseTypeEnum.MYSQL && !isMysqlInodbStorageEngine(properties.getTarget().getTargetSchema(), - tableDescription.getTableName(), writer.getDataSource())) { + sourceProperties.getPrefixTable() + tableDescription.getTableName(), writer.getDataSource())) { this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer); } else { - List fields = mds.queryTableColumnName(tableDescription.getSchemaName(), - tableDescription.getTableName()); - this.doIncreaseSynchronize(tableDescription, sourceProperties, sourceDataSource, writer, pks1, - fields); + List fields = mds.queryTableColumnName(tableDescription.getSchemaName(), tableDescription.getTableName()); + this.doIncreaseSynchronize(tableDescription, sourceProperties, sourceDataSource, writer, pks1, fields); } } else { this.doFullCoverSynchronize(tableDescription, sourceProperties, sourceDataSource, writer);