版本：Next

JDBC

JDBC 源连接器

描述

通过 JDBC 读取外部数据源数据。

提示

警告：为了符合许可证要求，您必须自己提供数据库驱动程序，复制到 $SEATUNNEL_HOME/lib/ 目录以使其工作。

例如，如果您使用 MySQL，应下载并复制 mysql-connector-java-xxx.jar 到 $SEATUNNEL_HOME/lib/。对于 Spark/Flink，您还应将其复制到 $SPARK_HOME/jars/ 或 $FLINK_HOME/lib/。

使用依赖

对于 Spark/Flink 引擎

您需要确保 jdbc 驱动程序 jar 包已放置在目录 ${SEATUNNEL_HOME}/plugins/ 中。

对于 SeaTunnel Zeta 引擎

您需要确保 jdbc 驱动程序 jar 包已放置在目录 ${SEATUNNEL_HOME}/lib/ 中。

关键特性

支持查询 SQL 并可以实现投影效果。

选项

参数名	类型	必须	默认值	描述
url	String	是	-	JDBC 连接的 URL。参考示例：jdbc:postgresql://localhost/test
driver	String	是	-	用于连接到远程数据源的 jdbc 类名，如果您使用 MySQL，值为 `com.mysql.cj.jdbc.Driver`。
username	String	否	-	用户名
password	String	否	-	密码
query	String	否	-	查询语句
compatible_mode	String	否	-	数据库的兼容模式，当数据库支持多种兼容模式时需要。例如，使用 OceanBase 数据库时，需要将其设置为 'mysql' 或 'oracle'。使用 starrocks 时，需要将其设置为 `starrocks`
dialect	String	否	-	指定的方言，如果不存在，仍然根据 url 获取，优先级高于 url。例如，使用 starrocks 时，需要将其设置为 `starrocks`
connection_check_timeout_sec	Int	否	30	等待用于验证连接的数据库操作完成的时间（秒）。
partition_column	String	否	-	用于分割数据的列名。
partition_upper_bound	Long	否	-	partition_column 的最大值用于扫描，如果未设置，SeaTunnel 将查询数据库获取最大值。
partition_lower_bound	Long	否	-	partition_column 的最小值用于扫描，如果未设置，SeaTunnel 将查询数据库获取最小值。
partition_num	Int	否	job parallelism	不建议使用，正确的方法是通过 `split.size` 控制分割数量注意：此参数仅在使用 `query` 参数时生效。使用 `table_path` 参数时不生效。
decimal_type_narrowing	Boolean	否	true	十进制类型缩小，如果为 true，十进制类型将缩小为 int 或 long 类型（如果没有精度损失）。目前仅支持 Oracle。请参考下面的 `decimal_type_narrowing`
int_type_narrowing	Boolean	否	true	Int 类型缩小，如果为 true，tinyint(1) 类型将缩小为布尔类型（如果没有精度损失）。目前支持 MySQL。请参考下面的 `int_type_narrowing`
handle_blob_as_string	Boolean	否	false	如果为 true，BLOB 类型将转换为 STRING 类型。仅支持 Oracle 数据库。这对于处理超过默认大小限制的 Oracle 中的大 BLOB 字段很有用。将 Oracle 的 BLOB 字段传输到 Doris 等系统时，将其设置为 true 可以使数据传输更高效。
use_select_count	Boolean	否	false	在动态块分割阶段使用 select count 来获取表计数，而不是其他方法。这目前仅适用于 jdbc-oracle。在这种情况下，当使用 sql 从分析表更新统计信息更快时，直接使用 select count
skip_analyze	Boolean	否	false	在动态块分割阶段跳过表计数分析。这目前仅适用于 jdbc-oracle。在这种情况下，您定期安排分析表 sql 来更新相关表统计信息，或您的表数据不经常更改
use_regex	Boolean	否	false	控制 table_path 的正则表达式匹配。设置为 `true` 时，table_path 将被视为正则表达式模式。设置为 `false` 或未指定时，table_path 将被视为精确路径（无正则表达式匹配）。
fetch_size	Int	否	0	对于返回大量对象的查询，您可以配置查询中使用的行提取大小，以通过减少满足选择条件所需的数据库命中次数来提高性能。零表示使用 jdbc 默认值。
properties	Map	否	-	其他连接配置参数，当 properties 和 URL 具有相同参数时，优先级由驱动程序的具体实现确定。例如，在 MySQL 中，properties 优先于 URL。
table_path	String	否	-	表的完整路径，您可以使用此配置代替 `query`。示例： `- mysql: "testdb.table1"` `- oracle: "test_schema.table1"` `- sqlserver: "testdb.test_schema.table1"` `- postgresql: "testdb.test_schema.table1"` `- iris: "test_schema.table1"`
table_list	Array	否	-	要读取的表列表，您可以使用此配置代替 `table_path`
where_condition	String	否	-	所有表/查询的通用行过滤条件，必须以 `where` 开头。例如 `where id > 100`
split.size	Int	否	8096	一个分割中有多少行，捕获的表在读取时被分成多个分割。注意：此参数仅在使用 `table_path` 参数时生效。使用 `query` 参数时不生效。
common-options		否	-	源插件通用参数，请参考源通用选项详见。

表匹配

JDBC 源连接器支持两种方式指定表：

精确表路径：使用 table_path 指定单个表及其完整路径。
```
table_path = "testdb.table1"
```

正则表达式：使用 table_path 与正则表达式模式匹配多个表。

table_path = "testdb.table\\d+"  # 匹配 table1, table2, table3 等
use_regex = true

表名的正则表达式支持

JDBC 连接器支持使用正则表达式匹配多个表。此功能允许您使用单个源配置处理多个表。

配置

要对表路径使用正则表达式匹配：

设置 use_regex = true 以启用正则表达式匹配
如果未设置 use_regex 或设置为 false，连接器将把 table_path 视为精确路径（无正则表达式匹配）

正则表达式语法注意事项

路径分隔符：点 (.) 被视为数据库、模式和表名之间的分隔符。
转义点：如果您需要在正则表达式中使用点 (.) 作为通配符来匹配任何字符，必须用反斜杠 (\.) 转义。
路径格式：对于 database.table 或 database.schema.table 之类的路径，最后一个未转义的点将表模式与数据库/模式模式分开。
模式示例：
- test.table\\d+ - 匹配 test 数据库中的 table1、table2 等表
- test.* - 匹配 test 数据库中的所有表（用于整个数据库同步）
- postgres.public.test_db_\.* - 匹配 postgres 数据库的 public 模式中以 test_db_ 开头的所有表

示例

source {
  Jdbc {
    url = "jdbc:mysql://localhost:3306/test"
    driver = "com.mysql.cj.jdbc.Driver"
    user = "root"
    password = "password"

    table_list = [
      {
        # 正则表达式匹配 - 匹配 test 数据库中的任何表
        table_path = "test.*"
        use_regex = true
      },
      {
        # 正则表达式匹配 - 匹配名称为 "user" 后跟数字的表
        table_path = "test.user\\d+"
        use_regex = true
      },
      {
        # 精确匹配 - 简单表名
        table_path = "test.config"
        # use_regex 未指定，默认为 false
      },
    ]
  }
}

多表同步

使用正则表达式时，连接器将从所有匹配的表中读取数据。每个表将被独立处理，数据将在输出中合并。

多表同步的示例配置：

Jdbc {
    url = "jdbc:mysql://localhost/test"
    driver = "com.mysql.cj.jdbc.Driver"
    user = "root"
    password = "123456"

    # 使用显式配置的正则表达式
    table_list = [
      {
        table_path = "testdb.table\\d+"
        use_regex = true
      }
    ]
}

decimal_type_narrowing

十进制类型缩小，如果为 true，十进制类型将缩小为 int 或 long 类型（如果没有精度损失）。目前仅支持 Oracle。

例如：

decimal_type_narrowing = true

Oracle	SeaTunnel
NUMBER(1, 0)	Boolean
NUMBER(6, 0)	INT
NUMBER(10, 0)	BIGINT

