SQL 类型 | 说明 | 示例 |
SHOW 语句 | 查询元数据信息 | SHOW CATALOGS;、SHOW DATABASES;、SHOW TABLES; |
DESCRIBE 语句 | 查看表结构 | DESCRIBE table_name; |
SELECT 查询 | 数据查询 | SELECT * FROM source_table; |
CREATE 语句 | 创建临时表/视图 | CREATE TEMPORARY TABLE ... WITH (...); |
INSERT 语句 | 数据写入(提交 Flink 作业) | INSERT INTO sink_table SELECT ... FROM source_table; |
SET 语句 | 设置执行参数 | SET 'execution.runtime-mode' = 'streaming'; |
EXPLAIN 语句 | 查看执行计划 | EXPLAIN SELECT ...; |
USE 语句 | 切换 Catalog/Database | USE CATALOG my_catalog; |
-- 查看当前 Catalog 和 DatabaseSHOW CURRENT CATALOG;SHOW CURRENT DATABASE;-- 查看所有 CatalogSHOW CATALOGS;-- 简单查询SELECT 1;SELECT CURRENT_TIMESTAMP AS ts, UUID() AS u;SELECT CAST('2026-01-01' AS DATE) AS d;-- 多列查询SELECT 1 AS id, 'hello' AS name, 3.14 AS pi;
-- 创建临时表(数据生成器)CREATE TEMPORARY TABLE datagen_source (id INT,name STRING) WITH ('connector' = 'datagen','rows-per-second' = '1','number-of-rows' = '10');-- 查询临时表SELECT * FROM datagen_source;-- 聚合查询SELECT COUNT(*) AS cnt, AVG(id) AS avg_id FROM datagen_source;
-- 切换到 Paimon CatalogUSE CATALOG my_paimon_catalog;-- 查看数据库和表SHOW DATABASES;USE my_database;SHOW TABLES;-- 查询 Paimon 表SELECT * FROM my_table LIMIT 100;SELECT COUNT(*) FROM my_table;
-- VALUES 构造数据查询SELECT * FROM (VALUES (1, 'a'), (2, 'b'), (3, 'c')) AS t(id, name);-- WHERE 过滤SELECT x, x*x AS sq FROM (VALUES (1),(2),(3),(4),(5)) AS t(x) WHERE x > 2;-- GROUP BY 聚合SELECT grp, COUNT(*) AS cnt, SUM(val) AS totalFROM (VALUES ('a',1), ('a',2), ('b',10), ('b',20)) AS t(grp, val)GROUP BY grp;
-- 查看当前配置SET;-- 查看指定配置SET 'parallelism.default';-- 切换执行模式SET 'execution.runtime-mode' = 'streaming';SET 'execution.runtime-mode' = 'batch';-- 设置时区SET 'table.local-time-zone' = 'Asia/Shanghai';
文档反馈