github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 06:51:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Ensure table name to lower

Browse Source
This commit is contained in:
chase.wc 2018-12-17 11:04:17 +08:00
parent a57425d558
commit 8b538d0a8d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsClientProxy.java
View File

@ -90,14 +90,14 @@ public class AdsClientProxy implements AdsProxy {
throw DataXException.asDataXException(AdsWriterErrorCode.INVALID_CONFIG_VALUE, throw DataXException.asDataXException(AdsWriterErrorCode.INVALID_CONFIG_VALUE,
"url should be in host:port format!"); "url should be in host:port format!");
} }
this.table = table.toLowerCase();
databaseConfig.setHost(hostAndPort[0]); databaseConfig.setHost(hostAndPort[0]);
databaseConfig.setPort(Integer.parseInt(hostAndPort[1])); databaseConfig.setPort(Integer.parseInt(hostAndPort[1]));
databaseConfig.setUser(configuration.getString(Key.USERNAME)); databaseConfig.setUser(configuration.getString(Key.USERNAME));
databaseConfig.setPassword(configuration.getString(Key.PASSWORD)); databaseConfig.setPassword(configuration.getString(Key.PASSWORD));
databaseConfig.setDatabase(configuration.getString(Key.SCHEMA)); databaseConfig.setDatabase(configuration.getString(Key.SCHEMA));
databaseConfig.setTable(Collections.singletonList(table)); databaseConfig.setTable(Collections.singletonList(this.table));
this.table = table; databaseConfig.setColumns(this.table, columns);
databaseConfig.setColumns(table, columns);
// 如果出现insert失败，是否跳过 // 如果出现insert失败，是否跳过
boolean ignoreInsertError = configuration.getBool("ignoreInsertError", false); boolean ignoreInsertError = configuration.getBool("ignoreInsertError", false);