Flutter/Dart中使用PostgreSQL的IN操作符查询List<String>的方法

我看你在尝试用逗号分隔的custID字符串过滤PostgreSQL数据时遇到了问题，这其实是因为字符串拆分后的元素处理和IN子查询的用法没到位，我来给你一步步梳理解决方案：

问题根源 #

你的custID是带空格的逗号分隔字符串（比如ABC123, LP8338），直接用string_to_array(@cust_id,',')拆分后，每个元素会保留空格（比如第二个元素是 LP8338），导致和数据库里的cust_id不匹配；另外string_to_array返回的是数组类型，直接用IN (select cust_id from ...)的子查询写法也不对，因为string_to_array返回的数组不能直接当成表来查，需要用unnest把数组转成行。

解决方案1：用unnest+trim处理数组元素 #

修改你的SQL查询，先拆分字符串成数组，再用unnest展开成单行记录，同时用trim去掉每个元素的空格：

List<dynamic> detailedPositions = [];
Future<List<dynamic>> fetchDetailedPositions(String custID) async {
  try {
    print(custID);               //output: ABC123, LP8338
    print(custID.runtimeType);   //output: string 
    await connection!.open();
    await connection!.transaction((fetchDataConn) async {
      _fetchMasterPositionData = await fetchDataConn.query(
        """
        select cust_id, array_agg((cust_id, cust_name, quantity, item_nme, average_price)) 
        from orders
        where cust_id in (
          select trim(unnest(string_to_array(@cust_id, ',')))
        ) and status='OPEN'
        """,
        substitutionValues: {'cust_id': custID},
        timeoutInSeconds: 30,
      );
    });
    // 这里记得把查询结果赋值给detailedPositions
    detailedPositions = _fetchMasterPositionData.toList();
  } catch (exc) {
    print('Exception in fetchDetailedPositions');
    print(exc.toString());
    detailedPositions = [];
  } finally {
    // 建议最后关闭连接，避免资源泄漏
    await connection?.close();
  }
  return detailedPositions;
}

解决方案2：用= ANY操作符更简洁 #

PostgreSQL里可以直接用= ANY操作符匹配数组，这样不需要子查询，写法更简单：

List<dynamic> detailedPositions = [];
Future<List<dynamic>> fetchDetailedPositions(String custID) async {
  try {
    print(custID);               //output: ABC123, LP8338
    print(custID.runtimeType);   //output: string 
    await connection!.open();
    await connection!.transaction((fetchDataConn) async {
      _fetchMasterPositionData = await fetchDataConn.query(
        """
        select cust_id, array_agg((cust_id, cust_name, quantity, item_nme, average_price)) 
        from orders
        where cust_id = ANY(string_to_array(trim(regexp_replace(@cust_id, '\s+', ' ', 'g')), ',')) 
          and status='OPEN'
        """,
        substitutionValues: {'cust_id': custID},
        timeoutInSeconds: 30,
      );
    });
    detailedPositions = _fetchMasterPositionData.toList();
  } catch (exc) {
    print('Exception in fetchDetailedPositions');
    print(exc.toString());
    detailedPositions = [];
  } finally {
    await connection?.close();
  }
  return detailedPositions;
}

这里用regexp_replace先把多个空格换成单个，再用trim去掉首尾空格，确保拆分后的每个cust_id都没有多余空格。

额外注意点 #

• 你的代码里substitutionValues里的status变量没看到定义，我直接在SQL里写了status='OPEN'，如果是动态变量的话记得补全。
• 记得在finally块里关闭数据库连接，避免资源泄漏。
• array_agg返回的是复合类型数组，后续处理的时候要注意解析格式，如果需要更清晰的结构，可以考虑用json_agg转成JSON格式。

内容的提问来源于stack exchange，提问作者anilraj