526互联

一些SQL小技巧，不定期更新...

发布时间 2023-09-21 13:02:54作者: 李好秀

要将查询结果作为IN语句的查询条件，查询结果作为子查询，并在主查询中使用IN子句。

SELECT table_ids
    FROM cdc_table_sync
    WHERE sync_id = 'FLINK_CDC_SYNC_TABLE_198';

结果为：c2a9f78ecc3f6a6c97c12956d25e1adc,24d883d4a419578d09dd3801f001b93e,f3e569a5c68023c76b5bb22e25768739,df9e3fe91219ce1d042ee84a0b4b58ea,465d014da17e858fd16bca733141126a,6572ff4511b9164bffb1bfbc480d364e
这样的字符串

SELECT *
FROM your_table
WHERE column_name IN (
  SELECT split_part(result, ',', generate_series(1, array_length(string_to_array(result, ','), 1))) AS element
  FROM (
    SELECT string_agg(quote_literal(table_ids) || ',', '') AS result
    FROM cdc_table_sync
    WHERE sync_id = 'FLINK_CDC_SYNC_TABLE_198'
  ) subquery
);

your_table替换表名，column_name`替换为进行IN匹配的列名。

这里将首先使用之前提供的查询语句，将查询结果以逗号分隔并加上单引号。然后，使用string_to_array函数将结果拆分为一个数组。接下来，通过generate_series函数生成一个序列，用来获取数组中的每个元素。最后，使用split_part函数将每个元素分别作为子查询的结果，并在主查询中使用IN子句。

当主查询执行时，它将比对指定列的值与子查询的结果，如果匹配则返回相应的行。