Flink CDC 里 内置函数，可以将 '1,2,3' 转换成 [1,2,3]吗？

Apache Flink SQL内建的函数并不能直接将逗号分隔的字符串 '1,2,3' 转换为数组 [1,2,3]，不过可以通过一系列函数组合实现这个转换。下面是一个示例步骤，展示如何使用现有函数拼接实现这一转换：

-- 假设原始字段名为 `str_field`，内容为 '1,2,3'

-- 使用 SPLIT 函数将字符串按逗号分割为字符串数组
SELECT 
  SPLIT(str_field, ',') AS str_array
FROM 
  your_table;

-- 结果将是 ['1', '2', '3']


-- 接下来需要将字符串数组转换为整数数组，但这一步Flink SQL内置函数暂不支持直接转换
-- 但如果是在Java API层面，你可以编写自定义函数或者UDF来实现这样的转换
-- 例如，如果是在Java Table API中，可以使用map或flatMap等函数配合StringTokenizer等工具类进行转换

若要在纯SQL环境中完成转换，可能需要使用用户自定义函数（UDF）来实现。例如，创建一个接受字符串作为输入并返回INT数组的UDF。而在许多数据库系统中，这种转换通常需要多步操作，每一项都需要单独转换为整数然后再组装成数组。Flink暂时没有直接提供这种内置函数来简化这一过程。

对于某些场景，如果你可以接受将每个数字作为一个单独的字段（而不是数组形式），则可以结合UNNEST函数：

WITH exploded AS (
  SELECT 
    CAST(SPLIT(str_field, ',') AS ARRAY<STRING>) AS str_array
  FROM 
    your_table
)

SELECT 
  EXPLODE(str_array) AS number
FROM 
  exploded;

这将会得到每行一个数字的结果，而非数组。但对于真正的数组类型转换，需要自定义逻辑。