From 2b3255bc230b35666feabd3677a087a179417ea4 Mon Sep 17 00:00:00 2001 From: MindFocus Date: Mon, 26 Aug 2024 15:42:04 +0800 Subject: [PATCH] fix typo --- .../rdbms/writer/util/OriginalConfPretreatmentUtil.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java index 556e50ac..04bf479f 100755 --- a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java +++ b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/OriginalConfPretreatmentUtil.java @@ -101,9 +101,9 @@ public final class OriginalConfPretreatmentUtil { boolean isPreCheck = originalConfig.getBool(Key.DRYRUN, false); List allColumns; if (isPreCheck){ - allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnecttionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo()); + allColumns = DBUtil.getTableColumnsByConn(DATABASE_TYPE,connectionFactory.getConnectionWithoutRetry(), oneTable, connectionFactory.getConnectionInfo()); }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, @@ -123,7 +123,7 @@ public final class OriginalConfPretreatmentUtil { ListUtil.makeSureNoValueDuplicate(userConfiguredColumns, false); Connection connection = null; try { - connection = connectionFactory.getConnecttion(); + connection = connectionFactory.getConnection(); // 检查列是否都为数据库表中正确的列（通过执行一次 select column from table 进行判断） DBUtil.getColumnMetaData(connection, oneTable,StringUtils.join(userConfiguredColumns, ",")); } finally {