跳到主要内容
版本：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 放入对应引擎的目录。

把 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_pathSeaTunnel 执行用户提供的 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 日志。

  1. 按照使用依赖的说明放置兼容版本的 PostgreSQL JDBC 驱动。

  2. 使用 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 用于保证教程数据可以重复初始化，请勿对业务表执行这条语句。

  1. 把下面的任务保存为 ${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 {}
}
  1. 运行任务：
cd "${SEATUNNEL_HOME}"
./bin/seatunnel.sh --config ./config/jdbc-source-quick-start.conf -m local
  1. 确认 Console Sink 输出包含以下字段值：
idcustomer_nameamount
1Alice120.50
2Bob80.00
3Carol42.00

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

备注

连接 MariaDB 时，请使用 MariaDB Connector/J 以及匹配的 URL 和驱动：

url = "jdbc:mariadb://localhost:3306/database"
driver = "org.mariadb.jdbc.Driver"

不要使用 MySQL Connector/J 和 jdbc:mysql: URL 连接 MariaDB。该配置会选择 MySQL 方言，可能将 MariaDB 服务端版本判定为不支持的 MySQL 版本。

关键特性​

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

选项​

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

参数名类型必须默认值描述
urlString是-JDBC 连接的 URL。参考示例：jdbc:postgresql://localhost/test
driverString是-用于连接到远程数据源的 jdbc 类名，如果您使用 MySQL，值为 com.mysql.cj.jdbc.Driver。
usernameString否-数据库账号。历史配置键 user 仍作为兼容键支持。
passwordString否-数据库账号的密码。
queryString否-要执行的 SQL。需要同时明确表身份和元数据时，可以与 table_path 组合使用。
compatible_modeString否-数据库的兼容模式，当数据库支持多种兼容模式时需要。
例如，使用 OceanBase 数据库时，需要将其设置为 'mysql' 或 'oracle'。
使用 starrocks 时，需要将其设置为 starrocks
dialectString否-指定的方言，如果不存在，仍然根据 url 获取，优先级高于 url。
例如，使用 starrocks 时，需要将其设置为 starrocks
connection_check_timeout_secInt否30等待用于验证连接的数据库操作完成的时间（秒）。
connect_timeout_msInt否86400000建立 JDBC 连接时的连接超时时间，单位毫秒。0 表示不超时。
socket_timeout_msInt否86400000JDBC 连接建立后的 socket 读取超时时间，单位毫秒。0 表示不超时。
partition_columnString否-用于分割数据的列名。
partition_upper_boundString否-query 分区读取使用的闭区间上界。未配置时，SeaTunnel 会从源表查询最大值。
partition_lower_boundString否-query 分区读取使用的闭区间下界。未配置时，SeaTunnel 会从源表查询最小值。
partition_numInt否10顶层 query 与 partition_column 触发 fixed splitter 时的分片数，无论是否同时配置 table_path。动态 table_path 和 table_list 布局改用 split.size。
decimal_type_narrowingBoolean否true十进制类型缩小，如果为 true，十进制类型将缩小为 int 或 long 类型（如果没有精度损失）。目前仅支持 Oracle。请参考下面的 decimal_type_narrowing
int_type_narrowingBoolean否trueInt 类型缩小，如果为 true，tinyint(1) 类型将缩小为布尔类型（如果没有精度损失）。目前支持 MySQL。请参考下面的 int_type_narrowing
handle_blob_as_stringBoolean否false如果为 true，BLOB 类型将转换为 STRING 类型。仅支持 Oracle 数据库。这对于处理超过默认大小限制的 Oracle 中的大 BLOB 字段很有用。将 Oracle 的 BLOB 字段传输到 Doris 等系统时，将其设置为 true 可以使数据传输更高效。
use_kerberosBoolean否false是否为 JDBC 连接启用 Kerberos 认证。
kerberos_principalString否-use_kerberos = true 时使用的 Kerberos principal。
kerberos_keytab_pathString否-use_kerberos = true 时使用的 Kerberos keytab 文件路径。
krb5_pathString否/etc/krb5.confKerberos krb5 配置文件路径。
use_select_countBoolean否false在动态块分割阶段使用 select count 来获取表计数，而不是其他方法。这目前仅适用于 jdbc-oracle。在这种情况下，当使用 sql 从分析表更新统计信息更快时，直接使用 select count
skip_analyzeBoolean否false在动态块分割阶段跳过表计数分析。这目前仅适用于 jdbc-oracle。在这种情况下，您定期安排分析表 sql 来更新相关表统计信息，或您的表数据不经常更改
use_regexBoolean否false控制 table_path 的正则表达式匹配。设置为 true 时，table_path 将被视为正则表达式模式。设置为 false 或未指定时，table_path 将被视为精确路径（无正则表达式匹配）。
fetch_sizeInt否0对于返回大量对象的查询，您可以配置查询中使用的行提取大小，以通过减少满足选择条件所需的数据库命中次数来提高性能。零表示使用 jdbc 默认值。
propertiesMap否-其他连接配置参数，当 properties 和 URL 具有相同参数时，优先级由
驱动程序的具体实现确定。例如，在 MySQL 中，properties 优先于 URL。
table_pathString否-表的完整路径。在单表布局中可以单独使用，也可以与 query 组合。
示例：
- mysql: "testdb.table1"
- oracle: "test_schema.table1"
- sqlserver: "testdb.test_schema.table1"
- postgresql: "testdb.test_schema.table1"
- iris: "test_schema.table1"
table_listArray否-要读取的表列表，您可以使用此配置代替 table_path
where_conditionString否-所有表/查询的通用行过滤条件，必须以 where 开头。例如 where id > 100
split.sizeInt否8096使用动态分片时每个 split 的目标行数，适用于 table_path 和 table_list 布局；不控制顶层 query 与 partition_column 的 fixed partition 模式。
split.even-distribution.factor.lower-boundDouble否0.05不建议修改。
分片键分布因子的下界。该因子用于判断表数据是否均匀分布。如果计算出的分布因子大于或等于此下界（即 (MAX(id) - MIN(id) + 1) / 行数），则将优化为均匀分布的分片方式。否则，如果分布因子更小，则表将被视为非均匀分布，当预估的分片数超过 sample-sharding.threshold 指定的值时，将使用基于采样的分片策略。默认值为 0.05。
split.even-distribution.factor.upper-boundDouble否100不建议修改。
分片键分布因子的上界。该因子用于判断表数据是否均匀分布。如果计算出的分布因子小于或等于此上界（即 (MAX(id) - MIN(id) + 1) / 行数），则将优化为均匀分布的分片方式。否则，如果分布因子更大，则表将被视为非均匀分布，当预估的分片数超过 sample-sharding.threshold 指定的值时，将使用基于采样的分片策略。默认值为 100.0。
split.sample-sharding.thresholdInt否1000此配置指定触发采样分片策略的预估分片数阈值。当分布因子超出 split.even-distribution.factor.upper-bound 和 split.even-distribution.factor.lower-bound 指定的范围，且预估分片数（计算方式为近似行数 / 分片大小）超过此阈值时，将使用采样分片策略。这有助于更高效地处理大数据集。默认值为 1000。
split.inverse-sampling.rateInt否1000采样分片策略中使用的采样率的倒数。例如，如果此值设置为 1000，则表示在采样过程中应用 1/1000 的采样率。此选项提供了控制采样粒度的灵活性，从而影响最终的分片数量。在处理大数据集时尤为有用，此时较低的采样率可能更合适。默认值为 1000。
split.allow-samplingBoolean否true是否启用基于采样的分片策略。当设置为 false 时，无论预估分片数是否超过阈值，系统都将回退到非均匀分片方式（迭代查询方式）。默认值为 true。
enable_concurrent_readBoolean否true是否在快照阶段启用基于分片的并发读取。当设置为 false 时，source 会跳过分片分析，并以单个 split 读取整张表，适合没有索引的表。默认值为 true。
split.string_split_modeString否sample支持不同的字符串分割算法。默认使用 sample，通过采样字符串值来确定分割。可以切换为 charset_based 启用基于字符集的字符串分割算法。设置为 charset_based 时，算法假定 partition_column 的字符在 ASCII 32-126 范围内，覆盖了大多数基于字符的分割场景。
split.string-strategyString否-控制 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_collateString否-当 string_split_mode 设置为 charset_based 且表具有特殊排序规则时，指定要使用的排序规则。如果未指定，将使用数据库的默认排序规则。
common-options否-源插件通用参数，请参考 源通用选项 详见。

