跳到主要内容
版本:2.3.10

MySQL

JDBC Mysql 源连接器

描述

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

支持 Mysql 版本

  • 5.5/5.6/5.7/8.0/8.1/8.2/8.3/8.4

支持的引擎

Spark
Flink
SeaTunnel Zeta

需要的依赖项

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

对于 SeaTunnel Zeta 引擎

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

主要功能

支持 SQL 查询,并能实现列投影效果

支持的数据源信息

数据源支持的版本驱动器网址Maven下载链接
Mysql不同的依赖版本具有不同的驱动程序类。com.mysql.cj.jdbc.Driverjdbc:mysql://localhost:3306:3306/test下载

数据类型映射

Mysql 数据类型SeaTunnel 数据类型
BIT(1)
TINYINT(1)
BOOLEAN
TINYINTBYTE
TINYINT UNSIGNED
SMALLINT
SMALLINT
SMALLINT UNSIGNED
MEDIUMINT
MEDIUMINT UNSIGNED
INT
INTEGER
YEAR
INT
INT UNSIGNED
INTEGER UNSIGNED
BIGINT
BIGINT
BIGINT UNSIGNEDDECIMAL(20,0)
DECIMAL(x,y)(获取指定列的列大小<38)DECIMAL(x,y)
DECIMAL(x,y)(获取指定列的列大小>38)DECIMAL(38,18)
DECIMAL UNSIGNEDDECIMAL((获取指定列的列大小)+1,
(获取指定列的小数点右侧的位数))
FLOAT
FLOAT UNSIGNED
FLOAT
DOUBLE
DOUBLE UNSIGNED
DOUBLE
CHAR
VARCHAR
TINYTEXT
MEDIUMTEXT
TEXT
LONGTEXT
JSON
ENUM
STRING
DATEDATE
TIME(s)TIME(s)
DATETIME
TIMESTAMP(s)
TIMESTAMP(s)
TINYBLOB
MEDIUMBLOB
BLOB
LONGBLOB
BINARY
VARBINAR
BIT(n)
GEOMETRY
BYTES

数据源参数

名称类型是否必填默认值描述
urlString-JDBC 连接的 URL。参见示例:
jdbc:mysql://localhost:3306:3306/test
driverString-用于连接远程数据源的 JDBC 类名,
如果使用 MySQL,值为 com.mysql.cj.jdbc.Driver
userString-连接实例用户名。
passwordString-连接实例密码。
queryString-查询语句。
connection_check_timeout_secInt30验证数据库连接所使用的操作完成的等待时间(秒)。
partition_columnString-用于并行度分区的列名,仅支持数字类型,仅支持数字类型的主键,并且只能配置一列。
partition_lower_boundBigDecimal-扫描时 partition_column 的最小值,如果未设置,SeaTunnel 将查询数据库以获取最小值。
partition_upper_boundBigDecimal-扫描时 partition_column 的最大值,如果未设置,SeaTunnel 将查询数据库以获取最大值。
partition_numInt作业并行度分区数量,仅支持正整数。
默认值为作业并行度。
fetch_sizeInt0对于返回大量对象的查询,可以配置查询的行提取大小,以通过减少满足选择条件所需的数据库访问次数来提高性能。
设置为零表示使用 JDBC 的默认值。
propertiesMap-额外的连接配置参数,当属性和 URL 中有相同的参数时,优先级由驱动程序的具体实现决定。
例如,在 MySQL 中,属性优先于 URL。
table_pathString-表的完整路径,您可以使用此配置代替 query
示例:
mysql: "testdb.table1"
oracle: "test_schema.table1"
sqlserver: "testdb.test_schema.table1"
postgresql: "testdb.test_schema.table1"
table_listArray-要读取的表的列表,您可以使用此配置代替 table_path,示例如下: [{ table_path = "testdb.table1"}, {table_path = "testdb.table2", query = "select * id, name from testdb.table2"}]
where_conditionString-所有表/查询的通用行过滤条件,必须以 where 开头。例如 where id > 100
split.sizeInt8096表的分割大小(行数),当读取表时,捕获的表会被分割成多个分片。
split.even-distribution.factor.lower-boundDouble0.05分片键分布因子的下限。该因子用于判断表数据的分布是否均匀。如果计算得到的分布因子大于或等于该下限(即,(MAX(id) - MIN(id) + 1) / 行数),则会对表的分片进行优化,以确保数据的均匀分布。反之,如果分布因子较低,则表数据将被视为分布不均匀。如果估算的分片数量超过 sample-sharding.threshold 所指定的值,则会采用基于采样的分片策略。默认值为 0.05。
split.even-distribution.factor.upper-boundDouble100分片键分布因子的上限。该因子用于判断表数据的分布是否均匀。如果计算得到的分布因子小于或等于该上限(即,(MAX(id) - MIN(id) + 1) / 行数),则会对表的分片进行优化,以确保数据的均匀分布。反之,如果分布因子较大,则表数据将被视为分布不均匀,并且如果估算的分片数量超过 sample-sharding.threshold 所指定的值,则会采用基于采样的分片策略。默认值为 100.0。
split.sample-sharding.thresholdInt10000此配置指定了触发样本分片策略的估算分片数阈值。当分布因子超出由 chunk-key.even-distribution.factor.upper-boundchunk-key.even-distribution.factor.lower-bound 指定的范围,并且估算的分片数量(计算方法为大致行数 / 分片大小)超过此阈值时,将使用样本分片策略。此配置有助于更高效地处理大型数据集。默认值为 1000 个分片。
split.inverse-sampling.rateInt1000样本分片策略中使用的采样率的倒数。例如,如果该值设置为 1000,则表示在采样过程中应用 1/1000 的采样率。此选项提供了灵活性,可以控制采样的粒度,从而影响最终的分片数量。特别适用于处理非常大的数据集,在这种情况下通常会选择较低的采样率。默认值为 1000。
common-options-源插件的常见参数,请参阅 源常见参数 了解详细信息。

并行读取器

JDBC 源连接器支持从表中并行读取数据。SeaTunnel 将使用特定规则将表中的数据进行分割,然后将这些数据交给读取器进行读取。读取器的数量由 parallelism 选项决定。 拆分键规则:

  1. 如果 partition_column 不为空,它将用于计算数据的分片。该列必须属于 支持的分片数据类型
  2. 如果 partition_column 为空,SeaTunnel 将从表中读取模式并获取主键和唯一索引。如果主键和唯一索引中有多个列,则会选择第一个属于 支持的分片数据类型 的列来进行数据分片。例如,如果表的主键是 (nn guid, name varchar),因为 guid 不属于 支持的分片数据类型,所以会选择列 name 来进行数据分片。

