You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/03/19 04:20:32 UTC
[incubator-seatunnel] branch dev updated: [Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of jdbc source. (#4158) (#4210)
This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 3d7ff831f [Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of jdbc source. (#4158) (#4210)
3d7ff831f is described below
commit 3d7ff831f90dade78171070bb157e98384ca1591
Author: HuPengCheng <30...@qq.com>
AuthorDate: Sun Mar 19 12:20:24 2023 +0800
[Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of jdbc source. (#4158) (#4210)
* [Bug][Connector-V2] Field aliases are not supported in the query of jdbc source. (#4158)
* [Bug][Connector-V2] Field aliases are not supported in the query of jdbc source. (#4158)
---------
Co-authored-by: HuPC <pe...@percent.cn>
---
.../apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java
index ec1cc5b91..90f630afe 100644
--- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java
+++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java
@@ -151,7 +151,8 @@ public class JdbcSource
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) {