kalencaya edited a comment 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` (
`bigint_type` bigint unsigned DEFAULT 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) DEFAULT NULL
) ENGINE=InnoDB COMMENT='测试表';
CREATE TABLE `test_test` (
`bigint_type` bigint unsigned DEFAULT 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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
