[GitHub] [incubator-seatunnel] kalencaya removed a comment on issue #1428: [Bug] [flink-jdbc-connector] various jdbc type of dialect compatibility between JdbcSource and JdbcSink

[GitBox <gi...@apache.org>]

kalencaya removed a comment on issue #1428:
URL: https://github.com/apache/incubator-seatunnel/issues/1428#issuecomment-1061351013


   > flink_jdbc_source_sink.conf
   > 
   > ```
   > env {
   >   execution.parallelism = 1
   > }
   > 
   > source {
   >   JdbcSource {
   >     driver = com.mysql.cj.jdbc.Driver
   >     url = "jdbc:mysql://localhost:3306/data_service"
   >     username = root
   >     password = 123
   >     query = "select * from test"
   >     result_table_name = jdbc
   >   }
   > }
   > 
   > transform {
   > }
   > 
   > sink {
   >   JdbcSink {
   >     driver = com.mysql.cj.jdbc.Driver
   >     url = "jdbc:mysql://localhost:3306/data_service"
   >     username = root
   >     password = 123
   >     query = "insert into test_test(bigint_type,int_type,integer_type,mediumint_type,smallint_type,tinyint_type,bigint_type_2,int_type_2,integer_type_2,mediumint_type_2,smallint_type_2,tinyint_type_2,decimal_type,dec_type,float_type,double_type,time_type,date_type,datetime_type,timestamp_type,varchar_type,char_type) values (?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?,?,?,?, ?,?)"
   >     source_table_name = jdbc
   >   }
   > }
   > ```
   > 
   > mysql ddl:
   > 
   > ```
   > CREATE TABLE `test` (
   >   `int_type` int unsigned DEFAULT NULL,
   >   `integer_type` int unsigned DEFAULT NULL,
   >   `mediumint_type` mediumint unsigned DEFAULT NULL,
   >   `smallint_type` smallint unsigned DEFAULT NULL,
   >   `tinyint_type` tinyint unsigned DEFAULT NULL,
   >   `bigint_type_2` bigint DEFAULT NULL,
   >   `int_type_2` int DEFAULT NULL,
   >   `integer_type_2` int DEFAULT NULL,
   >   `mediumint_type_2` mediumint DEFAULT NULL,
   >   `smallint_type_2` smallint DEFAULT NULL,
   >   `tinyint_type_2` tinyint DEFAULT NULL,
   >   `decimal_type` decimal(20,2) DEFAULT NULL,
   >   `dec_type` decimal(20,2) DEFAULT NULL,
   >   `float_type` float DEFAULT NULL,
   >   `double_type` double DEFAULT NULL,
   >   `time_type` time DEFAULT NULL,
   >   `date_type` date DEFAULT NULL,
   >   `datetime_type` datetime DEFAULT NULL,
   >   `timestamp_type` timestamp NULL DEFAULT NULL,
   >   `varchar_type` varchar(32) DEFAULT NULL,
   >   `char_type` char(1) DEFAULT NULL
   > ) ENGINE=InnoDB COMMENT='测试表';
   > 
   > CREATE TABLE `test_test` (
   >   `bigint_type` bigint unsigned NOT NULL,
   >   `int_type` int unsigned DEFAULT NULL,
   >   `integer_type` int unsigned DEFAULT NULL,
   >   `mediumint_type` mediumint unsigned DEFAULT NULL,
   >   `smallint_type` smallint unsigned DEFAULT NULL,
   >   `tinyint_type` tinyint unsigned DEFAULT NULL,
   >   `bigint_type_2` bigint DEFAULT NULL,
   >   `int_type_2` int DEFAULT NULL,
   >   `integer_type_2` int DEFAULT NULL,
   >   `mediumint_type_2` mediumint DEFAULT NULL,
   >   `smallint_type_2` smallint DEFAULT NULL,
   >   `tinyint_type_2` tinyint DEFAULT NULL,
   >   `decimal_type` decimal(20,2) DEFAULT NULL,
   >   `dec_type` decimal(20,2) DEFAULT NULL,
   >   `float_type` float DEFAULT NULL,
   >   `double_type` double DEFAULT NULL,
   >   `time_type` time DEFAULT NULL,
   >   `date_type` date DEFAULT NULL,
   >   `datetime_type` datetime DEFAULT NULL,
   >   `timestamp_type` timestamp NULL DEFAULT NULL,
   >   `varchar_type` varchar(32) DEFAULT NULL,
   >   `char_type` char(1) CHARACTER DEFAULT NULL
   > ) ENGINE=InnoDB COMMENT='测试表';
   > ```
   
   Because JdbcSource is not a streaming source, but JdbcSink is a streaming sink, this config is invalid for now dev branch and I just pull my request for JdbcSink supporting batch sink waiting for review.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org