seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-jdbc-flink-e2e/src/test/resources/jdbc/jdbc_mysql_source_and_sink_datatype.conf

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

env {
  execution.parallelism = 1
  job.mode = "BATCH"
}

source{
    jdbc{
        url = "jdbc:mysql://mysql:3306/test"
        driver = "com.mysql.cj.jdbc.Driver"
        user = "root"
        password = "test"
        query = "select * from type_source_table"
    }
}

transform {
}

sink {
    jdbc {
        url = "jdbc:mysql://mysql:3306/test"
        driver = "com.mysql.cj.jdbc.Driver"
        user = "root"
        password = "test"
        query = """ INSERT INTO `type_sink_table` (
                 	`binary`,
                 	`blob`,
                 	`long_varbinary`,
                 	`longblob`,
                 	`tinyblob`,
                 	`varbinary`,
                 	`tinyint`,
                 	`tinyint_unsigned`,
                 	`smallint`,
                 	`smallint_unsigned`,
                 	`mediumint`,
                 	`mediumint_unsigned`,
                 	`int`,
                 	`int_unsigned`,
                 	`integer`,
                 	`integer_unsigned`,
                 	`bigint`,
                 	`bigint_unsigned`,
                 	`numeric`,
                 	`decimal`,
                 	`float`,
                 	`double`,
                 	`double_precision`,
                 	`longtext`,
                 	`mediumtext`,
                 	`text`,
                 	`tinytext`,
                 	`varchar`,
                 	`json`,
                 	`date`,
                 	`datetime`,
                 	`time`,
                 	`year`,
                 	`timestamp`
                 )
                 VALUES
                 	(
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 		?,
                 	    ?
                 	)"""
    }
}