flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java [28:109]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MySqlTypeUtils { // ------ MySQL Type ------ // https://dev.mysql.com/doc/refman/8.0/en/data-types.html private static final String BIT = "BIT"; /* * BOOLEAN type will be returned when handling the change event from SQL like: * ALTER TABLE `student` CHANGE COLUMN `is_male` `is_female` BOOLEAN NULL; */ private static final String BOOLEAN = "BOOLEAN"; private static final String BOOL = "BOOL"; private static final String TINYINT = "TINYINT"; private static final String TINYINT_UNSIGNED = "TINYINT UNSIGNED"; private static final String TINYINT_UNSIGNED_ZEROFILL = "TINYINT UNSIGNED ZEROFILL"; private static final String SMALLINT = "SMALLINT"; private static final String SMALLINT_UNSIGNED = "SMALLINT UNSIGNED"; private static final String SMALLINT_UNSIGNED_ZEROFILL = "SMALLINT UNSIGNED ZEROFILL"; private static final String MEDIUMINT = "MEDIUMINT"; private static final String MEDIUMINT_UNSIGNED = "MEDIUMINT UNSIGNED"; private static final String MEDIUMINT_UNSIGNED_ZEROFILL = "MEDIUMINT UNSIGNED ZEROFILL"; private static final String INT = "INT"; private static final String INT_UNSIGNED = "INT UNSIGNED"; private static final String INT_UNSIGNED_ZEROFILL = "INT UNSIGNED ZEROFILL"; private static final String INTEGER = "INTEGER"; private static final String INTEGER_UNSIGNED = "INTEGER UNSIGNED"; private static final String INTEGER_UNSIGNED_ZEROFILL = "INTEGER UNSIGNED ZEROFILL"; private static final String BIGINT = "BIGINT"; private static final String SERIAL = "SERIAL"; private static final String BIGINT_UNSIGNED = "BIGINT UNSIGNED"; private static final String BIGINT_UNSIGNED_ZEROFILL = "BIGINT UNSIGNED ZEROFILL"; private static final String REAL = "REAL"; private static final String REAL_UNSIGNED = "REAL UNSIGNED"; private static final String REAL_UNSIGNED_ZEROFILL = "REAL UNSIGNED ZEROFILL"; private static final String FLOAT = "FLOAT"; private static final String FLOAT_UNSIGNED = "FLOAT UNSIGNED"; private static final String FLOAT_UNSIGNED_ZEROFILL = "FLOAT UNSIGNED ZEROFILL"; private static final String DOUBLE = "DOUBLE"; private static final String DOUBLE_UNSIGNED = "DOUBLE UNSIGNED"; private static final String DOUBLE_UNSIGNED_ZEROFILL = "DOUBLE UNSIGNED ZEROFILL"; private static final String DOUBLE_PRECISION = "DOUBLE PRECISION"; private static final String DOUBLE_PRECISION_UNSIGNED = "DOUBLE PRECISION UNSIGNED"; private static final String DOUBLE_PRECISION_UNSIGNED_ZEROFILL = "DOUBLE PRECISION UNSIGNED ZEROFILL"; private static final String NUMERIC = "NUMERIC"; private static final String NUMERIC_UNSIGNED = "NUMERIC UNSIGNED"; private static final String NUMERIC_UNSIGNED_ZEROFILL = "NUMERIC UNSIGNED ZEROFILL"; private static final String FIXED = "FIXED"; private static final String FIXED_UNSIGNED = "FIXED UNSIGNED"; private static final String FIXED_UNSIGNED_ZEROFILL = "FIXED UNSIGNED ZEROFILL"; private static final String DECIMAL = "DECIMAL"; private static final String DECIMAL_UNSIGNED = "DECIMAL UNSIGNED"; private static final String DECIMAL_UNSIGNED_ZEROFILL = "DECIMAL UNSIGNED ZEROFILL"; private static final String CHAR = "CHAR"; private static final String VARCHAR = "VARCHAR"; private static final String TINYTEXT = "TINYTEXT"; private static final String MEDIUMTEXT = "MEDIUMTEXT"; private static final String TEXT = "TEXT"; private static final String LONGTEXT = "LONGTEXT"; private static final String DATE = "DATE"; private static final String TIME = "TIME"; private static final String DATETIME = "DATETIME"; private static final String TIMESTAMP = "TIMESTAMP"; private static final String YEAR = "YEAR"; private static final String BINARY = "BINARY"; private static final String VARBINARY = "VARBINARY"; private static final String TINYBLOB = "TINYBLOB"; private static final String MEDIUMBLOB = "MEDIUMBLOB"; private static final String BLOB = "BLOB"; private static final String LONGBLOB = "LONGBLOB"; private static final String JSON = "JSON"; private static final String SET = "SET"; private static final String ENUM = "ENUM"; private static final String GEOMETRY = "GEOMETRY"; private static final String POINT = "POINT"; private static final String LINESTRING = "LINESTRING"; private static final String POLYGON = "POLYGON"; private static final String GEOMCOLLECTION = "GEOMCOLLECTION"; private static final String GEOMETRYCOLLECTION = "GEOMETRYCOLLECTION"; private static final String MULTIPOINT = "MULTIPOINT"; private static final String MULTIPOLYGON = "MULTIPOLYGON"; private static final String MULTILINESTRING = "MULTILINESTRING"; private static final String UNKNOWN = "UNKNOWN"; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlTypeUtils.java [26:107]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public class MySqlTypeUtils { // ------ MySQL Type ------ // https://dev.mysql.com/doc/refman/8.0/en/data-types.html private static final String BIT = "BIT"; /* * BOOLEAN type will be returned when handling the change event from SQL like: * ALTER TABLE `student` CHANGE COLUMN `is_male` `is_female` BOOLEAN NULL; */ private static final String BOOLEAN = "BOOLEAN"; private static final String BOOL = "BOOL"; private static final String TINYINT = "TINYINT"; private static final String TINYINT_UNSIGNED = "TINYINT UNSIGNED"; private static final String TINYINT_UNSIGNED_ZEROFILL = "TINYINT UNSIGNED ZEROFILL"; private static final String SMALLINT = "SMALLINT"; private static final String SMALLINT_UNSIGNED = "SMALLINT UNSIGNED"; private static final String SMALLINT_UNSIGNED_ZEROFILL = "SMALLINT UNSIGNED ZEROFILL"; private static final String MEDIUMINT = "MEDIUMINT"; private static final String MEDIUMINT_UNSIGNED = "MEDIUMINT UNSIGNED"; private static final String MEDIUMINT_UNSIGNED_ZEROFILL = "MEDIUMINT UNSIGNED ZEROFILL"; private static final String INT = "INT"; private static final String INT_UNSIGNED = "INT UNSIGNED"; private static final String INT_UNSIGNED_ZEROFILL = "INT UNSIGNED ZEROFILL"; private static final String INTEGER = "INTEGER"; private static final String INTEGER_UNSIGNED = "INTEGER UNSIGNED"; private static final String INTEGER_UNSIGNED_ZEROFILL = "INTEGER UNSIGNED ZEROFILL"; private static final String BIGINT = "BIGINT"; private static final String SERIAL = "SERIAL"; private static final String BIGINT_UNSIGNED = "BIGINT UNSIGNED"; private static final String BIGINT_UNSIGNED_ZEROFILL = "BIGINT UNSIGNED ZEROFILL"; private static final String REAL = "REAL"; private static final String REAL_UNSIGNED = "REAL UNSIGNED"; private static final String REAL_UNSIGNED_ZEROFILL = "REAL UNSIGNED ZEROFILL"; private static final String FLOAT = "FLOAT"; private static final String FLOAT_UNSIGNED = "FLOAT UNSIGNED"; private static final String FLOAT_UNSIGNED_ZEROFILL = "FLOAT UNSIGNED ZEROFILL"; private static final String DOUBLE = "DOUBLE"; private static final String DOUBLE_UNSIGNED = "DOUBLE UNSIGNED"; private static final String DOUBLE_UNSIGNED_ZEROFILL = "DOUBLE UNSIGNED ZEROFILL"; private static final String DOUBLE_PRECISION = "DOUBLE PRECISION"; private static final String DOUBLE_PRECISION_UNSIGNED = "DOUBLE PRECISION UNSIGNED"; private static final String DOUBLE_PRECISION_UNSIGNED_ZEROFILL = "DOUBLE PRECISION UNSIGNED ZEROFILL"; private static final String NUMERIC = "NUMERIC"; private static final String NUMERIC_UNSIGNED = "NUMERIC UNSIGNED"; private static final String NUMERIC_UNSIGNED_ZEROFILL = "NUMERIC UNSIGNED ZEROFILL"; private static final String FIXED = "FIXED"; private static final String FIXED_UNSIGNED = "FIXED UNSIGNED"; private static final String FIXED_UNSIGNED_ZEROFILL = "FIXED UNSIGNED ZEROFILL"; private static final String DECIMAL = "DECIMAL"; private static final String DECIMAL_UNSIGNED = "DECIMAL UNSIGNED"; private static final String DECIMAL_UNSIGNED_ZEROFILL = "DECIMAL UNSIGNED ZEROFILL"; private static final String CHAR = "CHAR"; private static final String VARCHAR = "VARCHAR"; private static final String TINYTEXT = "TINYTEXT"; private static final String MEDIUMTEXT = "MEDIUMTEXT"; private static final String TEXT = "TEXT"; private static final String LONGTEXT = "LONGTEXT"; private static final String DATE = "DATE"; private static final String TIME = "TIME"; private static final String DATETIME = "DATETIME"; private static final String TIMESTAMP = "TIMESTAMP"; private static final String YEAR = "YEAR"; private static final String BINARY = "BINARY"; private static final String VARBINARY = "VARBINARY"; private static final String TINYBLOB = "TINYBLOB"; private static final String MEDIUMBLOB = "MEDIUMBLOB"; private static final String BLOB = "BLOB"; private static final String LONGBLOB = "LONGBLOB"; private static final String JSON = "JSON"; private static final String SET = "SET"; private static final String ENUM = "ENUM"; private static final String GEOMETRY = "GEOMETRY"; private static final String POINT = "POINT"; private static final String LINESTRING = "LINESTRING"; private static final String POLYGON = "POLYGON"; private static final String GEOMCOLLECTION = "GEOMCOLLECTION"; private static final String GEOMETRYCOLLECTION = "GEOMETRYCOLLECTION"; private static final String MULTIPOINT = "MULTIPOINT"; private static final String MULTIPOLYGON = "MULTIPOLYGON"; private static final String MULTILINESTRING = "MULTILINESTRING"; private static final String UNKNOWN = "UNKNOWN"; - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -