Apache Flink 漫谈系列(10) - JOIN LATERAL

一、聊什么

上一篇《Apache Flink 漫谈系列 - JOIN算子》我们对最常见的JOIN做了细致的说明，本篇先容一个非凡的JOIN，那就是JOIN LATERAL。JOIN LATERAL为什么非凡呢，直观说由于JOIN的右边不是一个现实的物理表，而是一个VIEW可能Table-valued Funciton。本篇会先先容传统数据库对LATERAL JOIN的支持，然后先容Apache Flink今朝对LATERAL JOIN的支持环境。

二、现实题目

假设我们有两张表，一张是Customers表(斲丧者id, 地址都市), 一张是Orders表(订单id,斲丧者id)，两张表的DDL(SQL Server)如下：

• Customers

CREATE TABLE Customers ( 
customerid char(5) NOT NULL, 
city varchar (10) NOT NULL 
) 
 
insert into Customers values('C001','Beijing'); 
insert into Customers values('C002','Beijing'); 
insert into Customers values('C003','Beijing'); 
insert into Customers values('C004','HangZhou'); 

查察数据：

• Orders

CREATE TABLE Orders( 
orderid char(5) NOT NULL, 
customerid char(5) NULL 
) 
 
insert into Orders values('O001','C001'); 
insert into Orders values('O002','C001'); 
insert into Orders values('O003','C003'); 
insert into Orders values('O004','C001'); 

查察数据：

1. 题目示例

假设我们想查询全部Customers的客户ID，所在和订单信息,我们想获得的信息是：

(1) 用INNER JOIN办理

假如各人查阅了《Apache Flink 漫谈系列 - JOIN算子》，我想看到这样的查询需求会想到INNER JOIN来办理，SQL如下：

SELECT 
c.customerid, c.city, o.orderid 
FROM Customers c JOIN Orders o 
    ON o.customerid = c.customerid 

查询功效如下：

但假如我们真的用上面的方法来办理，就不会有本篇要先容的内容了，以是我们换一种写法。

2. 用 Correlated subquery办理

Correlated subquery 是在subquery中行使关联表的字段，subquery可以在FROM Clause中也可以在WHERE Clause中。

• WHERE Clause

用WHERE Clause实现上面的查询需求，SQL如下：

SELECT 
c.customerid, c.city 
FROM Customers c WHERE c.customerid IN ( 
SELECT 
o.customerid, o.orderid 
FROM Orders o 
WHERE o.customerid = c.customerid 
) 

执行环境：

上面的题目是用在WHERE Clause内里subquery的查询列必需和必要较量的列对应，不然我们无法对o.orderid举办投影, 上面查询我为什么要加一个o.orderid呢，由于查询需求是必要o.orderid的，去掉o.orderid查询能乐成，可是拿到的功效并不是我们想要的，如下：

SELECT 
c.customerid, c.city 
FROM Customers c WHERE c.customerid IN ( 
SELECT 
o.customerid 
FROM Orders o 
WHERE o.customerid = c.customerid 
) 

查询功效：

可见上面查询功效穷乏了o.orderid,不能满意我们的查询需求。

• FROM Clause

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!