前面我们介绍过在flink中,整个table sql的结构是:${catalog}.${database}.${table}。这里的database其实就是数据库,和我们日常理解的数据库是一个意思。
在flink table sql里面创建database的语法是:
CREATE DATABASE [IF NOT EXISTS] [catalog_name.]db_name [COMMENT database_comment] WITH (key1=val1, key2=val2, ... )
一般情况下,除了在多数据源目录的需求下,我们可能创建的database会带有with,在其他普通情况下,这里一般是不需要with的,直接和普通sql一样创建数据库即可,例如:
create database test1;
补充说明:
1、查看所有的database
show databases;
2、使用某个databases;
use test1;
还没有评论,来说两句吧...