版本：Next

JDBC

描述

JDBC Source 通过数据库厂商提供的 JDBC 驱动读取表或自定义查询结果，支持列投影、行过滤、并行快照读取，以及在一个 Source 配置中读取多张表。

JDBC Source 是有界数据源：它读取数据库查询当前可见的数据后结束。如果任务需要持续捕获后续的新增、更新和删除，请使用对应的 CDC Connector。

第一次配置 JDBC Source 时，请先阅读选择读取模式和快速入门，再按需查阅后面的完整参数说明。

使用依赖

先安装 connector-jdbc 插件：

--seatunnel-connectors--
connector-jdbc
--end--

cd "${SEATUNNEL_HOME}"
sh bin/install-plugin.sh

不同数据库厂商的 JDBC 驱动具有不同的许可证和再分发条款，而且驱动版本还必须同时兼容数据库和 Java 运行时，因此 SeaTunnel 不会统一内置所有 JDBC 驱动。请自行下载合适的驱动，并在启动任务前把 JAR 放入对应引擎的目录。

Spark 和 Flink 引擎

把 JDBC 驱动放到每个 SeaTunnel 执行节点的 ${SEATUNNEL_HOME}/plugins/Jdbc/lib/。

Zeta 引擎

把 JDBC 驱动放到每个 SeaTunnel 节点的 ${SEATUNNEL_HOME}/lib/，然后重启受影响的 SeaTunnel 进程，让驱动进入类路径。

常用驱动类名和下载地址见驱动参考。

选择读取模式

配置并行读取前，先选择单表或多表布局。单表布局中，table_path 和 query 可以单独使用，也可以组合使用；多表 table_list 与顶层 table_path、query 互斥。

使用场景	配置方式	行为
读取单表，并自动发现 schema 和动态分片	`table_path`	推荐用于整表快照。SeaTunnel 读取表元数据；表存在可用分片键时，通过 `split.size` 控制分片大小。
自定义读取列、JOIN 或数据库表达式	`query`，可以同时配置 `table_path`	SeaTunnel 执行用户提供的 SQL。需要明确表身份和元数据时可同时配置 `table_path`。部分 JOIN 无法安全推断查询主键，详见 Query 与主键注意事项。
读取多张表或按表名模式匹配	`table_list`	每一项可以配置 `table_path`、可选 `query` 和分片参数。使用 `table_list` 时，不能再配置顶层 `table_path` 或 `query`。

只有需要给所有选中表或查询追加同一过滤条件时才使用 where_condition。它必须以 where 开头，例如 where updated_at >= '2026-01-01'。

快速入门：PostgreSQL

下面从 PostgreSQL 读取三行数据，并通过 Console Sink 输出到 SeaTunnel 日志。

按照使用依赖的说明放置兼容版本的 PostgreSQL JDBC 驱动。
使用 PostgreSQL 管理员账号连接已有的 sales 数据库，创建专用教程表，并为只读账号授权。如果 seatunnel_reader 已经存在，请省略 CREATE ROLE 并复用该账号：

CREATE ROLE seatunnel_reader WITH LOGIN PASSWORD 'change_me';

DROP TABLE IF EXISTS public.seatunnel_jdbc_source_quick_start;

CREATE TABLE public.seatunnel_jdbc_source_quick_start (
  id BIGINT PRIMARY KEY,
  customer_name VARCHAR(100) NOT NULL,
  amount DECIMAL(10, 2) NOT NULL
);

INSERT INTO public.seatunnel_jdbc_source_quick_start VALUES
  (1, 'Alice', 120.50),
  (2, 'Bob', 80.00),
  (3, 'Carol', 42.00);

GRANT CONNECT ON DATABASE sales TO seatunnel_reader;
GRANT USAGE ON SCHEMA public TO seatunnel_reader;
GRANT SELECT ON TABLE public.seatunnel_jdbc_source_quick_start TO seatunnel_reader;

DROP TABLE 用于保证教程数据可以重复初始化，请勿对业务表执行这条语句。

把下面的任务保存为 ${SEATUNNEL_HOME}/config/jdbc-source-quick-start.conf，并按实际环境替换主机、账号和数据库名。

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

source {
  Jdbc {
    url = "jdbc:postgresql://postgresql.example.com:5432/sales"
    driver = "org.postgresql.Driver"
    username = "seatunnel_reader"
    password = "change_me"
    query = "SELECT id, customer_name, amount FROM public.seatunnel_jdbc_source_quick_start ORDER BY id"
  }
}

