大家好，我是土哥。

今天分享几个 Flink1.17 最新版本中常见的一些 SQL 函数的使用方式。

1 时间函数

1. CURRENT_TIME() 返回当前时间（时分秒）

2. CURRENT_DATE() 返回当前日期（年月日）

3. LOCALTIME() 返回当前时区的当前时间（时分秒）

4. LOCALTIMESTAMP() 返回当前时区的当前时间戳（年月日时分秒）

SELECT CURRENT_TIME(), CURRENT_DATE(), LOCALTIME(), LOCALTIMESTAMP()

执行以上 SQL 语句会返回当前时间和日期的值，例如：

2 数值函数

1. ABS(n) 返回 n 的绝对值

2. CEIL(n) 返回不小于 n 的最小整数

3. FLOOR(n) 返回不大于 n 的最大整数

4. LOG(n[,base]) 返回 n 的对数，可指定底数

5. POWER(n,exponent) 返回 n 的 exponent 次幂

6. ROUND(n[,d]) 返回四舍五入到 d 位小数的 n

7. SIGN(n) 返回 n 的符号（1、0 或 -1）

SELECT ABS(-10), CEIL(3.14), FLOOR(3.14), LOG(100, 10), 
POWER(2, 3), ROUND(3.14159, 2), SIGN(-10)

执行以上 SQL 语句会返回数值函数的计算结果，例如：

3 字符串函数

1. CONCAT(s1,s2,...) 将多个字符串连接为一个字符串

2. LENGTH(s) 返回字符串 s 的长度

3. LOWER(s) 将字符串 s 转换为小写

4. UPPER(s) 将字符串 s 转换为大写

5. TRIM([BOTH | LEADING | TRAILING] trimStr FROM s) 去除字符串 s 开头、结尾或两端的 trimStr 字符串

SELECT CONCAT('Hello', ' ', 'world'), LENGTH('Hello'), LOWER('Hello'), 
UPPER('Hello'), TRIM('x' FROM 'xxxHelloxxx')

执行以上 SQL 语句会返回字符串函数的计算结果，如下所示：

4 数组函数

1. ARRAY[length](v1, v2, ..., vn) 创建一个长度为 length 的数组，元素为 v1, v2, …, vn

2. ARRAY[1, v2, ..., vn] 创建一个包含元素 1, v2, …, vn 的数组

3. CARDINALITY(a) 返回数组 a 的长度

4. ELEMENT(a, n) 返回数组 a 的第 n 个元素

5. ARRAY_CONTAINS(a, v) 判断数组 a 是否包含元素 v

SELECT ARRAY[1, 2, 3], ARRAY[1, 2] || ARRAY[3], 
CARDINALITY(ARRAY[1, 2, 3]), ELEMENT(ARRAY[1, 2, 3], 2), 
ARRAY_CONTAINS(ARRAY[1, 2, 3], 2)

执行以上 SQL 语句会返回数组函数的计算结果，例如：

以上就是关于 Flink 1.17 版本中一些常用的函数。

-END--

现在已经 4 月中旬阶段，如果你因为找工作而烦恼，不会制作简历，不会备战复习，不会面试技巧，不会 HR 面，不会谈薪，不用怕，有土哥。

土哥社招参加 28 场面试，100% 通过率，拿到全部 offer！

土哥这半年的悲惨人生，经历过被鸽 offer,最终触底反弹~

可以找土哥修改简历，1 对 1 辅导项目、面试技巧，HR 面以及谈薪等，同时发你总结的最新面经试题（有偿哈），具体价格私信土哥。

毕竟免费的东西，不仅你不会上心，土哥也没有多大精力认真去修改和辅导。

如果有任何意愿，可以加土哥微信，备注：简历修改+面试辅导，当然，想进群的，也可以扫码，备注：加群~