(seatunnel) branch dev updated: [Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead of bytes (#9305)

wanghailin Thu, 15 May 2025 18:48:03 -0700

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git



The following commit(s) were added to refs/heads/dev by this push:
     new 454a88f81a [Feature][Connector-JDBC] Supprot read Oracle BLOB data as 
string instead of bytes (#9305)
454a88f81a is described below

commit 454a88f81a3797aaec9decb820f876c89d599051
Author: yzeng1618 <[email protected]>
AuthorDate: Fri May 16 09:47:52 2025 +0800

    [Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead 
of bytes (#9305)
    
    Co-authored-by: zengyi <[email protected]>
---
 docs/en/connector-v2/changelog/connector-jdbc.md   | 627 +++++++++++----------
 docs/en/connector-v2/source/Jdbc.md                |  23 +
 .../cdc/oracle/utils/OracleTypeUtils.java          |   2 +-
 .../seatunnel/jdbc/catalog/JdbcCatalogOptions.java |   4 +-
 .../jdbc/catalog/oracle/OracleCatalog.java         |  15 +-
 .../jdbc/catalog/oracle/OracleCatalogFactory.java  |   3 +-
 .../jdbc/config/JdbcConnectionConfig.java          |  18 +
 .../seatunnel/jdbc/config/JdbcOptions.java         |   7 +
 .../seatunnel/jdbc/config/JdbcSourceConfig.java    |   2 +
 .../jdbc/internal/dialect/JdbcDialectFactory.java  |  17 +
 .../jdbc/internal/dialect/JdbcDialectLoader.java   |  31 +-
 .../internal/dialect/oracle/OracleDialect.java     |  17 +-
 .../dialect/oracle/OracleDialectFactory.java       |  13 +-
 .../dialect/oracle/OracleTypeConverter.java        |  20 +-
 .../internal/dialect/oracle/OracleTypeMapper.java  |  13 +-
 .../seatunnel/jdbc/source/JdbcSourceFactory.java   |   3 +-
 .../seatunnel/jdbc/utils/JdbcCatalogUtils.java     |   2 +-
 .../seatunnel/jdbc/utils/JdbcFieldTypeUtils.java   |  15 +
 .../dialect/oracle/OracleTypeConverterTest.java    |  37 ++
 .../connectors/seatunnel/jdbc/JdbcOracleIT.java    |   7 +
 ..._oracle_source_to_sink_with_blob_as_string.conf | 104 ++++
 21 files changed, 645 insertions(+), 335 deletions(-)

diff --git a/docs/en/connector-v2/changelog/connector-jdbc.md 
b/docs/en/connector-v2/changelog/connector-jdbc.md
index d9a81f7534..3f8438c738 100644
--- a/docs/en/connector-v2/changelog/connector-jdbc.md
+++ b/docs/en/connector-v2/changelog/connector-jdbc.md
@@ -1,317 +1,318 @@
 <details><summary> Change Log </summary>
 
-| Change | Commit | Version |
-| --- | --- | --- |
-|[Hotfix][Jdbc] Fix mysql tinyint(1) type mapping for TypeMapper 
(#9012)|https://github.com/apache/seatunnel/commit/5f85d7668a| dev |
-|[Feature][Jdbc] Add String type column split Support by charset-based 
splitting algorithm 
(#9002)|https://github.com/apache/seatunnel/commit/dbe41e74cd| dev |
-|[Fix][Paimon] nullable and comment attribute was lost during automatic table 
creation (#9020)|https://github.com/apache/seatunnel/commit/eb54fdd52c| dev |
-|[Fix][Connector-JDBC] Fix JDBC driver selection for data source connections 
(#8986)|https://github.com/apache/seatunnel/commit/a5aafa7301| dev |
-|[Improve][Jdbc] Upgrade sap-hana driver from 2.14.7 to 2.23.10 
(#9013)|https://github.com/apache/seatunnel/commit/9ba9f169be| dev |
-|[Feature][Jdbc] Support sink ddl for sqlserver #8114 
(#8936)|https://github.com/apache/seatunnel/commit/30aa485b38|2.3.10|
-|[Fix][Connector-V2] Fix parse SqlServer JDBC Url error 
(#8784)|https://github.com/apache/seatunnel/commit/373d2162d3|2.3.10|
-|[Improve][Jdbc] Support upsert for opengauss 
(#8627)|https://github.com/apache/seatunnel/commit/56110bf392|2.3.10|
-|[Improve][Jdbc] Remove useless utils. 
(#8793)|https://github.com/apache/seatunnel/commit/36a7533e85|2.3.10|
-|[Improve][Jdbc] Improve catalog connection cache 
(#8626)|https://github.com/apache/seatunnel/commit/6205065b25|2.3.10|
-|[Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear 
(#8653)|https://github.com/apache/seatunnel/commit/cf35eecdfc|2.3.10|
-|[Feature][Jdbc] Support sink ddl for dameng 
(#8380)|https://github.com/apache/seatunnel/commit/5ff3427428|2.3.10|
-|[Improve] restruct connector common options 
(#8634)|https://github.com/apache/seatunnel/commit/f3499a6eeb|2.3.10|
-|[Improve][Jdbc] Remove oracle &#x27;v$database&#x27; query 
(#8571)|https://github.com/apache/seatunnel/commit/3cf09f61ca|2.3.10|
-|[Fix] [Connector-V2] Postgres support for multiple primary keys 
(#8526)|https://github.com/apache/seatunnel/commit/04db40d973|2.3.10|
-|[Feature][JDBC source] pg support char types 
(#8420)|https://github.com/apache/seatunnel/commit/776ac94478|2.3.9|
-|[Feature][Jdbc] Support sink ddl for postgresql 
(#8276)|https://github.com/apache/seatunnel/commit/353bbd21a1|2.3.9|
-|[Feature][Connector-V2] Support the jdbc connector for highgo db 
(#8282)|https://github.com/apache/seatunnel/commit/aa381cbfb4|2.3.9|
-|[Improve][Jdbc] Support nvarchar in dm 
(#8270)|https://github.com/apache/seatunnel/commit/2f1c54ee2e|2.3.9|
-|[Improve][Connector-v2] Use regex to match filedName placeholders in jdbc 
sink (#8222)|https://github.com/apache/seatunnel/commit/c02d4fed36|2.3.9|
-|[Improve][Connector-V2] Support read comment when jdbc dialect without 
catalog (#8196)|https://github.com/apache/seatunnel/commit/567cd54de5|2.3.9|
-|[Improve][Connector-V2] The interface supports jdbc respects the target 
database field type 
(#8031)|https://github.com/apache/seatunnel/commit/1de056a9a4|2.3.9|
-|[Improve][dist]add shade check rule 
(#8136)|https://github.com/apache/seatunnel/commit/51ef800016|2.3.9|
-|[Improve][Jdbc] Improve ddl write validate 
(#8158)|https://github.com/apache/seatunnel/commit/9cdaacddd9|2.3.9|
-|[Feature][Jdbc] Add Jdbc default dialect for all jdbc series database without 
dialect (#8132)|https://github.com/apache/seatunnel/commit/399eabcd3f|2.3.9|
-|[Improve][Jdbc] Refactor ddl change 
(#8134)|https://github.com/apache/seatunnel/commit/e1f0a238f7|2.3.9|
-|[Feature][Core] Rename `result_table_name`/`source_table_name` to 
`plugin_input/plugin_output` 
(#8072)|https://github.com/apache/seatunnel/commit/c7bbd322db|2.3.9|
-|[Improve][Connector-V2] Improve schema evolution on column insert after for 
mysql-jdbc (#8017)|https://github.com/apache/seatunnel/commit/3fb05da365|2.3.9|
-|[Feature][Core] Support cdc task ddl restore for zeta 
(#7463)|https://github.com/apache/seatunnel/commit/8e322281ed|2.3.9|
-|[Feature][transform] transform support explode 
(#7928)|https://github.com/apache/seatunnel/commit/132278c06a|2.3.9|
-|[Feature][Connector-v2] Support schema evolution for Oracle connector 
(#7908)|https://github.com/apache/seatunnel/commit/79406bcc2f|2.3.9|
-|[Improve][Connector-V2] Improve jdbc merge table from path and query when 
type is decimal 
(#7917)|https://github.com/apache/seatunnel/commit/8baa012ced|2.3.9|
-|[Fix][Connector-V2] Fix hana type loss of precision 
(#7912)|https://github.com/apache/seatunnel/commit/18dcca36cd|2.3.9|
-|[Feature][Connector-V2] Jdbc DB2 support upsert SQL  
(#7879)|https://github.com/apache/seatunnel/commit/139919334d|2.3.9|
-|[Improve][Jdbc] Optimize index name conflicts when create table for 
postgresql (#7875)|https://github.com/apache/seatunnel/commit/312ee866fb|2.3.9|
-|[Improve][Jdbc] Support postgresql inet type. 
(#7820)|https://github.com/apache/seatunnel/commit/25b68b3623|2.3.9|
-|[Fix][Connector-V2]Oceanbase vector database is added as the source server 
(#7832)|https://github.com/apache/seatunnel/commit/258f931765|2.3.9|
-|[Feature][connector-v2]Support opengauss jdbc connnector using opengauss 
driver. (#7622)|https://github.com/apache/seatunnel/commit/bbf643772e|2.3.9|
-|[Improve][Jdbc] Support save mode for the sink of jdbc-dm 
(#7814)|https://github.com/apache/seatunnel/commit/b87d732c81|2.3.9|
-|[Feature][Restapi] Allow metrics information to be associated to logical plan 
nodes (#7786)|https://github.com/apache/seatunnel/commit/6b7c53d03c|2.3.9|
-|[Feature][Connector-V2] SqlServer support user-defined type 
(#7706)|https://github.com/apache/seatunnel/commit/fb89033273|2.3.8|
-|[Hotfix][CDC] Fix ddl duplicate execution error when config 
multi_table_sink_replica 
(#7634)|https://github.com/apache/seatunnel/commit/23ab3edbbb|2.3.8|
-|[Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon 
writing efficiency 
(#7335)|https://github.com/apache/seatunnel/commit/bc0326cba8|2.3.8|
-|[Fix][Connector-V2] Fix jdbc test case failed 
(#7690)|https://github.com/apache/seatunnel/commit/4f5d27f625|2.3.8|
-|[Improve][Jdbc] Jdbc truncate table should check table not database 
(#7654)|https://github.com/apache/seatunnel/commit/0c0eb7e41b|2.3.8|
-|[Feature][Connector-V2] jdbc saphana source tablepath support view and  
synonym (#7670)|https://github.com/apache/seatunnel/commit/7e0c20a488|2.3.8|
-|[Fix][Connector-v2] Throw Exception in sql query for JdbcCatalog in table or 
db exists query 
(#7651)|https://github.com/apache/seatunnel/commit/70ec59ce0e|2.3.8|
-|[Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks 
connector (#7578)|https://github.com/apache/seatunnel/commit/020aab422e|2.3.8|
-|[Feature] Support tidb cdc connector source #7199 
(#7477)|https://github.com/apache/seatunnel/commit/87ec786bd6|2.3.8|
-|[bugfix] fix oracle query table length 
(#7627)|https://github.com/apache/seatunnel/commit/2e002ce09b|2.3.8|
-|[Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which 
used the table_list 
(#7544)|https://github.com/apache/seatunnel/commit/555028217a|2.3.8|
-|[Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc 
(#7530)|https://github.com/apache/seatunnel/commit/657fe69b26|2.3.8|
-|[Improve][Connector-v2] Release resource in closeStatements even exception 
occurred in executeBatch 
(#7533)|https://github.com/apache/seatunnel/commit/590f7d110d|2.3.8|
-|[Fix][Connector-V2] Fix jdbc query sql can not get table path 
(#7484)|https://github.com/apache/seatunnel/commit/8e0ca8f725|2.3.8|
-|[Feature][Connector-V2] Add `decimal_type_narrowing` option in jdbc 
(#7461)|https://github.com/apache/seatunnel/commit/696f2948fa|2.3.8|
-|[Improve][Connector-V2] update vectorType 
(#7446)|https://github.com/apache/seatunnel/commit/1bba72385b|2.3.8|
-|[Improve][API] Move catalog open to SaveModeHandler 
(#7439)|https://github.com/apache/seatunnel/commit/8c2c5c79a1|2.3.8|
-|[FIX][E2E]Modify the OceanBase test case to the latest imageChange image 
(#7452)|https://github.com/apache/seatunnel/commit/6abb83deab|2.3.8|
-|[Feature][Connector-V2][OceanBase] Support vector types on OceanBase 
(#7375)|https://github.com/apache/seatunnel/commit/a6b188d552|2.3.8|
-|[Improve][Connector-V2] Remove system table limit 
(#7391)|https://github.com/apache/seatunnel/commit/adf888e008|2.3.8|
-|[Fix] Fix oracle sample data from column error 
(#7340)|https://github.com/apache/seatunnel/commit/2130e0d5ad|2.3.8|
-|[Improve][Connector-V2] Close all ResultSet after used 
(#7389)|https://github.com/apache/seatunnel/commit/853e973212|2.3.8|
-|[Hotifx][Jdbc] Fix MySQL unsupport &#x27;ZEROFILL&#x27; column type 
(#7407)|https://github.com/apache/seatunnel/commit/7130382123|2.3.8|
-|[Improvement] add starrocks jdbc dialect 
(#7294)|https://github.com/apache/seatunnel/commit/b5140f598e|2.3.8|
-|[Hotfix][Connector] Fix jdbc compile error 
(#7359)|https://github.com/apache/seatunnel/commit/2769ed5029|2.3.7|
-|[Fix][Connector-V2][OceanBase] Remove OceanBase catalog&#x27;s dependency on 
mysql driver 
(#7311)|https://github.com/apache/seatunnel/commit/3130ae089e|2.3.7|
-|[Improve][Jdbc] Skip all index when auto create table to improve performance 
of write (#7288)|https://github.com/apache/seatunnel/commit/dc3c23981b|2.3.7|
-|[Improve][Jdbc] Remove MysqlType references in JdbcDialect 
(#7333)|https://github.com/apache/seatunnel/commit/16eeb1c123|2.3.7|
-|[Improve][Jdbc] Merge user config primary key when create table 
(#7313)|https://github.com/apache/seatunnel/commit/819c685651|2.3.7|
-|[Improve][Connector-v2] Optimize the way of databases and tables are checked 
for existence 
(#7261)|https://github.com/apache/seatunnel/commit/f012b2a6f0|2.3.7|
-|[Feature][Jdbc] Support hive compatibleMode add inceptor dialect 
(#7262)|https://github.com/apache/seatunnel/commit/31e59cdf82|2.3.6|
-|[Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and 
oracle-cdc (#7248)|https://github.com/apache/seatunnel/commit/0d08b20061|2.3.6|
-|[Feature][Core] Support using upstream table placeholders in sink options and 
auto replacement 
(#7131)|https://github.com/apache/seatunnel/commit/c4ca74122c|2.3.6|
-|[Fix] Fix Hana type converter decimal scale is 0 convert to int error 
(#7167)|https://github.com/apache/seatunnel/commit/6e33a97c86|2.3.6|
-|[Improve][Jdbc] Support write unicode text into sqlserver 
(#7159)|https://github.com/apache/seatunnel/commit/e44e8b93bc|2.3.6|
-|[Improve][Jdbc] Remove user info in catalog-table options 
(#7178)|https://github.com/apache/seatunnel/commit/4e001be25c|2.3.6|
-|[Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 
(#7151)|https://github.com/apache/seatunnel/commit/dbdbdf015b|2.3.6|
-|[Feature][Connector-V2] Support jdbc hana catalog and type convertor 
(#6950)|https://github.com/apache/seatunnel/commit/d663398739|2.3.6|
-|[Improve] Change catalog table log to debug level 
(#7136)|https://github.com/apache/seatunnel/commit/b111d2f843|2.3.6|
-|[Improve][Connector-V2] Support schema evolution for mysql-cdc and mysql-jdbc 
(#6929)|https://github.com/apache/seatunnel/commit/cf91e51fc7|2.3.6|
-|[connector-jdbc][bugfix] fix sqlServer create table comment special string 
bug (#7024)|https://github.com/apache/seatunnel/commit/403564db13|2.3.6|
-|[bugfix] fix pgsql create table comment special string bug 
(#7022)|https://github.com/apache/seatunnel/commit/9fe844f62a|2.3.6|
-|[connector-jdbc][bugfix] fix oracle create table comment special string bug 
(#7012)|https://github.com/apache/seatunnel/commit/a9e0f67873|2.3.6|
-|[bugfix] fix mysql create table comment special string bug 
(#6998)|https://github.com/apache/seatunnel/commit/904e9cf785|2.3.6|
-|[Improve][[Jdbc]sink sql support custom field.(#6515) 
(#6525)|https://github.com/apache/seatunnel/commit/ef3e61dbc4|2.3.6|
-|[Feature][Jdbc] Support redshift catalog 
(#6992)|https://github.com/apache/seatunnel/commit/8d5cbcee74|2.3.6|
-|[Improve][Connector-V2] Clean key name in catalog table 
(#6942)|https://github.com/apache/seatunnel/commit/a399ef48c6|2.3.6|
-|[Improve][Zeta] Move SaveMode behavior to master 
(#6843)|https://github.com/apache/seatunnel/commit/80cf91318d|2.3.6|
-|[Improve][Jdbc] Quotes the identifier for table path 
(#6951)|https://github.com/apache/seatunnel/commit/d70ec61f35|2.3.6|
-|[Hotfix][Jdbc] Fix oracle savemode create table 
(#6651)|https://github.com/apache/seatunnel/commit/4b6c13e8fc|2.3.6|
-|[Improve][JDBC Source] Fix Split can not be cancel 
(#6825)|https://github.com/apache/seatunnel/commit/ee3b7c3723|2.3.6|
-|[Feature][Doris] Add Doris type converter 
(#6354)|https://github.com/apache/seatunnel/commit/5189991843|2.3.6|
-|[Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read 
(#6684)|https://github.com/apache/seatunnel/commit/868ba4d7c7|2.3.6|
-|[Improve][Connector] Add some sqlserver IDENTITY type for catalog 
(#6822)|https://github.com/apache/seatunnel/commit/f698396555|2.3.6|
-|[Feature][Jdbc] Support the jdbc connector for InterSystems IRIS 
(#6797)|https://github.com/apache/seatunnel/commit/46600969bb|2.3.6|
-|[Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated 
(#6781)|https://github.com/apache/seatunnel/commit/a5609d600e|2.3.6|
-|[Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog 
(#6771)|https://github.com/apache/seatunnel/commit/df1954d520|2.3.6|
-|[Fix] Fix Oracle type converter handle negative scale in number type 
(#6758)|https://github.com/apache/seatunnel/commit/6d710690c5|2.3.6|
-|[Improve][mysql-cdc] Support mysql 5.5 versions 
(#6710)|https://github.com/apache/seatunnel/commit/058f5594a3|2.3.6|
-|[Improve][Jdbc] Add quote identifier for sql 
(#6669)|https://github.com/apache/seatunnel/commit/849d748d3d|2.3.5|
-|[Improve][Jdbc] Increase tyepe converter when auto creating tables 
(#6617)|https://github.com/apache/seatunnel/commit/cc660206d8|2.3.5|
-|[feature][connector-v2] add xugudb connector 
(#6561)|https://github.com/apache/seatunnel/commit/80f392afbb|2.3.5|
-|[Hotfix] Fix DEFAULT TABLE problem 
(#6352)|https://github.com/apache/seatunnel/commit/cdb1856e84|2.3.5|
-|[Improve] Improve MultiTableSinkWriter prepare commit performance 
(#6495)|https://github.com/apache/seatunnel/commit/2086b0e8a6|2.3.5|
-|[Improve][JDBC] Optimized code style for getting jdbc field types 
(#6583)|https://github.com/apache/seatunnel/commit/ddca95f32c|2.3.5|
-|[Improve] Add SaveMode log of process detail 
(#6375)|https://github.com/apache/seatunnel/commit/b0d70ce224|2.3.5|
-|[Improve][Jdbc] Support custom case-sensitive config for dameng 
(#6510)|https://github.com/apache/seatunnel/commit/d6dcb03bf3|2.3.5|
-|feat: jdbc support copy in statement. 
(#6443)|https://github.com/apache/seatunnel/commit/ca4a65fc00|2.3.5|
-|[Improve][Jdbc] Using varchar2 datatype store string in oracle 
(#6392)|https://github.com/apache/seatunnel/commit/14405fa8d4|2.3.5|
-|[Improve][API] Unify type system api(data &amp; type) 
(#5872)|https://github.com/apache/seatunnel/commit/b38c7edcc9|2.3.5|
-|Fix Jdbc sink target table name error 
(#6269)|https://github.com/apache/seatunnel/commit/2f62235e38|2.3.4|
-|[Improve][JDBC] Use PreparedStatement to sample data from column 
(#6242)|https://github.com/apache/seatunnel/commit/bd0e66d533|2.3.4|
-|[Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table 
(#5972)|https://github.com/apache/seatunnel/commit/8156036a2f|2.3.4|
-|[Feature][JDBC、CDC] Support Short and Byte Type in spliter 
(#6027)|https://github.com/apache/seatunnel/commit/6f8d0a5040|2.3.4|
-|[Improve] Support `int identity` type in sql server 
(#6186)|https://github.com/apache/seatunnel/commit/1a8da1c843|2.3.4|
-|[Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data 
(#6026)|https://github.com/apache/seatunnel/commit/635c24e8b2|2.3.4|
-| [Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc 
(#5986)|https://github.com/apache/seatunnel/commit/97438b9402|2.3.4|
-|Add date type and float type column split support 
(#6160)|https://github.com/apache/seatunnel/commit/b9a62e5c3f|2.3.4|
-|[Improve] Extend `SupportResourceShare` to spark/flink 
(#5847)|https://github.com/apache/seatunnel/commit/c69da93b87|2.3.4|
-|[Feature] Support `uuid` in postgres jdbc 
(#6185)|https://github.com/apache/seatunnel/commit/f56855098b|2.3.4|
-|[Feature][Connector-V2][Oracle-cdc]Support for oracle cdc 
(#5196)|https://github.com/apache/seatunnel/commit/aaef22b31b|2.3.4|
-|[Feature][Connector] update pgsql catalog for save mode 
(#6080)|https://github.com/apache/seatunnel/commit/84ce516929|2.3.4|
-|[Hotfix][Jdbc] Fix dameng catalog query table sql 
(#6141)|https://github.com/apache/seatunnel/commit/413fa74500|2.3.4|
-|[improve][catalog-postgres] Improve get column sql compatibility 
(#5664)|https://github.com/apache/seatunnel/commit/23ce592ad2|2.3.4|
-|[Feature][Connector] update oracle catalog for save mode 
(#6092)|https://github.com/apache/seatunnel/commit/dfbf92769c|2.3.4|
-|[Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types 
(#6122)|https://github.com/apache/seatunnel/commit/6673f6f771|2.3.4|
-|[Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector 
(#6116)|https://github.com/apache/seatunnel/commit/dd698c95bf|2.3.4|
-|[Feature][Connector] update sqlserver catalog for save mode 
(#6086)|https://github.com/apache/seatunnel/commit/edcaacecb1|2.3.4|
-|[Feature][Connector-V2][PostgresSql] add JDBC source support string type as 
partition key 
(#6079)|https://github.com/apache/seatunnel/commit/3522eb157c|2.3.4|
-|[Hotfix][Jdbc] Fix jdbc setFetchSize error 
(#6005)|https://github.com/apache/seatunnel/commit/d41af8a6ed|2.3.4|
-|Support using multiple hadoop account 
(#5903)|https://github.com/apache/seatunnel/commit/d69d88d1aa|2.3.4|
-|[Feature] Add unsupported datatype check for all catalog 
(#5890)|https://github.com/apache/seatunnel/commit/b9791285a0|2.3.4|
-|[Hotfix][Split] Fix split key not support BigInteger 
type|https://github.com/apache/seatunnel/commit/5adf5d2b9a|2.3.4|
-|[Improve] Replace SeaTunnelRowType with TableSchema in the 
JdbcRowConverter|https://github.com/apache/seatunnel/commit/1cc1b1b8cd|2.3.4|
-|[Hotfix][Jdbc] Fix cdc updates were not filtering same primary key 
(#5923)|https://github.com/apache/seatunnel/commit/38d3b85814|2.3.4|
-|[Improve]Change System.out.println to log output. 
(#5912)|https://github.com/apache/seatunnel/commit/bbedb07a9c|2.3.4|
-|[Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath 
(#5891)|https://github.com/apache/seatunnel/commit/f0b6092c15|2.3.4|
-|Reduce the time cost of getCatalogTable in jdbc 
(#5908)|https://github.com/apache/seatunnel/commit/51a3737578|2.3.4|
-|[Improve] Improve Jdbc connector error message when datatype unsupported 
(#5864)|https://github.com/apache/seatunnel/commit/69f79af3a4|2.3.4|
-|[Improve] Rename `getCountSql` to `getExistDataSql` 
(#5838)|https://github.com/apache/seatunnel/commit/2233b3a381|2.3.4|
-|[Fix] Fix read from Oracle Date type value lose time 
(#5814)|https://github.com/apache/seatunnel/commit/2d704e36bd|2.3.4|
-|[Improve][JdbcSource] Optimize catalog-table metadata merge logic 
(#5828)|https://github.com/apache/seatunnel/commit/7d8028a60b|2.3.4|
-|[Improve][Common] Introduce new error define rule 
(#5793)|https://github.com/apache/seatunnel/commit/9d1b2582b2|2.3.4|
-|[Feature][Hive JDBC Source] Support Hive JDBC Source Connector 
(#5424)|https://github.com/apache/seatunnel/commit/a64e177d06|2.3.4|
-|[Improve] Remove use `SeaTunnelSink::getConsumedType` method and mark it as 
deprecated (#5755)|https://github.com/apache/seatunnel/commit/8de7408100|2.3.4|
-|[Improve][Connector] Add field name to `DataTypeConvertor` to improve error 
message (#5782)|https://github.com/apache/seatunnel/commit/ab60790f0d|2.3.4|
-|[Feature][Oracle] Support XMLTYPE data integration #5716 
(#5723)|https://github.com/apache/seatunnel/commit/620f081adb|2.3.4|
-|[Fix] Fix Postgres create table test case failed 
(#5778)|https://github.com/apache/seatunnel/commit/b98b6bcee3|2.3.4|
-|[Improve][Jdbc] Fix database identifier 
(#5756)|https://github.com/apache/seatunnel/commit/dbfc8a670a|2.3.4|
-|[Fix] Fix PG will not create index when using auto create table 
#5721|https://github.com/apache/seatunnel/commit/e5fd88dbe7|2.3.4|
-|[Improve] Remove all useless `prepare`, `getProducedType` method 
(#5741)|https://github.com/apache/seatunnel/commit/ed94fffbb9|2.3.4|
-|[feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) 
connector has been realized 
(#5663)|https://github.com/apache/seatunnel/commit/eff17ccbe5|2.3.4|
-|[Bug] [connector-jdbc] Nullable Column source have null data could be 
unexpected results. 
(#5560)|https://github.com/apache/seatunnel/commit/3f429e1f0a|2.3.4|
-|[Improve] Add default implement for `SeaTunnelSink::setTypeInfo` 
(#5682)|https://github.com/apache/seatunnel/commit/86cba87450|2.3.4|
-|[BUG][Connector-V2][Jdbc] support postgresql xml type  
(#5724)|https://github.com/apache/seatunnel/commit/5f5d4da13f|2.3.4|
-|[Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode 
(#5697)|https://github.com/apache/seatunnel/commit/879c2aa07c|2.3.4|
-|[Feature][Jdbc] Support read multiple tables 
(#5581)|https://github.com/apache/seatunnel/commit/33fa8ff248|2.3.4|
-|[Feature] Support multi-table sink 
(#5620)|https://github.com/apache/seatunnel/commit/81ac173189|2.3.4|
-|[Improve] Remove catalog tag for config file 
(#5645)|https://github.com/apache/seatunnel/commit/dc509aa080|2.3.4|
-|[Feature][Jdbc] Supporting more ways to configure connection parameters. 
(#5388)|https://github.com/apache/seatunnel/commit/d31e9478f7|2.3.4|
-|[Feature][Connector-V2][Jdbc] Add OceanBase catalog 
(#5439)|https://github.com/apache/seatunnel/commit/cd4b7ff7d2|2.3.4|
-|[BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null point 
(#5517)|https://github.com/apache/seatunnel/commit/103da931f3|2.3.4|
-|Support config column/primaryKey/constraintKey in schema 
(#5564)|https://github.com/apache/seatunnel/commit/eac76b4e50|2.3.4|
-|[Improve] Refactor CatalogTable and add 
`SeaTunnelSource::getProducedCatalogTables` 
(#5562)|https://github.com/apache/seatunnel/commit/41173357f8|2.3.4|
-|[Feature][Jdbc] Add Dameng catalog 
(#5451)|https://github.com/apache/seatunnel/commit/c23070919c|2.3.4|
-|[Feature] Add tidb datatype convertor 
(#5440)|https://github.com/apache/seatunnel/commit/61391bda9f|2.3.4|
-|[Feature][Connector-V2]  jdbc connector supports Kingbase database 
(#4803)|https://github.com/apache/seatunnel/commit/9538567159|2.3.4|
-|[Feature][Catalog] Catalog add Case Conversion Definition 
(#5328)|https://github.com/apache/seatunnel/commit/7b5b28bdbe|2.3.4|
-|[Feature][Jdbc] Jdbc database support identifier 
(#5089)|https://github.com/apache/seatunnel/commit/38b6d6e4bb|2.3.4|
-|[Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog 
(#5096)|https://github.com/apache/seatunnel/commit/dde3104f76|2.3.4|
-|[Improve][CheckStyle] Remove useless &#x27;SuppressWarnings&#x27; annotation 
of checkstyle. 
(#5260)|https://github.com/apache/seatunnel/commit/51c0d709ba|2.3.4|
-|[Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one 
(#5284)|https://github.com/apache/seatunnel/commit/ed5eadcf73|2.3.3|
-|[bug][jdbc][oracle]Fix the Oracle number type mapping problem 
(#5209)|https://github.com/apache/seatunnel/commit/9d3c3de90d|2.3.3|
-|[BUG][Connector-V2][Jdbc] support postgresql json type  
(#5194)|https://github.com/apache/seatunnel/commit/7a862d14b7|2.3.3|
-|[Improve] [Connector-V2] Remove scheduler in JDBC sink #4736 
(#5168)|https://github.com/apache/seatunnel/commit/3b0a393145|2.3.3|
-|[CI] Split updated modules integration test for part 5 
(#5208)|https://github.com/apache/seatunnel/commit/18f14d6087|2.3.3|
-|[Bug] [connector-v2] PostgreSQL versions below 9.5 are compatible use cdc 
sync problem 
(#5120)|https://github.com/apache/seatunnel/commit/9af696a1dd|2.3.3|
-|[Improve][Connector-v2][Jdbc]  check url not null throw friendly message 
(#5097)|https://github.com/apache/seatunnel/commit/b0815f2a95|2.3.3|
-|[Feature][Catalog] Add JDBC Catalog auto create table 
(#4917)|https://github.com/apache/seatunnel/commit/63eb137671|2.3.3|
-|[Feature][CDC] Support tables without primary keys (with unique keys) (#163) 
(#5150)|https://github.com/apache/seatunnel/commit/32b7f2b690|2.3.3|
-|[Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database 
connection leak 
(#4802)|https://github.com/apache/seatunnel/commit/4cc10e83e7|2.3.3|
-|[Feature][JDBC Sink] Add DM upsert support 
(#5073)|https://github.com/apache/seatunnel/commit/5e8d982e25|2.3.3|
-|[Improve] Improve savemode api 
(#4767)|https://github.com/apache/seatunnel/commit/4acd370d48|2.3.3|
-|[Feature][Connector-V2] JDBC source support string type as partition key 
(#4947)|https://github.com/apache/seatunnel/commit/d1d2677658|2.3.3|
-|[Feature][Connector-V2][Jdbc] Add oceanbase dialect factory 
(#4989)|https://github.com/apache/seatunnel/commit/7ba11cecdf|2.3.3|
-|Fix XA Transaction bug 
(#5020)|https://github.com/apache/seatunnel/commit/852fe104bc|2.3.3|
-|[Improve][CDC]Remove  driver for cdc connector 
(#4952)|https://github.com/apache/seatunnel/commit/b65f40c3c9|2.3.3|
-|[Improve] Documentation and partial word optimization. 
(#4936)|https://github.com/apache/seatunnel/commit/6e8de0e2a6|2.3.3|
-|[Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict keys 
 (#4634)|https://github.com/apache/seatunnel/commit/d56bb1ba1c|2.3.3|
-|[Bugfix][zeta] Fix the deadlock issue with JDBC driver loading 
(#4878)|https://github.com/apache/seatunnel/commit/c30a2a1b1c|2.3.2|
-|[Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) 
(#4866)|https://github.com/apache/seatunnel/commit/bde19b6377|2.3.2|
-|[Feature][Connector-v2] Add Snowflake Source&amp;Sink connector 
(#4470)|https://github.com/apache/seatunnel/commit/06c59a25f3|2.3.2|
-|[Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column 
in sink (#4815)|https://github.com/apache/seatunnel/commit/0eff3aeed0|2.3.2|
-|[Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception 
(#4801)|https://github.com/apache/seatunnel/commit/ea3bc1a673|2.3.2|
-|[Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity 
(#4806)|https://github.com/apache/seatunnel/commit/2ca7426d22|2.3.2|
-|[Hotfix][Jdbc][Oracle] Fix oracle sql table identifier 
(#4754)|https://github.com/apache/seatunnel/commit/84cb51ff83|2.3.2|
-|[Improve][Jdbc] Populate primary key when jdbc sink is created using 
CatalogTable 
(#4755)|https://github.com/apache/seatunnel/commit/4af3bf9015|2.3.2|
-|[Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… 
(#4673)|https://github.com/apache/seatunnel/commit/a5af4d9b6e|2.3.2|
-|[Improve][Core] Add check of sink and source config to avoid null pointer 
exception. (#4734)|https://github.com/apache/seatunnel/commit/8f66ce96cb|2.3.2|
-|[Hotfix][JDBC-SINK] Fix TiDBCatalog without open 
(#4718)|https://github.com/apache/seatunnel/commit/34a7f3eaa4|2.3.2|
-|[Feature][E2E] Add mysql-cdc e2e testcase 
(#4639)|https://github.com/apache/seatunnel/commit/87001dfd16|2.3.2|
-|[Hotfix][JDBC Sink] Fix JDBC Sink oom bug 
(#4690)|https://github.com/apache/seatunnel/commit/08b6f992aa|2.3.2|
-|Improve the option rule for jdbc sink 
(#4694)|https://github.com/apache/seatunnel/commit/a6b3704414|2.3.2|
-|[feature][catalog] Support for multiplexing connections 
(#4550)|https://github.com/apache/seatunnel/commit/41277d7f78|2.3.2|
-|[Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to 
Boolean type 
(#4671)|https://github.com/apache/seatunnel/commit/89b0099ff4|2.3.2|
-|[Hotfix][Jdbc[SqlServer] Fix sqlserver jdbc url parse 
(#4697)|https://github.com/apache/seatunnel/commit/b24c3226ec|2.3.2|
-|Revert &quot;[Improve][Catalog] refactor catalog (#4540)&quot; 
(#4628)|https://github.com/apache/seatunnel/commit/2d1933195d|2.3.2|
-|[Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres 
(#4575)|https://github.com/apache/seatunnel/commit/91f5125976|2.3.2|
-|[Improve][Catalog] refactor catalog 
(#4540)|https://github.com/apache/seatunnel/commit/b0a701cb83|2.3.2|
-|[Bug] [JDBC Source] fix split exception when source table is empty 
(#4570)|https://github.com/apache/seatunnel/commit/c73b9331ce|2.3.2|
-|[Feature][Connector][Jdbc] Add vertica connector. 
(#4303)|https://github.com/apache/seatunnel/commit/e6b4f98721|2.3.2|
-|[Hotfix][Catalog] Filter out unavailable constrain keys 
(#4557)|https://github.com/apache/seatunnel/commit/5e5859546a|2.3.2|
-|[Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority 
(#4548)|https://github.com/apache/seatunnel/commit/74d4d24858|2.3.2|
-|[Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI 
(#4264)|https://github.com/apache/seatunnel/commit/a97f33797d|2.3.2|
-|[Jdbc][Chore] improve the exception message when primary key not found in row 
(#4474)|https://github.com/apache/seatunnel/commit/06fa850da9|2.3.2|
-|[hotfix][JDBC] Fix the table name is not automatically obtained when multiple 
tables (#4514)|https://github.com/apache/seatunnel/commit/c84d6f8d11|2.3.2|
-|[Chore][Jdbc] add the log for sql and update some style 
(#4475)|https://github.com/apache/seatunnel/commit/a9e6503045|2.3.2|
-|[Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: 
generate_sink_sql 
(#4471)|https://github.com/apache/seatunnel/commit/7da11c2f44|2.3.2|
-|[feature][jdbc][TiDB] add TiDB catalog 
(#4438)|https://github.com/apache/seatunnel/commit/9a32db6fc0|2.3.2|
-|[Hotfix][Connector] Fix sqlserver catalog 
(#4441)|https://github.com/apache/seatunnel/commit/8540c7f9f3|2.3.2|
-|[Feature][CDC][SqlServer] Support multi-table read 
(#4377)|https://github.com/apache/seatunnel/commit/c4e3f2dc03|2.3.2|
-|[Improve][JdbcSink]Fix connection failure caused by connection timeout. 
(#4322)|https://github.com/apache/seatunnel/commit/e1f6d3b3fd|2.3.2|
-|[Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of 
jdbc source. (#4158) 
(#4210)|https://github.com/apache/seatunnel/commit/3d7ff831f9|2.3.1|
-|Change file type to file_format_type in file source/sink 
(#4249)|https://github.com/apache/seatunnel/commit/973a2fae3c|2.3.1|
-|Change redshift type to lowercase 
(#4248)|https://github.com/apache/seatunnel/commit/10447ae103|2.3.1|
-|Add redshift datatype convertor 
(#4245)|https://github.com/apache/seatunnel/commit/b19011517f|2.3.1|
-|[improve][zeta] fix zeta 
bugs|https://github.com/apache/seatunnel/commit/3a82e8b39f|2.3.1|
-|[Improve] Support MySqlCatalog Use JDBC URL With Custom 
Suffix|https://github.com/apache/seatunnel/commit/210d0ff1f8|2.3.1|
-|[hotfix] fixed jdbc IT 
error|https://github.com/apache/seatunnel/commit/dd20af0a9e|2.3.1|
-|Merge branch &#x27;dev&#x27; into 
merge/cdc|https://github.com/apache/seatunnel/commit/4324ee1912|2.3.1|
-|[Improve][Project] Code format with spotless 
plugin.|https://github.com/apache/seatunnel/commit/423b583038|2.3.1|
-|[improve][jdbc] use ReadonlyConfig instead of Config 
(#4236)|https://github.com/apache/seatunnel/commit/c90c58e243|2.3.1|
-|[Improve][Jdbc-sink] add database field to sink config 
(#4199)|https://github.com/apache/seatunnel/commit/ec368902f4|2.3.1|
-|[improve][jdbc] Reduce jdbc options configuration 
(#4218)|https://github.com/apache/seatunnel/commit/ddd8f808b5|2.3.1|
-|Fix mysql get default value 
(#4204)|https://github.com/apache/seatunnel/commit/6848434f2d|2.3.1|
-|[hotfix][zeta] fix zeta multi-table parser error 
(#4193)|https://github.com/apache/seatunnel/commit/98f2ad0c19|2.3.1|
-|[Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule 
(#4194)|https://github.com/apache/seatunnel/commit/9d088017a3|2.3.1|
-|[Improve] [Connector-V2] [StarRocks] Starrocks Support Auto Create Table 
(#4177)|https://github.com/apache/seatunnel/commit/7e0008e6fb|2.3.1|
-|[improve][catalog][jdbc] Add MySQL catalog factory 
(#4168)|https://github.com/apache/seatunnel/commit/95e3cbf875|2.3.1|
-|[Improve][build] Give the maven module a human readable name 
(#4114)|https://github.com/apache/seatunnel/commit/d7cd601051|2.3.1|
-|Add convertor factory 
(#4119)|https://github.com/apache/seatunnel/commit/cbdea45d95|2.3.1|
-|Add ElasticSearch catalog 
(#4108)|https://github.com/apache/seatunnel/commit/9ee4d8394c|2.3.1|
-|Add Kafka catalog 
(#4106)|https://github.com/apache/seatunnel/commit/34f1f21e48|2.3.1|
-|[Improve][Project] Code format with spotless plugin. 
(#4101)|https://github.com/apache/seatunnel/commit/a2ab166561|2.3.1|
-|Add DataTypeConvertor in Catalog 
(#4094)|https://github.com/apache/seatunnel/commit/840c3e5eb4|2.3.1|
-|[Feature] [Catalog] Support create/drop table, create/drop database in 
catalog (#4075)|https://github.com/apache/seatunnel/commit/d8a0be84ca|2.3.1|
-| [Bug][Connector-V2][Jdbc] Fixed no exception throwing problem 
(#3957)|https://github.com/apache/seatunnel/commit/6ab266e594|2.3.1|
-|[Bug][CDC] Fix jdbc sink generate update sql 
(#3940)|https://github.com/apache/seatunnel/commit/233465d4e4|2.3.1|
-|[Improve][JDBC] improve jdbc sink option 
(#3864)|https://github.com/apache/seatunnel/commit/768a9300e8|2.3.1|
-|Fix Source Class Support Parallelism judge &amp; Add UT for it 
(#3878)|https://github.com/apache/seatunnel/commit/ce85a8c68b|2.3.1|
-|[Feature][Connector] add get source method to all source connector 
(#3846)|https://github.com/apache/seatunnel/commit/417178fb84|2.3.1|
-|[Feature][Connector-V2] Jdbc connector support SAP HANA. 
(#3017)|https://github.com/apache/seatunnel/commit/fe0180fab2|2.3.1|
-|[Feature][API &amp; Connector &amp; Doc] add parallelism and column 
projection interface 
(#3829)|https://github.com/apache/seatunnel/commit/b9164b8ba1|2.3.1|
-|[Improve][JDBC Connector]improve option rule 
(#3802)|https://github.com/apache/seatunnel/commit/139256741a|2.3.1|
-|[Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore 
(#3809)|https://github.com/apache/seatunnel/commit/39dae4cfd9|2.3.1|
-|[Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector 
(#3750)|https://github.com/apache/seatunnel/commit/5328e9d847|2.3.1|
-|[Improve][Connector-v2] Remove unused options for jdbc source factory 
(#3794)|https://github.com/apache/seatunnel/commit/861004d309|2.3.1|
-|[Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. 
(#3796)|https://github.com/apache/seatunnel/commit/38646b11b8|2.3.1|
-|[hotfix][ST-Engine] fix jdbc connector exactly-once null pointer 
(#3730)|https://github.com/apache/seatunnel/commit/0c5986fbec|2.3.0|
-|[Improve][connector-jdbc] Add config item enable upsert by query 
(#3708)|https://github.com/apache/seatunnel/commit/e1f951f782|2.3.0|
-|[Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds 
#3701 (#3705)|https://github.com/apache/seatunnel/commit/f351ceaf4b|2.3.0|
-|[Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug 
(#3670)|https://github.com/apache/seatunnel/commit/6fe0e6aece|2.3.0|
-|[Improve][Connector-V2][JDBC] Unified exception for JDBC source &amp; sink 
(#3598)|https://github.com/apache/seatunnel/commit/865ca2bba9|2.3.0|
-|[Connector][JDBC]Support Redshift sink and source 
(#3615)|https://github.com/apache/seatunnel/commit/8d9d8638d2|2.3.0|
-|[Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink 
#3589|https://github.com/apache/seatunnel/commit/e77fdbbef7|2.3.0|
-|[Hotfix][OptionRule] Fix option rule about all connectors 
(#3592)|https://github.com/apache/seatunnel/commit/226dc6a119|2.3.0|
-|[Feature][Connector-V2][Doris]Add Doris Source &amp; Sink connector 
(#3586)|https://github.com/apache/seatunnel/commit/3d46b79614|2.3.0|
-|[Feature][Connector-V2][Teradata] Add Teradata Source And Sink 
Connector|https://github.com/apache/seatunnel/commit/3a095d30fd|2.3.0|
-|[Feature][Connector-V2][JDBC] support sqlite Source &amp; Sink 
(#3089)|https://github.com/apache/seatunnel/commit/a73bb3e714|2.3.0|
-|Bump postgresql in /seatunnel-connectors-v2/connector-jdbc 
(#3559)|https://github.com/apache/seatunnel/commit/c8dfdf3e46|2.3.0|
-|[feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema 
(#3499)|https://github.com/apache/seatunnel/commit/ff44db116e|2.3.0|
-|[JDBC] [ORACLE] Improve Oracle Type to SeaTunnel Type Mapping 
(#3486)|https://github.com/apache/seatunnel/commit/8fe0dda6e2|2.3.0|
-|[JDBC] [Config] Add JDBC Fetch Size Config And Custom Postgres 
PrepareStatement 
(#3478)|https://github.com/apache/seatunnel/commit/d60a705f5d|2.3.0|
-|[feature][connector][jdbc] expose configurable options in JDBC 
(#3410)|https://github.com/apache/seatunnel/commit/72b8a73cab|2.3.0|
-|[feature][connector][jdbc] Support write cdc changelog event in jdbc sink 
(#3444)|https://github.com/apache/seatunnel/commit/b12a908f01|2.3.0|
-|[Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig 
(#3453)|https://github.com/apache/seatunnel/commit/cfb1e97853|2.3.0|
-|[Improve][Connector-v2] Unset AutoCommit default to true 
(#3451)|https://github.com/apache/seatunnel/commit/439f686d92|2.3.0|
-|[Feature][connector-v2] add tablestore source and sink  
(#3309)|https://github.com/apache/seatunnel/commit/ebebf0b633|2.3.0|
-|Close jdbc connection after use. 
(#3358)|https://github.com/apache/seatunnel/commit/219fea517c|2.3.0|
-|[Improve] [Engine] Improve Engine performance. 
(#3216)|https://github.com/apache/seatunnel/commit/7393c47327|2.3.0|
-|[Bug][Connector-V2][JDBC]fix jdbc split bug 
(#3220)|https://github.com/apache/seatunnel/commit/40d67ab902|2.3.0|
-|[Feature][Connector-V2][JDBC] Support DB2 Source &amp; Sink 
(#2410)|https://github.com/apache/seatunnel/commit/bf1ef69e84|2.3.0|
-|update org.postgresql:postgresql 42.3.3 to 42.4.1 
(#3097)|https://github.com/apache/seatunnel/commit/2852516490|2.3.0|
-|[Feature][Connector-V2][Jdbc] support gbase 8a  
(#3026)|https://github.com/apache/seatunnel/commit/dc6e85d06f|2.3.0-beta|
-|[Bug] [sqlserver] timestamp convert exception 
(#3024)|https://github.com/apache/seatunnel/commit/99ac1a655e|2.3.0-beta|
-|[Feature][Connector-V2] oracle connector 
(#2550)|https://github.com/apache/seatunnel/commit/384ece1913|2.3.0-beta|
-|[Improve][Connector-v2][jdbc] Support for specify number of partitions when 
parallel reading 
(#2950)|https://github.com/apache/seatunnel/commit/fc284ac32e|2.3.0-beta|
-|[Feature][Connector-V2] add sqlserver connector 
(#2646)|https://github.com/apache/seatunnel/commit/05d105dea3|2.3.0-beta|
-|[Improve][e2e] Unified e2e IT for DaMengDB 
(#2946)|https://github.com/apache/seatunnel/commit/15636bdea1|2.3.0-beta|
-|[Improve][e2e] modify DM-driver by downLoad and add the value comparison of 
all columns 
(#2772)|https://github.com/apache/seatunnel/commit/f3ff39bdfe|2.3.0-beta|
-|[Improve][e2e] Improve jdbc driver management 
(#2770)|https://github.com/apache/seatunnel/commit/f907927a35|2.3.0-beta|
-|[hotfix][connector][jdbc] fix JDBC split exception 
(#2904)|https://github.com/apache/seatunnel/commit/57342c6545|2.3.0-beta|
-|[Improve][connector-jdbc] Calculate splits only once in 
JdbcSourceSplitEnumerator 
(#2900)|https://github.com/apache/seatunnel/commit/7622f28999|2.3.0-beta|
-|[Feature] [Connector-V2 E2E] Add mysql and postgres e2e test and bug fix 
(#2838)|https://github.com/apache/seatunnel/commit/db434adc15|2.2.0-beta|
-|fix XAConnection being wrongly submitted 
(#2805)|https://github.com/apache/seatunnel/commit/d9a6039fd3|2.2.0-beta|
-|fix spark execute exception is not thrown 
(#2791)|https://github.com/apache/seatunnel/commit/b1711c984e|2.2.0-beta|
-|[Improve][e2e] Add driver-jar to lib 
(#2719)|https://github.com/apache/seatunnel/commit/d64d452c86|2.2.0-beta|
-|[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton 
pattern 
(#2706)|https://github.com/apache/seatunnel/commit/cbf82f755c|2.2.0-beta|
-|[Connector-V2][JDBC-connector] support Jdbc dm 
(#2377)|https://github.com/apache/seatunnel/commit/7278209ca2|2.2.0-beta|
-|[#2606]Dependency management split 
(#2630)|https://github.com/apache/seatunnel/commit/fc047be69b|2.2.0-beta|
-|[Bug] [connector-jdbc-v2] Fix transaction force commit when autoCommit is 
enabled 
(#2636)|https://github.com/apache/seatunnel/commit/8cd8cf7aa2|2.2.0-beta|
-| [Feature][Connector-V2] Add phoenix connector sink  
(#2499)|https://github.com/apache/seatunnel/commit/05ccf9d68c|2.2.0-beta|
-|[Connector-V2][JDBC] Support database: greenplum 
(#2429)|https://github.com/apache/seatunnel/commit/3561d3878f|2.2.0-beta|
-|Add jdbc connector e2e test 
(#2321)|https://github.com/apache/seatunnel/commit/5fbcb811c6|2.2.0-beta|
-|StateT of SeaTunnelSource should extend `Serializable` 
(#2214)|https://github.com/apache/seatunnel/commit/8c426ef850|2.2.0-beta|
-|update the condition to 1 = 0 about get table operation 
(#2186)|https://github.com/apache/seatunnel/commit/7c56d7143b|2.2.0-beta|
-|[SeaTunnel API] [Sink] remove useless context field 
(#2124)|https://github.com/apache/seatunnel/commit/a31fdeedcc|2.2.0-beta|
-|[bugfix] Check isOpen before closing 
(#2107)|https://github.com/apache/seatunnel/commit/7ec0ada2b9|2.2.0-beta|
-|[API-DRAFT] [MERGE] fix merge 
error|https://github.com/apache/seatunnel/commit/3c0e984648|2.2.0-beta|
-|merge dev to 
api-draft|https://github.com/apache/seatunnel/commit/d265597c64|2.2.0-beta|
-|[api-draft][Optimize] Optimize module name 
(#2062)|https://github.com/apache/seatunnel/commit/f79e3112b1|2.2.0-beta|
+| Change                                                                       
                                  | Commit | Version |
+|----------------------------------------------------------------------------------------------------------------|
 --- | --- |
+| [Feature][Jdbc] Modify the mapping method of the blob field to support large 
blob fields in Oracle              
|https://github.com/apache/seatunnel/commit/COMMIT_HASH| dev |
+| [Hotfix][Jdbc] Fix mysql tinyint(1) type mapping for TypeMapper (#9012)      
                                  
|https://github.com/apache/seatunnel/commit/5f85d7668a| dev |
+| [Feature][Jdbc] Add String type column split Support by charset-based 
splitting algorithm (#9002)              
|https://github.com/apache/seatunnel/commit/dbe41e74cd| dev |
+| [Fix][Paimon] nullable and comment attribute was lost during automatic table 
creation (#9020)                  
|https://github.com/apache/seatunnel/commit/eb54fdd52c| dev |
+| [Fix][Connector-JDBC] Fix JDBC driver selection for data source connections 
(#8986)                            
|https://github.com/apache/seatunnel/commit/a5aafa7301| dev |
+| [Improve][Jdbc] Upgrade sap-hana driver from 2.14.7 to 2.23.10 (#9013)       
                                  
|https://github.com/apache/seatunnel/commit/9ba9f169be| dev |
+| [Feature][Jdbc] Support sink ddl for sqlserver #8114 (#8936)                 
                                  
|https://github.com/apache/seatunnel/commit/30aa485b38|2.3.10|
+| [Fix][Connector-V2] Fix parse SqlServer JDBC Url error (#8784)               
                                  
|https://github.com/apache/seatunnel/commit/373d2162d3|2.3.10|
+| [Improve][Jdbc] Support upsert for opengauss (#8627)                         
                                  
|https://github.com/apache/seatunnel/commit/56110bf392|2.3.10|
+| [Improve][Jdbc] Remove useless utils. (#8793)                                
                                  
|https://github.com/apache/seatunnel/commit/36a7533e85|2.3.10|
+| [Improve][Jdbc] Improve catalog connection cache (#8626)                     
                                  
|https://github.com/apache/seatunnel/commit/6205065b25|2.3.10|
+| [Fix][Connector-V2] Fix jdbc sink statement buffer wrong time to clear 
(#8653)                                 
|https://github.com/apache/seatunnel/commit/cf35eecdfc|2.3.10|
+| [Feature][Jdbc] Support sink ddl for dameng (#8380)                          
                                  
|https://github.com/apache/seatunnel/commit/5ff3427428|2.3.10|
+| [Improve] restruct connector common options (#8634)                          
                                  
|https://github.com/apache/seatunnel/commit/f3499a6eeb|2.3.10|
+| [Improve][Jdbc] Remove oracle &#x27;v$database&#x27; query (#8571)           
                                  
|https://github.com/apache/seatunnel/commit/3cf09f61ca|2.3.10|
+| [Fix] [Connector-V2] Postgres support for multiple primary keys (#8526)      
                                  
|https://github.com/apache/seatunnel/commit/04db40d973|2.3.10|
+| [Feature][JDBC source] pg support char types (#8420)                         
                                  
|https://github.com/apache/seatunnel/commit/776ac94478|2.3.9|
+| [Feature][Jdbc] Support sink ddl for postgresql (#8276)                      
                                  
|https://github.com/apache/seatunnel/commit/353bbd21a1|2.3.9|
+| [Feature][Connector-V2] Support the jdbc connector for highgo db (#8282)     
                                  
|https://github.com/apache/seatunnel/commit/aa381cbfb4|2.3.9|
+| [Improve][Jdbc] Support nvarchar in dm (#8270)                               
                                  
|https://github.com/apache/seatunnel/commit/2f1c54ee2e|2.3.9|
+| [Improve][Connector-v2] Use regex to match filedName placeholders in jdbc 
sink (#8222)                         
|https://github.com/apache/seatunnel/commit/c02d4fed36|2.3.9|
+| [Improve][Connector-V2] Support read comment when jdbc dialect without 
catalog (#8196)                         
|https://github.com/apache/seatunnel/commit/567cd54de5|2.3.9|
+| [Improve][Connector-V2] The interface supports jdbc respects the target 
database field type (#8031)            
|https://github.com/apache/seatunnel/commit/1de056a9a4|2.3.9|
+| [Improve][dist]add shade check rule (#8136)                                  
                                  
|https://github.com/apache/seatunnel/commit/51ef800016|2.3.9|
+| [Improve][Jdbc] Improve ddl write validate (#8158)                           
                                  
|https://github.com/apache/seatunnel/commit/9cdaacddd9|2.3.9|
+| [Feature][Jdbc] Add Jdbc default dialect for all jdbc series database 
without dialect (#8132)                  
|https://github.com/apache/seatunnel/commit/399eabcd3f|2.3.9|
+| [Improve][Jdbc] Refactor ddl change (#8134)                                  
                                  
|https://github.com/apache/seatunnel/commit/e1f0a238f7|2.3.9|
+| [Feature][Core] Rename `result_table_name`/`source_table_name` to 
`plugin_input/plugin_output` (#8072)         
|https://github.com/apache/seatunnel/commit/c7bbd322db|2.3.9|
+| [Improve][Connector-V2] Improve schema evolution on column insert after for 
mysql-jdbc (#8017)                 
|https://github.com/apache/seatunnel/commit/3fb05da365|2.3.9|
+| [Feature][Core] Support cdc task ddl restore for zeta (#7463)                
                                  
|https://github.com/apache/seatunnel/commit/8e322281ed|2.3.9|
+| [Feature][transform] transform support explode (#7928)                       
                                  
|https://github.com/apache/seatunnel/commit/132278c06a|2.3.9|
+| [Feature][Connector-v2] Support schema evolution for Oracle connector 
(#7908)                                  
|https://github.com/apache/seatunnel/commit/79406bcc2f|2.3.9|
+| [Improve][Connector-V2] Improve jdbc merge table from path and query when 
type is decimal (#7917)              
|https://github.com/apache/seatunnel/commit/8baa012ced|2.3.9|
+| [Fix][Connector-V2] Fix hana type loss of precision (#7912)                  
                                  
|https://github.com/apache/seatunnel/commit/18dcca36cd|2.3.9|
+| [Feature][Connector-V2] Jdbc DB2 support upsert SQL  (#7879)                 
                                  
|https://github.com/apache/seatunnel/commit/139919334d|2.3.9|
+| [Improve][Jdbc] Optimize index name conflicts when create table for 
postgresql (#7875)                         
|https://github.com/apache/seatunnel/commit/312ee866fb|2.3.9|
+| [Improve][Jdbc] Support postgresql inet type. (#7820)                        
                                  
|https://github.com/apache/seatunnel/commit/25b68b3623|2.3.9|
+| [Fix][Connector-V2]Oceanbase vector database is added as the source server 
(#7832)                             
|https://github.com/apache/seatunnel/commit/258f931765|2.3.9|
+| [Feature][connector-v2]Support opengauss jdbc connnector using opengauss 
driver. (#7622)                       
|https://github.com/apache/seatunnel/commit/bbf643772e|2.3.9|
+| [Improve][Jdbc] Support save mode for the sink of jdbc-dm (#7814)            
                                  
|https://github.com/apache/seatunnel/commit/b87d732c81|2.3.9|
+| [Feature][Restapi] Allow metrics information to be associated to logical 
plan nodes (#7786)                    
|https://github.com/apache/seatunnel/commit/6b7c53d03c|2.3.9|
+| [Feature][Connector-V2] SqlServer support user-defined type (#7706)          
                                  
|https://github.com/apache/seatunnel/commit/fb89033273|2.3.8|
+| [Hotfix][CDC] Fix ddl duplicate execution error when config 
multi_table_sink_replica (#7634)                   
|https://github.com/apache/seatunnel/commit/23ab3edbbb|2.3.8|
+| [Feature][Connector-Paimon] Support dynamic bucket splitting improves Paimon 
writing efficiency (#7335)        
|https://github.com/apache/seatunnel/commit/bc0326cba8|2.3.8|
+| [Fix][Connector-V2] Fix jdbc test case failed (#7690)                        
                                  
|https://github.com/apache/seatunnel/commit/4f5d27f625|2.3.8|
+| [Improve][Jdbc] Jdbc truncate table should check table not database (#7654)  
                                  
|https://github.com/apache/seatunnel/commit/0c0eb7e41b|2.3.8|
+| [Feature][Connector-V2] jdbc saphana source tablepath support view and  
synonym (#7670)                        
|https://github.com/apache/seatunnel/commit/7e0c20a488|2.3.8|
+| [Fix][Connector-v2] Throw Exception in sql query for JdbcCatalog in table or 
db exists query (#7651)           
|https://github.com/apache/seatunnel/commit/70ec59ce0e|2.3.8|
+| [Fix][JDBC] Fix starrocks jdbc dialect catalog conflict with starrocks 
connector (#7578)                       
|https://github.com/apache/seatunnel/commit/020aab422e|2.3.8|
+| [Feature] Support tidb cdc connector source #7199 (#7477)                    
                                  
|https://github.com/apache/seatunnel/commit/87ec786bd6|2.3.8|
+| [bugfix] fix oracle query table length (#7627)                               
                                  
|https://github.com/apache/seatunnel/commit/2e002ce09b|2.3.8|
+| [Hotfix][Connector-v2] Fix the NullPointerException for jdbc oracle which 
used the table_list (#7544)          
|https://github.com/apache/seatunnel/commit/555028217a|2.3.8|
+| [Improve][Connector-v2] Support mysql 8.1/8.2/8.3 for jdbc (#7530)           
                                  
|https://github.com/apache/seatunnel/commit/657fe69b26|2.3.8|
+| [Improve][Connector-v2] Release resource in closeStatements even exception 
occurred in executeBatch (#7533)    
|https://github.com/apache/seatunnel/commit/590f7d110d|2.3.8|
+| [Fix][Connector-V2] Fix jdbc query sql can not get table path (#7484)        
                                  
|https://github.com/apache/seatunnel/commit/8e0ca8f725|2.3.8|
+| [Feature][Connector-V2] Add `decimal_type_narrowing` option in jdbc (#7461)  
                                  
|https://github.com/apache/seatunnel/commit/696f2948fa|2.3.8|
+| [Improve][Connector-V2] update vectorType (#7446)                            
                                  
|https://github.com/apache/seatunnel/commit/1bba72385b|2.3.8|
+| [Improve][API] Move catalog open to SaveModeHandler (#7439)                  
                                  
|https://github.com/apache/seatunnel/commit/8c2c5c79a1|2.3.8|
+| [FIX][E2E]Modify the OceanBase test case to the latest imageChange image 
(#7452)                               
|https://github.com/apache/seatunnel/commit/6abb83deab|2.3.8|
+| [Feature][Connector-V2][OceanBase] Support vector types on OceanBase (#7375) 
                                  
|https://github.com/apache/seatunnel/commit/a6b188d552|2.3.8|
+| [Improve][Connector-V2] Remove system table limit (#7391)                    
                                  
|https://github.com/apache/seatunnel/commit/adf888e008|2.3.8|
+| [Fix] Fix oracle sample data from column error (#7340)                       
                                  
|https://github.com/apache/seatunnel/commit/2130e0d5ad|2.3.8|
+| [Improve][Connector-V2] Close all ResultSet after used (#7389)               
                                  
|https://github.com/apache/seatunnel/commit/853e973212|2.3.8|
+| [Hotifx][Jdbc] Fix MySQL unsupport &#x27;ZEROFILL&#x27; column type (#7407)  
                                  
|https://github.com/apache/seatunnel/commit/7130382123|2.3.8|
+| [Improvement] add starrocks jdbc dialect (#7294)                             
                                  
|https://github.com/apache/seatunnel/commit/b5140f598e|2.3.8|
+| [Hotfix][Connector] Fix jdbc compile error (#7359)                           
                                  
|https://github.com/apache/seatunnel/commit/2769ed5029|2.3.7|
+| [Fix][Connector-V2][OceanBase] Remove OceanBase catalog&#x27;s dependency on 
mysql driver (#7311)              
|https://github.com/apache/seatunnel/commit/3130ae089e|2.3.7|
+| [Improve][Jdbc] Skip all index when auto create table to improve performance 
of write (#7288)                  
|https://github.com/apache/seatunnel/commit/dc3c23981b|2.3.7|
+| [Improve][Jdbc] Remove MysqlType references in JdbcDialect (#7333)           
                                  
|https://github.com/apache/seatunnel/commit/16eeb1c123|2.3.7|
+| [Improve][Jdbc] Merge user config primary key when create table (#7313)      
                                  
|https://github.com/apache/seatunnel/commit/819c685651|2.3.7|
+| [Improve][Connector-v2] Optimize the way of databases and tables are checked 
for existence (#7261)             
|https://github.com/apache/seatunnel/commit/f012b2a6f0|2.3.7|
+| [Feature][Jdbc] Support hive compatibleMode add inceptor dialect (#7262)     
                                  
|https://github.com/apache/seatunnel/commit/31e59cdf82|2.3.6|
+| [Improve][Connector-v2] Optimize the count table rows for jdbc-oracle and 
oracle-cdc (#7248)                   
|https://github.com/apache/seatunnel/commit/0d08b20061|2.3.6|
+| [Feature][Core] Support using upstream table placeholders in sink options 
and auto replacement (#7131)         
|https://github.com/apache/seatunnel/commit/c4ca74122c|2.3.6|
+| [Fix] Fix Hana type converter decimal scale is 0 convert to int error 
(#7167)                                  
|https://github.com/apache/seatunnel/commit/6e33a97c86|2.3.6|
+| [Improve][Jdbc] Support write unicode text into sqlserver (#7159)            
                                  
|https://github.com/apache/seatunnel/commit/e44e8b93bc|2.3.6|
+| [Improve][Jdbc] Remove user info in catalog-table options (#7178)            
                                  
|https://github.com/apache/seatunnel/commit/4e001be25c|2.3.6|
+| [Improve][connector-v2-jdbc-mysql] Add support for MySQL 8.4 (#7151)         
                                  
|https://github.com/apache/seatunnel/commit/dbdbdf015b|2.3.6|
+| [Feature][Connector-V2] Support jdbc hana catalog and type convertor (#6950) 
                                  
|https://github.com/apache/seatunnel/commit/d663398739|2.3.6|
+| [Improve] Change catalog table log to debug level (#7136)                    
                                  
|https://github.com/apache/seatunnel/commit/b111d2f843|2.3.6|
+| [Improve][Connector-V2] Support schema evolution for mysql-cdc and 
mysql-jdbc (#6929)                          
|https://github.com/apache/seatunnel/commit/cf91e51fc7|2.3.6|
+| [connector-jdbc][bugfix] fix sqlServer create table comment special string 
bug (#7024)                         
|https://github.com/apache/seatunnel/commit/403564db13|2.3.6|
+| [bugfix] fix pgsql create table comment special string bug (#7022)           
                                  
|https://github.com/apache/seatunnel/commit/9fe844f62a|2.3.6|
+| [connector-jdbc][bugfix] fix oracle create table comment special string bug 
(#7012)                            
|https://github.com/apache/seatunnel/commit/a9e0f67873|2.3.6|
+| [bugfix] fix mysql create table comment special string bug (#6998)           
                                  
|https://github.com/apache/seatunnel/commit/904e9cf785|2.3.6|
+| [Improve][[Jdbc]sink sql support custom field.(#6515) (#6525)                
                                  
|https://github.com/apache/seatunnel/commit/ef3e61dbc4|2.3.6|
+| [Feature][Jdbc] Support redshift catalog (#6992)                             
                                  
|https://github.com/apache/seatunnel/commit/8d5cbcee74|2.3.6|
+| [Improve][Connector-V2] Clean key name in catalog table (#6942)              
                                  
|https://github.com/apache/seatunnel/commit/a399ef48c6|2.3.6|
+| [Improve][Zeta] Move SaveMode behavior to master (#6843)                     
                                  
|https://github.com/apache/seatunnel/commit/80cf91318d|2.3.6|
+| [Improve][Jdbc] Quotes the identifier for table path (#6951)                 
                                  
|https://github.com/apache/seatunnel/commit/d70ec61f35|2.3.6|
+| [Hotfix][Jdbc] Fix oracle savemode create table (#6651)                      
                                  
|https://github.com/apache/seatunnel/commit/4b6c13e8fc|2.3.6|
+| [Improve][JDBC Source] Fix Split can not be cancel (#6825)                   
                                  
|https://github.com/apache/seatunnel/commit/ee3b7c3723|2.3.6|
+| [Feature][Doris] Add Doris type converter (#6354)                            
                                  
|https://github.com/apache/seatunnel/commit/5189991843|2.3.6|
+| [Hotfix][Jdbc/CDC] Fix postgresql uuid type in jdbc read (#6684)             
                                  
|https://github.com/apache/seatunnel/commit/868ba4d7c7|2.3.6|
+| [Improve][Connector] Add some sqlserver IDENTITY type for catalog (#6822)    
                                  
|https://github.com/apache/seatunnel/commit/f698396555|2.3.6|
+| [Feature][Jdbc] Support the jdbc connector for InterSystems IRIS (#6797)     
                                  
|https://github.com/apache/seatunnel/commit/46600969bb|2.3.6|
+| [Fix][MySQL]: Fix MySqlTypeConverter could not be instantiated (#6781)       
                                  
|https://github.com/apache/seatunnel/commit/a5609d600e|2.3.6|
+| [Hotfix][Jdbc] Fix table/query columns order merge for jdbc catalog (#6771)  
                                  
|https://github.com/apache/seatunnel/commit/df1954d520|2.3.6|
+| [Fix] Fix Oracle type converter handle negative scale in number type (#6758) 
                                  
|https://github.com/apache/seatunnel/commit/6d710690c5|2.3.6|
+| [Improve][mysql-cdc] Support mysql 5.5 versions (#6710)                      
                                  
|https://github.com/apache/seatunnel/commit/058f5594a3|2.3.6|
+| [Improve][Jdbc] Add quote identifier for sql (#6669)                         
                                  
|https://github.com/apache/seatunnel/commit/849d748d3d|2.3.5|
+| [Improve][Jdbc] Increase tyepe converter when auto creating tables (#6617)   
                                  
|https://github.com/apache/seatunnel/commit/cc660206d8|2.3.5|
+| [feature][connector-v2] add xugudb connector (#6561)                         
                                  
|https://github.com/apache/seatunnel/commit/80f392afbb|2.3.5|
+| [Hotfix] Fix DEFAULT TABLE problem (#6352)                                   
                                  
|https://github.com/apache/seatunnel/commit/cdb1856e84|2.3.5|
+| [Improve] Improve MultiTableSinkWriter prepare commit performance (#6495)    
                                  
|https://github.com/apache/seatunnel/commit/2086b0e8a6|2.3.5|
+| [Improve][JDBC] Optimized code style for getting jdbc field types (#6583)    
                                  
|https://github.com/apache/seatunnel/commit/ddca95f32c|2.3.5|
+| [Improve] Add SaveMode log of process detail (#6375)                         
                                  
|https://github.com/apache/seatunnel/commit/b0d70ce224|2.3.5|
+| [Improve][Jdbc] Support custom case-sensitive config for dameng (#6510)      
                                  
|https://github.com/apache/seatunnel/commit/d6dcb03bf3|2.3.5|
+| feat: jdbc support copy in statement. (#6443)                                
                                  
|https://github.com/apache/seatunnel/commit/ca4a65fc00|2.3.5|
+| [Improve][Jdbc] Using varchar2 datatype store string in oracle (#6392)       
                                  
|https://github.com/apache/seatunnel/commit/14405fa8d4|2.3.5|
+| [Improve][API] Unify type system api(data &amp; type) (#5872)                
                                  
|https://github.com/apache/seatunnel/commit/b38c7edcc9|2.3.5|
+| Fix Jdbc sink target table name error (#6269)                                
                                  
|https://github.com/apache/seatunnel/commit/2f62235e38|2.3.4|
+| [Improve][JDBC] Use PreparedStatement to sample data from column (#6242)     
                                  
|https://github.com/apache/seatunnel/commit/bd0e66d533|2.3.4|
+| [Improve][JDBC-sink] Improve query Approximate Total Row Count of a Table 
(#5972)                              
|https://github.com/apache/seatunnel/commit/8156036a2f|2.3.4|
+| [Feature][JDBC、CDC] Support Short and Byte Type in spliter (#6027)           
                                  
|https://github.com/apache/seatunnel/commit/6f8d0a5040|2.3.4|
+| [Improve] Support `int identity` type in sql server (#6186)                  
                                  
|https://github.com/apache/seatunnel/commit/1a8da1c843|2.3.4|
+| [Bugfix][JDBC、CDC] Fix Spliter Error in Case of Extensive Duplicate Data 
(#6026)                               
|https://github.com/apache/seatunnel/commit/635c24e8b2|2.3.4|
+| [Feature][Connector-V2][Postgres-cdc]Support for Postgres cdc (#5986)        
                                  
|https://github.com/apache/seatunnel/commit/97438b9402|2.3.4|
+| Add date type and float type column split support (#6160)                    
                                  
|https://github.com/apache/seatunnel/commit/b9a62e5c3f|2.3.4|
+| [Improve] Extend `SupportResourceShare` to spark/flink (#5847)               
                                  
|https://github.com/apache/seatunnel/commit/c69da93b87|2.3.4|
+| [Feature] Support `uuid` in postgres jdbc (#6185)                            
                                  
|https://github.com/apache/seatunnel/commit/f56855098b|2.3.4|
+| [Feature][Connector-V2][Oracle-cdc]Support for oracle cdc (#5196)            
                                  
|https://github.com/apache/seatunnel/commit/aaef22b31b|2.3.4|
+| [Feature][Connector] update pgsql catalog for save mode (#6080)              
                                  
|https://github.com/apache/seatunnel/commit/84ce516929|2.3.4|
+| [Hotfix][Jdbc] Fix dameng catalog query table sql (#6141)                    
                                  
|https://github.com/apache/seatunnel/commit/413fa74500|2.3.4|
+| [improve][catalog-postgres] Improve get column sql compatibility (#5664)     
                                  
|https://github.com/apache/seatunnel/commit/23ce592ad2|2.3.4|
+| [Feature][Connector] update oracle catalog for save mode (#6092)             
                                  
|https://github.com/apache/seatunnel/commit/dfbf92769c|2.3.4|
+| [Feature][Connectors-V2][Jdbc] Supports Sqlserver Niche Data Types (#6122)   
                                  
|https://github.com/apache/seatunnel/commit/6673f6f771|2.3.4|
+| [Improve][Connector-V2][Jdbc] Shade hikari in jdbc connector (#6116)         
                                  
|https://github.com/apache/seatunnel/commit/dd698c95bf|2.3.4|
+| [Feature][Connector] update sqlserver catalog for save mode (#6086)          
                                  
|https://github.com/apache/seatunnel/commit/edcaacecb1|2.3.4|
+| [Feature][Connector-V2][PostgresSql] add JDBC source support string type as 
partition key (#6079)              
|https://github.com/apache/seatunnel/commit/3522eb157c|2.3.4|
+| [Hotfix][Jdbc] Fix jdbc setFetchSize error (#6005)                           
                                  
|https://github.com/apache/seatunnel/commit/d41af8a6ed|2.3.4|
+| Support using multiple hadoop account (#5903)                                
                                  
|https://github.com/apache/seatunnel/commit/d69d88d1aa|2.3.4|
+| [Feature] Add unsupported datatype check for all catalog (#5890)             
                                  
|https://github.com/apache/seatunnel/commit/b9791285a0|2.3.4|
+| [Hotfix][Split] Fix split key not support BigInteger type                    
                                  
|https://github.com/apache/seatunnel/commit/5adf5d2b9a|2.3.4|
+| [Improve] Replace SeaTunnelRowType with TableSchema in the JdbcRowConverter  
                                  
|https://github.com/apache/seatunnel/commit/1cc1b1b8cd|2.3.4|
+| [Hotfix][Jdbc] Fix cdc updates were not filtering same primary key (#5923)   
                                  
|https://github.com/apache/seatunnel/commit/38d3b85814|2.3.4|
+| [Improve]Change System.out.println to log output. (#5912)                    
                                  
|https://github.com/apache/seatunnel/commit/bbedb07a9c|2.3.4|
+| [Bug] Fix Hive-Jdbc use krb5 overwrite kerberosKeytabPath (#5891)            
                                  
|https://github.com/apache/seatunnel/commit/f0b6092c15|2.3.4|
+| Reduce the time cost of getCatalogTable in jdbc (#5908)                      
                                  
|https://github.com/apache/seatunnel/commit/51a3737578|2.3.4|
+| [Improve] Improve Jdbc connector error message when datatype unsupported 
(#5864)                               
|https://github.com/apache/seatunnel/commit/69f79af3a4|2.3.4|
+| [Improve] Rename `getCountSql` to `getExistDataSql` (#5838)                  
                                  
|https://github.com/apache/seatunnel/commit/2233b3a381|2.3.4|
+| [Fix] Fix read from Oracle Date type value lose time (#5814)                 
                                  
|https://github.com/apache/seatunnel/commit/2d704e36bd|2.3.4|
+| [Improve][JdbcSource] Optimize catalog-table metadata merge logic (#5828)    
                                  
|https://github.com/apache/seatunnel/commit/7d8028a60b|2.3.4|
+| [Improve][Common] Introduce new error define rule (#5793)                    
                                  
|https://github.com/apache/seatunnel/commit/9d1b2582b2|2.3.4|
+| [Feature][Hive JDBC Source] Support Hive JDBC Source Connector (#5424)       
                                  
|https://github.com/apache/seatunnel/commit/a64e177d06|2.3.4|
+| [Improve] Remove use `SeaTunnelSink::getConsumedType` method and mark it as 
deprecated (#5755)                 
|https://github.com/apache/seatunnel/commit/8de7408100|2.3.4|
+| [Improve][Connector] Add field name to `DataTypeConvertor` to improve error 
message (#5782)                    
|https://github.com/apache/seatunnel/commit/ab60790f0d|2.3.4|
+| [Feature][Oracle] Support XMLTYPE data integration #5716 (#5723)             
                                  
|https://github.com/apache/seatunnel/commit/620f081adb|2.3.4|
+| [Fix] Fix Postgres create table test case failed (#5778)                     
                                  
|https://github.com/apache/seatunnel/commit/b98b6bcee3|2.3.4|
+| [Improve][Jdbc] Fix database identifier (#5756)                              
                                  
|https://github.com/apache/seatunnel/commit/dbfc8a670a|2.3.4|
+| [Fix] Fix PG will not create index when using auto create table #5721        
                                  
|https://github.com/apache/seatunnel/commit/e5fd88dbe7|2.3.4|
+| [Improve] Remove all useless `prepare`, `getProducedType` method (#5741)     
                                  
|https://github.com/apache/seatunnel/commit/ed94fffbb9|2.3.4|
+| [feature][connector-jdbc]Add Save Mode function and Connector-JDBC (MySQL) 
connector has been realized (#5663) 
|https://github.com/apache/seatunnel/commit/eff17ccbe5|2.3.4|
+| [Bug] [connector-jdbc] Nullable Column source have null data could be 
unexpected results. (#5560)              
|https://github.com/apache/seatunnel/commit/3f429e1f0a|2.3.4|
+| [Improve] Add default implement for `SeaTunnelSink::setTypeInfo` (#5682)     
                                  
|https://github.com/apache/seatunnel/commit/86cba87450|2.3.4|
+| [BUG][Connector-V2][Jdbc] support postgresql xml type  (#5724)               
                                  
|https://github.com/apache/seatunnel/commit/5f5d4da13f|2.3.4|
+| [Improve][E2E][Jdbc] Enable IT case for Oceanbase Mysql mode (#5697)         
                                  
|https://github.com/apache/seatunnel/commit/879c2aa07c|2.3.4|
+| [Feature][Jdbc] Support read multiple tables (#5581)                         
                                  
|https://github.com/apache/seatunnel/commit/33fa8ff248|2.3.4|
+| [Feature] Support multi-table sink (#5620)                                   
                                  
|https://github.com/apache/seatunnel/commit/81ac173189|2.3.4|
+| [Improve] Remove catalog tag for config file (#5645)                         
                                  
|https://github.com/apache/seatunnel/commit/dc509aa080|2.3.4|
+| [Feature][Jdbc] Supporting more ways to configure connection parameters. 
(#5388)                               
|https://github.com/apache/seatunnel/commit/d31e9478f7|2.3.4|
+| [Feature][Connector-V2][Jdbc] Add OceanBase catalog (#5439)                  
                                  
|https://github.com/apache/seatunnel/commit/cd4b7ff7d2|2.3.4|
+| [BUGFIX][Catalog] oracle catalog create table repeat and oracle pg null 
point (#5517)                          
|https://github.com/apache/seatunnel/commit/103da931f3|2.3.4|
+| Support config column/primaryKey/constraintKey in schema (#5564)             
                                  
|https://github.com/apache/seatunnel/commit/eac76b4e50|2.3.4|
+| [Improve] Refactor CatalogTable and add 
`SeaTunnelSource::getProducedCatalogTables` (#5562)                    
|https://github.com/apache/seatunnel/commit/41173357f8|2.3.4|
+| [Feature][Jdbc] Add Dameng catalog (#5451)                                   
                                  
|https://github.com/apache/seatunnel/commit/c23070919c|2.3.4|
+| [Feature] Add tidb datatype convertor (#5440)                                
                                  
|https://github.com/apache/seatunnel/commit/61391bda9f|2.3.4|
+| [Feature][Connector-V2]  jdbc connector supports Kingbase database (#4803)   
                                  
|https://github.com/apache/seatunnel/commit/9538567159|2.3.4|
+| [Feature][Catalog] Catalog add Case Conversion Definition (#5328)            
                                  
|https://github.com/apache/seatunnel/commit/7b5b28bdbe|2.3.4|
+| [Feature][Jdbc] Jdbc database support identifier (#5089)                     
                                  
|https://github.com/apache/seatunnel/commit/38b6d6e4bb|2.3.4|
+| [Improve][Connector-v2][Jdbc] Refactor AbstractJdbcCatalog (#5096)           
                                  
|https://github.com/apache/seatunnel/commit/dde3104f76|2.3.4|
+| [Improve][CheckStyle] Remove useless &#x27;SuppressWarnings&#x27; annotation 
of checkstyle. (#5260)            
|https://github.com/apache/seatunnel/commit/51c0d709ba|2.3.4|
+| [Hotfix] Fix com.google.common.base.Preconditions to seatunnel shade one 
(#5284)                               
|https://github.com/apache/seatunnel/commit/ed5eadcf73|2.3.3|
+| [bug][jdbc][oracle]Fix the Oracle number type mapping problem (#5209)        
                                  
|https://github.com/apache/seatunnel/commit/9d3c3de90d|2.3.3|
+| [BUG][Connector-V2][Jdbc] support postgresql json type  (#5194)              
                                  
|https://github.com/apache/seatunnel/commit/7a862d14b7|2.3.3|
+| [Improve] [Connector-V2] Remove scheduler in JDBC sink #4736 (#5168)         
                                  
|https://github.com/apache/seatunnel/commit/3b0a393145|2.3.3|
+| [CI] Split updated modules integration test for part 5 (#5208)               
                                  
|https://github.com/apache/seatunnel/commit/18f14d6087|2.3.3|
+| [Bug] [connector-v2] PostgreSQL versions below 9.5 are compatible use cdc 
sync problem (#5120)                 
|https://github.com/apache/seatunnel/commit/9af696a1dd|2.3.3|
+| [Improve][Connector-v2][Jdbc]  check url not null throw friendly message 
(#5097)                               
|https://github.com/apache/seatunnel/commit/b0815f2a95|2.3.3|
+| [Feature][Catalog] Add JDBC Catalog auto create table (#4917)                
                                  
|https://github.com/apache/seatunnel/commit/63eb137671|2.3.3|
+| [Feature][CDC] Support tables without primary keys (with unique keys) (#163) 
(#5150)                           
|https://github.com/apache/seatunnel/commit/32b7f2b690|2.3.3|
+| [Hotfix][Connector][Jdbc] Fix the problem of JdbcOutputFormat database 
connection leak (#4802)                 
|https://github.com/apache/seatunnel/commit/4cc10e83e7|2.3.3|
+| [Feature][JDBC Sink] Add DM upsert support (#5073)                           
                                  
|https://github.com/apache/seatunnel/commit/5e8d982e25|2.3.3|
+| [Improve] Improve savemode api (#4767)                                       
                                  
|https://github.com/apache/seatunnel/commit/4acd370d48|2.3.3|
+| [Feature][Connector-V2] JDBC source support string type as partition key 
(#4947)                               
|https://github.com/apache/seatunnel/commit/d1d2677658|2.3.3|
+| [Feature][Connector-V2][Jdbc] Add oceanbase dialect factory (#4989)          
                                  
|https://github.com/apache/seatunnel/commit/7ba11cecdf|2.3.3|
+| Fix XA Transaction bug (#5020)                                               
                                  
|https://github.com/apache/seatunnel/commit/852fe104bc|2.3.3|
+| [Improve][CDC]Remove  driver for cdc connector (#4952)                       
                                  
|https://github.com/apache/seatunnel/commit/b65f40c3c9|2.3.3|
+| [Improve] Documentation and partial word optimization. (#4936)               
                                  
|https://github.com/apache/seatunnel/commit/6e8de0e2a6|2.3.3|
+| [Improve][Connector-V2][Jdbc-Source] Support for Decimal types as splict 
keys  (#4634)                         
|https://github.com/apache/seatunnel/commit/d56bb1ba1c|2.3.3|
+| [Bugfix][zeta] Fix the deadlock issue with JDBC driver loading (#4878)       
                                  
|https://github.com/apache/seatunnel/commit/c30a2a1b1c|2.3.2|
+| [Hotfix][Jdbc] Fix XA DataSource crash(Oracle/Dameng/SqlServer) (#4866)      
                                  
|https://github.com/apache/seatunnel/commit/bde19b6377|2.3.2|
+| [Feature][Connector-v2] Add Snowflake Source&amp;Sink connector (#4470)      
                                  
|https://github.com/apache/seatunnel/commit/06c59a25f3|2.3.2|
+| [Hotfix][Connector-V2][Jdbc] Fix the error of extracting primary key column 
in sink (#4815)                    
|https://github.com/apache/seatunnel/commit/0eff3aeed0|2.3.2|
+| [Hotfix][Connector][Jdbc] Fix reconnect throw close statement exception 
(#4801)                                
|https://github.com/apache/seatunnel/commit/ea3bc1a673|2.3.2|
+| [Hotfix][Connector][Jdbc] Fix sqlserver system table case sensitivity 
(#4806)                                  
|https://github.com/apache/seatunnel/commit/2ca7426d22|2.3.2|
+| [Hotfix][Jdbc][Oracle] Fix oracle sql table identifier (#4754)               
                                  
|https://github.com/apache/seatunnel/commit/84cb51ff83|2.3.2|
+| [Improve][Jdbc] Populate primary key when jdbc sink is created using 
CatalogTable (#4755)                      
|https://github.com/apache/seatunnel/commit/4af3bf9015|2.3.2|
+| [Feature][PostgreSQL-jdbc] Supports GEOMETRY data type for PostgreSQL… 
(#4673)                                 
|https://github.com/apache/seatunnel/commit/a5af4d9b6e|2.3.2|
+| [Improve][Core] Add check of sink and source config to avoid null pointer 
exception. (#4734)                   
|https://github.com/apache/seatunnel/commit/8f66ce96cb|2.3.2|
+| [Hotfix][JDBC-SINK] Fix TiDBCatalog without open (#4718)                     
                                  
|https://github.com/apache/seatunnel/commit/34a7f3eaa4|2.3.2|
+| [Feature][E2E] Add mysql-cdc e2e testcase (#4639)                            
                                  
|https://github.com/apache/seatunnel/commit/87001dfd16|2.3.2|
+| [Hotfix][JDBC Sink] Fix JDBC Sink oom bug (#4690)                            
                                  
|https://github.com/apache/seatunnel/commit/08b6f992aa|2.3.2|
+| Improve the option rule for jdbc sink (#4694)                                
                                  
|https://github.com/apache/seatunnel/commit/a6b3704414|2.3.2|
+| [feature][catalog] Support for multiplexing connections (#4550)              
                                  
|https://github.com/apache/seatunnel/commit/41277d7f78|2.3.2|
+| [Bugfix][Jdbc-Mysql Mysql-CDC] Fix MySQL BIT type incorrectly converted to 
Boolean type (#4671)                
|https://github.com/apache/seatunnel/commit/89b0099ff4|2.3.2|
+| [Hotfix][Jdbc[SqlServer] Fix sqlserver jdbc url parse (#4697)                
                                  
|https://github.com/apache/seatunnel/commit/b24c3226ec|2.3.2|
+| Revert &quot;[Improve][Catalog] refactor catalog (#4540)&quot; (#4628)       
                                  
|https://github.com/apache/seatunnel/commit/2d1933195d|2.3.2|
+| [Feature][Connector][Jdbc] Add DataTypeConvertor for JDBC-Postgres (#4575)   
                                  
|https://github.com/apache/seatunnel/commit/91f5125976|2.3.2|
+| [Improve][Catalog] refactor catalog (#4540)                                  
                                  
|https://github.com/apache/seatunnel/commit/b0a701cb83|2.3.2|
+| [Bug] [JDBC Source] fix split exception when source table is empty (#4570)   
                                  
|https://github.com/apache/seatunnel/commit/c73b9331ce|2.3.2|
+| [Feature][Connector][Jdbc] Add vertica connector. (#4303)                    
                                  
|https://github.com/apache/seatunnel/commit/e6b4f98721|2.3.2|
+| [Hotfix][Catalog] Filter out unavailable constrain keys (#4557)              
                                  
|https://github.com/apache/seatunnel/commit/5e5859546a|2.3.2|
+| [Hotfix][Connector-V2][Jdbc] Simple sql has the highest priority (#4548)     
                                  
|https://github.com/apache/seatunnel/commit/74d4d24858|2.3.2|
+| [Improve][Connector-V2][Jdbc] Jdbc source supports factory SPI (#4264)       
                                  
|https://github.com/apache/seatunnel/commit/a97f33797d|2.3.2|
+| [Jdbc][Chore] improve the exception message when primary key not found in 
row (#4474)                          
|https://github.com/apache/seatunnel/commit/06fa850da9|2.3.2|
+| [hotfix][JDBC] Fix the table name is not automatically obtained when 
multiple tables (#4514)                   
|https://github.com/apache/seatunnel/commit/c84d6f8d11|2.3.2|
+| [Chore][Jdbc] add the log for sql and update some style (#4475)              
                                  
|https://github.com/apache/seatunnel/commit/a9e6503045|2.3.2|
+| [Hotfix][Connector-V2][Jdbc] Set default value to false of JdbcOption: 
generate_sink_sql (#4471)               
|https://github.com/apache/seatunnel/commit/7da11c2f44|2.3.2|
+| [feature][jdbc][TiDB] add TiDB catalog (#4438)                               
                                  
|https://github.com/apache/seatunnel/commit/9a32db6fc0|2.3.2|
+| [Hotfix][Connector] Fix sqlserver catalog (#4441)                            
                                  
|https://github.com/apache/seatunnel/commit/8540c7f9f3|2.3.2|
+| [Feature][CDC][SqlServer] Support multi-table read (#4377)                   
                                  
|https://github.com/apache/seatunnel/commit/c4e3f2dc03|2.3.2|
+| [Improve][JdbcSink]Fix connection failure caused by connection timeout. 
(#4322)                                
|https://github.com/apache/seatunnel/commit/e1f6d3b3fd|2.3.2|
+| [Hotfix][Connector-V2][Jdbc] Field aliases are not supported in the query of 
jdbc source. (#4158) (#4210)      
|https://github.com/apache/seatunnel/commit/3d7ff831f9|2.3.1|
+| Change file type to file_format_type in file source/sink (#4249)             
                                  
|https://github.com/apache/seatunnel/commit/973a2fae3c|2.3.1|
+| Change redshift type to lowercase (#4248)                                    
                                  
|https://github.com/apache/seatunnel/commit/10447ae103|2.3.1|
+| Add redshift datatype convertor (#4245)                                      
                                  
|https://github.com/apache/seatunnel/commit/b19011517f|2.3.1|
+| [improve][zeta] fix zeta bugs                                                
                                  
|https://github.com/apache/seatunnel/commit/3a82e8b39f|2.3.1|
+| [Improve] Support MySqlCatalog Use JDBC URL With Custom Suffix               
                                  
|https://github.com/apache/seatunnel/commit/210d0ff1f8|2.3.1|
+| [hotfix] fixed jdbc IT error                                                 
                                  
|https://github.com/apache/seatunnel/commit/dd20af0a9e|2.3.1|
+| Merge branch &#x27;dev&#x27; into merge/cdc                                  
                                  
|https://github.com/apache/seatunnel/commit/4324ee1912|2.3.1|
+| [Improve][Project] Code format with spotless plugin.                         
                                  
|https://github.com/apache/seatunnel/commit/423b583038|2.3.1|
+| [improve][jdbc] use ReadonlyConfig instead of Config (#4236)                 
                                  
|https://github.com/apache/seatunnel/commit/c90c58e243|2.3.1|
+| [Improve][Jdbc-sink] add database field to sink config (#4199)               
                                  
|https://github.com/apache/seatunnel/commit/ec368902f4|2.3.1|
+| [improve][jdbc] Reduce jdbc options configuration (#4218)                    
                                  
|https://github.com/apache/seatunnel/commit/ddd8f808b5|2.3.1|
+| Fix mysql get default value (#4204)                                          
                                  
|https://github.com/apache/seatunnel/commit/6848434f2d|2.3.1|
+| [hotfix][zeta] fix zeta multi-table parser error (#4193)                     
                                  
|https://github.com/apache/seatunnel/commit/98f2ad0c19|2.3.1|
+| [Improve] Remove AUTO_COMMIT To Optional In JDBC OptionRule (#4194)          
                                  
|https://github.com/apache/seatunnel/commit/9d088017a3|2.3.1|
+| [Improve] [Connector-V2] [StarRocks] Starrocks Support Auto Create Table 
(#4177)                               
|https://github.com/apache/seatunnel/commit/7e0008e6fb|2.3.1|
+| [improve][catalog][jdbc] Add MySQL catalog factory (#4168)                   
                                  
|https://github.com/apache/seatunnel/commit/95e3cbf875|2.3.1|
+| [Improve][build] Give the maven module a human readable name (#4114)         
                                  
|https://github.com/apache/seatunnel/commit/d7cd601051|2.3.1|
+| Add convertor factory (#4119)                                                
                                  
|https://github.com/apache/seatunnel/commit/cbdea45d95|2.3.1|
+| Add ElasticSearch catalog (#4108)                                            
                                  
|https://github.com/apache/seatunnel/commit/9ee4d8394c|2.3.1|
+| Add Kafka catalog (#4106)                                                    
                                  
|https://github.com/apache/seatunnel/commit/34f1f21e48|2.3.1|
+| [Improve][Project] Code format with spotless plugin. (#4101)                 
                                  
|https://github.com/apache/seatunnel/commit/a2ab166561|2.3.1|
+| Add DataTypeConvertor in Catalog (#4094)                                     
                                  
|https://github.com/apache/seatunnel/commit/840c3e5eb4|2.3.1|
+| [Feature] [Catalog] Support create/drop table, create/drop database in 
catalog (#4075)                         
|https://github.com/apache/seatunnel/commit/d8a0be84ca|2.3.1|
+| [Bug][Connector-V2][Jdbc] Fixed no exception throwing problem (#3957)        
                                  
|https://github.com/apache/seatunnel/commit/6ab266e594|2.3.1|
+| [Bug][CDC] Fix jdbc sink generate update sql (#3940)                         
                                  
|https://github.com/apache/seatunnel/commit/233465d4e4|2.3.1|
+| [Improve][JDBC] improve jdbc sink option (#3864)                             
                                  
|https://github.com/apache/seatunnel/commit/768a9300e8|2.3.1|
+| Fix Source Class Support Parallelism judge &amp; Add UT for it (#3878)       
                                  
|https://github.com/apache/seatunnel/commit/ce85a8c68b|2.3.1|
+| [Feature][Connector] add get source method to all source connector (#3846)   
                                  
|https://github.com/apache/seatunnel/commit/417178fb84|2.3.1|
+| [Feature][Connector-V2] Jdbc connector support SAP HANA. (#3017)             
                                  
|https://github.com/apache/seatunnel/commit/fe0180fab2|2.3.1|
+| [Feature][API &amp; Connector &amp; Doc] add parallelism and column 
projection interface (#3829)               
|https://github.com/apache/seatunnel/commit/b9164b8ba1|2.3.1|
+| [Improve][JDBC Connector]improve option rule (#3802)                         
                                  
|https://github.com/apache/seatunnel/commit/139256741a|2.3.1|
+| [Hotfix][Jdbc Sink] fix xa transaction commit failure on pipeline restore 
(#3809)                              
|https://github.com/apache/seatunnel/commit/39dae4cfd9|2.3.1|
+| [Improve][Connector-V2][JDBC] Add exactly-once for JDBC source connector 
(#3750)                               
|https://github.com/apache/seatunnel/commit/5328e9d847|2.3.1|
+| [Improve][Connector-v2] Remove unused options for jdbc source factory 
(#3794)                                  
|https://github.com/apache/seatunnel/commit/861004d309|2.3.1|
+| [Feature][Connector-jdbc] Fix JDBC Connector Throw Exception Error. (#3796)  
                                  
|https://github.com/apache/seatunnel/commit/38646b11b8|2.3.1|
+| [hotfix][ST-Engine] fix jdbc connector exactly-once null pointer (#3730)     
                                  
|https://github.com/apache/seatunnel/commit/0c5986fbec|2.3.0|
+| [Improve][connector-jdbc] Add config item enable upsert by query (#3708)     
                                  
|https://github.com/apache/seatunnel/commit/e1f951f782|2.3.0|
+| [Hotfix][connector-v2] fix SemanticXidGenerator#generateXid indexOutOfBounds 
#3701 (#3705)                     
|https://github.com/apache/seatunnel/commit/f351ceaf4b|2.3.0|
+| [Hotfix][Connector-V2][jdbc] fix jdbc connection reset bug (#3670)           
                                  
|https://github.com/apache/seatunnel/commit/6fe0e6aece|2.3.0|
+| [Improve][Connector-V2][JDBC] Unified exception for JDBC source &amp; sink 
(#3598)                             
|https://github.com/apache/seatunnel/commit/865ca2bba9|2.3.0|
+| [Connector][JDBC]Support Redshift sink and source (#3615)                    
                                  
|https://github.com/apache/seatunnel/commit/8d9d8638d2|2.3.0|
+| [Improve][Connectors-V2][jdbc] Adapts to multiple versions of Flink #3589    
                                  
|https://github.com/apache/seatunnel/commit/e77fdbbef7|2.3.0|
+| [Hotfix][OptionRule] Fix option rule about all connectors (#3592)            
                                  
|https://github.com/apache/seatunnel/commit/226dc6a119|2.3.0|
+| [Feature][Connector-V2][Doris]Add Doris Source &amp; Sink connector (#3586)  
                                  
|https://github.com/apache/seatunnel/commit/3d46b79614|2.3.0|
+| [Feature][Connector-V2][Teradata] Add Teradata Source And Sink Connector     
                                  
|https://github.com/apache/seatunnel/commit/3a095d30fd|2.3.0|
+| [Feature][Connector-V2][JDBC] support sqlite Source &amp; Sink (#3089)       
                                  
|https://github.com/apache/seatunnel/commit/a73bb3e714|2.3.0|
+| Bump postgresql in /seatunnel-connectors-v2/connector-jdbc (#3559)           
                                  
|https://github.com/apache/seatunnel/commit/c8dfdf3e46|2.3.0|
+| [feature][connector][cdc] add SeaTunnelRowDebeziumDeserializeSchema (#3499)  
                                  
|https://github.com/apache/seatunnel/commit/ff44db116e|2.3.0|
+| [JDBC] [ORACLE] Improve Oracle Type to SeaTunnel Type Mapping (#3486)        
                                  
|https://github.com/apache/seatunnel/commit/8fe0dda6e2|2.3.0|
+| [JDBC] [Config] Add JDBC Fetch Size Config And Custom Postgres 
PrepareStatement (#3478)                        
|https://github.com/apache/seatunnel/commit/d60a705f5d|2.3.0|
+| [feature][connector][jdbc] expose configurable options in JDBC (#3410)       
                                  
|https://github.com/apache/seatunnel/commit/72b8a73cab|2.3.0|
+| [feature][connector][jdbc] Support write cdc changelog event in jdbc sink 
(#3444)                              
|https://github.com/apache/seatunnel/commit/b12a908f01|2.3.0|
+| [Improve][Connector-v2][Jdbc] Add AutoCommit to jdbcConfig (#3453)           
                                  
|https://github.com/apache/seatunnel/commit/cfb1e97853|2.3.0|
+| [Improve][Connector-v2] Unset AutoCommit default to true (#3451)             
                                  
|https://github.com/apache/seatunnel/commit/439f686d92|2.3.0|
+| [Feature][connector-v2] add tablestore source and sink  (#3309)              
                                  
|https://github.com/apache/seatunnel/commit/ebebf0b633|2.3.0|
+| Close jdbc connection after use. (#3358)                                     
                                  
|https://github.com/apache/seatunnel/commit/219fea517c|2.3.0|
+| [Improve] [Engine] Improve Engine performance. (#3216)                       
                                  
|https://github.com/apache/seatunnel/commit/7393c47327|2.3.0|
+| [Bug][Connector-V2][JDBC]fix jdbc split bug (#3220)                          
                                  
|https://github.com/apache/seatunnel/commit/40d67ab902|2.3.0|
+| [Feature][Connector-V2][JDBC] Support DB2 Source &amp; Sink (#2410)          
                                  
|https://github.com/apache/seatunnel/commit/bf1ef69e84|2.3.0|
+| update org.postgresql:postgresql 42.3.3 to 42.4.1 (#3097)                    
                                  
|https://github.com/apache/seatunnel/commit/2852516490|2.3.0|
+| [Feature][Connector-V2][Jdbc] support gbase 8a  (#3026)                      
                                  
|https://github.com/apache/seatunnel/commit/dc6e85d06f|2.3.0-beta|
+| [Bug] [sqlserver] timestamp convert exception (#3024)                        
                                  
|https://github.com/apache/seatunnel/commit/99ac1a655e|2.3.0-beta|
+| [Feature][Connector-V2] oracle connector (#2550)                             
                                  
|https://github.com/apache/seatunnel/commit/384ece1913|2.3.0-beta|
+| [Improve][Connector-v2][jdbc] Support for specify number of partitions when 
parallel reading (#2950)           
|https://github.com/apache/seatunnel/commit/fc284ac32e|2.3.0-beta|
+| [Feature][Connector-V2] add sqlserver connector (#2646)                      
                                  
|https://github.com/apache/seatunnel/commit/05d105dea3|2.3.0-beta|
+| [Improve][e2e] Unified e2e IT for DaMengDB (#2946)                           
                                  
|https://github.com/apache/seatunnel/commit/15636bdea1|2.3.0-beta|
+| [Improve][e2e] modify DM-driver by downLoad and add the value comparison of 
all columns (#2772)                
|https://github.com/apache/seatunnel/commit/f3ff39bdfe|2.3.0-beta|
+| [Improve][e2e] Improve jdbc driver management (#2770)                        
                                  
|https://github.com/apache/seatunnel/commit/f907927a35|2.3.0-beta|
+| [hotfix][connector][jdbc] fix JDBC split exception (#2904)                   
                                  
|https://github.com/apache/seatunnel/commit/57342c6545|2.3.0-beta|
+| [Improve][connector-jdbc] Calculate splits only once in 
JdbcSourceSplitEnumerator (#2900)                      
|https://github.com/apache/seatunnel/commit/7622f28999|2.3.0-beta|
+| [Feature] [Connector-V2 E2E] Add mysql and postgres e2e test and bug fix 
(#2838)                               
|https://github.com/apache/seatunnel/commit/db434adc15|2.2.0-beta|
+| fix XAConnection being wrongly submitted (#2805)                             
                                  
|https://github.com/apache/seatunnel/commit/d9a6039fd3|2.2.0-beta|
+| fix spark execute exception is not thrown (#2791)                            
                                  
|https://github.com/apache/seatunnel/commit/b1711c984e|2.2.0-beta|
+| [Improve][e2e] Add driver-jar to lib (#2719)                                 
                                  
|https://github.com/apache/seatunnel/commit/d64d452c86|2.2.0-beta|
+| [DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton 
pattern (#2706)                       
|https://github.com/apache/seatunnel/commit/cbf82f755c|2.2.0-beta|
+| [Connector-V2][JDBC-connector] support Jdbc dm (#2377)                       
                                  
|https://github.com/apache/seatunnel/commit/7278209ca2|2.2.0-beta|
+| [#2606]Dependency management split (#2630)                                   
                                  
|https://github.com/apache/seatunnel/commit/fc047be69b|2.2.0-beta|
+| [Bug] [connector-jdbc-v2] Fix transaction force commit when autoCommit is 
enabled (#2636)                      
|https://github.com/apache/seatunnel/commit/8cd8cf7aa2|2.2.0-beta|
+| [Feature][Connector-V2] Add phoenix connector sink  (#2499)                  
                                  
|https://github.com/apache/seatunnel/commit/05ccf9d68c|2.2.0-beta|
+| [Connector-V2][JDBC] Support database: greenplum (#2429)                     
                                  
|https://github.com/apache/seatunnel/commit/3561d3878f|2.2.0-beta|
+| Add jdbc connector e2e test (#2321)                                          
                                  
|https://github.com/apache/seatunnel/commit/5fbcb811c6|2.2.0-beta|
+| StateT of SeaTunnelSource should extend `Serializable` (#2214)               
                                  
|https://github.com/apache/seatunnel/commit/8c426ef850|2.2.0-beta|
+| update the condition to 1 = 0 about get table operation (#2186)              
                                  
|https://github.com/apache/seatunnel/commit/7c56d7143b|2.2.0-beta|
+| [SeaTunnel API] [Sink] remove useless context field (#2124)                  
                                  
|https://github.com/apache/seatunnel/commit/a31fdeedcc|2.2.0-beta|
+| [bugfix] Check isOpen before closing (#2107)                                 
                                  
|https://github.com/apache/seatunnel/commit/7ec0ada2b9|2.2.0-beta|
+| [API-DRAFT] [MERGE] fix merge error                                          
                                  
|https://github.com/apache/seatunnel/commit/3c0e984648|2.2.0-beta|
+| merge dev to api-draft                                                       
                                  
|https://github.com/apache/seatunnel/commit/d265597c64|2.2.0-beta|
+| [api-draft][Optimize] Optimize module name (#2062)                           
                                  
|https://github.com/apache/seatunnel/commit/f79e3112b1|2.2.0-beta|
 
 </details>
diff --git a/docs/en/connector-v2/source/Jdbc.md 
b/docs/en/connector-v2/source/Jdbc.md
index 972294cb8a..3d2d6b995a 100644
--- a/docs/en/connector-v2/source/Jdbc.md
+++ b/docs/en/connector-v2/source/Jdbc.md
@@ -56,6 +56,7 @@ supports query SQL and can achieve projection effect.
 | partition_lower_bound                      | Long    | No       | -          
     | The partition_column min value for scan, if not set SeaTunnel will query 
database get min value.                                                         
                                                                                
                                                                                
                                                                                
              [...]
 | partition_num                              | Int     | No       | job 
parallelism | Not recommended for use, The correct approach is to control the 
number of split through `split.size`<br/> **Note:** This parameter takes effect 
only when using the `query` parameter. It does not take effect when using the 
`table_path` parameter.                                                         
                                                                                
                         [...]
 | decimal_type_narrowing                     | Boolean | No       | true       
     | Decimal type narrowing, if true, the decimal type will be narrowed to 
the int or long type if without loss of precision. Only support for Oracle at 
now. Please refer to `decimal_type_narrowing` below                             
                                                                                
                                                                                
                   [...]
+| handle_blob_as_string                      | Boolean | No       | false      
     | If true, BLOB type will be converted to STRING type. **Only supported 
for Oracle database**. This is useful for handling large BLOB fields in Oracle 
that exceed the default size limit. When transmitting Oracle's BLOB fields to 
systems like Doris, setting this to true can make the data transfer more 
efficient.                                                                      
                           [...]
 | use_select_count                           | Boolean | No       | false      
     | Use select count for table count rather then other methods in dynamic 
chunk split stage. This is currently only available for jdbc-oracle.In this 
scenario, select count directly is used when it is faster to update statistics 
using sql from analysis table                                                   
                                                                                
                      [...]
 | skip_analyze                               | Boolean | No       | false      
     | Skip the analysis of table count in dynamic chunk split stage. This is 
currently only available for jdbc-oracle.In this scenario, you schedule 
analysis table sql to update related table statistics periodically or your 
table data does not change frequently                                           
                                                                                
                             [...]
 | fetch_size                                 | Int     | No       | 0          
     | For queries that return a large number of objects, you can configure the 
row fetch size used in the query to improve performance by reducing the number 
database hits required to satisfy the selection criteria. Zero means use jdbc 
default value.                                                                  
                                                                                
                 [...]
@@ -208,6 +209,28 @@ Jdbc {
 }
 ```
 
+#### Case 4 Oracle Source with BLOB as string to Doris Sink
+
+This example demonstrates how to handle Oracle's BLOB data as strings when 
transferring to Doris. This is useful for large BLOB fields.
+
+```
+env {
+  parallelism = 1
+  job.mode = "BATCH"
+}
+
+source {
+  Jdbc {
+    driver = oracle.jdbc.driver.OracleDriver
+    url = "jdbc:oracle:thin:@oracle_host:1521/SERVICE_NAME"
+    user = "username"
+    password = "password"
+    query = "SELECT ID, NAME, CONTENT_BLOB FROM MY_TABLE"
+    handle_blob_as_string = true  # Enable BLOB to String conversion for Oracle
+  }
+}
+```
+
 ### parallel by partition_column
 
 ```
diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleTypeUtils.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleTypeUtils.java
index 8147a187bb..38a52aa88f 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleTypeUtils.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleTypeUtils.java
@@ -69,6 +69,6 @@ public class OracleTypeUtils {
             builder.scale(column.length());
         }
 
-        return new OracleTypeConverter(false).convert(builder.build());
+        return new OracleTypeConverter(false, false).convert(builder.build());
     }
 }
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/JdbcCatalogOptions.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/JdbcCatalogOptions.java
index 53e40c1e9b..6c0ebeef31 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/JdbcCatalogOptions.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/JdbcCatalogOptions.java
@@ -59,11 +59,13 @@ public interface JdbcCatalogOptions {
                             "The compatible mode of database, required when 
the database supports multiple compatible modes. "
                                     + "For example, when using OceanBase 
database, you need to set it to 'mysql' or 'oracle'.");
 
+    Option<Boolean> HANDLE_BLOB_AS_STRING = JdbcOptions.HANDLE_BLOB_AS_STRING;
+
     OptionRule.Builder BASE_RULE =
             OptionRule.builder()
                     .required(BASE_URL)
                     .required(USERNAME, PASSWORD)
-                    .optional(SCHEMA, JdbcOptions.DECIMAL_TYPE_NARROWING);
+                    .optional(SCHEMA, JdbcOptions.DECIMAL_TYPE_NARROWING, 
HANDLE_BLOB_AS_STRING);
 
     Option<String> TABLE_PREFIX =
             Options.key("tablePrefix")
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java
index d7d86c46b1..d228e0b04a 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java
@@ -75,6 +75,7 @@ public class OracleCatalog extends AbstractJdbcCatalog {
                     + "    cols.column_id \n";
 
     private boolean decimalTypeNarrowing;
+    private boolean handleBlobAsString;
 
     public OracleCatalog(
             String catalogName,
@@ -90,7 +91,8 @@ public class OracleCatalog extends AbstractJdbcCatalog {
                 urlInfo,
                 defaultSchema,
                 JdbcOptions.DECIMAL_TYPE_NARROWING.defaultValue(),
-                driverClass);
+                driverClass,
+                false);
     }
 
     public OracleCatalog(
@@ -100,9 +102,11 @@ public class OracleCatalog extends AbstractJdbcCatalog {
             JdbcUrlUtil.UrlInfo urlInfo,
             String defaultSchema,
             boolean decimalTypeNarrowing,
-            String driverClass) {
+            String driverClass,
+            boolean handleBlobAsString) {
         super(catalogName, username, pwd, urlInfo, defaultSchema, driverClass);
         this.decimalTypeNarrowing = decimalTypeNarrowing;
+        this.handleBlobAsString = handleBlobAsString;
     }
 
     @Override
@@ -187,7 +191,8 @@ public class OracleCatalog extends AbstractJdbcCatalog {
                         .defaultValue(defaultValue)
                         .comment(columnComment)
                         .build();
-        return new 
OracleTypeConverter(decimalTypeNarrowing).convert(typeDefine);
+        return new OracleTypeConverter(decimalTypeNarrowing, 
handleBlobAsString)
+                .convert(typeDefine);
     }
 
     @Override
@@ -204,7 +209,9 @@ public class OracleCatalog extends AbstractJdbcCatalog {
     public CatalogTable getTable(String sqlQuery) throws SQLException {
         Connection defaultConnection = getConnection(defaultUrl);
         return CatalogUtils.getCatalogTable(
-                defaultConnection, sqlQuery, new 
OracleTypeMapper(decimalTypeNarrowing));
+                defaultConnection,
+                sqlQuery,
+                new OracleTypeMapper(decimalTypeNarrowing, 
handleBlobAsString));
     }
 
     @Override
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalogFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalogFactory.java
index 209d307c40..10b02ce4a8 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalogFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalogFactory.java
@@ -55,7 +55,8 @@ public class OracleCatalogFactory implements CatalogFactory {
                 urlInfo,
                 options.get(JdbcCatalogOptions.SCHEMA),
                 options.get(JdbcOptions.DECIMAL_TYPE_NARROWING),
-                options.get(JdbcOptions.DRIVER));
+                options.get(JdbcOptions.DRIVER),
+                
options.getOptional(JdbcOptions.HANDLE_BLOB_AS_STRING).orElse(false));
     }
 
     @Override
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java
index 9e45646f09..b6fa447421 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java
@@ -64,6 +64,8 @@ public class JdbcConnectionConfig implements Serializable {
 
     private Map<String, String> properties;
 
+    private boolean handleBlobAsString = 
JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue();
+
     public static JdbcConnectionConfig of(ReadonlyConfig config) {
         JdbcConnectionConfig.Builder builder = JdbcConnectionConfig.builder();
         builder.url(config.get(JdbcOptions.URL));
@@ -73,6 +75,7 @@ public class JdbcConnectionConfig implements Serializable {
         builder.maxRetries(config.get(JdbcOptions.MAX_RETRIES));
         
builder.connectionCheckTimeoutSeconds(config.get(JdbcOptions.CONNECTION_CHECK_TIMEOUT_SEC));
         builder.batchSize(config.get(JdbcOptions.BATCH_SIZE));
+        
builder.handleBlobAsString(config.get(JdbcOptions.HANDLE_BLOB_AS_STRING));
         if (config.get(JdbcOptions.IS_EXACTLY_ONCE)) {
             
builder.xaDataSourceClassName(config.get(JdbcOptions.XA_DATA_SOURCE_CLASS_NAME));
             
builder.maxCommitAttempts(config.get(JdbcOptions.MAX_COMMIT_ATTEMPTS));
@@ -124,6 +127,7 @@ public class JdbcConnectionConfig implements Serializable {
         private int batchSize = JdbcOptions.BATCH_SIZE.defaultValue();
         private String xaDataSourceClassName;
         private boolean decimalTypeNarrowing = 
JdbcOptions.DECIMAL_TYPE_NARROWING.defaultValue();
+        private boolean handleBlobAsString = 
JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue();
         private int maxCommitAttempts = 
JdbcOptions.MAX_COMMIT_ATTEMPTS.defaultValue();
         private int transactionTimeoutSec = 
JdbcOptions.TRANSACTION_TIMEOUT_SEC.defaultValue();
         private Map<String, String> properties;
@@ -235,6 +239,11 @@ public class JdbcConnectionConfig implements Serializable {
             return this;
         }
 
+        public Builder handleBlobAsString(boolean handleBlobAsString) {
+            this.handleBlobAsString = handleBlobAsString;
+            return this;
+        }
+
         public JdbcConnectionConfig build() {
             JdbcConnectionConfig jdbcConnectionConfig = new 
JdbcConnectionConfig();
             jdbcConnectionConfig.batchSize = this.batchSize;
@@ -250,6 +259,7 @@ public class JdbcConnectionConfig implements Serializable {
             jdbcConnectionConfig.maxCommitAttempts = this.maxCommitAttempts;
             jdbcConnectionConfig.xaDataSourceClassName = 
this.xaDataSourceClassName;
             jdbcConnectionConfig.decimalTypeNarrowing = 
this.decimalTypeNarrowing;
+            jdbcConnectionConfig.handleBlobAsString = this.handleBlobAsString;
             jdbcConnectionConfig.useKerberos = this.useKerberos;
             jdbcConnectionConfig.kerberosPrincipal = this.kerberosPrincipal;
             jdbcConnectionConfig.kerberosKeytabPath = this.kerberosKeytabPath;
@@ -260,4 +270,12 @@ public class JdbcConnectionConfig implements Serializable {
             return jdbcConnectionConfig;
         }
     }
+
+    public boolean isHandleBlobAsString() {
+        return handleBlobAsString;
+    }
+
+    public void setHandleBlobAsString(boolean handleBlobAsString) {
+        this.handleBlobAsString = handleBlobAsString;
+    }
 }
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
index 319f4cecf1..f8b1643d91 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java
@@ -108,6 +108,13 @@ public interface JdbcOptions {
                     .withDescription(
                             "decimal type narrowing, if true, the decimal type 
will be narrowed to the int or long type if without loss of precision. Only 
support for Oracle at now.");
 
+    Option<Boolean> HANDLE_BLOB_AS_STRING =
+            Options.key("handle_blob_as_string")
+                    .booleanType()
+                    .defaultValue(false)
+                    .withDescription(
+                            "If true, BLOB type will be converted to STRING 
type. Only support for Oracle at now.");
+
     Option<String> XA_DATA_SOURCE_CLASS_NAME =
             Options.key("xa_data_source_class_name")
                     .stringType()
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java
index 80d479d610..7c46040577 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java
@@ -44,6 +44,7 @@ public class JdbcSourceConfig implements Serializable {
     private int splitSampleShardingThreshold;
     private int splitInverseSamplingRate;
     private boolean decimalTypeNarrowing;
+    private boolean handleBlobAsString;
 
     private StringSplitMode stringSplitMode;
 
@@ -72,6 +73,7 @@ public class JdbcSourceConfig implements Serializable {
         
builder.splitInverseSamplingRate(config.get(JdbcSourceOptions.SPLIT_INVERSE_SAMPLING_RATE));
 
         
builder.decimalTypeNarrowing(config.get(JdbcOptions.DECIMAL_TYPE_NARROWING));
+        
builder.handleBlobAsString(config.get(JdbcOptions.HANDLE_BLOB_AS_STRING));
 
         config.getOptional(JdbcSourceOptions.WHERE_CONDITION)
                 .ifPresent(
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectFactory.java
index 93ddb78248..c125a7e2b9 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectFactory.java
@@ -17,6 +17,8 @@
 
 package org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect;
 
+import 
org.apache.seatunnel.connectors.seatunnel.jdbc.config.JdbcConnectionConfig;
+
 /**
  * A factory to create a specific {@link JdbcDialect}
  *
@@ -48,9 +50,24 @@ public interface JdbcDialectFactory {
      * Create a {@link JdbcDialect} instance based on the driver type and 
compatible mode.
      *
      * @param compatibleMode The compatible mode
+     * @param fieldId The field identifier enumeration value
      * @return a new instance of {@link JdbcDialect}
      */
     default JdbcDialect create(String compatibleMode, String fieldId) {
         return create();
     }
+
+    /**
+     * Create a {@link JdbcDialect} instance based on the driver type, 
compatible mode, and JDBC
+     * connection config.
+     *
+     * @param compatibleMode The compatible mode
+     * @param fieldId The field identifier enumeration value
+     * @param jdbcConnectionConfig The JDBC connection configuration
+     * @return a new instance of {@link JdbcDialect}
+     */
+    default JdbcDialect create(
+            String compatibleMode, String fieldId, JdbcConnectionConfig 
jdbcConnectionConfig) {
+        return create(compatibleMode, fieldId);
+    }
 }
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java
index 7068e84f21..26c109e7ec 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java
@@ -17,6 +17,7 @@
 
 package org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect;
 
+import 
org.apache.seatunnel.connectors.seatunnel.jdbc.config.JdbcConnectionConfig;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorErrorCode;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.exception.JdbcConnectorException;
 
@@ -37,7 +38,15 @@ public final class JdbcDialectLoader {
     private JdbcDialectLoader() {}
 
     public static JdbcDialect load(String url, String dialect, String 
compatibleMode) {
-        return load(url, compatibleMode, dialect, "");
+        return load(url, compatibleMode, dialect, "", null);
+    }
+
+    public static JdbcDialect load(
+            String url,
+            String dialect,
+            String compatibleMode,
+            JdbcConnectionConfig jdbcConnectionConfig) {
+        return load(url, compatibleMode, dialect, "", jdbcConnectionConfig);
     }
 
     /**
@@ -51,6 +60,24 @@ public final class JdbcDialectLoader {
      */
     public static JdbcDialect load(
             String url, String compatibleMode, String dialect, String 
fieldIde) {
+        return load(url, compatibleMode, dialect, fieldIde, null);
+    }
+
+    /**
+     * Loads the unique JDBC Dialect that can handle the given database url.
+     *
+     * @param url A database URL.
+     * @param compatibleMode The compatible mode.
+     * @return The loaded dialect.
+     * @throws IllegalStateException if the loader cannot find exactly one 
dialect that can
+     *     unambiguously process the given database URL.
+     */
+    public static JdbcDialect load(
+            String url,
+            String compatibleMode,
+            String dialect,
+            String fieldIde,
+            JdbcConnectionConfig jdbcConnectionConfig) {
         ClassLoader cl = Thread.currentThread().getContextClassLoader();
         List<JdbcDialectFactory> foundFactories = discoverFactories(cl);
 
@@ -97,7 +124,7 @@ public final class JdbcDialectLoader {
                                     .collect(Collectors.joining("\n"))));
         }
 
-        return matchingFactories.get(0).create(compatibleMode, fieldIde);
+        return matchingFactories.get(0).create(compatibleMode, fieldIde, 
jdbcConnectionConfig);
     }
 
     private static List<JdbcDialectFactory> discoverFactories(ClassLoader 
classLoader) {
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java
index cc49ce6327..805761bdb1 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java
@@ -25,6 +25,7 @@ import 
org.apache.seatunnel.api.table.schema.event.AlterTableAddColumnEvent;
 import org.apache.seatunnel.api.table.schema.event.AlterTableChangeColumnEvent;
 import org.apache.seatunnel.api.table.schema.event.AlterTableColumnEvent;
 import org.apache.seatunnel.api.table.schema.event.AlterTableModifyColumnEvent;
+import org.apache.seatunnel.connectors.seatunnel.jdbc.config.JdbcOptions;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.converter.JdbcRowConverter;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.DatabaseIdentifier;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect;
@@ -53,12 +54,20 @@ public class OracleDialect implements JdbcDialect {
 
     private static final int DEFAULT_ORACLE_FETCH_SIZE = 128;
     public String fieldIde = FieldIdeEnum.ORIGINAL.getValue();
+    private final boolean handleBlobAsString;
 
     public OracleDialect(String fieldIde) {
-        this.fieldIde = fieldIde;
+        this(fieldIde, JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
+    }
+
+    public OracleDialect() {
+        this(FieldIdeEnum.ORIGINAL.getValue(), 
JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
     }
 
-    public OracleDialect() {}
+    public OracleDialect(String fieldIde, boolean handleBlobAsString) {
+        this.fieldIde = fieldIde;
+        this.handleBlobAsString = handleBlobAsString;
+    }
 
     @Override
     public String dialectName() {
@@ -72,7 +81,7 @@ public class OracleDialect implements JdbcDialect {
 
     @Override
     public TypeConverter<BasicTypeDefine> getTypeConverter() {
-        return OracleTypeConverter.INSTANCE;
+        return new OracleTypeConverter(true, handleBlobAsString);
     }
 
     @Override
@@ -82,7 +91,7 @@ public class OracleDialect implements JdbcDialect {
 
     @Override
     public JdbcDialectTypeMapper getJdbcDialectTypeMapper() {
-        return new OracleTypeMapper();
+        return new OracleTypeMapper(true, handleBlobAsString);
     }
 
     @Override
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialectFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialectFactory.java
index 54958894da..e4178a20ca 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialectFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialectFactory.java
@@ -17,6 +17,7 @@
 
 package org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.oracle;
 
+import 
org.apache.seatunnel.connectors.seatunnel.jdbc.config.JdbcConnectionConfig;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.DatabaseIdentifier;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialect;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.JdbcDialectFactory;
@@ -45,6 +46,16 @@ public class OracleDialectFactory implements 
JdbcDialectFactory {
 
     @Override
     public JdbcDialect create(@Nonnull String compatibleMode, String fieldIde) 
{
-        return new OracleDialect(fieldIde);
+        return create(compatibleMode, fieldIde, null);
+    }
+
+    @Override
+    public JdbcDialect create(
+            @Nonnull String compatibleMode,
+            String fieldIde,
+            JdbcConnectionConfig jdbcConnectionConfig) {
+        boolean handleBlobAsString =
+                jdbcConnectionConfig != null && 
jdbcConnectionConfig.isHandleBlobAsString();
+        return new OracleDialect(fieldIde, handleBlobAsString);
     }
 }
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java
index 01aa92ce7e..f4a7e2b82b 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java
@@ -27,6 +27,7 @@ import org.apache.seatunnel.api.table.type.LocalTimeType;
 import org.apache.seatunnel.api.table.type.PrimitiveByteArrayType;
 import org.apache.seatunnel.common.exception.CommonError;
 import org.apache.seatunnel.connectors.seatunnel.common.source.TypeDefineUtils;
+import org.apache.seatunnel.connectors.seatunnel.jdbc.config.JdbcOptions;
 import 
org.apache.seatunnel.connectors.seatunnel.jdbc.internal.dialect.DatabaseIdentifier;
 
 import com.google.auto.service.AutoService;
@@ -87,13 +88,19 @@ public class OracleTypeConverter implements 
TypeConverter<BasicTypeDefine> {
     public static final OracleTypeConverter INSTANCE = new 
OracleTypeConverter();
 
     private final boolean decimalTypeNarrowing;
+    private final boolean handleBlobAsString;
 
     public OracleTypeConverter() {
-        this(true);
+        this(true, JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
     }
 
     public OracleTypeConverter(boolean decimalTypeNarrowing) {
+        this(decimalTypeNarrowing, 
JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
+    }
+
+    public OracleTypeConverter(boolean decimalTypeNarrowing, boolean 
handleBlobAsString) {
         this.decimalTypeNarrowing = decimalTypeNarrowing;
+        this.handleBlobAsString = handleBlobAsString;
     }
 
     @Override
@@ -112,6 +119,7 @@ public class OracleTypeConverter implements 
TypeConverter<BasicTypeDefine> {
                         .comment(typeDefine.getComment());
 
         String oracleType = typeDefine.getDataType().toUpperCase();
+
         switch (oracleType) {
             case ORACLE_INTEGER:
                 builder.dataType(new DecimalType(DEFAULT_PRECISION, 0));
@@ -202,9 +210,13 @@ public class OracleTypeConverter implements 
TypeConverter<BasicTypeDefine> {
                 builder.columnLength(BYTES_4GB - 1);
                 break;
             case ORACLE_BLOB:
-                builder.dataType(PrimitiveByteArrayType.INSTANCE);
-                // The maximum length of the column is 4GB-1
-                builder.columnLength(BYTES_4GB - 1);
+                if (handleBlobAsString) {
+                    builder.dataType(BasicType.STRING_TYPE);
+                    builder.columnLength(BYTES_4GB - 1);
+                } else {
+                    builder.dataType(PrimitiveByteArrayType.INSTANCE);
+                    builder.columnLength(BYTES_4GB - 1);
+                }
                 break;
             case ORACLE_RAW:
                 builder.dataType(PrimitiveByteArrayType.INSTANCE);
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
index ee725fb1b4..8c74e124ff 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeMapper.java
@@ -33,18 +33,27 @@ import java.util.Arrays;
 public class OracleTypeMapper implements JdbcDialectTypeMapper {
 
     private final boolean decimalTypeNarrowing;
+    private final boolean handleBlobAsString;
 
     public OracleTypeMapper() {
-        this(JdbcOptions.DECIMAL_TYPE_NARROWING.defaultValue());
+        this(
+                JdbcOptions.DECIMAL_TYPE_NARROWING.defaultValue(),
+                JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
     }
 
     public OracleTypeMapper(boolean decimalTypeNarrowing) {
+        this(decimalTypeNarrowing, 
JdbcOptions.HANDLE_BLOB_AS_STRING.defaultValue());
+    }
+
+    public OracleTypeMapper(boolean decimalTypeNarrowing, boolean 
handleBlobAsString) {
         this.decimalTypeNarrowing = decimalTypeNarrowing;
+        this.handleBlobAsString = handleBlobAsString;
     }
 
     @Override
     public Column mappingColumn(BasicTypeDefine typeDefine) {
-        return new 
OracleTypeConverter(decimalTypeNarrowing).convert(typeDefine);
+        return new OracleTypeConverter(decimalTypeNarrowing, 
handleBlobAsString)
+                .convert(typeDefine);
     }
 
     @Override
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
index 720b9d84e9..738d27783e 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
@@ -74,7 +74,8 @@ public class JdbcSourceFactory implements TableSourceFactory {
                 JdbcDialectLoader.load(
                         config.getJdbcConnectionConfig().getUrl(),
                         config.getJdbcConnectionConfig().getDialect(),
-                        config.getJdbcConnectionConfig().getCompatibleMode());
+                        config.getJdbcConnectionConfig().getCompatibleMode(),
+                        config.getJdbcConnectionConfig());
         jdbcDialect.connectionUrlParse(
                 config.getJdbcConnectionConfig().getUrl(),
                 config.getJdbcConnectionConfig().getProperties(),
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
index 782f3c62e7..856cbafbda 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
@@ -405,7 +405,7 @@ public class JdbcCatalogUtils {
                 .ifPresent(val -> 
catalogConfig.put(JdbcCatalogOptions.COMPATIBLE_MODE.key(), val));
         catalogConfig.put(
                 JdbcOptions.DECIMAL_TYPE_NARROWING.key(), 
config.isDecimalTypeNarrowing());
-        catalogConfig.put(JdbcCatalogOptions.DRIVER.key(), 
config.getDriverName());
+        catalogConfig.put(JdbcOptions.HANDLE_BLOB_AS_STRING.key(), 
config.isHandleBlobAsString());
         return ReadonlyConfig.fromMap(catalogConfig);
     }
 }
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcFieldTypeUtils.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcFieldTypeUtils.java
index ca8edb6576..8944824779 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcFieldTypeUtils.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcFieldTypeUtils.java
@@ -56,6 +56,21 @@ public final class JdbcFieldTypeUtils {
     }
 
     public static String getString(ResultSet resultSet, int columnIndex) 
throws SQLException {
+        Object obj = resultSet.getObject(columnIndex);
+        if (obj == null) {
+            return null;
+        }
+
+        // Add special handling for the BLOB data type.
+        if (obj instanceof java.sql.Blob) {
+            java.sql.Blob blob = (java.sql.Blob) obj;
+            try {
+                byte[] bytes = blob.getBytes(1, (int) blob.length());
+                return new String(bytes, 
java.nio.charset.StandardCharsets.UTF_8);
+            } finally {
+                blob.free();
+            }
+        }
         return resultSet.getString(columnIndex);
     }
 
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverterTest.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverterTest.java
index 72e6c1bde1..eddbddde89 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverterTest.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverterTest.java
@@ -540,6 +540,43 @@ public class OracleTypeConverterTest {
         Assertions.assertEquals(typeDefine.getColumnType(), 
column.getSourceType());
     }
 
+    @Test
+    public void testConvertBlobAsByte() {
+        BasicTypeDefine typeDefine =
+                BasicTypeDefine.builder()
+                        .name("test_blob")
+                        .columnType("BLOB")
+                        .dataType("BLOB")
+                        .build();
+
+        Column column = INSTANCE.convert(typeDefine);
+
+        Assertions.assertEquals("test_blob", column.getName());
+        Assertions.assertEquals(PrimitiveByteArrayType.INSTANCE, 
column.getDataType());
+        Assertions.assertEquals("BLOB", column.getSourceType());
+        Assertions.assertEquals(
+                Long.valueOf((1L << 32) - 1), ((PhysicalColumn) 
column).getColumnLength());
+    }
+
+    @Test
+    public void testConvertBlobAsString() {
+        BasicTypeDefine typeDefine =
+                BasicTypeDefine.builder()
+                        .name("test_blob")
+                        .columnType("BLOB")
+                        .dataType("BLOB")
+                        .build();
+
+        OracleTypeConverter converterWithBlobAsString = new 
OracleTypeConverter(true, true);
+        Column column = converterWithBlobAsString.convert(typeDefine);
+
+        Assertions.assertEquals("test_blob", column.getName());
+        Assertions.assertEquals(BasicType.STRING_TYPE, column.getDataType());
+        Assertions.assertEquals("BLOB", column.getSourceType());
+        Assertions.assertEquals(
+                Long.valueOf((1L << 32) - 1), ((PhysicalColumn) 
column).getColumnLength());
+    }
+
     @Test
     public void testConvertDatetime() {
         BasicTypeDefine<Object> typeDefine =
diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOracleIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOracleIT.java
index 9d1cd79376..ccfb2a523e 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOracleIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOracleIT.java
@@ -175,6 +175,13 @@ public class JdbcOracleIT extends AbstractJdbcIT {
         Assertions.assertEquals(0, execResult.getExitCode());
     }
 
+    @TestTemplate
+    public void testOracleWithBlobAsString(TestContainer container) throws 
Exception {
+        Container.ExecResult execResult =
+                
container.executeJob("/jdbc_oracle_source_to_sink_with_blob_as_string.conf");
+        Assertions.assertEquals(0, execResult.getExitCode());
+    }
+
     @Override
     JdbcCase getJdbcCase() {
         Map<String, String> containerEnv = new HashMap<>();
diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/resources/jdbc_oracle_source_to_sink_with_blob_as_string.conf
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/resources/jdbc_oracle_source_to_sink_with_blob_as_string.conf
new file mode 100644
index 0000000000..9a79d9f2ef
--- /dev/null
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/resources/jdbc_oracle_source_to_sink_with_blob_as_string.conf
@@ -0,0 +1,104 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+######
+###### This config file is a demonstration of streaming processing in 
seatunnel config
+######
+
+env {
+  parallelism = 1
+  job.mode = "BATCH"
+}
+
+source {
+  # This is a example source plugin **only for test and demonstrate the 
feature source plugin**
+  Jdbc {
+    driver = oracle.jdbc.driver.OracleDriver
+    url = "jdbc:oracle:thin:@e2e_oracleDb:1521/TESTUSER"
+    user = testUser
+    password = testPassword
+    query = "SELECT VARCHAR_10_COL,CHAR_10_COL,CLOB_COL,BLOB_COL FROM 
E2E_TABLE_SOURCE"
+    handle_blob_as_string = true
+    properties {
+       database.oracle.jdbc.timezoneAsRegion = "false"
+    }
+  }
+
+  # If you would like to get more information about how to configure seatunnel 
and see full list of source plugins,
+  # please go to 
https://seatunnel.apache.org/docs/connector-v2/source/FakeSource
+}
+
+sink {
+  Assert {
+    rules {
+      row_rules = [
+        {
+          rule_type = MAX_ROW
+          rule_value = 20000
+        },
+        {
+          rule_type = MIN_ROW
+          rule_value = 20000
+        }
+      ],
+      field_rules = [
+        {
+          field_name = BLOB_COL
+          field_type = "string"
+          field_value = [
+            {
+              rule_type = NOT_NULL
+            },
+            {
+              rule_type = MIN_LENGTH
+              rule_value = 1000
+            }
+          ]
+        },
+        {
+          field_name = VARCHAR_10_COL
+          field_type = "string"
+          field_value = [
+            {
+              rule_type = NOT_NULL
+            }
+          ]
+        },
+        {
+          field_name = CHAR_10_COL
+          field_type = "string"
+          field_value = [
+            {
+              rule_type = NOT_NULL
+            }
+          ]
+        },
+        {
+          field_name = CLOB_COL
+          field_type = "string"
+          field_value = [
+            {
+              rule_type = NOT_NULL
+            }
+          ]
+        }
+      ]
+    }
+  }
+
+  # If you would like to get more information about how to configure seatunnel 
and see full list of sink plugins,
+  # please go to https://seatunnel.apache.org/docs/connector-v2/sink/Jdbc
+} 
\ No newline at end of file

(seatunnel) branch dev updated: [Feature][Connector-JDBC] Supprot read Oracle BLOB data as string instead of bytes (#9305)

Reply via email to