CREATE-CATALOG

Name

CREATE CATALOG

Description

该语句用于创建外部数据目录（catalog）

语法：

CREATE CATALOG [IF NOT EXISTS] catalog_name
    [PROPERTIES ("key"="value", ...)];

PROPERTIES 为 catalog 的连接信息。其中 "type" 属性必须指定，目前支持：

hms：Hive MetaStore
es：Elasticsearch
jdbc: 通过 JDBC 标准接口访问的数据库，目前仅支持 MySQL

Example

新建 MySQL Catalog

CREATE CATALOG jdbc PROPERTIES (
    "type"="jdbc",
    "user"="root",
    "password"="123456",
    "jdbc_url" = "jdbc:mysql://127.0.0.1:3316/doris_test?useSSL=false",
    "driver_url" = "mysql-connector-java-8.0.25.jar",
    "driver_class" = "com.mysql.cj.jdbc.Driver"
);

SelectDB 默认包含了 mysql-connector-java-8.0.25.jar、postgresql-42.5.0.jar、mssql-jdbc-11.2.0.jre8.jar、ojdbc6.jar 这 4 个常用的 driver 包，用户可以直接使用。如需使用其他 driver 包，请联系技术支持人员。

新建 Hive Catalog

CREATE CATALOG hive PROPERTIES (
     "type"="hms",
     'hive.metastore.uris' = 'thrift://172.21.0.1:7004',
     'dfs.nameservices'='service1',
     'dfs.ha.namenodes. service1'='nn1,nn2',
     'dfs.namenode.rpc-address.HDFS8000871.nn1'='172.21.0.2:4007',
     'dfs.namenode.rpc-address.HDFS8000871.nn2'='172.21.0.3:4007',
     'dfs.client.failover.proxy.provider.HDFS8000871'='org.apache.hadoop.hdfs.server.namenode.ha.ConfiguredFailoverProxyProvider'
 );

新建 Elasticsearch Catalog

CREATE CATALOG test_es PROPERTIES (
     "type"="es",
     "hosts"="http://127.0.0.1:9200",
     "user"="test_user",
     "password"="test_passwd",
     "nodes_discovery"="false"
);

注意：公有云ES服务通常采用负载均衡服务作为ES请求入口，无法直接访问集群节点，这里nodes_discovery需设置为false。

Keywords

CREATE, CATALOG

Best Practice

CANCEL-ALTER-TABLE CREATE-DATABASE