You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by GitBox <gi...@apache.org> on 2022/03/08 02:46:25 UTC

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

kalencaya commented on issue #1428:
URL: https://github.com/apache/incubator-seatunnel/issues/1428#issuecomment-1061349912


   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='测试表';
   ```


-- 
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