decimal_type_narrowing = false

Oracle	SeaTunnel
NUMBER(1, 0)	Decimal(1, 0)
NUMBER(6, 0)	Decimal(6, 0)
NUMBER(10, 0)	Decimal(10, 0)

int_type_narrowing

Int 类型缩小，如果为 true，tinyint(1) 类型将缩小为布尔类型（如果没有精度损失）。目前支持 MySQL。

例如：

int_type_narrowing = true

MySQL	SeaTunnel
TINYINT(1)	Boolean

int_type_narrowing = false

MySQL	SeaTunnel
TINYINT(1)	TINYINT

dialect [string]

指定的方言，如果不存在，仍然根据 url 获取，优先级高于 url。例如，使用 starrocks 时，需要将其设置为 starrocks。类似地，使用 mysql 时，需要将其值设置为 mysql。

如果 SeaTunnel 不支持某个方言，它将使用默认方言 GenericDialect。只需确保您提供的驱动程序支持您想要连接的数据库。

方言列表

	方言名称
Greenplum	DB2	Dameng
Gbase8a	HIVE	KingBase
MySQL	StarRocks	Oracle
Phoenix	Postgres	Redshift
SapHana	Snowflake	Sqlite
SqlServer	Tablestore	Teradata
Vertica	OceanBase	XUGU
IRIS	Inceptor	Highgo

并行读取器

JDBC 源连接器支持从表中并行读取数据。SeaTunnel 将使用某些规则分割表中的数据，这些数据将交给读取器进行读取。读取器的数量由 parallelism 选项确定。

分割键规则：

如果 partition_column 不为 null，它将用于计算分割。该列必须在支持的分割数据类型中。
如果 partition_column 为 null，seatunnel 将从表中读取模式并获取主键和唯一索引。如果主键和唯一索引中有多个列，将使用支持的分割数据类型中的第一列来分割数据。例如，表有主键(nn guid, name varchar)，因为 guid 不在支持的分割数据类型中，所以列 name 将用于分割数据。

支持的分割数据类型：

String
Number(int, bigint, decimal, ...)
Date

提示

如果表无法分割（例如，表没有主键或唯一索引，且未设置 partition_column），它将以单并发运行。
使用 table_path 替换 query 进行单表读取。如果需要读取多个表，请使用 table_list。当基于 query 推断主键时，主键继承自结果集中第一列所在的底层表；如果 query 包含多表 JOIN 或同时从多张表读取，该主键对整个 JOIN 结果集的唯一性不作严格保证。

附录

以上参数有一些参考值。

数据源	驱动	URL	Maven
mysql	com.mysql.cj.jdbc.Driver	jdbc:mysql://localhost:3306/test	https://mvnrepository.com/artifact/mysql/mysql-connector-java
postgresql	org.postgresql.Driver	jdbc:postgresql://localhost:5432/postgres	https://mvnrepository.com/artifact/org.postgresql/postgresql
dm	dm.jdbc.driver.DmDriver	jdbc:dm://localhost:5236	https://mvnrepository.com/artifact/com.dameng/DmJdbcDriver18
oracle	oracle.jdbc.OracleDriver	jdbc:oracle:thin:@localhost:1521/xepdb1	https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8
sqlserver	com.microsoft.sqlserver.jdbc.SQLServerDriver	jdbc:sqlserver://localhost:1433	https://mvnrepository.com/artifact/com.microsoft.sqlserver/mssql-jdbc
starrocks	com.mysql.cj.jdbc.Driver	jdbc:mysql://localhost:3306/test	https://mvnrepository.com/artifact/mysql/mysql-connector-java
kingbase	com.kingbase8.Driver	jdbc:kingbase8://localhost:54321/db_test	https://repo1.maven.org/maven2/cn/com/kingbase/kingbase8/8.6.0/kingbase8-8.6.0.jar
oceanbase	com.oceanbase.jdbc.Driver	jdbc:oceanbase://localhost:2881	https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/2.4.12/oceanbase-client-2.4.12.jar
hive	org.apache.hive.jdbc.HiveDriver	jdbc:hive2://localhost:10000	https://repo1.maven.org/maven2/org/apache/hive/hive-jdbc/3.1.3/hive-jdbc-3.1.3-standalone.jar

示例

简单

情况 1

Jdbc {
    url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
    driver = "com.mysql.cj.jdbc.Driver"
    connection_check_timeout_sec = 100
    user = "root"
    password = "123456"
    query = "select * from type_bin"
}

情况 2 在动态块分割阶段使用 select count(*) 代替分析表来计算表行数

Jdbc {
    url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
    driver = "com.mysql.cj.jdbc.Driver"
    connection_check_timeout_sec = 100
    user = "root"
    password = "123456"
    use_select_count = true
    query = "select * from type_bin"
}

情况 3 使用 select NUM_ROWS from all_tables 获取表行数但跳过分析表

Jdbc {
    url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
    driver = "com.mysql.cj.jdbc.Driver"
    connection_check_timeout_sec = 100
    user = "root"
    password = "123456"
    skip_analyze = true
    query = "select * from type_bin"
}

情况 4 Oracle 源与 BLOB 作为字符串到 Doris Sink

此示例演示了在传输到 Doris 时如何将 Oracle 的 BLOB 数据作为字符串处理。这对于大型 BLOB 字段很有用。

env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  Jdbc {
    driver = oracle.jdbc.driver.OracleDriver
    url = "jdbc:oracle:thin:@oracle_host:1521/SERVICE_NAME"
    user = "username"
    password = "password"
    query = "SELECT ID, NAME, CONTENT_BLOB FROM MY_TABLE"
    handle_blob_as_string = true  # 为 Oracle 启用 BLOB 到字符串转换
  }
}

变更日志

Change Log

