[Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the q…

…uery of jdbc source. (apache#4158) (apache#4210) * [Bug][Connector-V2] Field aliases are not supported in the query of jdbc source. (apache#4158) * [Bug][Connector-V2] Field aliases are not supported in the query of jdbc source. (apache#4158) --------- Co-authored-by: HuPC <[email protected]>
ic4y · Mar 23, 2023 · 36586c9 · 36586c9
1 parent 00b9696
commit 36586c9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java b/...-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java
@@ -151,7 +151,8 @@ private SeaTunnelRowType initTableField(Connection conn) {
             ResultSetMetaData resultSetMetaData =
                     jdbcDialect.getResultSetMetaData(conn, jdbcSourceConfig);
             for (int i = 1; i <= resultSetMetaData.getColumnCount(); i++) {
-                fieldNames.add(resultSetMetaData.getColumnName(i));
+                // Support AS syntax
+                fieldNames.add(resultSetMetaData.getColumnLabel(i));
                 seaTunnelDataTypes.add(jdbcDialectTypeMapper.mapping(resultSetMetaData, i));
             }
         } catch (Exception e) {