表匹配​

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

数据库类型示例
MySQLsales.orders
PostgreSQL 和 SQL Serversales.public.orders
OracleSALES.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 会在发现元数据后再次精确核对标识符；对于大小写敏感的数据库，仍应确保配置与数据库中的真实标识符大小写完全一致。

视图与表匹配

table_path（无论是否启用 use_regex）是否会连带匹配到数据库视图（而不仅仅是基础表），取决于各方言内部列举表所使用的查询方式，目前没有可以显式包含或排除视图的配置项：

  • MySQL 和 PostgreSQL 会把视图和基础表列在一起，因此像 db.* 这样宽泛的匹配模式也会匹配到视图。
  • SQL Server 通过 TABLE_TYPE = 'BASE TABLE' 过滤，会排除视图。
  • Oracle 和 Dameng 查询的是 ALL_TABLES，视图不在其中，因此会被间接排除。

如果需要在任意方言下都只读取指定的基础表，建议直接在 table_list 中显式列出表名，而不要依赖宽泛的正则表达式。

decimal_type_narrowing​

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

例如：

decimal_type_narrowing = true

OracleSeaTunnel
NUMBER(1, 0)Boolean
NUMBER(6, 0)INT
NUMBER(10, 0)BIGINT

decimal_type_narrowing = false

OracleSeaTunnel
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

MySQLSeaTunnel
TINYINT(1)Boolean

int_type_narrowing = false

MySQLSeaTunnel
TINYINT(1)TINYINT

dialect [string]​

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

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

方言列表​

方言名称
GreenplumDB2Dameng
Gbase8aHIVEKingBase
MySQLStarRocksOracle
PhoenixPostgresRedshift
SapHanaSnowflakeSqlite
SqlServerTablestoreTeradata
VerticaOceanBaseXUGU
IRISInceptorHighgo
YashanDB

达梦 NCHAR 源字段会映射为 SeaTunnel STRING。

并行读取器​

任务 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 版本兼容性。

数据源驱动URLMaven
mysqlcom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
postgresqlorg.postgresql.Driverjdbc:postgresql://localhost:5432/postgreshttps://mvnrepository.com/artifact/org.postgresql/postgresql
dmdm.jdbc.driver.DmDriverjdbc:dm://localhost:5236https://mvnrepository.com/artifact/com.dameng/DmJdbcDriver18
phoenixorg.apache.phoenix.queryserver.client.Driverjdbc:phoenix:thin:url=http://localhost:8765;serialization=PROTOBUFhttps://mvnrepository.com/artifact/com.aliyun.phoenix/ali-phoenix-shaded-thin-client
oracleoracle.jdbc.OracleDriverjdbc:oracle:thin:@localhost:1521/xepdb1https://mvnrepository.com/artifact/com.oracle.database.jdbc/ojdbc8
sqlservercom.microsoft.sqlserver.jdbc.SQLServerDriverjdbc:sqlserver://localhost:1433https://mvnrepository.com/artifact/com.microsoft.sqlserver/mssql-jdbc
sqliteorg.sqlite.JDBCjdbc:sqlite:test.dbhttps://mvnrepository.com/artifact/org.xerial/sqlite-jdbc
gbase8acom.gbase.jdbc.Driverjdbc:gbase://localhost:5258/testhttps://cdn.gbase.cn/products/30/p5CiVwXBKQYIUGN8ecHvk/gbase-connector-java-9.5.0.7-build1-bin.jar
starrockscom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
db2com.ibm.db2.jcc.DB2Driverjdbc:db2://localhost:50000/testdbhttps://mvnrepository.com/artifact/com.ibm.db2.jcc/db2jcc/db2jcc4
tablestorecom.alicloud.openservices.tablestore.jdbc.OTSDriverjdbc:ots:https://<instance_name>.<region_id>.ots.aliyuncs.com/<instance_name>https://mvnrepository.com/artifact/com.aliyun.openservices/tablestore-jdbc
saphanacom.sap.db.jdbc.Driverjdbc:sap://localhost:39015https://mvnrepository.com/artifact/com.sap.cloud.db.jdbc/ngdbc
doriscom.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306/testhttps://mvnrepository.com/artifact/mysql/mysql-connector-java
teradatacom.teradata.jdbc.TeraDriverjdbc:teradata://localhost/DBS_PORT=1025,DATABASE=testhttps://mvnrepository.com/artifact/com.teradata.jdbc/terajdbc
Snowflakenet.snowflake.client.jdbc.SnowflakeDriverjdbc:snowflake://<account_name>.snowflakecomputing.comhttps://mvnrepository.com/artifact/net.snowflake/snowflake-jdbc
Redshiftcom.amazon.redshift.jdbc42.Driverjdbc:redshift://localhost:5439/testdb?defaultRowFetchSize=1000https://mvnrepository.com/artifact/com.amazon.redshift/redshift-jdbc42
Verticacom.vertica.jdbc.Driverjdbc:vertica://localhost:5433https://repo1.maven.org/maven2/com/vertica/jdbc/vertica-jdbc/12.0.3-0/vertica-jdbc-12.0.3-0.jar
kingbasecom.kingbase8.Driverjdbc:kingbase8://localhost:54321/db_testhttps://repo1.maven.org/maven2/cn/com/kingbase/kingbase8/8.6.0/kingbase8-8.6.0.jar
oceanbasecom.oceanbase.jdbc.Driverjdbc:oceanbase://localhost:2881https://repo1.maven.org/maven2/com/oceanbase/oceanbase-client/2.4.12/oceanbase-client-2.4.12.jar
hiveorg.apache.hive.jdbc.HiveDriverjdbc:hive2://localhost:10000https://repo1.maven.org/maven2/org/apache/hive/hive-jdbc/3.1.3/hive-jdbc-3.1.3-standalone.jar
xugucom.xugu.cloudjdbc.Driverjdbc:xugu://localhost:5138https://repo1.maven.org/maven2/com/xugudb/xugu-jdbc/12.2.0/xugu-jdbc-12.2.0.jar
InterSystems IRIScom.intersystems.jdbc.IRISDriverjdbc:IRIS://localhost:1972/%SYShttps://raw.githubusercontent.com/intersystems-community/iris-driver-distribution/main/JDBC/JDK18/intersystems-jdbc-3.8.4.jar
opengaussorg.opengauss.Driverjdbc:opengauss://localhost:5432/postgreshttps://repo1.maven.org/maven2/org/opengauss/opengauss-jdbc/5.1.0-og/opengauss-jdbc-5.1.0-og.jar
Highgocom.highgo.jdbc.Driverjdbc:highgo://localhost:5866/highgohttps://repo1.maven.org/maven2/com/highgo/HgdbJdbc/6.2.3/HgdbJdbc-6.2.3.jar
Prestocom.facebook.presto.jdbc.PrestoDriverjdbc:presto://localhost:8080/prestohttps://repo1.maven.org/maven2/com/facebook/presto/presto-jdbc/0.279/presto-jdbc-0.279.jar
Trinoio.trino.jdbc.TrinoDriverjdbc:trino://localhost:8080/trinohttps://repo1.maven.org/maven2/io/trino/trino-jdbc/460/trino-jdbc-460.jar
YashanDBcom.yashandb.jdbc.Driverjdbc:yasdb://localhost:1688/SYShttps://repo1.maven.org/maven2/com/yashandb/yashandb-jdbc/1.10.7/yashandb-jdbc-1.10.7.jar

