From e2a64daad893b6ee6278a0f45c60a639fe35940d Mon Sep 17 00:00:00 2001 From: zoemak Date: Sun, 4 Feb 2024 13:07:51 +0800 Subject: [PATCH] =?UTF-8?q?fixed=20issue=20#5037=20,=E4=BD=BF=E7=94=A8clie?= =?UTF-8?q?nt-adapter.rdb=E6=A8=A1=E5=9D=97=E8=BF=9B=E8=A1=8CETL=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=EF=BC=8C=E6=BA=90=E5=BA=93=E4=B8=BAMySQL=EF=BC=8C?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=BA=93=E5=90=8D=E6=9C=89=E7=9F=AD=E6=A8=AA?= =?UTF-8?q?=E7=BA=BF=EF=BC=8C=E8=AF=BB=E5=8F=96=E6=BA=90=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=97=B6=E6=8A=A5SQL=E5=BC=82=E5=B8=B8=20(#5044)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../canal/client/adapter/rdb/service/RdbEtlService.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java b/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java index 18a73404..d3d50689 100644 --- a/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java +++ b/client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java @@ -17,10 +17,7 @@ import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.otter.canal.client.adapter.rdb.config.MappingConfig; import com.alibaba.otter.canal.client.adapter.rdb.config.MappingConfig.DbMapping; import com.alibaba.otter.canal.client.adapter.rdb.support.SyncUtil; -import com.alibaba.otter.canal.client.adapter.support.AbstractEtlService; -import com.alibaba.otter.canal.client.adapter.support.AdapterConfig; -import com.alibaba.otter.canal.client.adapter.support.EtlResult; -import com.alibaba.otter.canal.client.adapter.support.Util; +import com.alibaba.otter.canal.client.adapter.support.*; /** * RDB ETL 操作业务类 @@ -44,7 +41,9 @@ public class RdbEtlService extends AbstractEtlService { */ public EtlResult importData(List params) { DbMapping dbMapping = config.getDbMapping(); - String sql = "SELECT * FROM " + dbMapping.getDatabase() + "." + dbMapping.getTable(); + // 获取源数据源，根据数据库类型拼装数据库名和表名 + DruidDataSource dataSource = DatasourceConfig.DATA_SOURCES.get(config.getDataSourceKey()); + String sql = "SELECT * FROM " + SyncUtil.getDbTableName(dbMapping, dataSource.getDbType()); return importData(sql, params); }