Flink应用开发系列（四十九）Table SQL开发之create catalog

在flink中catalog就是多数据源目录的意思，整个数据库的结构是：${catalog}.${database}.${table}。除了table，其他的都是默认的default。在flink中一般在数据湖领域的话会使用到catalog。

在flink table sql中创建catalog的语法是：

CREATE CATALOG catalog_name  
WITH (
key1=val1, 
key2=val2,
...
)

一般情况下这里的with的话和前面创建表的with是一样的。with里面主要带有的就是底层连接器的信息，例如我们创建一个基于mysql的catalog，示例sql如下：

CREATE CATALOG test WITH(
    'type' = 'jdbc',
    'default-database' = 'flinktest',
    'username' = 'root',
    'password' = '123456',
    'base-url' = 'jdbc:mysql://192.168.31.218:3306'
);

补充部分：

1、查看所有的catalog的sql是：

show catalogs;

2、使用某个catalog

use test;