Change	Commit	Version
[Fix][Connector-xugu] Fix several bugs in the xugu connector (#9820)	https://github.com/apache/seatunnel/commit/75c9adb280	dev
[Feature][Transform-V2] Support `AT TIME ZONE` statement for sql transform (#9784)	https://github.com/apache/seatunnel/commit/ad5278c5bb	dev
[Feature][Transform-V2] Support vector series sql function (#9765)	https://github.com/apache/seatunnel/commit/a40114cf7a	2.3.12
[Chore] fix typos filed -> field (#9757)	https://github.com/apache/seatunnel/commit/e3e1c67d29	2.3.12
[Feature][Core] Add plugin directory support for each connector (#9650)	https://github.com/apache/seatunnel/commit/4beb2b9336	2.3.12
[Improve][Core] Update apache common to apache common lang3 (#9694)	https://github.com/apache/seatunnel/commit/6e5737c1ec	2.3.12
[Improve][API] Optimize the enumerator API semantics and reduce lock calls at the connector level (#9671)	https://github.com/apache/seatunnel/commit/9212a77140	2.3.12
[Fix][connector-jdbc] prevent precision loss in Float to BigDecimal conversion (#9670)	https://github.com/apache/seatunnel/commit/6e11285bf6	2.3.12
[Fix][Connector-Jdbc] Supports reading and writing Postgres network dress types (#9618)	https://github.com/apache/seatunnel/commit/3dc79c1ddf	2.3.12
[improve] jdbc options (#9541)	https://github.com/apache/seatunnel/commit/d041e5fb32	2.3.12
[Fix][Connector-Jdbc]Fixed Vertica data source cannot upsert data. (#9607)	https://github.com/apache/seatunnel/commit/7b4d05171b	2.3.12
[Fix][Connectors-Jdbc] Postgres supports streaming and batch reading and writing of the `interval` data type (#9590)	https://github.com/apache/seatunnel/commit/58ab917024	2.3.12
[Feature][Connectors-v2] Optimize the size of CDC JAR Files (#9546)	https://github.com/apache/seatunnel/commit/1dd19c6823	2.3.12
[improve][Connector-jdbc] add comments when schema not include all columns (#9559)	https://github.com/apache/seatunnel/commit/02d2b69d85	2.3.12
[Hotfix][Connector-Jdbc] Write MySQL to support set collection data type (#9553)	https://github.com/apache/seatunnel/commit/3836c97a62	2.3.12
[Feature][Jdbc] Support read multiple tables by regular expressions (#9380)	https://github.com/apache/seatunnel/commit/670a52a918	2.3.12
[bugfix][Connector-V2] Fixed the load driver inaccurate situation (#9468)	https://github.com/apache/seatunnel/commit/c6639e81fe	2.3.12
[Fix][Connector-V2] Fix OceanBase Oracle create unsupported data type (#9383)	https://github.com/apache/seatunnel/commit/f4178c72f1	2.3.12
[improve][Connector-V2] delete jdbc param support_upsert_by_query_primary_key_exist (#9408)	https://github.com/apache/seatunnel/commit/d247fe1d8d	2.3.12
[Feature][Connector-V2] Jdbc mysql support read tinyint(1) to byte(tinyint) (#9373)	https://github.com/apache/seatunnel/commit/7b87aa6f12	2.3.12
[Improve] JdbcInputFormat nextRecord Exception throw TableId (#9374)	https://github.com/apache/seatunnel/commit/484aef593d	2.3.12
[Feature][Connector-V2][JDBC] Add presto/trino dialect (#9388)	https://github.com/apache/seatunnel/commit/3cac2bd126	2.3.12
[Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead of bytes (#9305)	https://github.com/apache/seatunnel/commit/454a88f81a	2.3.11
[Fix][Connector-jdbc] Fix postgresql sink trying to update unique key (#9293) (#9298)	https://github.com/apache/seatunnel/commit/d0c1de8357	2.3.11
[Fix][Connector-V2] Fix oceanbase mysql jdbc sink create statement error (#9267)	https://github.com/apache/seatunnel/commit/79f8125ea6	2.3.11
[Feature][Transform] Support define sink column type (#9114)	https://github.com/apache/seatunnel/commit/ab7119e507	2.3.11
[Feature][Checkpoint] Add check script for source/sink state class serialVersionUID missing (#9118)	https://github.com/apache/seatunnel/commit/4f5adeb1c7	2.3.11
[Fix][API] Fixed not invoke the `SinkAggregatedCommitter`'s init method (#9070)	https://github.com/apache/seatunnel/commit/df0d11d632	2.3.11
[Fix][Connector-V2] Fix SqlServer create table when database with dot (#9007)	https://github.com/apache/seatunnel/commit/e09445c789	2.3.11
[Fix][Connector-V2][OceanBase] oceanbase vector support simple vector index (#9072)	https://github.com/apache/seatunnel/commit/4140cd1d8f	2.3.11
[Improve][Connector-V2] Optimize dialect selection in jdbc (#8820)	https://github.com/apache/seatunnel/commit/92c62c5e63	2.3.11
[Fix][JDBC] fix jdbc default connection parameter invalid (#8185)	https://github.com/apache/seatunnel/commit/f85eb78b37	2.3.11
[Hotfix][Jdbc] Fix mysql tinyint(1) type mapping for TypeMapper (#9012)	https://github.com/apache/seatunnel/commit/5f85d7668a	2.3.11
[Feature][Jdbc] Add String type column split Support by charset-based splitting algorithm (#9002)	https://github.com/apache/seatunnel/commit/dbe41e74cd	2.3.11
[Fix][Paimon] nullable and comment attribute was lost during automatic table creation (#9020)	https://github.com/apache/seatunnel/commit/eb54fdd52c	2.3.11
[Fix][Connector-JDBC] Fix JDBC driver selection for data source connections (#8986)	https://github.com/apache/seatunnel/commit/a5aafa7301	2.3.11
[Improve][Jdbc] Upgrade sap-hana driver from 2.14.7 to 2.23.10 (#9013)	https://github.com/apache/seatunnel/commit/9ba9f169be	2.3.11
[Feature][Jdbc] Support sink ddl for sqlserver #8114 (#8936)	https://github.com/apache/seatunnel/commit/30aa485b38	2.3.10
[Fix][Connector-V2] Fix parse SqlServer JDBC Url error (#8784)	https://github.com/apache/seatunnel/commit/373d2162d3	2.3.10
[Improve][Jdbc] Support upsert for opengauss (#8627)	https://github.com/apache/seatunnel/commit/56110bf392	2.3.10
[Improve][Jdbc] Remove useless utils. (#8793)	https://github.com/apache/seatunnel/commit/36a7533e85	2.3.10
[Improve][Jdbc] Improve catalog connection cache (#8626)	https://github.com/apache/seatunnel/commit/6205065b25	2.3.10
[Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear (#8653)	https://github.com/apache/seatunnel/commit/cf35eecdfc	2.3.10
[Feature][Jdbc] Support sink ddl for dameng (#8380)	https://github.com/apache/seatunnel/commit/5ff3427428	2.3.10
[Improve] restruct connector common options (#8634)	https://github.com/apache/seatunnel/commit/f3499a6eeb	2.3.10
[Improve][Jdbc] Remove oracle 'v$database' query (#8571)	https://github.com/apache/seatunnel/commit/3cf09f61ca	2.3.10
[Fix][Connector-V2] Postgres support for multiple primary keys (#8526)	https://github.com/apache/seatunnel/commit/04db40d973	2.3.10
[Feature][JDBC source] pg support char types (#8420)	https://github.com/apache/seatunnel/commit/776ac94478	2.3.9
[Feature][Jdbc] Support sink ddl for postgresql (#8276)	https://github.com/apache/seatunnel/commit/353bbd21a1	2.3.9
[Feature][Connector-V2] Support the jdbc connector for highgo db (#8282)	https://github.com/apache/seatunnel/commit/aa381cbfb4	2.3.9
[Improve][Jdbc] Support nvarchar in dm (#8270)	https://github.com/apache/seatunnel/commit/2f1c54ee2e	2.3.9
[Improve][Connector-v2] Use regex to match filedName placeholders in jdbc sink (#8222)	https://github.com/apache/seatunnel/commit/c02d4fed36	2.3.9
[Improve][Connector-V2] Support read comment when jdbc dialect without catalog (#8196)	https://github.com/apache/seatunnel/commit/567cd54de5	2.3.9
[Improve][Connector-V2] The interface supports jdbc respects the target database field type (#8031)	https://github.com/apache/seatunnel/commit/1de056a9a4	2.3.9
[Improve][dist]add shade check rule (#8136)	https://github.com/apache/seatunnel/commit/51ef800016	2.3.9
[Improve][Jdbc] Improve ddl write validate (#8158)	https://github.com/apache/seatunnel/commit/9cdaacddd9	2.3.9
[Feature][Jdbc] Add Jdbc default dialect for all jdbc series database without dialect (#8132)	https://github.com/apache/seatunnel/commit/399eabcd3f	2.3.9
[Improve][Jdbc] Refactor ddl change (#8134)	https://github.com/apache/seatunnel/commit/e1f0a238f7	2.3.9
[Feature][Core] Rename `result_table_name`/`source_table_name` to `plugin_input/plugin_output` (#8072)	https://github.com/apache/seatunnel/commit/c7bbd322db	2.3.9
[Improve][Connector-V2] Improve schema evolution on column insert after for mysql-jdbc (#8017)	https://github.com/apache/seatunnel/commit/3fb05da365	2.3.9
[Feature][Core] Support cdc task ddl restore for zeta (#7463)	https://github.com/apache/seatunnel/commit/8e322281ed	2.3.9
[Feature][transform] transform support explode (#7928)	https://github.com/apache/seatunnel/commit/132278c06a	2.3.9
[Feature][Connector-v2] Support schema evolution for Oracle connector (#7908)	https://github.com/apache/seatunnel/commit/79406bcc2f	2.3.9
[Improve][Connector-V2] Improve jdbc merge table from path and query when type is decimal (#7917)	https://github.com/apache/seatunnel/commit/8baa012ced	2.3.9
[Fix][Connector-V2] Fix hana type loss of precision (#7912)	https://github.com/apache/seatunnel/commit/18dcca36cd	2.3.9
[Feature][Connector-V2] Jdbc DB2 support upsert SQL (#7879)	https://github.com/apache/seatunnel/commit/139919334d	2.3.9
[Improve][Jdbc] Optimize index name conflicts when create table for postgresql (#7875)	https://github.com/apache/seatunnel/commit/312ee866fb	2.3.9
[Improve][Jdbc] Support postgresql inet type. (#7820)	https://github.com/apache/seatunnel/commit/25b68b3623	2.3.9
[Fix][Connector-V2]Oceanbase vector database is added as the source server (#7832)	https://github.com/apache/seatunnel/commit/258f931765	2.3.9
[Feature][connector-v2]Support opengauss jdbc connnector using opengauss driver. (#7622)	https://github.com/apache/seatunnel/commit/bbf643772e	2.3.9
[Improve][Jdbc] Support save mode for the sink of jdbc-dm (#7814)	https://github.com/apache/seatunnel/commit/b87d732c81	2.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)	https://github.com/apache/seatunnel/commit/6b7c53d03c	2.3.9
[Feature][Connector-V2] SqlServer support user-defined type (#7706)	https://github.com/apache/seatunnel/commit/fb89033273	2.3.8
[Hotfix][CDC] Fix ddl duplicate execution error when config multi_table_sink_replica (#7634)	https://github.com/apache/seatunnel/commit/23ab3edbbb	2.3.8
[Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon writing efficiency (#7335)	https://github.com/apache/seatunnel/commit/bc0326cba8	2.3.8
[Fix][Connector-V2] Fix jdbc test case failed (#7690)	https://github.com/apache/seatunnel/commit/4f5d27f625	2.3.8
[Improve][Jdbc] Jdbc truncate table should check table not database (#7654)	https://github.com/apache/seatunnel/commit/0c0eb7e41b	2.3.8
[Feature][Connector-V2] jdbc saphana source tablepath support view and synonym (#7670)	https://github.com/apache/seatunnel/commit/7e0c20a488	2.3.8
[Fix][Connector-v2] Throw Exception in sql query for JdbcCatalog in table or db exists query (#7651)	https://github.com/apache/seatunnel/commit/70ec59ce0e	2.3.8
[Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks connector (#7578)	https://github.com/apache/seatunnel/commit/020aab422e	2.3.8
[Feature] Support tidb cdc connector source #7199 (#7477)	https://github.com/apache/seatunnel/commit/87ec786bd6	2.3.8
[bugfix] fix oracle query table length (#7627)	https://github.com/apache/seatunnel/commit/2e002ce09b	2.3.8
[Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which used the table_list (#7544)	https://github.com/apache/seatunnel/commit/555028217a	2.3.8
[Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc (#7530)	https://github.com/apache/seatunnel/commit/657fe69b26	2.3.8
[Improve][Connector-v2] Release resource in closeStatements even exception occurred in executeBatch (#7533)	https://github.com/apache/seatunnel/commit/590f7d110d	2.3.8
[Fix][Connector-V2] Fix jdbc query sql can not get table path (#7484)	https://github.com/apache/seatunnel/commit/8e0ca8f725	2.3.8
[Feature][Connector-V2] Add `decimal_type_narrowing` option in jdbc (#7461)	https://github.com/apache/seatunnel/commit/696f2948fa	2.3.8
[Improve][Connector-V2] update vectorType (#7446)	https://github.com/apache/seatunnel/commit/1bba72385b	2.3.8
[Improve][API] Move catalog open to SaveModeHandler (#7439)	https://github.com/apache/seatunnel/commit/8c2c5c79a1	2.3.8
[FIX][E2E]Modify the OceanBase test case to the latest imageChange image (#7452)	https://github.com/apache/seatunnel/commit/6abb83deab	2.3.8
[Feature][Connector-V2][OceanBase] Support vector types on OceanBase (#7375)	https://github.com/apache/seatunnel/commit/a6b188d552	2.3.8
[Improve][Connector-V2] Remove system table limit (#7391)	https://github.com/apache/seatunnel/commit/adf888e008	2.3.8
[Fix] Fix oracle sample data from column error (#7340)	https://github.com/apache/seatunnel/commit/2130e0d5ad	2.3.8
[Improve][Connector-V2] Close all ResultSet after used (#7389)	https://github.com/apache/seatunnel/commit/853e973212	2.3.8
[Hotifx][Jdbc] Fix MySQL unsupport 'ZEROFILL' column type (#7407)	https://github.com/apache/seatunnel/commit/7130382123	2.3.8
[Improvement] add starrocks jdbc dialect (#7294)	https://github.com/apache/seatunnel/commit/b5140f598e	2.3.8
[Hotfix][Connector] Fix jdbc compile error (#7359)	https://github.com/apache/seatunnel/commit/2769ed5029	2.3.7
[Fix][Connector-V2][OceanBase] Remove OceanBase catalog's dependency on mysql driver (#7311)	https://github.com/apache/seatunnel/commit/3130ae089e	2.3.7
[Improve][Jdbc] Skip all index when auto create table to improve performance of write (#7288)	https://github.com/apache/seatunnel/commit/dc3c23981b	2.3.7
[Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333)	https://github.com/apache/seatunnel/commit/16eeb1c123	2.3.7
[Improve][Jdbc] Merge user config primary key when create table (#7313)	https://github.com/apache/seatunnel/commit/819c685651	2.3.7
[Improve][Connector-v2] Optimize the way of databases and tables are checked for existence (#7261)	https://github.com/apache/seatunnel/commit/f012b2a6f0	2.3.7
[Feature][Jdbc] Support hive compatibleMode add inceptor dialect (#7262)	https://github.com/apache/seatunnel/commit/31e59cdf82	2.3.6
[Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and oracle-cdc (#7248)	https://github.com/apache/seatunnel/commit/0d08b20061	2.3.6
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)	https://github.com/apache/seatunnel/commit/c4ca74122c	2.3.6
[Fix] Fix Hana type converter decimal scale is 0 convert to int error (#7167)	https://github.com/apache/seatunnel/commit/6e33a97c86	2.3.6
[Improve][Jdbc] Support write unicode text into sqlserver (#7159)	https://github.com/apache/seatunnel/commit/e44e8b93bc	2.3.6
[Improve][Jdbc] Remove user info in catalog-table options (#7178)	https://github.com/apache/seatunnel/commit/4e001be25c	2.3.6
[Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)	https://github.com/apache/seatunnel/commit/dbdbdf015b	2.3.6
[Feature][Connector-V2] Support jdbc hana catalog and type convertor (#6950)	https://github.com/apache/seatunnel/commit/d663398739	2.3.6
[Improve] Change catalog table log to debug level (#7136)	https://github.com/apache/seatunnel/commit/b111d2f843	2.3.6
[Improve][Connector-V2] Support schema evolution for mysql-cdc and mysql-jdbc (#6929)	https://github.com/apache/seatunnel/commit/cf91e51fc7	2.3.6
[connector-jdbc][bugfix] fix sqlServer create table comment special string bug (#7024)	https://github.com/apache/seatunnel/commit/403564db13	2.3.6
[bugfix] fix pgsql create table comment special string bug (#7022)	https://github.com/apache/seatunnel/commit/9fe844f62a	2.3.6
[connector-jdbc][bugfix] fix oracle create table comment special string bug (#7012)	https://github.com/apache/seatunnel/commit/a9e0f67873	2.3.6
[bugfix] fix mysql create table comment special string bug (#6998)	https://github.com/apache/seatunnel/commit/904e9cf785	2.3.6
[Improve][Jdbc]sink sql support custom field.(#6515) (#6525)	https://github.com/apache/seatunnel/commit/ef3e61dbc4	2.3.6
[Feature][Jdbc] Support redshift catalog (#6992)	https://github.com/apache/seatunnel/commit/8d5cbcee74	2.3.6
[Improve][Connector-V2] Clean key name in catalog table (#6942)	https://github.com/apache/seatunnel/commit/a399ef48c6	2.3.6
[Improve][Zeta] Move SaveMode behavior to master (#6843)	https://github.com/apache/seatunnel/commit/80cf91318d	2.3.6
[Improve][Jdbc] Quotes the identifier for table path (#6951)	https://github.com/apache/seatunnel/commit/d70ec61f35	2.3.6
[Hotfix][Jdbc] Fix oracle savemode create table (#6651)	https://github.com/apache/seatunnel/commit/4b6c13e8fc	2.3.6
[Improve][JDBC Source] Fix Split can not be cancel (#6825)	https://github.com/apache/seatunnel/commit/ee3b7c3723	2.3.6
[Feature][Doris] Add Doris type converter (#6354)	https://github.com/apache/seatunnel/commit/5189991843	2.3.6
[Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read (#6684)	https://github.com/apache/seatunnel/commit/868ba4d7c7	2.3.6
[Improve][Connector] Add some sqlserver IDENTITY type for catalog (#6822)	https://github.com/apache/seatunnel/commit/f698396555	2.3.6
[Feature][Jdbc] Support the jdbc connector for InterSystems IRIS (#6797)	https://github.com/apache/seatunnel/commit/46600969bb	2.3.6
[Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated (#6781)	https://github.com/apache/seatunnel/commit/a5609d600e	2.3.6
[Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog (#6771)	https://github.com/apache/seatunnel/commit/df1954d520	2.3.6
[Fix] Fix Oracle type converter handle negative scale in number type (#6758)	https://github.com/apache/seatunnel/commit/6d710690c5	2.3.6
[Improve][mysql-cdc] Support mysql 5.5 versions (#6710)	https://github.com/apache/seatunnel/commit/058f5594a3	2.3.6
[Improve][Jdbc] Add quote identifier for sql (#6669)	https://github.com/apache/seatunnel/commit/849d748d3d	2.3.5
[Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)	https://github.com/apache/seatunnel/commit/cc660206d8	2.3.5
[feature][connector-v2] add xugudb connector (#6561)	https://github.com/apache/seatunnel/commit/80f392afbb	2.3.5
[Hotfix] Fix DEFAULT TABLE problem (#6352)	https://github.com/apache/seatunnel/commit/cdb1856e84	2.3.5
[Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)	https://github.com/apache/seatunnel/commit/2086b0e8a6	2.3.5
[Improve][JDBC] Optimized code style for getting jdbc field types (#6583)	https://github.com/apache/seatunnel/commit/ddca95f32c	2.3.5
[Improve] Add SaveMode log of process detail (#6375)	https://github.com/apache/seatunnel/commit/b0d70ce224	2.3.5
[Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)	https://github.com/apache/seatunnel/commit/d6dcb03bf3	2.3.5
feat: jdbc support copy in statement. (#6443)	https://github.com/apache/seatunnel/commit/ca4a65fc00	2.3.5
[Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)	https://github.com/apache/seatunnel/commit/14405fa8d4	2.3.5
[Improve][API] Unify type system api(data & type) (#5872)	https://github.com/apache/seatunnel/commit/b38c7edcc9	2.3.5
Fix Jdbc sink target table name error (#6269)	https://github.com/apache/seatunnel/commit/2f62235e38	2.3.4
[Improve][JDBC] Use PreparedStatement to sample data from column (#6242)	https://github.com/apache/seatunnel/commit/bd0e66d533	2.3.4
[Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table (#5972)	https://github.com/apache/seatunnel/commit/8156036a2f	2.3.4
[Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)	https://github.com/apache/seatunnel/commit/6f8d0a5040	2.3.4
[Improve] Support `int identity` type in sql server (#6186)	https://github.com/apache/seatunnel/commit/1a8da1c843	2.3.4
[Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data (#6026)	https://github.com/apache/seatunnel/commit/635c24e8b2	2.3.4
[Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc (#5986)	https://github.com/apache/seatunnel/commit/97438b9402	2.3.4
Add date type and float type column split support (#6160)	https://github.com/apache/seatunnel/commit/b9a62e5c3f	2.3.4
[Improve] Extend `SupportResourceShare` to spark/flink (#5847)	https://github.com/apache/seatunnel/commit/c69da93b87	2.3.4
[Feature] Support `uuid` in postgres jdbc (#6185)	https://github.com/apache/seatunnel/commit/f56855098b	2.3.4
[Feature][Connector-V2][Oracle-cdc]Support for oracle cdc (#5196)	https://github.com/apache/seatunnel/commit/aaef22b31b	2.3.4
[Feature][Connector] update pgsql catalog for save mode (#6080)	https://github.com/apache/seatunnel/commit/84ce516929	2.3.4
[Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)	https://github.com/apache/seatunnel/commit/413fa74500	2.3.4
[improve][catalog-postgres] Improve get column sql compatibility (#5664)	https://github.com/apache/seatunnel/commit/23ce592ad2	2.3.4
[Feature][Connector] update oracle catalog for save mode (#6092)	https://github.com/apache/seatunnel/commit/dfbf92769c	2.3.4
[Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types (#6122)	https://github.com/apache/seatunnel/commit/6673f6f771	2.3.4
[Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector (#6116)	https://github.com/apache/seatunnel/commit/dd698c95bf	2.3.4
[Feature][Connector] update sqlserver catalog for save mode (#6086)	https://github.com/apache/seatunnel/commit/edcaacecb1	2.3.4
[Feature][Connector-V2][PostgresSql] add JDBC source support string type as partition key (#6079)	https://github.com/apache/seatunnel/commit/3522eb157c	2.3.4
[Hotfix][Jdbc] Fix jdbc setFetchSize error (#6005)	https://github.com/apache/seatunnel/commit/d41af8a6ed	2.3.4
Support using multiple hadoop account (#5903)	https://github.com/apache/seatunnel/commit/d69d88d1aa	2.3.4
[Feature] Add unsupported datatype check for all catalog (#5890)	https://github.com/apache/seatunnel/commit/b9791285a0	2.3.4
[Hotfix][Split] Fix split key not support BigInteger type	https://github.com/apache/seatunnel/commit/5adf5d2b9a	2.3.4
[Improve] Replace SeaTunnelRowType with TableSchema in the JdbcRowConverter	https://github.com/apache/seatunnel/commit/1cc1b1b8cd	2.3.4
[Hotfix][Jdbc] Fix cdc updates were not filtering same primary key (#5923)	https://github.com/apache/seatunnel/commit/38d3b85814	2.3.4
[Improve]Change System.out.println to log output. (#5912)	https://github.com/apache/seatunnel/commit/bbedb07a9c	2.3.4
[Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath (#5891)	https://github.com/apache/seatunnel/commit/f0b6092c15	2.3.4
Reduce the time cost of getCatalogTable in jdbc (#5908)	https://github.com/apache/seatunnel/commit/51a3737578	2.3.4
[Improve] Improve Jdbc connector error message when datatype unsupported (#5864)	https://github.com/apache/seatunnel/commit/69f79af3a4	2.3.4
[Improve] Rename `getCountSql` to `getExistDataSql` (#5838)	https://github.com/apache/seatunnel/commit/2233b3a381	2.3.4
[Fix] Fix read from Oracle Date type value lose time (#5814)	https://github.com/apache/seatunnel/commit/2d704e36bd	2.3.4
[Improve][JdbcSource] Optimize catalog-table metadata merge logic (#5828)	https://github.com/apache/seatunnel/commit/7d8028a60b	2.3.4
[Improve][Common] Introduce new error define rule (#5793)	https://github.com/apache/seatunnel/commit/9d1b2582b2	2.3.4
[Feature][Hive JDBC Source] Support Hive JDBC Source Connector (#5424)	https://github.com/apache/seatunnel/commit/a64e177d06	2.3.4
[Improve] Remove use `SeaTunnelSink::getConsumedType` method and mark it as deprecated (#5755)	https://github.com/apache/seatunnel/commit/8de7408100	2.3.4
[Improve][Connector] Add field name to `DataTypeConvertor` to improve error message (#5782)	https://github.com/apache/seatunnel/commit/ab60790f0d	2.3.4
[Feature][Oracle] Support XMLTYPE data integration #5716 (#5723)	https://github.com/apache/seatunnel/commit/620f081adb	2.3.4
[Fix] Fix Postgres create table test case failed (#5778)	https://github.com/apache/seatunnel/commit/b98b6bcee3	2.3.4
[Improve][Jdbc] Fix database identifier (#5756)	https://github.com/apache/seatunnel/commit/dbfc8a670a	2.3.4
[Fix] Fix PG will not create index when using auto create table #5721	https://github.com/apache/seatunnel/commit/e5fd88dbe7	2.3.4
[Improve] Remove all useless `prepare`, `getProducedType` method (#5741)	https://github.com/apache/seatunnel/commit/ed94fffbb9	2.3.4
[feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) connector has been realized (#5663)	https://github.com/apache/seatunnel/commit/eff17ccbe5	2.3.4
[Bug][connector-jdbc] Nullable Column source have null data could be unexpected results. (#5560)	https://github.com/apache/seatunnel/commit/3f429e1f0a	2.3.4
[Improve] Add default implement for `SeaTunnelSink::setTypeInfo` (#5682)	https://github.com/apache/seatunnel/commit/86cba87450	2.3.4
[BUG][Connector-V2][Jdbc] support postgresql xml type (#5724)	https://github.com/apache/seatunnel/commit/5f5d4da13f	2.3.4
[Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode (#5697)	https://github.com/apache/seatunnel/commit/879c2aa07c	2.3.4
[Feature][Jdbc] Support read multiple tables (#5581)	https://github.com/apache/seatunnel/commit/33fa8ff248	2.3.4
[Feature] Support multi-table sink (#5620)	https://github.com/apache/seatunnel/commit/81ac173189	2.3.4
[Improve] Remove catalog tag for config file (#5645)	https://github.com/apache/seatunnel/commit/dc509aa080	2.3.4
[Feature][Jdbc] Supporting more ways to configure connection parameters. (#5388)	https://github.com/apache/seatunnel/commit/d31e9478f7	2.3.4
[Feature][Connector-V2][Jdbc] Add OceanBase catalog (#5439)	https://github.com/apache/seatunnel/commit/cd4b7ff7d2	2.3.4
[BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null point (#5517)	https://github.com/apache/seatunnel/commit/103da931f3	2.3.4
Support config column/primaryKey/constraintKey in schema (#5564)	https://github.com/apache/seatunnel/commit/eac76b4e50	2.3.4
[Improve] Refactor CatalogTable and add `SeaTunnelSource::getProducedCatalogTables` (#5562)	https://github.com/apache/seatunnel/commit/41173357f8	2.3.4
[Feature][Jdbc] Add Dameng catalog (#5451)	https://github.com/apache/seatunnel/commit/c23070919c	2.3.4
[Feature] Add tidb datatype convertor (#5440)	https://github.com/apache/seatunnel/commit/61391bda9f	2.3.4
[Feature][Connector-V2] jdbc connector supports Kingbase database (#4803)	https://github.com/apache/seatunnel/commit/9538567159	2.3.4
[Feature][Catalog] Catalog add Case Conversion Definition (#5328)	https://github.com/apache/seatunnel/commit/7b5b28bdbe	2.3.4
[Feature][Jdbc] Jdbc database support identifier (#5089)	https://github.com/apache/seatunnel/commit/38b6d6e4bb	2.3.4
[Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog (#5096)	https://github.com/apache/seatunnel/commit/dde3104f76	2.3.4
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260)	https://github.com/apache/seatunnel/commit/51c0d709ba	2.3.4
[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one (#5284)	https://github.com/apache/seatunnel/commit/ed5eadcf73	2.3.3
[bug][jdbc][oracle]Fix the Oracle number type mapping problem (#5209)	https://github.com/apache/seatunnel/commit/9d3c3de90d	2.3.3
[BUG][Connector-V2][Jdbc] support postgresql json type (#5194)	https://github.com/apache/seatunnel/commit/7a862d14b7	2.3.3
[Improve][Connector-V2] Remove scheduler in JDBC sink #4736 (#5168)	https://github.com/apache/seatunnel/commit/3b0a393145	2.3.3
[CI] Split updated modules integration test for part 5 (#5208)	https://github.com/apache/seatunnel/commit/18f14d6087	2.3.3
[Bug][connector-v2] PostgreSQL versions below 9.5 are compatible use cdc sync problem (#5120)	https://github.com/apache/seatunnel/commit/9af696a1dd	2.3.3
[Improve][Connector-v2][Jdbc] check url not null throw friendly message (#5097)	https://github.com/apache/seatunnel/commit/b0815f2a95	2.3.3
[Feature][Catalog] Add JDBC Catalog auto create table (#4917)	https://github.com/apache/seatunnel/commit/63eb137671	2.3.3
[Feature][CDC] Support tables without primary keys (with unique keys) (#163) (#5150)	https://github.com/apache/seatunnel/commit/32b7f2b690	2.3.3
[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak (#4802)	https://github.com/apache/seatunnel/commit/4cc10e83e7	2.3.3
[Feature][JDBC Sink] Add DM upsert support (#5073)	https://github.com/apache/seatunnel/commit/5e8d982e25	2.3.3
[Improve] Improve savemode api (#4767)	https://github.com/apache/seatunnel/commit/4acd370d48	2.3.3
[Feature][Connector-V2] JDBC source support string type as partition key (#4947)	https://github.com/apache/seatunnel/commit/d1d2677658	2.3.3
[Feature][Connector-V2][Jdbc] Add oceanbase dialect factory (#4989)	https://github.com/apache/seatunnel/commit/7ba11cecdf	2.3.3
Fix XA Transaction bug (#5020)	https://github.com/apache/seatunnel/commit/852fe104bc	2.3.3
[Improve][CDC]Remove driver for cdc connector (#4952)	https://github.com/apache/seatunnel/commit/b65f40c3c9	2.3.3
[Improve] Documentation and partial word optimization. (#4936)	https://github.com/apache/seatunnel/commit/6e8de0e2a6	2.3.3
[Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)	https://github.com/apache/seatunnel/commit/d56bb1ba1c	2.3.3
[Bugfix][zeta] Fix the deadlock issue with JDBC driver loading (#4878)	https://github.com/apache/seatunnel/commit/c30a2a1b1c	2.3.2
[Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)	https://github.com/apache/seatunnel/commit/bde19b6377	2.3.2
[Feature][Connector-v2] Add Snowflake Source&Sink connector (#4470)	https://github.com/apache/seatunnel/commit/06c59a25f3	2.3.2
[Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)	https://github.com/apache/seatunnel/commit/0eff3aeed0	2.3.2
[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception (#4801)	https://github.com/apache/seatunnel/commit/ea3bc1a673	2.3.2
[Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity (#4806)	https://github.com/apache/seatunnel/commit/2ca7426d22	2.3.2
[Hotfix][Jdbc][Oracle] Fix oracle sql table identifier (#4754)	https://github.com/apache/seatunnel/commit/84cb51ff83	2.3.2
[Improve][Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)	https://github.com/apache/seatunnel/commit/4af3bf9015	2.3.2
[Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… (#4673)	https://github.com/apache/seatunnel/commit/a5af4d9b6e	2.3.2
[Improve][Core] Add check of sink and source config to avoid null pointer exception. (#4734)	https://github.com/apache/seatunnel/commit/8f66ce96cb	2.3.2
[Hotfix][JDBC-SINK] Fix TiDBCatalog without open (#4718)	https://github.com/apache/seatunnel/commit/34a7f3eaa4	2.3.2
[Feature][E2E] Add mysql-cdc e2e testcase (#4639)	https://github.com/apache/seatunnel/commit/87001dfd16	2.3.2
[Hotfix][JDBC Sink] Fix JDBC Sink oom bug (#4690)	https://github.com/apache/seatunnel/commit/08b6f992aa	2.3.2
Improve the option rule for jdbc sink (#4694)	https://github.com/apache/seatunnel/commit/a6b3704414	2.3.2
[feature][catalog] Support for multiplexing connections (#4550)	https://github.com/apache/seatunnel/commit/41277d7f78	2.3.2
[Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to Boolean type (#4671)	https://github.com/apache/seatunnel/commit/89b0099ff4	2.3.2
[Hotfix]Jdbc[SqlServer] Fix sqlserver jdbc url parse (#4697)	https://github.com/apache/seatunnel/commit/b24c3226ec	2.3.2
Revert "[Improve][Catalog] refactor catalog (#4540)" (#4628)	https://github.com/apache/seatunnel/commit/2d1933195d	2.3.2
[Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres (#4575)	https://github.com/apache/seatunnel/commit/91f5125976	2.3.2
[Improve][Catalog] refactor catalog (#4540)	https://github.com/apache/seatunnel/commit/b0a701cb83	2.3.2
[Bug][JDBC Source] fix split exception when source table is empty (#4570)	https://github.com/apache/seatunnel/commit/c73b9331ce	2.3.2
[Feature][Connector][Jdbc] Add vertica connector. (#4303)	https://github.com/apache/seatunnel/commit/e6b4f98721	2.3.2
[Hotfix][Catalog] Filter out unavailable constrain keys (#4557)	https://github.com/apache/seatunnel/commit/5e5859546a	2.3.2
[Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)	https://github.com/apache/seatunnel/commit/74d4d24858	2.3.2
[Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)	https://github.com/apache/seatunnel/commit/a97f33797d	2.3.2
[Jdbc][Chore] improve the exception message when primary key not found in row (#4474)	https://github.com/apache/seatunnel/commit/06fa850da9	2.3.2
[hotfix][JDBC] Fix the table name is not automatically obtained when multiple tables (#4514)	https://github.com/apache/seatunnel/commit/c84d6f8d11	2.3.2
[Chore][Jdbc] add the log for sql and update some style (#4475)	https://github.com/apache/seatunnel/commit/a9e6503045	2.3.2
[Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)	https://github.com/apache/seatunnel/commit/7da11c2f44	2.3.2
[feature][jdbc][TiDB] add TiDB catalog (#4438)	https://github.com/apache/seatunnel/commit/9a32db6fc0	2.3.2
[Hotfix][Connector] Fix sqlserver catalog (#4441)	https://github.com/apache/seatunnel/commit/8540c7f9f3	2.3.2
[Feature][CDC][SqlServer] Support multi-table read (#4377)	https://github.com/apache/seatunnel/commit/c4e3f2dc03	2.3.2
[Improve][JdbcSink]Fix connection failure caused by connection timeout. (#4322)	https://github.com/apache/seatunnel/commit/e1f6d3b3fd	2.3.2
[Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of jdbc source. (#4158) (#4210)	https://github.com/apache/seatunnel/commit/3d7ff831f9	2.3.1
Change file type to file_format_type in file source/sink (#4249)	https://github.com/apache/seatunnel/commit/973a2fae3c	2.3.1
Change redshift type to lowercase (#4248)	https://github.com/apache/seatunnel/commit/10447ae103	2.3.1
Add redshift datatype convertor (#4245)	https://github.com/apache/seatunnel/commit/b19011517f	2.3.1
[improve][zeta] fix zeta bugs	https://github.com/apache/seatunnel/commit/3a82e8b39f	2.3.1
[Improve] Support MySqlCatalog Use JDBC URL With Custom Suffix	https://github.com/apache/seatunnel/commit/210d0ff1f8	2.3.1
[hotfix] fixed jdbc IT error	https://github.com/apache/seatunnel/commit/dd20af0a9e	2.3.1
Merge branch 'dev' into merge/cdc	https://github.com/apache/seatunnel/commit/4324ee1912	2.3.1
[Improve][Project] Code format with spotless plugin.	https://github.com/apache/seatunnel/commit/423b583038	2.3.1
[improve][jdbc] use ReadonlyConfig instead of Config (#4236)	https://github.com/apache/seatunnel/commit/c90c58e243	2.3.1
[Improve][Jdbc-sink] add database field to sink config (#4199)	https://github.com/apache/seatunnel/commit/ec368902f4	2.3.1
[improve][jdbc] Reduce jdbc options configuration (#4218)	https://github.com/apache/seatunnel/commit/ddd8f808b5	2.3.1
Fix mysql get default value (#4204)	https://github.com/apache/seatunnel/commit/6848434f2d	2.3.1
[hotfix][zeta] fix zeta multi-table parser error (#4193)	https://github.com/apache/seatunnel/commit/98f2ad0c19	2.3.1
[Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)	https://github.com/apache/seatunnel/commit/9d088017a3	2.3.1
[Improve][Connector-V2] [StarRocks] Starrocks Support Auto Create Table (#4177)	https://github.com/apache/seatunnel/commit/7e0008e6fb	2.3.1
[improve][catalog][jdbc] Add MySQL catalog factory (#4168)	https://github.com/apache/seatunnel/commit/95e3cbf875	2.3.1
[Improve][build] Give the maven module a human readable name (#4114)	https://github.com/apache/seatunnel/commit/d7cd601051	2.3.1
Add convertor factory (#4119)	https://github.com/apache/seatunnel/commit/cbdea45d95	2.3.1
Add ElasticSearch catalog (#4108)	https://github.com/apache/seatunnel/commit/9ee4d8394c	2.3.1
Add Kafka catalog (#4106)	https://github.com/apache/seatunnel/commit/34f1f21e48	2.3.1
[Improve][Project] Code format with spotless plugin. (#4101)	https://github.com/apache/seatunnel/commit/a2ab166561	2.3.1
Add DataTypeConvertor in Catalog (#4094)	https://github.com/apache/seatunnel/commit/840c3e5eb4	2.3.1
[Feature][Catalog] Support create/drop table, create/drop database in catalog (#4075)	https://github.com/apache/seatunnel/commit/d8a0be84ca	2.3.1
[Bug][Connector-V2][Jdbc] Fixed no exception throwing problem (#3957)	https://github.com/apache/seatunnel/commit/6ab266e594	2.3.1
[Bug][CDC] Fix jdbc sink generate update sql (#3940)	https://github.com/apache/seatunnel/commit/233465d4e4	2.3.1
[Improve][JDBC] improve jdbc sink option (#3864)	https://github.com/apache/seatunnel/commit/768a9300e8	2.3.1
Fix Source Class Support Parallelism judge & Add UT for it (#3878)	https://github.com/apache/seatunnel/commit/ce85a8c68b	2.3.1
[Feature][Connector] add get source method to all source connector (#3846)	https://github.com/apache/seatunnel/commit/417178fb84	2.3.1
[Feature][Connector-V2] Jdbc connector support SAP HANA. (#3017)	https://github.com/apache/seatunnel/commit/fe0180fab2	2.3.1
[Feature][API & Connector & Doc] add parallelism and column projection interface (#3829)	https://github.com/apache/seatunnel/commit/b9164b8ba1	2.3.1
[Improve][JDBC Connector]improve option rule (#3802)	https://github.com/apache/seatunnel/commit/139256741a	2.3.1
[Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore (#3809)	https://github.com/apache/seatunnel/commit/39dae4cfd9	2.3.1
[Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector (#3750)	https://github.com/apache/seatunnel/commit/5328e9d847	2.3.1
[Improve][Connector-v2] Remove unused options for jdbc source factory (#3794)	https://github.com/apache/seatunnel/commit/861004d309	2.3.1
[Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. (#3796)	https://github.com/apache/seatunnel/commit/38646b11b8	2.3.1
[hotfix][ST-Engine] fix jdbc connector exactly-once null pointer (#3730)	https://github.com/apache/seatunnel/commit/0c5986fbec	2.3.0
[Improve][connector-jdbc] Add config item enable upsert by query (#3708)	https://github.com/apache/seatunnel/commit/e1f951f782	2.3.0
[Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds #3701 (#3705)	https://github.com/apache/seatunnel/commit/f351ceaf4b	2.3.0
[Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug (#3670)	https://github.com/apache/seatunnel/commit/6fe0e6aece	2.3.0
[Improve][Connector-V2][JDBC] Unified exception for JDBC source & sink (#3598)	https://github.com/apache/seatunnel/commit/865ca2bba9	2.3.0
[Connector][JDBC]Support Redshift sink and source (#3615)	https://github.com/apache/seatunnel/commit/8d9d8638d2	2.3.0
[Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink #3589	https://github.com/apache/seatunnel/commit/e77fdbbef7	2.3.0
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)	https://github.com/apache/seatunnel/commit/226dc6a119	2.3.0
[Feature][Connector-V2][Doris]Add Doris Source & Sink connector (#3586)	https://github.com/apache/seatunnel/commit/3d46b79614	2.3.0
[Feature][Connector-V2][Teradata] Add Teradata Source And Sink Connector	https://github.com/apache/seatunnel/commit/3a095d30fd	2.3.0
[Feature][Connector-V2][JDBC] support sqlite Source & Sink (#3089)	https://github.com/apache/seatunnel/commit/a73bb3e714	2.3.0
Bump postgresql in /seatunnel-connectors-v2/connector-jdbc (#3559)	https://github.com/apache/seatunnel/commit/c8dfdf3e46	2.3.0
[feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema (#3499)	https://github.com/apache/seatunnel/commit/ff44db116e	2.3.0
[JDBC][ORACLE] Improve Oracle Type to SeaTunnel Type Mapping (#3486)	https://github.com/apache/seatunnel/commit/8fe0dda6e2	2.3.0
[JDBC][Config] Add JDBC Fetch Size Config And Custom Postgres PrepareStatement (#3478)	https://github.com/apache/seatunnel/commit/d60a705f5d	2.3.0
[feature][connector][jdbc] expose configurable options in JDBC (#3410)	https://github.com/apache/seatunnel/commit/72b8a73cab	2.3.0
[feature][connector][jdbc] Support write cdc changelog event in jdbc sink (#3444)	https://github.com/apache/seatunnel/commit/b12a908f01	2.3.0
[Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig (#3453)	https://github.com/apache/seatunnel/commit/cfb1e97853	2.3.0
[Improve][Connector-v2] Unset AutoCommit default to true (#3451)	https://github.com/apache/seatunnel/commit/439f686d92	2.3.0
[Feature][connector-v2] add tablestore source and sink (#3309)	https://github.com/apache/seatunnel/commit/ebebf0b633	2.3.0
Close jdbc connection after use. (#3358)	https://github.com/apache/seatunnel/commit/219fea517c	2.3.0
[Improve][Engine] Improve Engine performance. (#3216)	https://github.com/apache/seatunnel/commit/7393c47327	2.3.0
[Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)	https://github.com/apache/seatunnel/commit/40d67ab902	2.3.0
[Feature][Connector-V2][JDBC] Support DB2 Source & Sink (#2410)	https://github.com/apache/seatunnel/commit/bf1ef69e84	2.3.0
update org.postgresql:postgresql 42.3.3 to 42.4.1 (#3097)	https://github.com/apache/seatunnel/commit/2852516490	2.3.0
[Feature][Connector-V2][Jdbc] support gbase 8a (#3026)	https://github.com/apache/seatunnel/commit/dc6e85d06f	2.3.0-beta
[Bug][sqlserver] timestamp convert exception (#3024)	https://github.com/apache/seatunnel/commit/99ac1a655e	2.3.0-beta
[Feature][Connector-V2] oracle connector (#2550)	https://github.com/apache/seatunnel/commit/384ece1913	2.3.0-beta
[Improve][Connector-v2][jdbc] Support for specify number of partitions when parallel reading (#2950)	https://github.com/apache/seatunnel/commit/fc284ac32e	2.3.0-beta
[Feature][Connector-V2] add sqlserver connector (#2646)	https://github.com/apache/seatunnel/commit/05d105dea3	2.3.0-beta
[Improve][e2e] Unified e2e IT for DaMengDB (#2946)	https://github.com/apache/seatunnel/commit/15636bdea1	2.3.0-beta
[Improve][e2e] modify DM-driver by downLoad and add the value comparison of all columns (#2772)	https://github.com/apache/seatunnel/commit/f3ff39bdfe	2.3.0-beta
[Improve][e2e] Improve jdbc driver management (#2770)	https://github.com/apache/seatunnel/commit/f907927a35	2.3.0-beta
[hotfix][connector][jdbc] fix JDBC split exception (#2904)	https://github.com/apache/seatunnel/commit/57342c6545	2.3.0-beta
[Improve][connector-jdbc] Calculate splits only once in JdbcSourceSplitEnumerator (#2900)	https://github.com/apache/seatunnel/commit/7622f28999	2.3.0-beta
[Feature][Connector-V2 E2E] Add mysql and postgres e2e test and bug fix (#2838)	https://github.com/apache/seatunnel/commit/db434adc15	2.2.0-beta
fix XAConnection being wrongly submitted (#2805)	https://github.com/apache/seatunnel/commit/d9a6039fd3	2.2.0-beta
fix spark execute exception is not thrown (#2791)	https://github.com/apache/seatunnel/commit/b1711c984e	2.2.0-beta
[Improve][e2e] Add driver-jar to lib (#2719)	https://github.com/apache/seatunnel/commit/d64d452c86	2.2.0-beta
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)	https://github.com/apache/seatunnel/commit/cbf82f755c	2.2.0-beta
[Connector-V2][JDBC-connector] support Jdbc dm (#2377)	https://github.com/apache/seatunnel/commit/7278209ca2	2.2.0-beta
[#2606]Dependency management split (#2630)	https://github.com/apache/seatunnel/commit/fc047be69b	2.2.0-beta
[Bug][connector-jdbc-v2] Fix transaction force commit when autoCommit is enabled (#2636)	https://github.com/apache/seatunnel/commit/8cd8cf7aa2	2.2.0-beta
[Feature][Connector-V2] Add phoenix connector sink (#2499)	https://github.com/apache/seatunnel/commit/05ccf9d68c	2.2.0-beta
[Connector-V2][JDBC] Support database: greenplum (#2429)	https://github.com/apache/seatunnel/commit/3561d3878f	2.2.0-beta
Add jdbc connector e2e test (#2321)	https://github.com/apache/seatunnel/commit/5fbcb811c6	2.2.0-beta
StateT of SeaTunnelSource should extend `Serializable` (#2214)	https://github.com/apache/seatunnel/commit/8c426ef850	2.2.0-beta
update the condition to 1 = 0 about get table operation (#2186)	https://github.com/apache/seatunnel/commit/7c56d7143b	2.2.0-beta
[SeaTunnel API][Sink] remove useless context field (#2124)	https://github.com/apache/seatunnel/commit/a31fdeedcc	2.2.0-beta
[bugfix] Check isOpen before closing (#2107)	https://github.com/apache/seatunnel/commit/7ec0ada2b9	2.2.0-beta
[API-DRAFT][MERGE] fix merge error	https://github.com/apache/seatunnel/commit/3c0e984648	2.2.0-beta
merge dev to api-draft	https://github.com/apache/seatunnel/commit/d265597c64	2.2.0-beta
[api-draft][Optimize] Optimize module name (#2062)	https://github.com/apache/seatunnel/commit/f79e3112b1	2.2.0-beta

JDBC

描述​

使用依赖​

对于 Spark/Flink 引擎​

对于 SeaTunnel Zeta 引擎​

关键特性​

选项​

表匹配​

表名的正则表达式支持​

配置​

正则表达式语法注意事项​

示例​

多表同步​

decimal_type_narrowing​

int_type_narrowing​

dialect [string]​

方言列表​

并行读取器​

提示​

附录​

示例​

简单​

情况 1​

情况 2 在动态块分割阶段使用 select count(*) 代替分析表来计算表行数​

情况 3 使用 select NUM_ROWS from all_tables 获取表行数但跳过分析表​

情况 4 Oracle 源与 BLOB 作为字符串到 Doris Sink​

变更日志​

描述