大佬们，我刚接触flink，请教个问题，flinksql不支持这样写吗，数据库函数？ 在数据库是可以执行的，但是在flink校验sql的 时候报错了？
以下为热心网友提供的参考意见
您好！Flink SQL 支持大部分标准 SQL 功能，并且可以与许多开源数据库系统（如 MySQL 和 PostgreSQL）进行交互。然而，在某些情况下，可能会遇到无法直接翻译成查询计划的问题，特别是在处理复杂表达式或特定功能方面。
您的示例中包含 GROUP_CONCAT() 函数，这是一个用于将多个字符串连接在一起并返回一个单一字符串的功能。虽然 Flink 不原生提供此函数，但可以通过 UDF 或外部表来模拟类似行为。这里是一个简单的例子说明如何通过 UDF 实现 GROUP_CONCAT:
CREATE TEMPORARY TABLE my_group_concat AS (
SELECT
goods_id,
ARRAY(
STRING[MCS_TYPE_CODE]
FROM (SELECT DISTINCT CONTRAST_COLUMN FROM compare_table)
) as contrast_columns,
ARRAY[
CASE WHEN COLUMN_NAME IN ('PRODUCT_ID', 'GOODS_ID') THEN 'PRODUCT_ID' ELSE '' END,
CASE WHEN COLUMN_NAME IN ('REGCARD_ID', 'HI_MCS_TYPENAME') THEN CONCAT('','REGCARD_ID') ELSE '' END,
CASE WHEN COLUMN_NAME IN ('LV1_TYPE_NAME', 'LV2_TYPE_NAME') THEN CONCAT('','LV1_TYPE_NAME') ELSE '' END,
COLUMN_VALUE separator ','
] as update_content,
dict_id
FROM (
select distinct goods_id GOODS_ID from slink table ( upload_id , contrast_column )
));
INSERT INTO my_group_concat SELECT UPLOAD_ID, GROUP_CONCAT(column_name separator ','), UPDATE_RECORD, -1 CONTRAST_USER, now() CONTRAST_DATE, GOODS_ID, MY_SEQUENCE_VALUE, GROUP_CONCAT(column_value separator ',') as UPDATE_CONTENT, DICT_ID;
转转请注明出处：https://www.yunxiaoer.com/180462.html