Flink Sql Client初探

参考博客：https://www.cnblogs.com/bolingcavalry/p/13993021.html#4800352

1、首先进入flink目录，启动flink：bin/start-cluster.sh
2、其次启动Flink SQL Client：bin/sql-client.sh embedded -l sql_lib

DROP TABLE IF  EXISTS  `user`;

CREATE TABLE `user` (
    id INT, 
    name STRING,
    create_time TIMESTAMP(3)
) WITH (
    ‘connector.type‘ = ‘jdbc‘,
    ‘connector.url‘ = ‘jdbc:mysql://localhost:3306/test‘,
    ‘connector.table‘ = ‘user‘,
    ‘connector.driver‘ = ‘com.mysql.jdbc.Driver‘,
    ‘connector.username‘ = ‘root‘,
    ‘connector.password‘ = ‘root‘,
    ‘connector.lookup.cache.max-rows‘ = ‘5000‘,
    ‘connector.lookup.cache.ttl‘ = ‘10min‘
);

CREATE TABLE user_info (
    id INT,
    username STRING,
    password STRING
) WITH (
    ‘connector.type‘ = ‘jdbc‘,
    ‘connector.url‘ = ‘jdbc:mysql://localhost:3306/test‘,
    ‘connector.table‘ = ‘user_info‘,
    ‘connector.driver‘ = ‘com.mysql.jdbc.Driver‘,
    ‘connector.username‘ = ‘root‘,
    ‘connector.password‘ = ‘root‘,
    ‘connector.lookup.cache.max-rows‘ = ‘5000‘,
    ‘connector.lookup.cache.ttl‘ = ‘10min‘
);

select u.id,u.name,u.create_time,ui.id,ui.username,ui.password  
from `user` as u 
left join user_info as ui 
on u.id = ui.id;