sink {
  Console {}
}

运行任务：

cd "${SEATUNNEL_HOME}"
./bin/seatunnel.sh --config ./config/jdbc-source-quick-start.conf -m local

确认 Console Sink 输出包含以下字段值：

id	customer_name	amount
1	Alice	120.50
2	Bob	80.00
3	Carol	42.00

如果任务在读取数据前失败，请先检查故障排查。

关键特性

使用 query 可以只读取需要的列。

选项

url 和 driver 始终必填。由于部分数据库允许无认证连接，账号和密码不是统一必填项。请选择顶层单表布局或 table_list；顶层 table_path 与 query 可以组合使用。账号建议使用规范键 username，历史配置中的 user 仍作为兼容键继续支持。

参数名	类型	必须	默认值	描述
url	String	是	-	JDBC 连接的 URL。参考示例：jdbc:postgresql://localhost/test
driver	String	是	-	用于连接到远程数据源的 jdbc 类名，如果您使用 MySQL，值为 `com.mysql.cj.jdbc.Driver`。
username	String	否	-	数据库账号。历史配置键 `user` 仍作为兼容键支持。
password	String	否	-	数据库账号的密码。
query	String	否	-	要执行的 SQL。需要同时明确表身份和元数据时，可以与 `table_path` 组合使用。
compatible_mode	String	否	-	数据库的兼容模式，当数据库支持多种兼容模式时需要。例如，使用 OceanBase 数据库时，需要将其设置为 'mysql' 或 'oracle'。使用 starrocks 时，需要将其设置为 `starrocks`
dialect	String	否	-	指定的方言，如果不存在，仍然根据 url 获取，优先级高于 url。例如，使用 starrocks 时，需要将其设置为 `starrocks`
connection_check_timeout_sec	Int	否	30	等待用于验证连接的数据库操作完成的时间（秒）。
connect_timeout_ms	Int	否	86400000	建立 JDBC 连接时的连接超时时间，单位毫秒。`0` 表示不超时。
socket_timeout_ms	Int	否	86400000	JDBC 连接建立后的 socket 读取超时时间，单位毫秒。`0` 表示不超时。
partition_column	String	否	-	用于分割数据的列名。
partition_upper_bound	String	否	-	query 分区读取使用的闭区间上界。未配置时，SeaTunnel 会从源表查询最大值。
partition_lower_bound	String	否	-	query 分区读取使用的闭区间下界。未配置时，SeaTunnel 会从源表查询最小值。
partition_num	Int	否	10	顶层 `query` 与 `partition_column` 触发 fixed splitter 时的分片数，无论是否同时配置 `table_path`。动态 `table_path` 和 `table_list` 布局改用 `split.size`。
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_kerberos	Boolean	否	false	是否为 JDBC 连接启用 Kerberos 认证。
kerberos_principal	String	否	-	`use_kerberos = true` 时使用的 Kerberos principal。
kerberos_keytab_path	String	否	-	`use_kerberos = true` 时使用的 Kerberos keytab 文件路径。
krb5_path	String	否	/etc/krb5.conf	Kerberos krb5 配置文件路径。
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	使用动态分片时每个 split 的目标行数，适用于 `table_path` 和 `table_list` 布局；不控制顶层 `query` 与 `partition_column` 的 fixed partition 模式。
split.even-distribution.factor.lower-bound	Double	否	0.05	不建议修改。分片键分布因子的下界。该因子用于判断表数据是否均匀分布。如果计算出的分布因子大于或等于此下界（即 (MAX(id) - MIN(id) + 1) / 行数），则将优化为均匀分布的分片方式。否则，如果分布因子更小，则表将被视为非均匀分布，当预估的分片数超过 `sample-sharding.threshold` 指定的值时，将使用基于采样的分片策略。默认值为 0.05。
split.even-distribution.factor.upper-bound	Double	否	100	不建议修改。分片键分布因子的上界。该因子用于判断表数据是否均匀分布。如果计算出的分布因子小于或等于此上界（即 (MAX(id) - MIN(id) + 1) / 行数），则将优化为均匀分布的分片方式。否则，如果分布因子更大，则表将被视为非均匀分布，当预估的分片数超过 `sample-sharding.threshold` 指定的值时，将使用基于采样的分片策略。默认值为 100.0。
split.sample-sharding.threshold	Int	否	1000	此配置指定触发采样分片策略的预估分片数阈值。当分布因子超出 `split.even-distribution.factor.upper-bound` 和 `split.even-distribution.factor.lower-bound` 指定的范围，且预估分片数（计算方式为近似行数 / 分片大小）超过此阈值时，将使用采样分片策略。这有助于更高效地处理大数据集。默认值为 1000。
split.inverse-sampling.rate	Int	否	1000	采样分片策略中使用的采样率的倒数。例如，如果此值设置为 1000，则表示在采样过程中应用 1/1000 的采样率。此选项提供了控制采样粒度的灵活性，从而影响最终的分片数量。在处理大数据集时尤为有用，此时较低的采样率可能更合适。默认值为 1000。
split.allow-sampling	Boolean	否	true	是否启用基于采样的分片策略。当设置为 false 时，无论预估分片数是否超过阈值，系统都将回退到非均匀分片方式（迭代查询方式）。默认值为 true。
split.string_split_mode	String	否	sample	支持不同的字符串分割算法。默认使用 `sample`，通过采样字符串值来确定分割。可以切换为 `charset_based` 启用基于字符集的字符串分割算法。设置为 `charset_based` 时，算法假定 partition_column 的字符在 ASCII 32-126 范围内，覆盖了大多数基于字符的分割场景。
split.string-strategy	String	否	-	控制 String 分区列的分片方式，可选值为 `none`、`hash`、`range`、`auto`。`range` 和 `auto` 当前要求 MySQL binary collation，且键值为固定长度的可打印 ASCII 字符串。其他 JDBC 方言在显式验证 range 分片支持前会拒绝 `range` 和 `auto`。`auto` 会优先尝试 range 分片，range 不安全时回退为 hash 分片。未设置该参数时，SeaTunnel 保持现有 `split.string_split_mode` 行为。
split.string_split_mode_collate	String	否	-	当 string_split_mode 设置为 `charset_based` 且表具有特殊排序规则时，指定要使用的排序规则。如果未指定，将使用数据库的默认排序规则。
common-options		否	-	源插件通用参数，请参考源通用选项详见。