常用模式​

自定义查询​

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
ChangeCommitVersion
[Fix][Connector-xugu] Fix several bugs in the xugu connector (#9820)https://github.com/apache/seatunnel/commit/75c9adb280dev
[Feature][Transform-V2] Support AT TIME ZONE statement for sql transform (#9784)https://github.com/apache/seatunnel/commit/ad5278c5bbdev
[Feature][Transform-V2] Support vector series sql function (#9765)https://github.com/apache/seatunnel/commit/a40114cf7a2.3.12
[Chore] fix typos filed -> field (#9757)https://github.com/apache/seatunnel/commit/e3e1c67d292.3.12
[Feature][Core] Add plugin directory support for each connector (#9650)https://github.com/apache/seatunnel/commit/4beb2b93362.3.12
[Improve][Core] Update apache common to apache common lang3 (#9694)https://github.com/apache/seatunnel/commit/6e5737c1ec2.3.12
[Improve][API] Optimize the enumerator API semantics and reduce lock calls at the connector level (#9671)https://github.com/apache/seatunnel/commit/9212a771402.3.12
[Fix][connector-jdbc] prevent precision loss in Float to BigDecimal conversion (#9670)https://github.com/apache/seatunnel/commit/6e11285bf62.3.12
[Fix][Connector-Jdbc] Supports reading and writing Postgres network dress types (#9618)https://github.com/apache/seatunnel/commit/3dc79c1ddf2.3.12
[improve] jdbc options (#9541)https://github.com/apache/seatunnel/commit/d041e5fb322.3.12
[Fix][Connector-Jdbc]Fixed Vertica data source cannot upsert data. (#9607)https://github.com/apache/seatunnel/commit/7b4d05171b2.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/58ab9170242.3.12
[Feature][Connectors-v2] Optimize the size of CDC JAR Files (#9546)https://github.com/apache/seatunnel/commit/1dd19c68232.3.12
[improve][Connector-jdbc] add comments when schema not include all columns (#9559)https://github.com/apache/seatunnel/commit/02d2b69d852.3.12
[Hotfix][Connector-Jdbc] Write MySQL to support set collection data type (#9553)https://github.com/apache/seatunnel/commit/3836c97a622.3.12
[Feature][Jdbc] Support read multiple tables by regular expressions (#9380)https://github.com/apache/seatunnel/commit/670a52a9182.3.12
[bugfix][Connector-V2] Fixed the load driver inaccurate situation (#9468)https://github.com/apache/seatunnel/commit/c6639e81fe2.3.12
[Fix][Connector-V2] Fix OceanBase Oracle create unsupported data type (#9383)https://github.com/apache/seatunnel/commit/f4178c72f12.3.12
[improve][Connector-V2] delete jdbc param support_upsert_by_query_primary_key_exist (#9408)https://github.com/apache/seatunnel/commit/d247fe1d8d2.3.12
[Feature][Connector-V2] Jdbc mysql support read tinyint(1) to byte(tinyint) (#9373)https://github.com/apache/seatunnel/commit/7b87aa6f122.3.12
[Improve] JdbcInputFormat nextRecord Exception throw TableId (#9374)https://github.com/apache/seatunnel/commit/484aef593d2.3.12
[Feature][Connector-V2][JDBC] Add presto/trino dialect (#9388)https://github.com/apache/seatunnel/commit/3cac2bd1262.3.12
[Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead of bytes (#9305)https://github.com/apache/seatunnel/commit/454a88f81a2.3.11
[Fix][Connector-jdbc] Fix postgresql sink trying to update unique key (#9293) (#9298)https://github.com/apache/seatunnel/commit/d0c1de83572.3.11
[Fix][Connector-V2] Fix oceanbase mysql jdbc sink create statement error (#9267)https://github.com/apache/seatunnel/commit/79f8125ea62.3.11
[Feature][Transform] Support define sink column type (#9114)https://github.com/apache/seatunnel/commit/ab7119e5072.3.11
[Feature][Checkpoint] Add check script for source/sink state class serialVersionUID missing (#9118)https://github.com/apache/seatunnel/commit/4f5adeb1c72.3.11
[Fix][API] Fixed not invoke the SinkAggregatedCommitter's init method (#9070)https://github.com/apache/seatunnel/commit/df0d11d6322.3.11
[Fix][Connector-V2] Fix SqlServer create table when database with dot (#9007)https://github.com/apache/seatunnel/commit/e09445c7892.3.11
[Fix][Connector-V2][OceanBase] oceanbase vector support simple vector index (#9072)https://github.com/apache/seatunnel/commit/4140cd1d8f2.3.11
[Improve][Connector-V2] Optimize dialect selection in jdbc (#8820)https://github.com/apache/seatunnel/commit/92c62c5e632.3.11
[Fix][JDBC] fix jdbc default connection parameter invalid (#8185)https://github.com/apache/seatunnel/commit/f85eb78b372.3.11
[Hotfix][Jdbc] Fix mysql tinyint(1) type mapping for TypeMapper (#9012)https://github.com/apache/seatunnel/commit/5f85d7668a2.3.11
[Feature][Jdbc] Add String type column split Support by charset-based splitting algorithm (#9002)https://github.com/apache/seatunnel/commit/dbe41e74cd2.3.11
[Fix][Paimon] nullable and comment attribute was lost during automatic table creation (#9020)https://github.com/apache/seatunnel/commit/eb54fdd52c2.3.11
[Fix][Connector-JDBC] Fix JDBC driver selection for data source connections (#8986)https://github.com/apache/seatunnel/commit/a5aafa73012.3.11
[Improve][Jdbc] Upgrade sap-hana driver from 2.14.7 to 2.23.10 (#9013)https://github.com/apache/seatunnel/commit/9ba9f169be2.3.11
[Feature][Jdbc] Support sink ddl for sqlserver #8114 (#8936)https://github.com/apache/seatunnel/commit/30aa485b382.3.10
[Fix][Connector-V2] Fix parse SqlServer JDBC Url error (#8784)https://github.com/apache/seatunnel/commit/373d2162d32.3.10
[Improve][Jdbc] Support upsert for opengauss (#8627)https://github.com/apache/seatunnel/commit/56110bf3922.3.10
[Improve][Jdbc] Remove useless utils. (#8793)https://github.com/apache/seatunnel/commit/36a7533e852.3.10
[Improve][Jdbc] Improve catalog connection cache (#8626)https://github.com/apache/seatunnel/commit/6205065b252.3.10
[Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear (#8653)https://github.com/apache/seatunnel/commit/cf35eecdfc2.3.10
[Feature][Jdbc] Support sink ddl for dameng (#8380)https://github.com/apache/seatunnel/commit/5ff34274282.3.10
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6eeb2.3.10
[Improve][Jdbc] Remove oracle 'v$database' query (#8571)https://github.com/apache/seatunnel/commit/3cf09f61ca2.3.10
[Fix][Connector-V2] Postgres support for multiple primary keys (#8526)https://github.com/apache/seatunnel/commit/04db40d9732.3.10
[Feature][JDBC source] pg support char types (#8420)https://github.com/apache/seatunnel/commit/776ac944782.3.9
[Feature][Jdbc] Support sink ddl for postgresql (#8276)https://github.com/apache/seatunnel/commit/353bbd21a12.3.9
[Feature][Connector-V2] Support the jdbc connector for highgo db (#8282)https://github.com/apache/seatunnel/commit/aa381cbfb42.3.9
[Improve][Jdbc] Support nvarchar in dm (#8270)https://github.com/apache/seatunnel/commit/2f1c54ee2e2.3.9
[Improve][Connector-v2] Use regex to match filedName placeholders in jdbc sink (#8222)https://github.com/apache/seatunnel/commit/c02d4fed362.3.9
[Improve][Connector-V2] Support read comment when jdbc dialect without catalog (#8196)https://github.com/apache/seatunnel/commit/567cd54de52.3.9
[Improve][Connector-V2] The interface supports jdbc respects the target database field type (#8031)https://github.com/apache/seatunnel/commit/1de056a9a42.3.9
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef8000162.3.9
[Improve][Jdbc] Improve ddl write validate (#8158)https://github.com/apache/seatunnel/commit/9cdaacddd92.3.9
[Feature][Jdbc] Add Jdbc default dialect for all jdbc series database without dialect (#8132)https://github.com/apache/seatunnel/commit/399eabcd3f2.3.9
[Improve][Jdbc] Refactor ddl change (#8134)https://github.com/apache/seatunnel/commit/e1f0a238f72.3.9
[Feature][Core] Rename result_table_name/source_table_name to plugin_input/plugin_output (#8072)https://github.com/apache/seatunnel/commit/c7bbd322db2.3.9
[Improve][Connector-V2] Improve schema evolution on column insert after for mysql-jdbc (#8017)https://github.com/apache/seatunnel/commit/3fb05da3652.3.9
[Feature][Core] Support cdc task ddl restore for zeta (#7463)https://github.com/apache/seatunnel/commit/8e322281ed2.3.9
[Feature][transform] transform support explode (#7928)https://github.com/apache/seatunnel/commit/132278c06a2.3.9
[Feature][Connector-v2] Support schema evolution for Oracle connector (#7908)https://github.com/apache/seatunnel/commit/79406bcc2f2.3.9
[Improve][Connector-V2] Improve jdbc merge table from path and query when type is decimal (#7917)https://github.com/apache/seatunnel/commit/8baa012ced2.3.9
[Fix][Connector-V2] Fix hana type loss of precision (#7912)https://github.com/apache/seatunnel/commit/18dcca36cd2.3.9
[Feature][Connector-V2] Jdbc DB2 support upsert SQL (#7879)https://github.com/apache/seatunnel/commit/139919334d2.3.9
[Improve][Jdbc] Optimize index name conflicts when create table for postgresql (#7875)https://github.com/apache/seatunnel/commit/312ee866fb2.3.9
[Improve][Jdbc] Support postgresql inet type. (#7820)https://github.com/apache/seatunnel/commit/25b68b36232.3.9
[Fix][Connector-V2]Oceanbase vector database is added as the source server (#7832)https://github.com/apache/seatunnel/commit/258f9317652.3.9
[Feature][connector-v2]Support opengauss jdbc connnector using opengauss driver. (#7622)https://github.com/apache/seatunnel/commit/bbf643772e2.3.9
[Improve][Jdbc] Support save mode for the sink of jdbc-dm (#7814)https://github.com/apache/seatunnel/commit/b87d732c812.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[Feature][Connector-V2] SqlServer support user-defined type (#7706)https://github.com/apache/seatunnel/commit/fb890332732.3.8
[Hotfix][CDC] Fix ddl duplicate execution error when config multi_table_sink_replica (#7634)https://github.com/apache/seatunnel/commit/23ab3edbbb2.3.8
[Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon writing efficiency (#7335)https://github.com/apache/seatunnel/commit/bc0326cba82.3.8
[Fix][Connector-V2] Fix jdbc test case failed (#7690)https://github.com/apache/seatunnel/commit/4f5d27f6252.3.8
[Improve][Jdbc] Jdbc truncate table should check table not database (#7654)https://github.com/apache/seatunnel/commit/0c0eb7e41b2.3.8
[Feature][Connector-V2] jdbc saphana source tablepath support view and synonym (#7670)https://github.com/apache/seatunnel/commit/7e0c20a4882.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/70ec59ce0e2.3.8
[Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks connector (#7578)https://github.com/apache/seatunnel/commit/020aab422e2.3.8
[Feature] Support tidb cdc connector source #7199 (#7477)https://github.com/apache/seatunnel/commit/87ec786bd62.3.8
[bugfix] fix oracle query table length (#7627)https://github.com/apache/seatunnel/commit/2e002ce09b2.3.8
[Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which used the table_list (#7544)https://github.com/apache/seatunnel/commit/555028217a2.3.8
[Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc (#7530)https://github.com/apache/seatunnel/commit/657fe69b262.3.8
[Improve][Connector-v2] Release resource in closeStatements even exception occurred in executeBatch (#7533)https://github.com/apache/seatunnel/commit/590f7d110d2.3.8
[Fix][Connector-V2] Fix jdbc query sql can not get table path (#7484)https://github.com/apache/seatunnel/commit/8e0ca8f7252.3.8
[Feature][Connector-V2] Add decimal_type_narrowing option in jdbc (#7461)https://github.com/apache/seatunnel/commit/696f2948fa2.3.8
[Improve][Connector-V2] update vectorType (#7446)https://github.com/apache/seatunnel/commit/1bba72385b2.3.8
[Improve][API] Move catalog open to SaveModeHandler (#7439)https://github.com/apache/seatunnel/commit/8c2c5c79a12.3.8
[FIX][E2E]Modify the OceanBase test case to the latest imageChange image (#7452)https://github.com/apache/seatunnel/commit/6abb83deab2.3.8
[Feature][Connector-V2][OceanBase] Support vector types on OceanBase (#7375)https://github.com/apache/seatunnel/commit/a6b188d5522.3.8
[Improve][Connector-V2] Remove system table limit (#7391)https://github.com/apache/seatunnel/commit/adf888e0082.3.8
[Fix] Fix oracle sample data from column error (#7340)https://github.com/apache/seatunnel/commit/2130e0d5ad2.3.8
[Improve][Connector-V2] Close all ResultSet after used (#7389)https://github.com/apache/seatunnel/commit/853e9732122.3.8
[Hotifx][Jdbc] Fix MySQL unsupport 'ZEROFILL' column type (#7407)https://github.com/apache/seatunnel/commit/71303821232.3.8
[Improvement] add starrocks jdbc dialect (#7294)https://github.com/apache/seatunnel/commit/b5140f598e2.3.8
[Hotfix][Connector] Fix jdbc compile error (#7359)https://github.com/apache/seatunnel/commit/2769ed50292.3.7
[Fix][Connector-V2][OceanBase] Remove OceanBase catalog's dependency on mysql driver (#7311)https://github.com/apache/seatunnel/commit/3130ae089e2.3.7
[Improve][Jdbc] Skip all index when auto create table to improve performance of write (#7288)https://github.com/apache/seatunnel/commit/dc3c23981b2.3.7
[Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333)https://github.com/apache/seatunnel/commit/16eeb1c1232.3.7
[Improve][Jdbc] Merge user config primary key when create table (#7313)https://github.com/apache/seatunnel/commit/819c6856512.3.7
[Improve][Connector-v2] Optimize the way of databases and tables are checked for existence (#7261)https://github.com/apache/seatunnel/commit/f012b2a6f02.3.7
[Feature][Jdbc] Support hive compatibleMode add inceptor dialect (#7262)https://github.com/apache/seatunnel/commit/31e59cdf822.3.6
[Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and oracle-cdc (#7248)https://github.com/apache/seatunnel/commit/0d08b200612.3.6
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)https://github.com/apache/seatunnel/commit/c4ca74122c2.3.6
[Fix] Fix Hana type converter decimal scale is 0 convert to int error (#7167)https://github.com/apache/seatunnel/commit/6e33a97c862.3.6
[Improve][Jdbc] Support write unicode text into sqlserver (#7159)https://github.com/apache/seatunnel/commit/e44e8b93bc2.3.6
[Improve][Jdbc] Remove user info in catalog-table options (#7178)https://github.com/apache/seatunnel/commit/4e001be25c2.3.6
[Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)https://github.com/apache/seatunnel/commit/dbdbdf015b2.3.6
[Feature][Connector-V2] Support jdbc hana catalog and type convertor (#6950)https://github.com/apache/seatunnel/commit/d6633987392.3.6
[Improve] Change catalog table log to debug level (#7136)https://github.com/apache/seatunnel/commit/b111d2f8432.3.6
[Improve][Connector-V2] Support schema evolution for mysql-cdc and mysql-jdbc (#6929)https://github.com/apache/seatunnel/commit/cf91e51fc72.3.6
[connector-jdbc][bugfix] fix sqlServer create table comment special string bug (#7024)https://github.com/apache/seatunnel/commit/403564db132.3.6
[bugfix] fix pgsql create table comment special string bug (#7022)https://github.com/apache/seatunnel/commit/9fe844f62a2.3.6
[connector-jdbc][bugfix] fix oracle create table comment special string bug (#7012)https://github.com/apache/seatunnel/commit/a9e0f678732.3.6
[bugfix] fix mysql create table comment special string bug (#6998)https://github.com/apache/seatunnel/commit/904e9cf7852.3.6
[Improve][Jdbc]sink sql support custom field.(#6515) (#6525)https://github.com/apache/seatunnel/commit/ef3e61dbc42.3.6
[Feature][Jdbc] Support redshift catalog (#6992)https://github.com/apache/seatunnel/commit/8d5cbcee742.3.6
[Improve][Connector-V2] Clean key name in catalog table (#6942)https://github.com/apache/seatunnel/commit/a399ef48c62.3.6
[Improve][Zeta] Move SaveMode behavior to master (#6843)https://github.com/apache/seatunnel/commit/80cf91318d2.3.6
[Improve][Jdbc] Quotes the identifier for table path (#6951)https://github.com/apache/seatunnel/commit/d70ec61f352.3.6
[Hotfix][Jdbc] Fix oracle savemode create table (#6651)https://github.com/apache/seatunnel/commit/4b6c13e8fc2.3.6
[Improve][JDBC Source] Fix Split can not be cancel (#6825)https://github.com/apache/seatunnel/commit/ee3b7c37232.3.6
[Feature][Doris] Add Doris type converter (#6354)https://github.com/apache/seatunnel/commit/51899918432.3.6
[Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read (#6684)https://github.com/apache/seatunnel/commit/868ba4d7c72.3.6
[Improve][Connector] Add some sqlserver IDENTITY type for catalog (#6822)https://github.com/apache/seatunnel/commit/f6983965552.3.6
[Feature][Jdbc] Support the jdbc connector for InterSystems IRIS (#6797)https://github.com/apache/seatunnel/commit/46600969bb2.3.6
[Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated (#6781)https://github.com/apache/seatunnel/commit/a5609d600e2.3.6
[Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog (#6771)https://github.com/apache/seatunnel/commit/df1954d5202.3.6
[Fix] Fix Oracle type converter handle negative scale in number type (#6758)https://github.com/apache/seatunnel/commit/6d710690c52.3.6
[Improve][mysql-cdc] Support mysql 5.5 versions (#6710)https://github.com/apache/seatunnel/commit/058f5594a32.3.6
[Improve][Jdbc] Add quote identifier for sql (#6669)https://github.com/apache/seatunnel/commit/849d748d3d2.3.5
[Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)https://github.com/apache/seatunnel/commit/cc660206d82.3.5
[feature][connector-v2] add xugudb connector (#6561)https://github.com/apache/seatunnel/commit/80f392afbb2.3.5
[Hotfix] Fix DEFAULT TABLE problem (#6352)https://github.com/apache/seatunnel/commit/cdb1856e842.3.5
[Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)https://github.com/apache/seatunnel/commit/2086b0e8a62.3.5
[Improve][JDBC] Optimized code style for getting jdbc field types (#6583)https://github.com/apache/seatunnel/commit/ddca95f32c2.3.5
[Improve] Add SaveMode log of process detail (#6375)https://github.com/apache/seatunnel/commit/b0d70ce2242.3.5
[Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)https://github.com/apache/seatunnel/commit/d6dcb03bf32.3.5
feat: jdbc support copy in statement. (#6443)https://github.com/apache/seatunnel/commit/ca4a65fc002.3.5
[Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)https://github.com/apache/seatunnel/commit/14405fa8d42.3.5
[Improve][API] Unify type system api(data & type) (#5872)https://github.com/apache/seatunnel/commit/b38c7edcc92.3.5
Fix Jdbc sink target table name error (#6269)https://github.com/apache/seatunnel/commit/2f62235e382.3.4
[Improve][JDBC] Use PreparedStatement to sample data from column (#6242)https://github.com/apache/seatunnel/commit/bd0e66d5332.3.4
[Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table (#5972)https://github.com/apache/seatunnel/commit/8156036a2f2.3.4
[Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)https://github.com/apache/seatunnel/commit/6f8d0a50402.3.4
[Improve] Support int identity type in sql server (#6186)https://github.com/apache/seatunnel/commit/1a8da1c8432.3.4
[Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data (#6026)https://github.com/apache/seatunnel/commit/635c24e8b22.3.4
[Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc (#5986)https://github.com/apache/seatunnel/commit/97438b94022.3.4
Add date type and float type column split support (#6160)https://github.com/apache/seatunnel/commit/b9a62e5c3f2.3.4
[Improve] Extend SupportResourceShare to spark/flink (#5847)https://github.com/apache/seatunnel/commit/c69da93b872.3.4
[Feature] Support uuid in postgres jdbc (#6185)https://github.com/apache/seatunnel/commit/f56855098b2.3.4
[Feature][Connector-V2][Oracle-cdc]Support for oracle cdc (#5196)https://github.com/apache/seatunnel/commit/aaef22b31b2.3.4
[Feature][Connector] update pgsql catalog for save mode (#6080)https://github.com/apache/seatunnel/commit/84ce5169292.3.4
[Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)https://github.com/apache/seatunnel/commit/413fa745002.3.4
[improve][catalog-postgres] Improve get column sql compatibility (#5664)https://github.com/apache/seatunnel/commit/23ce592ad22.3.4
[Feature][Connector] update oracle catalog for save mode (#6092)https://github.com/apache/seatunnel/commit/dfbf92769c2.3.4
[Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types (#6122)https://github.com/apache/seatunnel/commit/6673f6f7712.3.4
[Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector (#6116)https://github.com/apache/seatunnel/commit/dd698c95bf2.3.4
[Feature][Connector] update sqlserver catalog for save mode (#6086)https://github.com/apache/seatunnel/commit/edcaacecb12.3.4
[Feature][Connector-V2][PostgresSql] add JDBC source support string type as partition key (#6079)https://github.com/apache/seatunnel/commit/3522eb157c2.3.4
[Hotfix][Jdbc] Fix jdbc setFetchSize error (#6005)https://github.com/apache/seatunnel/commit/d41af8a6ed2.3.4
Support using multiple hadoop account (#5903)https://github.com/apache/seatunnel/commit/d69d88d1aa2.3.4
[Feature] Add unsupported datatype check for all catalog (#5890)https://github.com/apache/seatunnel/commit/b9791285a02.3.4
[Hotfix][Split] Fix split key not support BigInteger typehttps://github.com/apache/seatunnel/commit/5adf5d2b9a2.3.4
[Improve] Replace SeaTunnelRowType with TableSchema in the JdbcRowConverterhttps://github.com/apache/seatunnel/commit/1cc1b1b8cd2.3.4
[Hotfix][Jdbc] Fix cdc updates were not filtering same primary key (#5923)https://github.com/apache/seatunnel/commit/38d3b858142.3.4
[Improve]Change System.out.println to log output. (#5912)https://github.com/apache/seatunnel/commit/bbedb07a9c2.3.4
[Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath (#5891)https://github.com/apache/seatunnel/commit/f0b6092c152.3.4
Reduce the time cost of getCatalogTable in jdbc (#5908)https://github.com/apache/seatunnel/commit/51a37375782.3.4
[Improve] Improve Jdbc connector error message when datatype unsupported (#5864)https://github.com/apache/seatunnel/commit/69f79af3a42.3.4
[Improve] Rename getCountSql to getExistDataSql (#5838)https://github.com/apache/seatunnel/commit/2233b3a3812.3.4
[Fix] Fix read from Oracle Date type value lose time (#5814)https://github.com/apache/seatunnel/commit/2d704e36bd2.3.4
[Improve][JdbcSource] Optimize catalog-table metadata merge logic (#5828)https://github.com/apache/seatunnel/commit/7d8028a60b2.3.4
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b22.3.4
[Feature][Hive JDBC Source] Support Hive JDBC Source Connector (#5424)https://github.com/apache/seatunnel/commit/a64e177d062.3.4
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de74081002.3.4
[Improve][Connector] Add field name to DataTypeConvertor to improve error message (#5782)https://github.com/apache/seatunnel/commit/ab60790f0d2.3.4
[Feature][Oracle] Support XMLTYPE data integration #5716 (#5723)https://github.com/apache/seatunnel/commit/620f081adb2.3.4
[Fix] Fix Postgres create table test case failed (#5778)https://github.com/apache/seatunnel/commit/b98b6bcee32.3.4
[Improve][Jdbc] Fix database identifier (#5756)https://github.com/apache/seatunnel/commit/dbfc8a670a2.3.4
[Fix] Fix PG will not create index when using auto create table #5721https://github.com/apache/seatunnel/commit/e5fd88dbe72.3.4
[Improve] Remove all useless prepare, getProducedType method (#5741)https://github.com/apache/seatunnel/commit/ed94fffbb92.3.4
[feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) connector has been realized (#5663)https://github.com/apache/seatunnel/commit/eff17ccbe52.3.4
[Bug][connector-jdbc] Nullable Column source have null data could be unexpected results. (#5560)https://github.com/apache/seatunnel/commit/3f429e1f0a2.3.4
[Improve] Add default implement for SeaTunnelSink::setTypeInfo (#5682)https://github.com/apache/seatunnel/commit/86cba874502.3.4
[BUG][Connector-V2][Jdbc] support postgresql xml type (#5724)https://github.com/apache/seatunnel/commit/5f5d4da13f2.3.4
[Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode (#5697)https://github.com/apache/seatunnel/commit/879c2aa07c2.3.4
[Feature][Jdbc] Support read multiple tables (#5581)https://github.com/apache/seatunnel/commit/33fa8ff2482.3.4
[Feature] Support multi-table sink (#5620)https://github.com/apache/seatunnel/commit/81ac1731892.3.4
[Improve] Remove catalog tag for config file (#5645)https://github.com/apache/seatunnel/commit/dc509aa0802.3.4
[Feature][Jdbc] Supporting more ways to configure connection parameters. (#5388)https://github.com/apache/seatunnel/commit/d31e9478f72.3.4
[Feature][Connector-V2][Jdbc] Add OceanBase catalog (#5439)https://github.com/apache/seatunnel/commit/cd4b7ff7d22.3.4
[BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null point (#5517)https://github.com/apache/seatunnel/commit/103da931f32.3.4
Support config column/primaryKey/constraintKey in schema (#5564)https://github.com/apache/seatunnel/commit/eac76b4e502.3.4
[Improve] Refactor CatalogTable and add SeaTunnelSource::getProducedCatalogTables (#5562)https://github.com/apache/seatunnel/commit/41173357f82.3.4
[Feature][Jdbc] Add Dameng catalog (#5451)https://github.com/apache/seatunnel/commit/c23070919c2.3.4
[Feature] Add tidb datatype convertor (#5440)https://github.com/apache/seatunnel/commit/61391bda9f2.3.4
[Feature][Connector-V2] jdbc connector supports Kingbase database (#4803)https://github.com/apache/seatunnel/commit/95385671592.3.4
[Feature][Catalog] Catalog add Case Conversion Definition (#5328)https://github.com/apache/seatunnel/commit/7b5b28bdbe2.3.4
[Feature][Jdbc] Jdbc database support identifier (#5089)https://github.com/apache/seatunnel/commit/38b6d6e4bb2.3.4
[Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog (#5096)https://github.com/apache/seatunnel/commit/dde3104f762.3.4
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260)https://github.com/apache/seatunnel/commit/51c0d709ba2.3.4
[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one (#5284)https://github.com/apache/seatunnel/commit/ed5eadcf732.3.3
[bug][jdbc][oracle]Fix the Oracle number type mapping problem (#5209)https://github.com/apache/seatunnel/commit/9d3c3de90d2.3.3
[BUG][Connector-V2][Jdbc] support postgresql json type (#5194)https://github.com/apache/seatunnel/commit/7a862d14b72.3.3
[Improve][Connector-V2] Remove scheduler in JDBC sink #4736 (#5168)https://github.com/apache/seatunnel/commit/3b0a3931452.3.3
[CI] Split updated modules integration test for part 5 (#5208)https://github.com/apache/seatunnel/commit/18f14d60872.3.3
[Bug][connector-v2] PostgreSQL versions below 9.5 are compatible use cdc sync problem (#5120)https://github.com/apache/seatunnel/commit/9af696a1dd2.3.3
[Improve][Connector-v2][Jdbc] check url not null throw friendly message (#5097)https://github.com/apache/seatunnel/commit/b0815f2a952.3.3
[Feature][Catalog] Add JDBC Catalog auto create table (#4917)https://github.com/apache/seatunnel/commit/63eb1376712.3.3
[Feature][CDC] Support tables without primary keys (with unique keys) (#163) (#5150)https://github.com/apache/seatunnel/commit/32b7f2b6902.3.3
[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak (#4802)https://github.com/apache/seatunnel/commit/4cc10e83e72.3.3
[Feature][JDBC Sink] Add DM upsert support (#5073)https://github.com/apache/seatunnel/commit/5e8d982e252.3.3
[Improve] Improve savemode api (#4767)https://github.com/apache/seatunnel/commit/4acd370d482.3.3
[Feature][Connector-V2] JDBC source support string type as partition key (#4947)https://github.com/apache/seatunnel/commit/d1d26776582.3.3
[Feature][Connector-V2][Jdbc] Add oceanbase dialect factory (#4989)https://github.com/apache/seatunnel/commit/7ba11cecdf2.3.3
Fix XA Transaction bug (#5020)https://github.com/apache/seatunnel/commit/852fe104bc2.3.3
[Improve][CDC]Remove driver for cdc connector (#4952)https://github.com/apache/seatunnel/commit/b65f40c3c92.3.3
[Improve] Documentation and partial word optimization. (#4936)https://github.com/apache/seatunnel/commit/6e8de0e2a62.3.3
[Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)https://github.com/apache/seatunnel/commit/d56bb1ba1c2.3.3
[Bugfix][zeta] Fix the deadlock issue with JDBC driver loading (#4878)https://github.com/apache/seatunnel/commit/c30a2a1b1c2.3.2
[Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)https://github.com/apache/seatunnel/commit/bde19b63772.3.2
[Feature][Connector-v2] Add Snowflake Source&Sink connector (#4470)https://github.com/apache/seatunnel/commit/06c59a25f32.3.2
[Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)https://github.com/apache/seatunnel/commit/0eff3aeed02.3.2
[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception (#4801)https://github.com/apache/seatunnel/commit/ea3bc1a6732.3.2
[Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity (#4806)https://github.com/apache/seatunnel/commit/2ca7426d222.3.2
[Hotfix][Jdbc][Oracle] Fix oracle sql table identifier (#4754)https://github.com/apache/seatunnel/commit/84cb51ff832.3.2
[Improve][Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)https://github.com/apache/seatunnel/commit/4af3bf90152.3.2
[Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… (#4673)https://github.com/apache/seatunnel/commit/a5af4d9b6e2.3.2
[Improve][Core] Add check of sink and source config to avoid null pointer exception. (#4734)https://github.com/apache/seatunnel/commit/8f66ce96cb2.3.2
[Hotfix][JDBC-SINK] Fix TiDBCatalog without open (#4718)https://github.com/apache/seatunnel/commit/34a7f3eaa42.3.2
[Feature][E2E] Add mysql-cdc e2e testcase (#4639)https://github.com/apache/seatunnel/commit/87001dfd162.3.2
[Hotfix][JDBC Sink] Fix JDBC Sink oom bug (#4690)https://github.com/apache/seatunnel/commit/08b6f992aa2.3.2
Improve the option rule for jdbc sink (#4694)https://github.com/apache/seatunnel/commit/a6b37044142.3.2
[feature][catalog] Support for multiplexing connections (#4550)https://github.com/apache/seatunnel/commit/41277d7f782.3.2
[Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to Boolean type (#4671)https://github.com/apache/seatunnel/commit/89b0099ff42.3.2
[Hotfix]Jdbc[SqlServer] Fix sqlserver jdbc url parse (#4697)https://github.com/apache/seatunnel/commit/b24c3226ec2.3.2
Revert "[Improve][Catalog] refactor catalog (#4540)" (#4628)https://github.com/apache/seatunnel/commit/2d1933195d2.3.2
[Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres (#4575)https://github.com/apache/seatunnel/commit/91f51259762.3.2
[Improve][Catalog] refactor catalog (#4540)https://github.com/apache/seatunnel/commit/b0a701cb832.3.2
[Bug][JDBC Source] fix split exception when source table is empty (#4570)https://github.com/apache/seatunnel/commit/c73b9331ce2.3.2
[Feature][Connector][Jdbc] Add vertica connector. (#4303)https://github.com/apache/seatunnel/commit/e6b4f987212.3.2
[Hotfix][Catalog] Filter out unavailable constrain keys (#4557)https://github.com/apache/seatunnel/commit/5e5859546a2.3.2
[Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)https://github.com/apache/seatunnel/commit/74d4d248582.3.2
[Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)https://github.com/apache/seatunnel/commit/a97f33797d2.3.2
[Jdbc][Chore] improve the exception message when primary key not found in row (#4474)https://github.com/apache/seatunnel/commit/06fa850da92.3.2
[hotfix][JDBC] Fix the table name is not automatically obtained when multiple tables (#4514)https://github.com/apache/seatunnel/commit/c84d6f8d112.3.2
[Chore][Jdbc] add the log for sql and update some style (#4475)https://github.com/apache/seatunnel/commit/a9e65030452.3.2
[Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)https://github.com/apache/seatunnel/commit/7da11c2f442.3.2
[feature][jdbc][TiDB] add TiDB catalog (#4438)https://github.com/apache/seatunnel/commit/9a32db6fc02.3.2
[Hotfix][Connector] Fix sqlserver catalog (#4441)https://github.com/apache/seatunnel/commit/8540c7f9f32.3.2
[Feature][CDC][SqlServer] Support multi-table read (#4377)https://github.com/apache/seatunnel/commit/c4e3f2dc032.3.2
[Improve][JdbcSink]Fix connection failure caused by connection timeout. (#4322)https://github.com/apache/seatunnel/commit/e1f6d3b3fd2.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/3d7ff831f92.3.1
Change file type to file_format_type in file source/sink (#4249)https://github.com/apache/seatunnel/commit/973a2fae3c2.3.1
Change redshift type to lowercase (#4248)https://github.com/apache/seatunnel/commit/10447ae1032.3.1
Add redshift datatype convertor (#4245)https://github.com/apache/seatunnel/commit/b19011517f2.3.1
[improve][zeta] fix zeta bugshttps://github.com/apache/seatunnel/commit/3a82e8b39f2.3.1
[Improve] Support MySqlCatalog Use JDBC URL With Custom Suffixhttps://github.com/apache/seatunnel/commit/210d0ff1f82.3.1
[hotfix] fixed jdbc IT errorhttps://github.com/apache/seatunnel/commit/dd20af0a9e2.3.1
Merge branch 'dev' into merge/cdchttps://github.com/apache/seatunnel/commit/4324ee19122.3.1
[Improve][Project] Code format with spotless plugin.https://github.com/apache/seatunnel/commit/423b5830382.3.1
[improve][jdbc] use ReadonlyConfig instead of Config (#4236)https://github.com/apache/seatunnel/commit/c90c58e2432.3.1
[Improve][Jdbc-sink] add database field to sink config (#4199)https://github.com/apache/seatunnel/commit/ec368902f42.3.1
[improve][jdbc] Reduce jdbc options configuration (#4218)https://github.com/apache/seatunnel/commit/ddd8f808b52.3.1
Fix mysql get default value (#4204)https://github.com/apache/seatunnel/commit/6848434f2d2.3.1
[hotfix][zeta] fix zeta multi-table parser error (#4193)https://github.com/apache/seatunnel/commit/98f2ad0c192.3.1
[Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)https://github.com/apache/seatunnel/commit/9d088017a32.3.1
[Improve][Connector-V2] [StarRocks] Starrocks Support Auto Create Table (#4177)https://github.com/apache/seatunnel/commit/7e0008e6fb2.3.1
[improve][catalog][jdbc] Add MySQL catalog factory (#4168)https://github.com/apache/seatunnel/commit/95e3cbf8752.3.1
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
Add convertor factory (#4119)https://github.com/apache/seatunnel/commit/cbdea45d952.3.1
Add ElasticSearch catalog (#4108)https://github.com/apache/seatunnel/commit/9ee4d8394c2.3.1
Add Kafka catalog (#4106)https://github.com/apache/seatunnel/commit/34f1f21e482.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
Add DataTypeConvertor in Catalog (#4094)https://github.com/apache/seatunnel/commit/840c3e5eb42.3.1
[Feature][Catalog] Support create/drop table, create/drop database in catalog (#4075)https://github.com/apache/seatunnel/commit/d8a0be84ca2.3.1
[Bug][Connector-V2][Jdbc] Fixed no exception throwing problem (#3957)https://github.com/apache/seatunnel/commit/6ab266e5942.3.1
[Bug][CDC] Fix jdbc sink generate update sql (#3940)https://github.com/apache/seatunnel/commit/233465d4e42.3.1
[Improve][JDBC] improve jdbc sink option (#3864)https://github.com/apache/seatunnel/commit/768a9300e82.3.1
Fix Source Class Support Parallelism judge & Add UT for it (#3878)https://github.com/apache/seatunnel/commit/ce85a8c68b2.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb842.3.1
[Feature][Connector-V2] Jdbc connector support SAP HANA. (#3017)https://github.com/apache/seatunnel/commit/fe0180fab22.3.1
[Feature][API &amp; Connector &amp; Doc] add parallelism and column projection interface (#3829)https://github.com/apache/seatunnel/commit/b9164b8ba12.3.1
[Improve][JDBC Connector]improve option rule (#3802)https://github.com/apache/seatunnel/commit/139256741a2.3.1
[Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore (#3809)https://github.com/apache/seatunnel/commit/39dae4cfd92.3.1
[Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector (#3750)https://github.com/apache/seatunnel/commit/5328e9d8472.3.1
[Improve][Connector-v2] Remove unused options for jdbc source factory (#3794)https://github.com/apache/seatunnel/commit/861004d3092.3.1
[Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. (#3796)https://github.com/apache/seatunnel/commit/38646b11b82.3.1
[hotfix][ST-Engine] fix jdbc connector exactly-once null pointer (#3730)https://github.com/apache/seatunnel/commit/0c5986fbec2.3.0
[Improve][connector-jdbc] Add config item enable upsert by query (#3708)https://github.com/apache/seatunnel/commit/e1f951f7822.3.0
[Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds #3701 (#3705)https://github.com/apache/seatunnel/commit/f351ceaf4b2.3.0
[Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug (#3670)https://github.com/apache/seatunnel/commit/6fe0e6aece2.3.0
[Improve][Connector-V2][JDBC] Unified exception for JDBC source & sink (#3598)https://github.com/apache/seatunnel/commit/865ca2bba92.3.0
[Connector][JDBC]Support Redshift sink and source (#3615)https://github.com/apache/seatunnel/commit/8d9d8638d22.3.0
[Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink #3589https://github.com/apache/seatunnel/commit/e77fdbbef72.3.0
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Feature][Connector-V2][Doris]Add Doris Source & Sink connector (#3586)https://github.com/apache/seatunnel/commit/3d46b796142.3.0
[Feature][Connector-V2][Teradata] Add Teradata Source And Sink Connectorhttps://github.com/apache/seatunnel/commit/3a095d30fd2.3.0
[Feature][Connector-V2][JDBC] support sqlite Source & Sink (#3089)https://github.com/apache/seatunnel/commit/a73bb3e7142.3.0
Bump postgresql in /seatunnel-connectors-v2/connector-jdbc (#3559)https://github.com/apache/seatunnel/commit/c8dfdf3e462.3.0
[feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema (#3499)https://github.com/apache/seatunnel/commit/ff44db116e2.3.0
[JDBC][ORACLE] Improve Oracle Type to SeaTunnel Type Mapping (#3486)https://github.com/apache/seatunnel/commit/8fe0dda6e22.3.0
[JDBC][Config] Add JDBC Fetch Size Config And Custom Postgres PrepareStatement (#3478)https://github.com/apache/seatunnel/commit/d60a705f5d2.3.0
[feature][connector][jdbc] expose configurable options in JDBC (#3410)https://github.com/apache/seatunnel/commit/72b8a73cab2.3.0
[feature][connector][jdbc] Support write cdc changelog event in jdbc sink (#3444)https://github.com/apache/seatunnel/commit/b12a908f012.3.0
[Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig (#3453)https://github.com/apache/seatunnel/commit/cfb1e978532.3.0
[Improve][Connector-v2] Unset AutoCommit default to true (#3451)https://github.com/apache/seatunnel/commit/439f686d922.3.0
[Feature][connector-v2] add tablestore source and sink (#3309)https://github.com/apache/seatunnel/commit/ebebf0b6332.3.0
Close jdbc connection after use. (#3358)https://github.com/apache/seatunnel/commit/219fea517c2.3.0
[Improve][Engine] Improve Engine performance. (#3216)https://github.com/apache/seatunnel/commit/7393c473272.3.0
[Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)https://github.com/apache/seatunnel/commit/40d67ab9022.3.0
[Feature][Connector-V2][JDBC] Support DB2 Source & Sink (#2410)https://github.com/apache/seatunnel/commit/bf1ef69e842.3.0
update org.postgresql:postgresql 42.3.3 to 42.4.1 (#3097)https://github.com/apache/seatunnel/commit/28525164902.3.0
[Feature][Connector-V2][Jdbc] support gbase 8a (#3026)https://github.com/apache/seatunnel/commit/dc6e85d06f2.3.0-beta
[Bug][sqlserver] timestamp convert exception (#3024)https://github.com/apache/seatunnel/commit/99ac1a655e2.3.0-beta
[Feature][Connector-V2] oracle connector (#2550)https://github.com/apache/seatunnel/commit/384ece19132.3.0-beta
[Improve][Connector-v2][jdbc] Support for specify number of partitions when parallel reading (#2950)https://github.com/apache/seatunnel/commit/fc284ac32e2.3.0-beta
[Feature][Connector-V2] add sqlserver connector (#2646)https://github.com/apache/seatunnel/commit/05d105dea32.3.0-beta
[Improve][e2e] Unified e2e IT for DaMengDB (#2946)https://github.com/apache/seatunnel/commit/15636bdea12.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/f3ff39bdfe2.3.0-beta
[Improve][e2e] Improve jdbc driver management (#2770)https://github.com/apache/seatunnel/commit/f907927a352.3.0-beta
[hotfix][connector][jdbc] fix JDBC split exception (#2904)https://github.com/apache/seatunnel/commit/57342c65452.3.0-beta
[Improve][connector-jdbc] Calculate splits only once in JdbcSourceSplitEnumerator (#2900)https://github.com/apache/seatunnel/commit/7622f289992.3.0-beta
[Feature][Connector-V2 E2E] Add mysql and postgres e2e test and bug fix (#2838)https://github.com/apache/seatunnel/commit/db434adc152.2.0-beta
fix XAConnection being wrongly submitted (#2805)https://github.com/apache/seatunnel/commit/d9a6039fd32.2.0-beta
fix spark execute exception is not thrown (#2791)https://github.com/apache/seatunnel/commit/b1711c984e2.2.0-beta
[Improve][e2e] Add driver-jar to lib (#2719)https://github.com/apache/seatunnel/commit/d64d452c862.2.0-beta
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)https://github.com/apache/seatunnel/commit/cbf82f755c2.2.0-beta
[Connector-V2][JDBC-connector] support Jdbc dm (#2377)https://github.com/apache/seatunnel/commit/7278209ca22.2.0-beta
[#2606]Dependency management split (#2630)https://github.com/apache/seatunnel/commit/fc047be69b2.2.0-beta
[Bug][connector-jdbc-v2] Fix transaction force commit when autoCommit is enabled (#2636)https://github.com/apache/seatunnel/commit/8cd8cf7aa22.2.0-beta
[Feature][Connector-V2] Add phoenix connector sink (#2499)https://github.com/apache/seatunnel/commit/05ccf9d68c2.2.0-beta
[Connector-V2][JDBC] Support database: greenplum (#2429)https://github.com/apache/seatunnel/commit/3561d3878f2.2.0-beta
Add jdbc connector e2e test (#2321)https://github.com/apache/seatunnel/commit/5fbcb811c62.2.0-beta
StateT of SeaTunnelSource should extend Serializable (#2214)https://github.com/apache/seatunnel/commit/8c426ef8502.2.0-beta
update the condition to 1 = 0 about get table operation (#2186)https://github.com/apache/seatunnel/commit/7c56d7143b2.2.0-beta
[SeaTunnel API][Sink] remove useless context field (#2124)https://github.com/apache/seatunnel/commit/a31fdeedcc2.2.0-beta
[bugfix] Check isOpen before closing (#2107)https://github.com/apache/seatunnel/commit/7ec0ada2b92.2.0-beta
[API-DRAFT][MERGE] fix merge errorhttps://github.com/apache/seatunnel/commit/3c0e9846482.2.0-beta
merge dev to api-drafthttps://github.com/apache/seatunnel/commit/d265597c642.2.0-beta
[api-draft][Optimize] Optimize module name (#2062)https://github.com/apache/seatunnel/commit/f79e3112b12.2.0-beta