From d35e785c39f76e0d6479726ff8bc0c0c4de13019 Mon Sep 17 00:00:00 2001 From: superPiKaChu <1623857502@qq.com> Date: Fri, 30 Sep 2022 15:34:12 +0800 Subject: [PATCH] [hotfix-#1289][jdbc-base] change column size used (#1290) --- .../com/dtstack/chunjun/connector/jdbc/util/JdbcUtil.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util/JdbcUtil.java b/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util/JdbcUtil.java index bb00e0c71e..5ab720af4e 100644 --- a/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util/JdbcUtil.java +++ b/chunjun-connectors/chunjun-connector-jdbc-base/src/main/java/com/dtstack/chunjun/connector/jdbc/util/JdbcUtil.java @@ -525,7 +525,7 @@ public static Pair, List> buildColumnWithMeta( List metaColumnType = tableMetaData.getRight(); List column = jdbcConf.getColumn(); - int size = column.size(); + int size = metaColumnName.size(); List columnNameList = new ArrayList<>(size); List columnTypeList = new ArrayList<>(size); if (column.size() == 1 && ConstantValue.STAR_SYMBOL.equals(column.get(0).getName())) { @@ -559,6 +559,7 @@ private static Pair, List> checkAndModifyColumnWithMeta( String constantType) { // check columnName and modify columnType int size = column.size(); + int metaColumnSize = metaColumnName.size(); List columnNameList = new ArrayList<>(size); List columnTypeList = new ArrayList<>(size); int index = 0; @@ -570,7 +571,7 @@ private static Pair, List> checkAndModifyColumnWithMeta( String name = fieldConf.getName(); String metaType = null; int i = 0; - for (; i < size; i++) { + for (; i < metaColumnSize; i++) { // todo get precision and scale if (metaColumnName.get(i).equalsIgnoreCase(name)) { metaType = metaColumnType.get(i); @@ -581,7 +582,7 @@ private static Pair, List> checkAndModifyColumnWithMeta( break; } } - if (i == size) { + if (i == metaColumnSize) { throw new ChunJunRuntimeException( String.format( "The column[%s] does not exist in the table[%s]",