reset ExtendOutputFormat

Author: todd5167

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/ExtendOutputFormat.java

@@ -70,7 +70,7 @@ public void fillRealIndexes() throws SQLException {
             }
             String column_name = rs.getString("COLUMN_NAME");
             if (StringUtils.isNotBlank(column_name)) {
-                column_name = column_name;
+                column_name = column_name.toUpperCase();
             }
             map.get(indexName).add(column_name);
         }
@@ -94,7 +94,7 @@ public void fillFullColumns() throws SQLException {
         while (rs.next()) {
             String columnName = rs.getString("COLUMN_NAME");
             if (StringUtils.isNotBlank(columnName)) {
-                getFullField().add(columnName);
+                getFullField().add(columnName.toUpperCase());
             }
         }
     }