EricJoy2048 commented on code in PR #4639:
URL: 
https://github.com/apache/incubator-seatunnel/pull/4639#discussion_r1177709745


##########
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/ddl/mysql_cdc.sql:
##########
@@ -0,0 +1,52 @@
+--
+-- 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.
+--
+
+-- 
----------------------------------------------------------------------------------------------------------------
+-- DATABASE:  inventory
+-- 
----------------------------------------------------------------------------------------------------------------
+CREATE DATABASE IF NOT EXISTS `mysql_cdc`;
+
+use mysql_cdc;
+-- Create a mysql data source table
+CREATE TABLE mysql_cdc.products_cdc (

Review Comment:
   create table if not exists test1000004
   (
       id                   int auto_increment primary key,
       f_binary             binary(64)          null,
       f_blob               blob                null,
       f_long_varbinary     mediumblob          null,
       f_longblob           longblob            null,
       f_tinyblob           tinyblob            null,
       f_varbinary          varbinary(100)      null,
       f_smallint           smallint            null,
       f_smallint_unsigned  smallint unsigned   null,
       f_mediumint          mediumint           null,
       f_mediumint_unsigned mediumint unsigned  null,
       f_int                int                 null,
       f_int_unsigned       int unsigned        null,
       f_integer            int                 null,
       f_integer_unsigned   int unsigned        null,
       f_bigint             bigint              null,
       f_bigint_unsigned    bigint unsigned     null,
       f_numeric            decimal             null,
       f_decimal            decimal             null,
       f_float              float               null,
       f_double             double              null,
       f_double_precision   double              null,
       f_longtext           longtext            null,
       f_mediumtext         mediumtext          null,
       f_text               text                null,
       f_tinytext           tinytext            null,
       f_varchar            varchar(100)        null,
       f_date               date                null,
       f_datetime           datetime            null,
       f_timestamp          timestamp           null,
       f_bit1 BIT(1) NULL,
       f_bit64 BIT(64) NULL,
       f_char CHAR NULL,
       f_enum ENUM('enum1', 'enum2', 'enum3') NULL,
       f_mediumblob MEDIUMBLOB NULL,
       f_long_varchar LONG VARCHAR NULL,
       f_real REAL NULL,
       f_time TIME NULL,
       f_tinyint TINYINT NULL,
       f_tinyint_unsigned TINYINT UNSIGNED NULL,
       f_json json NULL,
       f_year  year null,
       f_set set('set1', 'set2', 'set3') null
   );



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

Reply via email to