FlinkSQL JDBC表开发建议
Flink SQL与JDBC数据类型对应关系
参考表1开发Flink SQL作业。
| Flink SQL数据类型 | MySQL数据类型 | Oracle数据类型 | PostgreSQL数据类型 | SQL Server数据类型 |
|---|---|---|---|---|
| BOOLEAN | BOOLEAN TINYINT(1) | - | BOOLEAN | BIT |
| TINYINT | TINYINT | - | - | TINYINT |
| SMALLINT | SMALLINT TINYINT UNSIGNED | - | SMALLINT INT2 SMALLSERIAL SERIAL2 | SMALLINT |
| INT | INT MEDIUMINT SMALLINT UNSIGNED | - | INTEGER SERIAL | INT |
| BIGINT | BIGINT INT UNSIGNED | - | BIGINT BIGSERIAL | BIGINT |
| FLOAT | FLOAT | BINARY_FLOAT | REAL FLOAT4 | REAL |
| DOUBLE | DOUBLE DOUBLE PRECISION | BINARY_DOUBLE | FLOAT8 DOUBLE PRECISION | FLOAT |
| STRING | CHAR(n) VARCHAR(n) TEXT | CHAR(n) VARCHAR(n) CLOB | CHAR(n) CHARACTER(n) VARCHAR(n) CHARACTER VARYING(n) TEXT | CHAR(n) NCHAR(n) VARCHAR(n) NVARCHAR(n) TEXT NTEXT |
| BYTES | BINARY VARBINARY BLOB | RAW(s) BLOB | BYTEA | BINARY(n) VARBINARY(n) |
| ARRAY | - | - | ARRAY | - |
| DATE | DATE | DATE | DATE | DATE |
| TIME [(p)] [WITHOUT TIMEZONE] | TIME [(p)] | DATE | TIME [(p)] [WITHOUT TIMEZONE] | TIME(0) |
| TIMESTAMP [(p)] [WITHOUT TIMEZONE] | DATETIME [(p)] | TIMESTAMP [(p)] [WITHOUT TIMEZONE] | TIMESTAMP [(p)] [WITHOUT TIMEZONE] | DATETIME DATETIME2 |
| DECIMAL(20, 0) | BIGINT UNSIGNED | - | - | - |
| DECIMAL(p, s) | NUMERIC(p, s) DECIMAL(p, s) | SMALLINT FLOAT(s) DOUBLE PRECISION REAL NUMBER(p, s) | NUMERIC(p, s) DECIMAL(p, s) | DECIMAL(p, s) |