支持的拆分数据类型:

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

与拆分相关的参数

split.size

每个分片中的行数,捕获的表在读取时会被分成多个分片。

split.even-distribution.factor.lower-bound

不推荐使用

分片键分布因子的下限。该因子用于判断表数据是否均匀分布。如果计算出的分布因子大于或等于此下限(即,(最大(id) - 最小(id) + 1)/ 行数),则表的分片将被优化为均匀分布。否则,如果分布因子较小,则表的数据将被认为是不均匀分布的。如果估算的分片数量超过 sample-sharding.threshold 所指定的值,将使用基于采样的分片策略。默认值为 0.05。

split.even-distribution.factor.upper-bound

不推荐使用

分片键分布因子的上限。该因子用于判断表数据是否均匀分布。如果计算出的分布因子小于或等于此上限(即,(最大(id) - 最小(id) + 1)/ 行数),则表的分片将被优化为均匀分布。否则,如果分布因子较大,则表的数据将被认为是不均匀分布的。如果估算的分片数量超过 sample-sharding.threshold 所指定的值,将使用基于采样的分片策略。默认值为 100.0。

split.sample-sharding.threshold

此配置指定了触发采样分片策略的估算分片数量阈值。当分布因子超出 chunk-key.even-distribution.factor.upper-boundchunk-key.even-distribution.factor.lower-bound 指定的范围,并且估算的分片数量(按大致行数除以分片大小计算)超过该阈值时,将使用采样分片策略。这有助于更高效地处理大数据集。默认值为 1000 个分片。

split.inverse-sampling.rate

采样分片策略中使用的采样率的倒数。例如,如果此值设置为 1000,则意味着在采样过程中应用 1/1000 的采样率。此选项提供了灵活性,可以控制采样的粒度,从而影响最终的分片数量。在处理非常大的数据集时,较低的采样率通常是首选。默认值为 1000。

partition_column [string]

拆分数据的列名称。

partition_upper_bound [BigDecimal]

扫描时 partition_column 的最大值。如果未设置,SeaTunnel 将查询数据库以获取最大值。

partition_lower_bound [BigDecimal]

扫描时 partition_column 的最小值。如果未设置,SeaTunnel 将查询数据库以获取最小值。

partition_num [int]

不推荐使用,正确的方法是通过 split.size 来控制分片的数量。

需要拆分成多少个分片,只支持正整数。默认值为作业并行度。

提示

如果表无法拆分(例如,表没有主键或唯一索引,且未设置 partition_column),则将以单线程并发方式运行。

使用 table_path 替代 query 来进行单表读取。如果需要读取多个表,请使用 table_list

任务示例

简单的例子:

这个示例以单线程并行的方式查询测试数据库中 type_bin 为 'table' 的16条数据,并查询所有字段。你也可以指定查询哪些字段,并将最终结果输出到控制台。

# 定义运行时环境
env {
parallelism = 4
job.mode = "BATCH"
}
source{
Jdbc {
url = "jdbc:mysql://localhost:3306/test?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"
query = "select * from type_bin limit 16"
}
}

transform {
# 如果您想了解更多关于如何配置 SeaTunnel 的信息,并查看完整的转换插件列表,
# 请访问 https://seatunnel.apache.org/docs/transform-v2/sql
}

sink {
Console {}
}

partition_column 并行

env {
parallelism = 4
job.mode = "BATCH"
}
source {
Jdbc {
url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"
query = "select * from type_bin"
partition_column = "id"
split.size = 10000
# Read start boundary
#partition_lower_bound = ...
# Read end boundary
#partition_upper_bound = ...
}
}

sink {
Console {}
}

按主键或唯一索引并行

配置 table_path 将启用自动拆分,您可以配置 split.* 来调整拆分策略

env {
parallelism = 4
job.mode = "BATCH"
}
source {
Jdbc {
url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"
table_path = "testdb.table1"
query = "select * from testdb.table1"
split.size = 10000
}
}

sink {
Console {}
}

并行边界:

指定数据的上下边界查询会更加高效。根据您配置的上下边界读取数据源会更高效。

source {
Jdbc {
url = "jdbc:mysql://localhost:3306/test?serverTimezone=GMT%2b8&useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"
# Define query logic as required
query = "select * from type_bin"
partition_column = "id"
# Read start boundary
partition_lower_bound = 1
# Read end boundary
partition_upper_bound = 500
partition_num = 10
properties {
useSSL=false
}
}
}

多表读取:

配置 table_list 将启用自动拆分,您可以配置 `split.` 来调整拆分策略*

env {
job.mode = "BATCH"
parallelism = 4
}
source {
Jdbc {
url = "jdbc:mysql://localhost/test?serverTimezone=GMT%2b8"
driver = "com.mysql.cj.jdbc.Driver"
connection_check_timeout_sec = 100
user = "root"
password = "123456"

table_list = [
{
table_path = "testdb.table1"
},
{
table_path = "testdb.table2"
# Use query filetr rows & columns
query = "select id, name from testdb.table2 where id > 100"
}
]
#where_condition= "where id > 100"
#split.size = 8096
#split.even-distribution.factor.upper-bound = 100
#split.even-distribution.factor.lower-bound = 0.05
#split.sample-sharding.threshold = 1000
#split.inverse-sampling.rate = 1000
}
}

sink {
Console {}
}

变更日志

