From aedc679c738f291ac1cb50f9f61ec1016e1dce6b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=83=A1=E6=99=97?= <huhan@yunjiglobal.com>
Date: Thu, 13 Aug 2020 16:15:49 +0800
Subject: [PATCH] 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);