github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 17:22:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

replace @table in querySql

Browse Source
This commit is contained in:
胡晗 2020-08-13 16:15:49 +08:00
parent f6afdefa9e
commit aedc679c73
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/CommonRdbmsReader.java
View File

@ -174,6 +174,7 @@ public class CommonRdbmsReader {
TaskPluginCollector taskPluginCollector, int fetchSize) { TaskPluginCollector taskPluginCollector, int fetchSize) {
String querySql = readerSliceConfig.getString(Key.QUERY_SQL); String querySql = readerSliceConfig.getString(Key.QUERY_SQL);
String table = readerSliceConfig.getString(Key.TABLE); String table = readerSliceConfig.getString(Key.TABLE);
querySql = querySql.replaceAll(Constant.TABLE_NAME_PLACEHOLDER, table);
PerfTrace.getInstance().addTaskDetails(taskId, table + "," + basicMsg); PerfTrace.getInstance().addTaskDetails(taskId, table + "," + basicMsg);