表匹配

请按照数据库方言要求填写完整表路径：

数据库类型	示例
MySQL	`sales.orders`
PostgreSQL 和 SQL Server	`sales.public.orders`
Oracle	`SALES.ORDERS`

use_regex = false 表示精确匹配，也是最安全的默认方式。只有明确需要把 table_path 的表名部分作为正则表达式时，才设置 use_regex = true：

table_path = "sales.orders_\\d+"
use_regex = true

HOCON 字符串中的正则反斜杠需要转义，因此正则中的 \d+ 在配置文件里要写成 \\d+。最后一个未转义的点用于分隔数据库/schema 路径和表名模式。

许多 JDBC 驱动会把传给 DatabaseMetaData 的 schema 和表名参数当作 SQL LIKE 模式。SeaTunnel 会在发现元数据后再次精确核对标识符；对于大小写敏感的数据库，仍应确保配置与数据库中的真实标识符大小写完全一致。

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
YashanDB

并行读取器

任务 parallelism 决定最多可以同时运行多少个 Reader；分片配置决定实际有多少个独立 split 可以分配给 Reader。

推荐方式：`table_path` 动态分片

整表快照建议配置 table_path，通常让 SeaTunnel 自动发现分片键。显式配置 partition_column 时优先使用该列；否则依次从主键和唯一索引中选择第一个受支持的列。支持 String、数值和 Date 类型的分片键。

split.size 表示每个分片的目标行数，并不是严格的行数上限，实际大小会受到键值分布和数据库统计信息影响。如果表没有可用的主键、唯一索引或显式 partition_column，即使任务并行度大于 1，该表仍然只有一个读取分片。

顶层 `query` 固定分区

只有顶层同时配置 query 和 partition_column 时才会使用旧版 fixed splitter，再通过 partition_num 控制分片数。分区列必须包含在 query 结果中。配置上下界可以避免额外执行 MIN/MAX 查询，但错误的边界会漏读源数据，因此只有确认完整数据范围时才应设置。

table_list 中的条目即使配置了 query 或分区参数，仍然使用动态分片。split.size 不影响顶层 fixed partition 模式。

Query 与主键注意事项

SeaTunnel 为 query 推断主键时，会继承结果集第一列所属底层表的元数据。对于 JOIN 或多表查询，该主键不保证在完整结果集中唯一。此类查询应使用单 Reader，或者显式选择能够安全划分查询结果的分区列。

驱动参考

