在 Flink SQL 中，数据类型与 SQL Server 的数据类型有所不同。以下是一些常见的 SQL Server 字段类型与对应的 java.sql 类型以及在 Flink SQL 中推荐的映

陈吉俊

522人浏览 · 2024-04-03 17:41:27

陈吉俊 · 2024-04-03 17:41:27 发布

在 Flink SQL 中，数据类型与 SQL Server 的数据类型有所不同。以下是一些常见的 SQL Server 字段类型与对应的 java.sql 类型以及在 Flink SQL 中推荐的映射：

SQL Server 字段类型	`java.sql` 类型	Flink SQL 类型
`BIT`	`BOOLEAN`	`BOOLEAN`
`TINYINT`	`TINYINT`	`INT`
`SMALLINT`	`SMALLINT`	`SMALLINT`
`INT`	`INTEGER`	`INT`
`BIGINT`	`BIGINT`	`BIGINT`
`DECIMAL`	`DECIMAL`	`DECIMAL`
`NUMERIC`	`DECIMAL`	`DECIMAL`
`FLOAT`	`DOUBLE`	`DOUBLE`
`REAL`	`FLOAT`	`FLOAT`
`DATE`	`DATE`	`DATE`
`DATETIME`	`TIMESTAMP`	`TIMESTAMP(3)`
`DATETIME2`	`TIMESTAMP`	`TIMESTAMP(3)`
`SMALLDATETIME`	`TIMESTAMP`	`TIMESTAMP(3)`
`TIME`	`TIME`	`TIME(0)`
`CHAR`	`CHAR`	`STRING`
`VARCHAR`	`VARCHAR`	`STRING`
`NCHAR`	`NCHAR`	`STRING`
`NVARCHAR`	`NVARCHAR`	`STRING`
`TEXT`	`LONGVARCHAR`	`STRING`
`NTEXT`	`LONGVARCHAR`	`STRING`
`BINARY`	`BINARY`	`BYTES`
`VARBINARY`	`VARBINARY`	`BYTES`
`IMAGE`	`BLOB`	`BYTES`
`UNIQUEIDENTIFIER`	`VARCHAR`	`STRING`
`XML`	`SQLXML`	`STRING`

请注意，Flink SQL 中的 STRING 类型用于表示变长字符串，它可以容纳任何形式的文本数据，包括字符和二进制数据。BYTES 类型用于表示二进制数据。

对于 DECIMAL 和 NUMERIC 类型，Flink SQL 支持指定精度和标度，例如 DECIMAL(precision, scale)。在 java.sql 中，这些类型通常被表示为 DECIMAL 类型。

对于时间类型，Flink SQL 默认情况下使用 TIMESTAMP(3) 来表示时间戳数据，其中数字 3 表示毫秒级的时间戳。如果需要其他精度，可以相应地调整 Flink SQL 类型后面的数字。

在实际应用中，当使用 Flink JDBC 连接器连接 SQL Server 数据库时，通常不需要手动进行类型映射，因为连接器会自动处理这些转换。但是，了解这些映射关系有助于在需要自定义转换或处理特殊情况时进行调试和优化。

魔乐社区

魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。

更多推荐

小参数・大码力・易部署 | Qwen3.6-27B上线魔乐社区，基于昇腾的部署教程来了

继一周前模型开源发布后，千问再度开源Qwen3.6-27B —— 一个拥有270亿参数的稠密多模态模型，也是社区呼声最高的模型规格。Qwen3.6-27B 依然支持多模态思考与非思考模式，在智能体编程方面达到了旗舰级表现，全面超越前代开源旗舰 Qwen3.5-397B-A17B（总参数397B / 激活参数17B的MoE模型）。作为稠密架构，它无需MoE路由即可部署，是开发者在实用、可广泛部署规模