From aedc679c738f291ac1cb50f9f61ec1016e1dce6b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=83=A1=E6=99=97?= Date: Thu, 13 Aug 2020 16:15:49 +0800 Subject: [PATCH 1/2] replace @table in querySql --- .../com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java | 1 + 1 file changed, 1 insertion(+) diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java index f3180402..a06b1afb 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java @@ -174,6 +174,7 @@ public class CommonRdbmsReader { TaskPluginCollector taskPluginCollector, int fetchSize) { String querySql = readerSliceConfig.getString(Key.QUERY_SQL); String table = readerSliceConfig.getString(Key.TABLE); + querySql = querySql.replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table); PerfTrace.getInstance().addTaskDetails(taskId, table + "," + basicMsg); From 1282ab2c8d6e6f57c44ad20a09f1c6dc7327d140 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=83=A1=E6=99=97?= Date: Thu, 13 Aug 2020 16:24:24 +0800 Subject: [PATCH 2/2] optimize code --- .../alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java index a06b1afb..fe0e5577 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java @@ -172,9 +172,8 @@ public class CommonRdbmsReader { public void startRead(Configuration readerSliceConfig, RecordSender recordSender, TaskPluginCollector taskPluginCollector, int fetchSize) { - String querySql = readerSliceConfig.getString(Key.QUERY_SQL); String table = readerSliceConfig.getString(Key.TABLE); - querySql = querySql.replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table); + String querySql = readerSliceConfig.getString(Key.QUERY_SQL).replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table); PerfTrace.getInstance().addTaskDetails(taskId, table + "," + basicMsg);