[hotfix-#1853] [connector jdbc] jdbc toInternal methods should proces…

…s data by field name rather than index #1853
DTStack · Dec 18, 2023 · 9bbdb45 · 9bbdb45
1 parent 41989a8
commit 9bbdb45
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcDynamicTableSource.java b/...-base/src/main/java/com/dtstack/chunjun/connector/jdbc/source/JdbcDynamicTableSource.java
@@ -122,9 +122,10 @@ public LookupRuntimeProvider getLookupRuntimeProvider(LookupContext context) {
     public ScanRuntimeProvider getScanRuntimeProvider(ScanContext runtimeProviderContext) {
         final RowType rowType = (RowType) physicalRowDataType.getLogicalType();
         TypeInformation<RowData> typeInformation = InternalTypeInfo.of(rowType);
-
+        ResolvedSchema projectionSchema =
+                ResolvedSchema.physical(rowType.getFieldNames(), physicalRowDataType.getChildren());
         JdbcInputFormatBuilder builder = this.builder;
-        List<Column> columns = resolvedSchema.getColumns();
+        List<Column> columns = projectionSchema.getColumns();
         List<FieldConfig> columnList = new ArrayList<>(columns.size());
         for (Column column : columns) {
             FieldConfig field = new FieldConfig();