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

fix typo

Browse Source
This commit is contained in:
MindFocus 2024-08-26 15:42:04 +08:00 committed by GitHub
parent 025d5009ca
commit 2b3255bc23
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java
View File

@ -101,9 +101,9 @@ public final class OriginalConfPretreatmentUtil {
boolean isPreCheck = originalConfig.getBool(Key.DRYRUN, false); boolean isPreCheck = originalConfig.getBool(Key.DRYRUN, false);
List<String> allColumns; List<String> allColumns;
if (isPreCheck){ if (isPreCheck){
allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnecttionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo()); allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnectionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo());
}else{ }else{
allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnecttion(), oneTable, connectionFactory.getConnectionInfo()); allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnection(), oneTable, connectionFactory.getConnectionInfo());
} }
LOG.info("table:[{}] all columns:[\n{}\n].", oneTable, LOG.info("table:[{}] all columns:[\n{}\n].", oneTable,
@ -123,7 +123,7 @@ public final class OriginalConfPretreatmentUtil {
ListUtil.makeSureNoValueDuplicate(userConfiguredColumns, false); ListUtil.makeSureNoValueDuplicate(userConfiguredColumns, false);
Connection connection = null; Connection connection = null;
try { try {
connection = connectionFactory.getConnecttion(); connection = connectionFactory.getConnection();
// 检查列是否都为数据库表中正确的列（通过执行一次 select column from table 进行判断） // 检查列是否都为数据库表中正确的列（通过执行一次 select column from table 进行判断）
DBUtil.getColumnMetaData(connection, oneTable,StringUtils.join(userConfiguredColumns, ",")); DBUtil.getColumnMetaData(connection, oneTable,StringUtils.join(userConfiguredColumns, ","));
} finally { } finally {