PolarDB多主分表集群执行IN子查询报错，如何调整适配？

问题原因 #

两张表dt1、dt2均按b字段哈希分表，原SQL中的IN子查询select b from dt2 group by b会先在所有分片执行分组并汇总结果，再用这些结果关联dt1，这种跨分片的协调查询触发了集群不支持的分布式事务场景，因此抛出ERROR 8820 (HY000): Don't support distributed transaction错误。

调整方案 #

方案1：改用JOIN替代IN子查询 #

利用两张表同分片键（b）的特性，使用JOIN让关联逻辑在各分片本地执行，避免跨分片事务协调：

-- 方式1：通过JOIN+DISTINCT实现等价逻辑
SELECT DISTINCT dt1.* 
FROM dt1 
JOIN dt2 ON dt1.b = dt2.b;

-- 方式2：先对dt2的b去重再JOIN，逻辑更贴近原SQL
SELECT dt1.* 
FROM dt1 
JOIN (SELECT DISTINCT b FROM dt2) t ON dt1.b = t.b;

方案2：客户端分两次执行SQL #

先拉取dt2分组后的b值到客户端，再将具体值作为IN参数传入查询dt1：

1. 执行获取b列表：

SELECT b FROM dt2 GROUP BY b;

2. 将返回的b值拼接为IN参数，执行查询：

SELECT * FROM dt1 WHERE b IN (1, 2, 3, ...); -- 替换为实际获取的b值

这种方式让第二次查询能根据每个b值直接路由到对应分片，无需跨分片事务协调。

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