Flink SQL JDBC Development Suggestions
Mapping Between Flink SQL and JDBC Data Types
Develop a Flink SQL job based on the mapping information in Table 1.
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) |
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.See the reply and handling status in My Cloud VOC.
For any further questions, feel free to contact us through the chatbot.
Chatbot