下表仅作为起点。部署前应向数据库厂商确认驱动制品、许可证、数据库版本兼容性和 Java 版本兼容性。

数据源	驱动	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
phoenix	org.apache.phoenix.queryserver.client.Driver	jdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUF	https://mvnrepository.com/artifact/com.aliyun.phoenix/ali-phoenix-shaded-thin-client
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
sqlite	org.sqlite.JDBC	jdbc:sqlite:test.db	https://mvnrepository.com/artifact/org.xerial/sqlite-jdbc
gbase8a	com.gbase.jdbc.Driver	jdbc:gbase://localhost:5258/test	https://cdn.gbase.cn/products/30/p5CiVwXBKQYIUGN8ecHvk/gbase-connector-java-9.5.0.7-build1-bin.jar
starrocks	com.mysql.cj.jdbc.Driver	jdbc:mysql://localhost:3306/test	https://mvnrepository.com/artifact/mysql/mysql-connector-java
db2	com.ibm.db2.jcc.DB2Driver	jdbc:db2://localhost:50000/testdb	https://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc/db2jcc4
tablestore	com.alicloud.openservices.tablestore.jdbc.OTSDriver	jdbc:ots:https://myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance	https://mvnrepository.com/artifact/com.aliyun.openservices/tablestore-jdbc
saphana	com.sap.db.jdbc.Driver	jdbc:sap://localhost:39015	https://mvnrepository.com/artifact/com.sap.cloud.db.jdbc/ngdbc
doris	com.mysql.cj.jdbc.Driver	jdbc:mysql://localhost:3306/test	https://mvnrepository.com/artifact/mysql/mysql-connector-java
teradata	com.teradata.jdbc.TeraDriver	jdbc:teradata://localhost/DBS_PORT=1025,DATABASE=test	https://mvnrepository.com/artifact/com.teradata.jdbc/terajdbc
Snowflake	net.snowflake.client.jdbc.SnowflakeDriver	jdbc:snowflake://<account_name>.snowflakecomputing.com	https://mvnrepository.com/artifact/net.snowflake/snowflake-jdbc
Redshift	com.amazon.redshift.jdbc42.Driver	jdbc:redshift://localhost:5439/testdb?defaultRowFetchSize=1000	https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42
Vertica	com.vertica.jdbc.Driver	jdbc:vertica://localhost:5433	https://repo1.maven.org/maven2/com/vertica/jdbc/vertica-jdbc/12.0.3-0/vertica-jdbc-12.0.3-0.jar
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
xugu	com.xugu.cloudjdbc.Driver	jdbc:xugu://localhost:5138	https://repo1.maven.org/maven2/com/xugudb/xugu-jdbc/12.2.0/xugu-jdbc-12.2.0.jar
InterSystems IRIS	com.intersystems.jdbc.IRISDriver	jdbc:IRIS://localhost:1972/%SYS	https://raw.githubusercontent.com/intersystems-community/iris-driver-distribution/main/JDBC/JDK18/intersystems-jdbc-3.8.4.jar
opengauss	org.opengauss.Driver	jdbc:opengauss://localhost:5432/postgres	https://repo1.maven.org/maven2/org/opengauss/opengauss-jdbc/5.1.0-og/opengauss-jdbc-5.1.0-og.jar
Highgo	com.highgo.jdbc.Driver	jdbc:highgo://localhost:5866/highgo	https://repo1.maven.org/maven2/com/highgo/HgdbJdbc/6.2.3/HgdbJdbc-6.2.3.jar
Presto	com.facebook.presto.jdbc.PrestoDriver	jdbc:presto://localhost:8080/presto	https://repo1.maven.org/maven2/com/facebook/presto/presto-jdbc/0.279/presto-jdbc/0.279.jar
Trino	io.trino.jdbc.TrinoDriver	jdbc:trino://localhost:8080/trino	https://repo1.maven.org/maven2/io/trino/trino-jdbc/460/trino-jdbc-460.jar
YashanDB	com.yashandb.jdbc.Driver	jdbc:yasdb://localhost:1688/SYS	https://mvnrepository.com/artifact/com.yashandb/yashandb-jdbc

常用模式

自定义查询

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

source {
  Jdbc {
    url = "jdbc:mysql://mysql.example.com:3306/sales"
    driver = "com.mysql.cj.jdbc.Driver"
    username = "seatunnel_reader"
    password = "change_me"
    query = "SELECT id, customer_name, amount FROM orders WHERE status = 'PAID'"
  }
}

