flink sql join demo

这里提供一个Flink SQL中JOIN操作的示例代码，演示如何使用Flink SQL进行JOIN操作。

假设有两个表，分别为Orders和Users，表结构如下：

Orders表：

| order_id | user_id | order_total |
|----------|---------|-------------|
| 1 | 100 | 20 |
| 2 | 101 | 30 |
| 3 | 102 | 40 |

Users表：

| user_id | user_name |
|---------|-----------|
| 100 | Alice |
| 101 | Bob |
| 103 | Carol |

现在需要将这两个表进行JOIN操作，输出结果为订单的详细信息和用户的姓名，如果用户表中没有对应的用户信息，则输出NULL值。具体的Flink SQL代码如下：

-- 定义Orders表
CREATE TABLE Orders (
    order_id INT,
    user_id INT,
    order_total INT,
    PRIMARY KEY (order_id) NOT ENFORCED
) WITH (
    'connector.type' = 'filesystem',
    'format.type' = 'csv',
    'connector.path' = 'file:///path/to/orders.csv',
    'csv.field.delimiter' = ','
);

-- 定义Users表
CREATE TABLE Users (
    user_id INT,
    user_name STRING,
    PRIMARY KEY (user_id) NOT ENFORCED
) WITH (
    'connector.type' = 'filesystem',
    'format.type' = 'csv',
    'connector.path' = 'file:///path/to/users.csv',
    'csv.field.delimiter' = ','
);

-- 执行JOIN操作
SELECT o.order_id, o.order_total, u.user_name
FROM Orders o
LEFT JOIN Users u ON o.user_id = u.user_id;

上述代码中，首先定义了Orders表和Users表的表结构和数据源，然后执行了左连接（LEFT JOIN）操作，将Orders表和Users表按照user_id进行JOIN操作，输出订单的详细信息和对应用户的姓名。如果用户表中没有对应的用户信息，则输出NULL值。