KSQL：无效的连接条件：当连接超过 2 个表时，不支持将外键表-表连接作为 n 路的一部分

Question

我有 3 个主题，其中包含 KAFKA_INT 关键

客户、订单、订单详细信息

当我仅连接 2 个表时

select * from orders o join customer c on o.custid = c.custid emit changes; -- OK 

select od.id, od.orderid from orderdetails od join orders o on od.orderid = o.orderid emit changes; -- OK


-- NOT OK
 
select * from orderdetails od
join order o on od.orderid = o.orderid
join customer c on o.custid = c.custid
emit changes limit 5; 

-- Error
Invalid join condition: foreign-key table-table joins are not supported as part of n-way joins. Got o.custid = c.custid.

但是，我找不到任何文档如何连接多个表以及它的限制是什么。

我正在使用 Confluence KAFKA HELM 版本 7.0

Answer 1

正如错误消息所述，ksqldb 不支持表到表多重联接（n 路联接）。为了进行该连接，您可能需要创建一个中间支持表。像这样：

CREATE TABLE orderdetails_join_order AS 
SELECT *
FROM orderdetails od
JOIN order o ON od.orderid = o.orderId;

现在您可以使用此表来执行查询：

SELECT * FROM orderdetails_join_order odjo
JOIN customer c ON odjo.custid = c.custid