sink {
  Console {}
}

Oracle BLOB 读取为 STRING

需要把 Oracle BLOB 暴露为 SeaTunnel STRING 时，可以设置 handle_blob_as_string = true，例如后续需要写入 Doris 的场景。

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

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

sink {
  Console {}
}

按列并行执行自定义 query

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

source {
  Jdbc {
    url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
    driver = "com.mysql.cj.jdbc.Driver"
    username = "seatunnel_reader"
    password = "change_me"
    query = "SELECT id, customer_name, amount FROM orders"
    partition_column = "id"
    partition_num = 10
  }
}

sink {
  Console {}
}

显式配置分区边界

只有上下界能够覆盖完整源数据范围时才应设置边界。SeaTunnel 不会读取配置区间之外的值。

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

source {
  Jdbc {
    url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
    driver = "com.mysql.cj.jdbc.Driver"
    username = "seatunnel_reader"
    password = "change_me"
    query = "SELECT id, customer_name, amount FROM orders"
    partition_column = "id"
    partition_lower_bound = 1
    partition_upper_bound = 500
    partition_num = 10
  }
}

sink {
  Console {}
}

通过主键或唯一索引动态分片

本示例只配置 table_path，没有同时配置顶层 query + partition_column，因此使用动态分片。建议先使用默认分片参数，再根据源库负载和任务吞吐实测结果调整 split.size。

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

source {
  Jdbc {
    url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
    driver = "com.mysql.cj.jdbc.Driver"
    username = "seatunnel_reader"
    password = "change_me"
    table_path = "sales.orders"
    split.size = 10000
  }
}

sink {
  Console {}
}

读取多张表

不同表需要不同 query 或匹配规则时使用 table_list：

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

source {
  Jdbc {
    url = "jdbc:mysql://mysql.example.com:3306/sales?serverTimezone=UTC"
    driver = "com.mysql.cj.jdbc.Driver"
    username = "seatunnel_reader"
    password = "change_me"

    table_list = [
      {
        table_path = "sales.orders"
      },
      {
        table_path = "sales.customers"
        query = "SELECT id, name FROM customers WHERE id > 100"
      },
      {
        table_path = "sales.archive_\\d+"
        use_regex = true
      }
    ]
  }
}

sink {
  Console {}
}

故障排查

找不到 JDBC 驱动类

确认每个执行节点的引擎对应目录中都有驱动 JAR，配置的 driver 类真实存在于该 JAR，并且添加 JAR 后已经重启受影响的进程。

SQL 客户端能连接，但 SeaTunnel 连接失败

主机名必须能从 SeaTunnel 进程所在环境访问，而不只是能从个人电脑访问。检查网络路由、防火墙、TLS、账号、数据库名和 connection_check_timeout_sec，不要直接使用未替换的示例主机名。

无法发现表或字段

检查数据库对应的 table_path 格式、标识符大小写，以及账号是否具有元数据和 SELECT 权限。使用自定义 query 时，先在数据库客户端中用同一账号执行完全相同的 SQL。

提高 parallelism 后 Reader 数量没有增加

使用动态分片时，确认表存在受支持的主键或唯一索引，或者显式配置 partition_column。要让顶层 query 使用旧版 fixed splitter，需要同时配置 partition_column 和合适的 partition_num。没有安全分片键的表会有意使用单个 split 读取。

配置分区边界后出现漏数

partition_lower_bound 和 partition_upper_bound 定义 SeaTunnel 实际读取的数据范围，并不只是性能提示。可以删除它们，让 SeaTunnel 自动发现边界；也可以修正边界，确保覆盖所有需要读取的行。

变更日志

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 引擎​

Zeta 引擎​

选择读取模式​

快速入门：PostgreSQL​

关键特性​

选项​

表匹配​

decimal_type_narrowing​

int_type_narrowing​

dialect [string]​

方言列表​

并行读取器​

推荐方式：table_path 动态分片​

顶层 query 固定分区​

Query 与主键注意事项​

驱动参考​

常用模式​

自定义查询​

Oracle BLOB 读取为 STRING​

按列并行执行自定义 query​

显式配置分区边界​

通过主键或唯一索引动态分片​

读取多张表​

故障排查​

找不到 JDBC 驱动类​

SQL 客户端能连接，但 SeaTunnel 连接失败​

无法发现表或字段​

提高 parallelism 后 Reader 数量没有增加​

配置分区边界后出现漏数​

变更日志​

描述