Change Log
ChangeCommitVersion
[Feature][Jdbc] Support sink ddl for sqlserver #8114 (#8936)https://github.com/apache/seatunnel/commit/30aa485b32.3.10
[Fix][Connector-V2] Fix parse SqlServer JDBC Url error (#8784)https://github.com/apache/seatunnel/commit/373d2162d2.3.10
[Improve][Jdbc] Support upsert for opengauss (#8627)https://github.com/apache/seatunnel/commit/56110bf392.3.10
[Improve][Jdbc] Remove useless utils. (#8793)https://github.com/apache/seatunnel/commit/36a7533e82.3.10
[Improve][Jdbc] Improve catalog connection cache (#8626)https://github.com/apache/seatunnel/commit/6205065b22.3.10
[Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear (#8653)https://github.com/apache/seatunnel/commit/cf35eecdf2.3.10
[Feature][Jdbc] Support sink ddl for dameng (#8380)https://github.com/apache/seatunnel/commit/5ff3427422.3.10
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6ee2.3.10
[Improve][Jdbc] Remove oracle 'v$database' query (#8571)https://github.com/apache/seatunnel/commit/3cf09f61c2.3.10
[Fix][Connector-V2] Postgres support for multiple primary keys (#8526)https://github.com/apache/seatunnel/commit/04db40d972.3.10
[Feature][JDBC source] pg support char types (#8420)https://github.com/apache/seatunnel/commit/776ac94472.3.9
[Feature][Jdbc] Support sink ddl for postgresql (#8276)https://github.com/apache/seatunnel/commit/353bbd21a2.3.9
[Feature][Connector-V2] Support the jdbc connector for highgo db (#8282)https://github.com/apache/seatunnel/commit/aa381cbfb2.3.9
[Improve][Jdbc] Support nvarchar in dm (#8270)https://github.com/apache/seatunnel/commit/2f1c54ee22.3.9
[Improve][Connector-v2] Use regex to match filedName placeholders in jdbc sink (#8222)https://github.com/apache/seatunnel/commit/c02d4fed32.3.9
[Improve][Connector-V2] Support read comment when jdbc dialect without catalog (#8196)https://github.com/apache/seatunnel/commit/567cd54de2.3.9
[Improve][Connector-V2] The interface supports jdbc respects the target database field type (#8031)https://github.com/apache/seatunnel/commit/1de056a9a2.3.9
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef800012.3.9
[Improve][Jdbc] Improve ddl write validate (#8158)https://github.com/apache/seatunnel/commit/9cdaacddd2.3.9
[Feature][Jdbc] Add Jdbc default dialect for all jdbc series database without dialect (#8132)https://github.com/apache/seatunnel/commit/399eabcd32.3.9
[Improve][Jdbc] Refactor ddl change (#8134)https://github.com/apache/seatunnel/commit/e1f0a238f2.3.9
[Feature][Core] Rename result_table_name/source_table_name to plugin_input/plugin_output (#8072)https://github.com/apache/seatunnel/commit/c7bbd322d2.3.9
[Improve][Connector-V2] Improve schema evolution on column insert after for mysql-jdbc (#8017)https://github.com/apache/seatunnel/commit/3fb05da362.3.9
[Feature][Core] Support cdc task ddl restore for zeta (#7463)https://github.com/apache/seatunnel/commit/8e322281e2.3.9
[Feature][transform] transform support explode (#7928)https://github.com/apache/seatunnel/commit/132278c062.3.9
[Feature][Connector-v2] Support schema evolution for Oracle connector (#7908)https://github.com/apache/seatunnel/commit/79406bcc22.3.9
[Improve][Connector-V2] Improve jdbc merge table from path and query when type is decimal (#7917)https://github.com/apache/seatunnel/commit/8baa012ce2.3.9
[Fix][Connector-V2] Fix hana type loss of precision (#7912)https://github.com/apache/seatunnel/commit/18dcca36c2.3.9
[Feature][Connector-V2] Jdbc DB2 support upsert SQL (#7879)https://github.com/apache/seatunnel/commit/1399193342.3.9
[Improve][Jdbc] Optimize index name conflicts when create table for postgresql (#7875)https://github.com/apache/seatunnel/commit/312ee866f2.3.9
[Improve][Jdbc] Support postgresql inet type. (#7820)https://github.com/apache/seatunnel/commit/25b68b3622.3.9
[Fix][Connector-V2]Oceanbase vector database is added as the source server (#7832)https://github.com/apache/seatunnel/commit/258f931762.3.9
[Feature][connector-v2]Support opengauss jdbc connnector using opengauss driver. (#7622)https://github.com/apache/seatunnel/commit/bbf6437722.3.9
[Improve][Jdbc] Support save mode for the sink of jdbc-dm (#7814)https://github.com/apache/seatunnel/commit/b87d732c82.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d032.3.9
[Feature][Connector-V2] SqlServer support user-defined type (#7706)https://github.com/apache/seatunnel/commit/fb89033272.3.8
[Hotfix][CDC] Fix ddl duplicate execution error when config multi_table_sink_replica (#7634)https://github.com/apache/seatunnel/commit/23ab3edbb2.3.8
[Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon writing efficiency (#7335)https://github.com/apache/seatunnel/commit/bc0326cba2.3.8
[Fix][Connector-V2] Fix jdbc test case failed (#7690)https://github.com/apache/seatunnel/commit/4f5d27f622.3.8
[Improve][Jdbc] Jdbc truncate table should check table not database (#7654)https://github.com/apache/seatunnel/commit/0c0eb7e412.3.8
[Feature][Connector-V2] jdbc saphana source tablepath support view and synonym (#7670)https://github.com/apache/seatunnel/commit/7e0c20a482.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/70ec59ce02.3.8
[Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks connector (#7578)https://github.com/apache/seatunnel/commit/020aab4222.3.8
[Feature] Support tidb cdc connector source #7199 (#7477)https://github.com/apache/seatunnel/commit/87ec786bd2.3.8
[bugfix] fix oracle query table length (#7627)https://github.com/apache/seatunnel/commit/2e002ce092.3.8
[Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which used the table_list (#7544)https://github.com/apache/seatunnel/commit/5550282172.3.8
[Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc (#7530)https://github.com/apache/seatunnel/commit/657fe69b22.3.8
[Improve][Connector-v2] Release resource in closeStatements even exception occurred in executeBatch (#7533)https://github.com/apache/seatunnel/commit/590f7d1102.3.8
[Fix][Connector-V2] Fix jdbc query sql can not get table path (#7484)https://github.com/apache/seatunnel/commit/8e0ca8f722.3.8
[Feature][Connector-V2] Add decimal_type_narrowing option in jdbc (#7461)https://github.com/apache/seatunnel/commit/696f2948f2.3.8
[Improve][Connector-V2] update vectorType (#7446)https://github.com/apache/seatunnel/commit/1bba723852.3.8
[Improve][API] Move catalog open to SaveModeHandler (#7439)https://github.com/apache/seatunnel/commit/8c2c5c79a2.3.8
[FIX][E2E]Modify the OceanBase test case to the latest imageChange image (#7452)https://github.com/apache/seatunnel/commit/6abb83dea2.3.8
[Feature][Connector-V2][OceanBase] Support vector types on OceanBase (#7375)https://github.com/apache/seatunnel/commit/a6b188d552.3.8
[Improve][Connector-V2] Remove system table limit (#7391)https://github.com/apache/seatunnel/commit/adf888e002.3.8
[Fix] Fix oracle sample data from column error (#7340)https://github.com/apache/seatunnel/commit/2130e0d5a2.3.8
[Improve][Connector-V2] Close all ResultSet after used (#7389)https://github.com/apache/seatunnel/commit/853e973212.3.8
[Hotifx][Jdbc] Fix MySQL unsupport 'ZEROFILL' column type (#7407)https://github.com/apache/seatunnel/commit/7130382122.3.8
[Improvement] add starrocks jdbc dialect (#7294)https://github.com/apache/seatunnel/commit/b5140f5982.3.8
[Hotfix][Connector] Fix jdbc compile error (#7359)https://github.com/apache/seatunnel/commit/2769ed5022.3.7
[Fix][Connector-V2][OceanBase] Remove OceanBase catalog's dependency on mysql driver (#7311)https://github.com/apache/seatunnel/commit/3130ae0892.3.7
[Improve][Jdbc] Skip all index when auto create table to improve performance of write (#7288)https://github.com/apache/seatunnel/commit/dc3c239812.3.7
[Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333)https://github.com/apache/seatunnel/commit/16eeb1c122.3.7
[Improve][Jdbc] Merge user config primary key when create table (#7313)https://github.com/apache/seatunnel/commit/819c685652.3.7
[Improve][Connector-v2] Optimize the way of databases and tables are checked for existence (#7261)https://github.com/apache/seatunnel/commit/f012b2a6f2.3.7
[Feature][Jdbc] Support hive compatibleMode add inceptor dialect (#7262)https://github.com/apache/seatunnel/commit/31e59cdf82.3.6
[Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and oracle-cdc (#7248)https://github.com/apache/seatunnel/commit/0d08b20062.3.6
[Feature][Core] Support using upstream table placeholders in sink options and auto replacement (#7131)https://github.com/apache/seatunnel/commit/c4ca741222.3.6
[Fix] Fix Hana type converter decimal scale is 0 convert to int error (#7167)https://github.com/apache/seatunnel/commit/6e33a97c82.3.6
[Improve][Jdbc] Support write unicode text into sqlserver (#7159)https://github.com/apache/seatunnel/commit/e44e8b93b2.3.6
[Improve][Jdbc] Remove user info in catalog-table options (#7178)https://github.com/apache/seatunnel/commit/4e001be252.3.6
[Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)https://github.com/apache/seatunnel/commit/dbdbdf0152.3.6
[Feature][Connector-V2] Support jdbc hana catalog and type convertor (#6950)https://github.com/apache/seatunnel/commit/d663398732.3.6
[Improve] Change catalog table log to debug level (#7136)https://github.com/apache/seatunnel/commit/b111d2f842.3.6
[Improve][Connector-V2] Support schema evolution for mysql-cdc and mysql-jdbc (#6929)https://github.com/apache/seatunnel/commit/cf91e51fc2.3.6
[connector-jdbc][bugfix] fix sqlServer create table comment special string bug (#7024)https://github.com/apache/seatunnel/commit/403564db12.3.6
[bugfix] fix pgsql create table comment special string bug (#7022)https://github.com/apache/seatunnel/commit/9fe844f622.3.6
[connector-jdbc][bugfix] fix oracle create table comment special string bug (#7012)https://github.com/apache/seatunnel/commit/a9e0f67872.3.6
[bugfix] fix mysql create table comment special string bug (#6998)https://github.com/apache/seatunnel/commit/904e9cf782.3.6
[Improve][Jdbc]sink sql support custom field.(#6515) (#6525)https://github.com/apache/seatunnel/commit/ef3e61dbc2.3.6
[Feature][Jdbc] Support redshift catalog (#6992)https://github.com/apache/seatunnel/commit/8d5cbcee72.3.6
[Improve][Connector-V2] Clean key name in catalog table (#6942)https://github.com/apache/seatunnel/commit/a399ef48c2.3.6
[Improve][Zeta] Move SaveMode behavior to master (#6843)https://github.com/apache/seatunnel/commit/80cf913182.3.6
[Improve][Jdbc] Quotes the identifier for table path (#6951)https://github.com/apache/seatunnel/commit/d70ec61f32.3.6
[Hotfix][Jdbc] Fix oracle savemode create table (#6651)https://github.com/apache/seatunnel/commit/4b6c13e8f2.3.6
[Improve][JDBC Source] Fix Split can not be cancel (#6825)https://github.com/apache/seatunnel/commit/ee3b7c3722.3.6
[Feature][Doris] Add Doris type converter (#6354)https://github.com/apache/seatunnel/commit/5189991842.3.6
[Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read (#6684)https://github.com/apache/seatunnel/commit/868ba4d7c2.3.6
[Improve][Connector] Add some sqlserver IDENTITY type for catalog (#6822)https://github.com/apache/seatunnel/commit/f698396552.3.6
[Feature][Jdbc] Support the jdbc connector for InterSystems IRIS (#6797)https://github.com/apache/seatunnel/commit/46600969b2.3.6
[Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated (#6781)https://github.com/apache/seatunnel/commit/a5609d6002.3.6
[Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog (#6771)https://github.com/apache/seatunnel/commit/df1954d522.3.6
[Fix] Fix Oracle type converter handle negative scale in number type (#6758)https://github.com/apache/seatunnel/commit/6d710690c2.3.6
[Improve][mysql-cdc] Support mysql 5.5 versions (#6710)https://github.com/apache/seatunnel/commit/058f5594a2.3.6
[Improve][Jdbc] Add quote identifier for sql (#6669)https://github.com/apache/seatunnel/commit/849d748d32.3.5
[Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)https://github.com/apache/seatunnel/commit/cc660206d2.3.5
[feature][connector-v2] add xugudb connector (#6561)https://github.com/apache/seatunnel/commit/80f392afb2.3.5
[Hotfix] Fix DEFAULT TABLE problem (#6352)https://github.com/apache/seatunnel/commit/cdb1856e82.3.5
[Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)https://github.com/apache/seatunnel/commit/2086b0e8a2.3.5
[Improve][JDBC] Optimized code style for getting jdbc field types (#6583)https://github.com/apache/seatunnel/commit/ddca95f322.3.5
[Improve] Add SaveMode log of process detail (#6375)https://github.com/apache/seatunnel/commit/b0d70ce222.3.5
[Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)https://github.com/apache/seatunnel/commit/d6dcb03bf2.3.5
feat: jdbc support copy in statement. (#6443)https://github.com/apache/seatunnel/commit/ca4a65fc02.3.5
[Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)https://github.com/apache/seatunnel/commit/14405fa8d2.3.5
[Improve][API] Unify type system api(data & type) (#5872)https://github.com/apache/seatunnel/commit/b38c7edcc2.3.5
Fix Jdbc sink target table name error (#6269)https://github.com/apache/seatunnel/commit/2f62235e32.3.4
[Improve][JDBC] Use PreparedStatement to sample data from column (#6242)https://github.com/apache/seatunnel/commit/bd0e66d532.3.4
[Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table (#5972)https://github.com/apache/seatunnel/commit/8156036a22.3.4
[Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)https://github.com/apache/seatunnel/commit/6f8d0a5042.3.4
[Improve] Support int identity type in sql server (#6186)https://github.com/apache/seatunnel/commit/1a8da1c842.3.4
[Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data (#6026)https://github.com/apache/seatunnel/commit/635c24e8b2.3.4
[Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc (#5986)https://github.com/apache/seatunnel/commit/97438b9402.3.4
Add date type and float type column split support (#6160)https://github.com/apache/seatunnel/commit/b9a62e5c32.3.4
[Improve] Extend SupportResourceShare to spark/flink (#5847)https://github.com/apache/seatunnel/commit/c69da93b82.3.4
[Feature] Support uuid in postgres jdbc (#6185)https://github.com/apache/seatunnel/commit/f568550982.3.4
[Feature][Connector-V2][Oracle-cdc]Support for oracle cdc (#5196)https://github.com/apache/seatunnel/commit/aaef22b312.3.4
[Feature][Connector] update pgsql catalog for save mode (#6080)https://github.com/apache/seatunnel/commit/84ce516922.3.4
[Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)https://github.com/apache/seatunnel/commit/413fa74502.3.4
[improve][catalog-postgres] Improve get column sql compatibility (#5664)https://github.com/apache/seatunnel/commit/23ce592ad2.3.4
[Feature][Connector] update oracle catalog for save mode (#6092)https://github.com/apache/seatunnel/commit/dfbf927692.3.4
[Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types (#6122)https://github.com/apache/seatunnel/commit/6673f6f772.3.4
[Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector (#6116)https://github.com/apache/seatunnel/commit/dd698c95b2.3.4
[Feature][Connector] update sqlserver catalog for save mode (#6086)https://github.com/apache/seatunnel/commit/edcaacecb2.3.4
[Feature][Connector-V2][PostgresSql] add JDBC source support string type as partition key (#6079)https://github.com/apache/seatunnel/commit/3522eb1572.3.4
[Hotfix][Jdbc] Fix jdbc setFetchSize error (#6005)https://github.com/apache/seatunnel/commit/d41af8a6e2.3.4
Support using multiple hadoop account (#5903)https://github.com/apache/seatunnel/commit/d69d88d1a2.3.4
[Feature] Add unsupported datatype check for all catalog (#5890)https://github.com/apache/seatunnel/commit/b9791285a2.3.4
[Hotfix][Split] Fix split key not support BigInteger typehttps://github.com/apache/seatunnel/commit/5adf5d2b92.3.4
[Improve] Replace SeaTunnelRowType with TableSchema in the JdbcRowConverterhttps://github.com/apache/seatunnel/commit/1cc1b1b8c2.3.4
[Hotfix][Jdbc] Fix cdc updates were not filtering same primary key (#5923)https://github.com/apache/seatunnel/commit/38d3b85812.3.4
[Improve]Change System.out.println to log output. (#5912)https://github.com/apache/seatunnel/commit/bbedb07a92.3.4
[Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath (#5891)https://github.com/apache/seatunnel/commit/f0b6092c12.3.4
Reduce the time cost of getCatalogTable in jdbc (#5908)https://github.com/apache/seatunnel/commit/51a3737572.3.4
[Improve] Improve Jdbc connector error message when datatype unsupported (#5864)https://github.com/apache/seatunnel/commit/69f79af3a2.3.4
[Improve] Rename getCountSql to getExistDataSql (#5838)https://github.com/apache/seatunnel/commit/2233b3a382.3.4
[Fix] Fix read from Oracle Date type value lose time (#5814)https://github.com/apache/seatunnel/commit/2d704e36b2.3.4
[Improve][JdbcSource] Optimize catalog-table metadata merge logic (#5828)https://github.com/apache/seatunnel/commit/7d8028a602.3.4
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b2.3.4
[Feature][Hive JDBC Source] Support Hive JDBC Source Connector (#5424)https://github.com/apache/seatunnel/commit/a64e177d02.3.4
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de7408102.3.4
[Improve][Connector] Add field name to DataTypeConvertor to improve error message (#5782)https://github.com/apache/seatunnel/commit/ab60790f02.3.4
[Feature][Oracle] Support XMLTYPE data integration #5716 (#5723)https://github.com/apache/seatunnel/commit/620f081ad2.3.4
[Fix] Fix Postgres create table test case failed (#5778)https://github.com/apache/seatunnel/commit/b98b6bcee2.3.4
[Improve][Jdbc] Fix database identifier (#5756)https://github.com/apache/seatunnel/commit/dbfc8a6702.3.4
[Fix] Fix PG will not create index when using auto create table #5721https://github.com/apache/seatunnel/commit/e5fd88dbe2.3.4
[Improve] Remove all useless prepare, getProducedType method (#5741)https://github.com/apache/seatunnel/commit/ed94fffbb2.3.4
[feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) connector has been realized (#5663)https://github.com/apache/seatunnel/commit/eff17ccbe2.3.4
[Bug][connector-jdbc] Nullable Column source have null data could be unexpected results. (#5560)https://github.com/apache/seatunnel/commit/3f429e1f02.3.4
[Improve] Add default implement for SeaTunnelSink::setTypeInfo (#5682)https://github.com/apache/seatunnel/commit/86cba87452.3.4
[BUG][Connector-V2][Jdbc] support postgresql xml type (#5724)https://github.com/apache/seatunnel/commit/5f5d4da132.3.4
[Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode (#5697)https://github.com/apache/seatunnel/commit/879c2aa072.3.4
[Feature][Jdbc] Support read multiple tables (#5581)https://github.com/apache/seatunnel/commit/33fa8ff242.3.4
[Feature] Support multi-table sink (#5620)https://github.com/apache/seatunnel/commit/81ac173182.3.4
[Improve] Remove catalog tag for config file (#5645)https://github.com/apache/seatunnel/commit/dc509aa082.3.4
[Feature][Jdbc] Supporting more ways to configure connection parameters. (#5388)https://github.com/apache/seatunnel/commit/d31e9478f2.3.4
[Feature][Connector-V2][Jdbc] Add OceanBase catalog (#5439)https://github.com/apache/seatunnel/commit/cd4b7ff7d2.3.4
[BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null point (#5517)https://github.com/apache/seatunnel/commit/103da931f2.3.4
Support config column/primaryKey/constraintKey in schema (#5564)https://github.com/apache/seatunnel/commit/eac76b4e52.3.4
[Improve] Refactor CatalogTable and add SeaTunnelSource::getProducedCatalogTables (#5562)https://github.com/apache/seatunnel/commit/41173357f2.3.4
[Feature][Jdbc] Add Dameng catalog (#5451)https://github.com/apache/seatunnel/commit/c230709192.3.4
[Feature] Add tidb datatype convertor (#5440)https://github.com/apache/seatunnel/commit/61391bda92.3.4
[Feature][Connector-V2] jdbc connector supports Kingbase database (#4803)https://github.com/apache/seatunnel/commit/9538567152.3.4
[Feature][Catalog] Catalog add Case Conversion Definition (#5328)https://github.com/apache/seatunnel/commit/7b5b28bdb2.3.4
[Feature][Jdbc] Jdbc database support identifier (#5089)https://github.com/apache/seatunnel/commit/38b6d6e4b2.3.4
[Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog (#5096)https://github.com/apache/seatunnel/commit/dde3104f72.3.4
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260)https://github.com/apache/seatunnel/commit/51c0d709b2.3.4
[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one (#5284)https://github.com/apache/seatunnel/commit/ed5eadcf72.3.3
[bug][jdbc][oracle]Fix the Oracle number type mapping problem (#5209)https://github.com/apache/seatunnel/commit/9d3c3de902.3.3
[BUG][Connector-V2][Jdbc] support postgresql json type (#5194)https://github.com/apache/seatunnel/commit/7a862d14b2.3.3
[Improve][Connector-V2] Remove scheduler in JDBC sink #4736 (#5168)https://github.com/apache/seatunnel/commit/3b0a393142.3.3
[CI] Split updated modules integration test for part 5 (#5208)https://github.com/apache/seatunnel/commit/18f14d6082.3.3
[Bug][connector-v2] PostgreSQL versions below 9.5 are compatible use cdc sync problem (#5120)https://github.com/apache/seatunnel/commit/9af696a1d2.3.3
[Improve][Connector-v2][Jdbc] check url not null throw friendly message (#5097)https://github.com/apache/seatunnel/commit/b0815f2a92.3.3
[Feature][Catalog] Add JDBC Catalog auto create table (#4917)https://github.com/apache/seatunnel/commit/63eb137672.3.3
[Feature][CDC] Support tables without primary keys (with unique keys) (#163) (#5150)https://github.com/apache/seatunnel/commit/32b7f2b692.3.3
[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database connection leak (#4802)https://github.com/apache/seatunnel/commit/4cc10e83e2.3.3
[Feature][JDBC Sink] Add DM upsert support (#5073)https://github.com/apache/seatunnel/commit/5e8d982e22.3.3
[Improve] Improve savemode api (#4767)https://github.com/apache/seatunnel/commit/4acd370d42.3.3
[Feature][Connector-V2] JDBC source support string type as partition key (#4947)https://github.com/apache/seatunnel/commit/d1d2677652.3.3
[Feature][Connector-V2][Jdbc] Add oceanbase dialect factory (#4989)https://github.com/apache/seatunnel/commit/7ba11cecd2.3.3
Fix XA Transaction bug (#5020)https://github.com/apache/seatunnel/commit/852fe104b2.3.3
[Improve][CDC]Remove driver for cdc connector (#4952)https://github.com/apache/seatunnel/commit/b65f40c3c2.3.3
[Improve] Documentation and partial word optimization. (#4936)https://github.com/apache/seatunnel/commit/6e8de0e2a2.3.3
[Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys (#4634)https://github.com/apache/seatunnel/commit/d56bb1ba12.3.3
[Bugfix][zeta] Fix the deadlock issue with JDBC driver loading (#4878)https://github.com/apache/seatunnel/commit/c30a2a1b12.3.2
[Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)https://github.com/apache/seatunnel/commit/bde19b6372.3.2
[Feature][Connector-v2] Add Snowflake Source&Sink connector (#4470)https://github.com/apache/seatunnel/commit/06c59a25f2.3.2
[Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column in sink (#4815)https://github.com/apache/seatunnel/commit/0eff3aeed2.3.2
[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception (#4801)https://github.com/apache/seatunnel/commit/ea3bc1a672.3.2
[Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity (#4806)https://github.com/apache/seatunnel/commit/2ca7426d22.3.2
[Hotfix][Jdbc][Oracle] Fix oracle sql table identifier (#4754)https://github.com/apache/seatunnel/commit/84cb51ff82.3.2
[Improve][Jdbc] Populate primary key when jdbc sink is created using CatalogTable (#4755)https://github.com/apache/seatunnel/commit/4af3bf9012.3.2
[Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… (#4673)https://github.com/apache/seatunnel/commit/a5af4d9b62.3.2
[Improve][Core] Add check of sink and source config to avoid null pointer exception. (#4734)https://github.com/apache/seatunnel/commit/8f66ce96c2.3.2
[Hotfix][JDBC-SINK] Fix TiDBCatalog without open (#4718)https://github.com/apache/seatunnel/commit/34a7f3eaa2.3.2
[Feature][E2E] Add mysql-cdc e2e testcase (#4639)https://github.com/apache/seatunnel/commit/87001dfd12.3.2
[Hotfix][JDBC Sink] Fix JDBC Sink oom bug (#4690)https://github.com/apache/seatunnel/commit/08b6f992a2.3.2
Improve the option rule for jdbc sink (#4694)https://github.com/apache/seatunnel/commit/a6b3704412.3.2
[feature][catalog] Support for multiplexing connections (#4550)https://github.com/apache/seatunnel/commit/41277d7f72.3.2
[Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to Boolean type (#4671)https://github.com/apache/seatunnel/commit/89b0099ff2.3.2
[Hotfix]Jdbc[SqlServer] Fix sqlserver jdbc url parse (#4697)https://github.com/apache/seatunnel/commit/b24c3226e2.3.2
Revert "[Improve][Catalog] refactor catalog (#4540)" (#4628)https://github.com/apache/seatunnel/commit/2d19331952.3.2
[Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres (#4575)https://github.com/apache/seatunnel/commit/91f5125972.3.2
[Improve][Catalog] refactor catalog (#4540)https://github.com/apache/seatunnel/commit/b0a701cb82.3.2
[Bug][JDBC Source] fix split exception when source table is empty (#4570)https://github.com/apache/seatunnel/commit/c73b9331c2.3.2
[Feature][Connector][Jdbc] Add vertica connector. (#4303)https://github.com/apache/seatunnel/commit/e6b4f98722.3.2
[Hotfix][Catalog] Filter out unavailable constrain keys (#4557)https://github.com/apache/seatunnel/commit/5e58595462.3.2
[Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)https://github.com/apache/seatunnel/commit/74d4d24852.3.2
[Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)https://github.com/apache/seatunnel/commit/a97f337972.3.2
[Jdbc][Chore] improve the exception message when primary key not found in row (#4474)https://github.com/apache/seatunnel/commit/06fa850da2.3.2
[hotfix][JDBC] Fix the table name is not automatically obtained when multiple tables (#4514)https://github.com/apache/seatunnel/commit/c84d6f8d12.3.2
[Chore][Jdbc] add the log for sql and update some style (#4475)https://github.com/apache/seatunnel/commit/a9e6503042.3.2
[Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: generate_sink_sql (#4471)https://github.com/apache/seatunnel/commit/7da11c2f42.3.2
[feature][jdbc][TiDB] add TiDB catalog (#4438)https://github.com/apache/seatunnel/commit/9a32db6fc2.3.2
[Hotfix][Connector] Fix sqlserver catalog (#4441)https://github.com/apache/seatunnel/commit/8540c7f9f2.3.2
[Feature][CDC][SqlServer] Support multi-table read (#4377)https://github.com/apache/seatunnel/commit/c4e3f2dc02.3.2
[Improve][JdbcSink]Fix connection failure caused by connection timeout. (#4322)https://github.com/apache/seatunnel/commit/e1f6d3b3f2.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/3d7ff831f2.3.1
Change file type to file_format_type in file source/sink (#4249)https://github.com/apache/seatunnel/commit/973a2fae32.3.1
Change redshift type to lowercase (#4248)https://github.com/apache/seatunnel/commit/10447ae102.3.1
Add redshift datatype convertor (#4245)https://github.com/apache/seatunnel/commit/b190115172.3.1
[improve][zeta] fix zeta bugshttps://github.com/apache/seatunnel/commit/3a82e8b392.3.1
[Improve] Support MySqlCatalog Use JDBC URL With Custom Suffixhttps://github.com/apache/seatunnel/commit/210d0ff1f2.3.1
[hotfix] fixed jdbc IT errorhttps://github.com/apache/seatunnel/commit/dd20af0a92.3.1
Merge branch 'dev' into merge/cdchttps://github.com/apache/seatunnel/commit/4324ee1912.3.1
[Improve][Project] Code format with spotless plugin.https://github.com/apache/seatunnel/commit/423b583032.3.1
[improve][jdbc] use ReadonlyConfig instead of Config (#4236)https://github.com/apache/seatunnel/commit/c90c58e242.3.1
[Improve][Jdbc-sink] add database field to sink config (#4199)https://github.com/apache/seatunnel/commit/ec368902f2.3.1
[improve][jdbc] Reduce jdbc options configuration (#4218)https://github.com/apache/seatunnel/commit/ddd8f808b2.3.1
Fix mysql get default value (#4204)https://github.com/apache/seatunnel/commit/6848434f22.3.1
[hotfix][zeta] fix zeta multi-table parser error (#4193)https://github.com/apache/seatunnel/commit/98f2ad0c12.3.1
[Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)https://github.com/apache/seatunnel/commit/9d088017a2.3.1
[Improve][Connector-V2] [StarRocks] Starrocks Support Auto Create Table (#4177)https://github.com/apache/seatunnel/commit/7e0008e6f2.3.1
[improve][catalog][jdbc] Add MySQL catalog factory (#4168)https://github.com/apache/seatunnel/commit/95e3cbf872.3.1
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd601052.3.1
Add convertor factory (#4119)https://github.com/apache/seatunnel/commit/cbdea45d92.3.1
Add ElasticSearch catalog (#4108)https://github.com/apache/seatunnel/commit/9ee4d83942.3.1
Add Kafka catalog (#4106)https://github.com/apache/seatunnel/commit/34f1f21e42.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab166562.3.1
Add DataTypeConvertor in Catalog (#4094)https://github.com/apache/seatunnel/commit/840c3e5eb2.3.1
[Feature][Catalog] Support create/drop table, create/drop database in catalog (#4075)https://github.com/apache/seatunnel/commit/d8a0be84c2.3.1
[Bug][Connector-V2][Jdbc] Fixed no exception throwing problem (#3957)https://github.com/apache/seatunnel/commit/6ab266e592.3.1
[Bug][CDC] Fix jdbc sink generate update sql (#3940)https://github.com/apache/seatunnel/commit/233465d4e2.3.1
[Improve][JDBC] improve jdbc sink option (#3864)https://github.com/apache/seatunnel/commit/768a9300e2.3.1
Fix Source Class Support Parallelism judge & Add UT for it (#3878)https://github.com/apache/seatunnel/commit/ce85a8c682.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb82.3.1
[Feature][Connector-V2] Jdbc connector support SAP HANA. (#3017)https://github.com/apache/seatunnel/commit/fe0180fab2.3.1
[Feature][API &amp; Connector &amp; Doc] add parallelism and column projection interface (#3829)https://github.com/apache/seatunnel/commit/b9164b8ba2.3.1
[Improve][JDBC Connector]improve option rule (#3802)https://github.com/apache/seatunnel/commit/1392567412.3.1
[Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore (#3809)https://github.com/apache/seatunnel/commit/39dae4cfd2.3.1
[Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector (#3750)https://github.com/apache/seatunnel/commit/5328e9d842.3.1
[Improve][Connector-v2] Remove unused options for jdbc source factory (#3794)https://github.com/apache/seatunnel/commit/861004d302.3.1
[Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. (#3796)https://github.com/apache/seatunnel/commit/38646b11b2.3.1
[hotfix][ST-Engine] fix jdbc connector exactly-once null pointer (#3730)https://github.com/apache/seatunnel/commit/0c5986fbe2.3.0
[Improve][connector-jdbc] Add config item enable upsert by query (#3708)https://github.com/apache/seatunnel/commit/e1f951f782.3.0
[Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds #3701 (#3705)https://github.com/apache/seatunnel/commit/f351ceaf42.3.0
[Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug (#3670)https://github.com/apache/seatunnel/commit/6fe0e6aec2.3.0
[Improve][Connector-V2][JDBC] Unified exception for JDBC source & sink (#3598)https://github.com/apache/seatunnel/commit/865ca2bba2.3.0
[Connector][JDBC]Support Redshift sink and source (#3615)https://github.com/apache/seatunnel/commit/8d9d8638d2.3.0
[Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink #3589https://github.com/apache/seatunnel/commit/e77fdbbef2.3.0
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a112.3.0
[Feature][Connector-V2][Doris]Add Doris Source & Sink connector (#3586)https://github.com/apache/seatunnel/commit/3d46b79612.3.0
[Feature][Connector-V2][Teradata] Add Teradata Source And Sink Connectorhttps://github.com/apache/seatunnel/commit/3a095d30f2.3.0
[Feature][Connector-V2][JDBC] support sqlite Source & Sink (#3089)https://github.com/apache/seatunnel/commit/a73bb3e712.3.0
Bump postgresql in /seatunnel-connectors-v2/connector-jdbc (#3559)https://github.com/apache/seatunnel/commit/c8dfdf3e42.3.0
[feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema (#3499)https://github.com/apache/seatunnel/commit/ff44db1162.3.0
[JDBC][ORACLE] Improve Oracle Type to SeaTunnel Type Mapping (#3486)https://github.com/apache/seatunnel/commit/8fe0dda6e2.3.0
[JDBC][Config] Add JDBC Fetch Size Config And Custom Postgres PrepareStatement (#3478)https://github.com/apache/seatunnel/commit/d60a705f52.3.0
[feature][connector][jdbc] expose configurable options in JDBC (#3410)https://github.com/apache/seatunnel/commit/72b8a73ca2.3.0
[feature][connector][jdbc] Support write cdc changelog event in jdbc sink (#3444)https://github.com/apache/seatunnel/commit/b12a908f02.3.0
[Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig (#3453)https://github.com/apache/seatunnel/commit/cfb1e97852.3.0
[Improve][Connector-v2] Unset AutoCommit default to true (#3451)https://github.com/apache/seatunnel/commit/439f686d92.3.0
[Feature][connector-v2] add tablestore source and sink (#3309)https://github.com/apache/seatunnel/commit/ebebf0b632.3.0
Close jdbc connection after use. (#3358)https://github.com/apache/seatunnel/commit/219fea5172.3.0
[Improve][Engine] Improve Engine performance. (#3216)https://github.com/apache/seatunnel/commit/7393c47322.3.0
[Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)https://github.com/apache/seatunnel/commit/40d67ab902.3.0
[Feature][Connector-V2][JDBC] Support DB2 Source & Sink (#2410)https://github.com/apache/seatunnel/commit/bf1ef69e82.3.0
update org.postgresql:postgresql 42.3.3 to 42.4.1 (#3097)https://github.com/apache/seatunnel/commit/2852516492.3.0
[Feature][Connector-V2][Jdbc] support gbase 8a (#3026)https://github.com/apache/seatunnel/commit/dc6e85d062.3.0-beta
[Bug][sqlserver] timestamp convert exception (#3024)https://github.com/apache/seatunnel/commit/99ac1a6552.3.0-beta
[Feature][Connector-V2] oracle connector (#2550)https://github.com/apache/seatunnel/commit/384ece1912.3.0-beta
[Improve][Connector-v2][jdbc] Support for specify number of partitions when parallel reading (#2950)https://github.com/apache/seatunnel/commit/fc284ac322.3.0-beta
[Feature][Connector-V2] add sqlserver connector (#2646)https://github.com/apache/seatunnel/commit/05d105dea2.3.0-beta
[Improve][e2e] Unified e2e IT for DaMengDB (#2946)https://github.com/apache/seatunnel/commit/15636bdea2.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/f3ff39bdf2.3.0-beta
[Improve][e2e] Improve jdbc driver management (#2770)https://github.com/apache/seatunnel/commit/f907927a32.3.0-beta
[hotfix][connector][jdbc] fix JDBC split exception (#2904)https://github.com/apache/seatunnel/commit/57342c6542.3.0-beta
[Improve][connector-jdbc] Calculate splits only once in JdbcSourceSplitEnumerator (#2900)https://github.com/apache/seatunnel/commit/7622f28992.3.0-beta
[Feature][Connector-V2 E2E] Add mysql and postgres e2e test and bug fix (#2838)https://github.com/apache/seatunnel/commit/db434adc12.2.0-beta
fix XAConnection being wrongly submitted (#2805)https://github.com/apache/seatunnel/commit/d9a6039fd2.2.0-beta
fix spark execute exception is not thrown (#2791)https://github.com/apache/seatunnel/commit/b1711c9842.2.0-beta
[Improve][e2e] Add driver-jar to lib (#2719)https://github.com/apache/seatunnel/commit/d64d452c82.2.0-beta
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)https://github.com/apache/seatunnel/commit/cbf82f7552.2.0-beta
[Connector-V2][JDBC-connector] support Jdbc dm (#2377)https://github.com/apache/seatunnel/commit/7278209ca2.2.0-beta
[#2606]Dependency management split (#2630)https://github.com/apache/seatunnel/commit/fc047be692.2.0-beta
[Bug][connector-jdbc-v2] Fix transaction force commit when autoCommit is enabled (#2636)https://github.com/apache/seatunnel/commit/8cd8cf7aa2.2.0-beta
[Feature][Connector-V2] Add phoenix connector sink (#2499)https://github.com/apache/seatunnel/commit/05ccf9d682.2.0-beta
[Connector-V2][JDBC] Support database: greenplum (#2429)https://github.com/apache/seatunnel/commit/3561d38782.2.0-beta
Add jdbc connector e2e test (#2321)https://github.com/apache/seatunnel/commit/5fbcb811c2.2.0-beta
StateT of SeaTunnelSource should extend Serializable (#2214)https://github.com/apache/seatunnel/commit/8c426ef852.2.0-beta
update the condition to 1 = 0 about get table operation (#2186)https://github.com/apache/seatunnel/commit/7c56d71432.2.0-beta
[SeaTunnel API][Sink] remove useless context field (#2124)https://github.com/apache/seatunnel/commit/a31fdeedc2.2.0-beta
[bugfix] Check isOpen before closing (#2107)https://github.com/apache/seatunnel/commit/7ec0ada2b2.2.0-beta
[API-DRAFT][MERGE] fix merge errorhttps://github.com/apache/seatunnel/commit/3c0e984642.2.0-beta
merge dev to api-drafthttps://github.com/apache/seatunnel/commit/d265597c62.2.0-beta
[api-draft][Optimize] Optimize module name (#2062)https://github.com/apache/seatunnel/commit/f79e3112b2.2.0-beta