全部產品
Search
文件中心

Data Lake Analytics - Deprecated:CREATE SCHEMA

更新時間:Jul 06, 2024

文法結構

CREATE SCHEMA [IF NOT EXISTS] db_name 
with dbproperties (
  CATALOG = <catalog>,
  LOCATION = <endpoint>
)
參數名稱參數說明
CATALOGDATABASE的類型,目前支援如下類型:
  • hive
  • mysql
  • sqlserver
  • postgresql
  • oracle
  • ots
  • ads (ADB2.0)
  • adb3 (ADB3.0)
  • adbpg
  • mongodb
  • redis
  • elasticsearch
  • druid
  • kudu
  • odps
LOCATION串連資訊。LOCATION格式會根據Schema的類型發生變化。

不同資料來源的文法樣本

建立hive資料庫

CREATE DATABASE oss_log_schema with DBPROPERTIES(
  catalog='hive',
  location = 'oss://analyticdb-bucket/log/'
);

建立MySQL資料庫

CREATE SCHEMA mysql_db WITH DBPROPERTIES (
  CATALOG = 'mysql', 
  LOCATION = 'jdbc:mysql://rm-2zer0vg58mfofake.mysql.rds.aliyuncs.com:3306/dla_test',
  USER = 'dla_test',
  PASSWORD = 'the-fake-password',
  VPC_ID = 'vpc-2zeij924vxd303kwifake',
  INSTANCE_ID = 'rm-2zer0vg58mfo5fake'
);
參數名稱參數說明
VPC_IDRDS所在的VPC的ID。
INSTANCE_IDRDS的執行個體ID。

建立SQL Server資料庫

CREATE SCHEMA `sqlserver_db` WITH DBPROPERTIES 
( 
  CATALOG = 'sqlserver', 
  LOCATION = 'jdbc:sqlserver://rm-bp15g1r5jf90hfake.sqlserver.rds.aliyuncs.com:3433;DatabaseName=dla_test',
  USER='dla_test1',
  PASSWORD='this-is-not-a-real-password',
  INSTANCE_ID = 'rm-bp15g1r5jf90fake',
  VPC_ID = 'vpc-bp1adypqlcn535yrdfake'
);
說明 LOCATION要指定資料庫的名字,您可以通過 DatabaseName=dla_test的方式來指定。這是由SQL Server JDBC URL定義的,不是由DLA定義的。

建立PostgreSQL資料庫

CREATE SCHEMA `postgresql_db` WITH DBPROPERTIES 
( 
  CATALOG = 'postgresql', 
  LOCATION = 'jdbc:postgresql://rm-bp1oo49r6j3hvfake.pg.rds.aliyuncs.com:3433/dla_test',
  USER='dla_test',
  PASSWORD='this-is-not-a-real-password',
  INSTANCE_ID = 'rm-bp1oo49r6j3hfake',
  VPC_ID = 'vpc-bp1adypqlcn535yrfake'
);

建立Oracle資料庫

CREATE DATABASE `oracle_db`
WITH DBPROPERTIES (
    catalog = 'oracle',
    location = 'jdbc:oracle:thin:@//127.0.0.01:1521/XE',
    instance = 'HR',
    user = 'hello',
    password = 'world'
)

建立OTS資料庫

create database ots_db with dbproperties (
  catalog = 'ots',
  location = 'https://hz-tpch-1x-vol.cn-hangzhou.vpc.tablestore.aliyuncs.com',
  instance = 'hz-tpch-1x-vol'
);
參數名稱參數說明
locationots的endpoint。
instance指定instance名。由於endpoint可以不帶執行個體名,最終映射到DLA的schema。

建立ADB2.0資料庫

CREATE DATABASE `ads2_db`
WITH DBPROPERTIES (
    catalog = 'ads',
    location = 'jdbc:mysql://adb-xxx-vpc.cn-beijing-f.ads.aliyuncs.com:10001/xxx',
    instance = 'adb_tongguan_test_52265',
    user = 'user001',
    password = 'pass001'
)
參數名稱參數說明
locationADB2.0伺服器的網域名稱和連接埠。
instanceADB2.0的執行個體。
userADB2.0的使用者名稱。
passwordADB2.0的密碼。

建立ADB3.0資料庫

CREATE DATABASE `adb3_db`
WITH DBPROPERTIES (
    catalog = 'adb3',
    location = 'jdbc:mysql://am-bp15huqy8t1118x4590650.ads.aliyuncs.com/adb3_it_db',
    user = 'dla_test',
    password = 'openanalytics@2018',
    vpc_id = 'vpc-bp1ll9szezdnbrob9auhs',
    instance_id = 'am-bp15huqy8t1118x45'
);
參數名稱參數說明
locationADB3.0伺服器的網域名稱和連接埠。
userADB3.0的使用者名稱。
passwordADB3.0的密碼。
vpc_idADB3.0所在的VPC的ID。
instance_idADB3.0的執行個體ID。

建立ADBPG資料庫

 CREATE SCHEMA  dla_adbpg_test_db 
 WITH DBPROPERTIES (
     CATALOG = 'adbpg',
     LOCATION = 'jdbc:postgresql://gp-bp13******.gpdb.rds.aliyuncs.com:3432/db-name',
     USER = 'user-name',
     PASSWORD = 'password',
     INSTANCE_ID = 'gp-bp*******',
     VPC_ID = 'vpc-bp********'
 );
參數名稱參數說明
locationadbpg伺服器的網域名稱和連接埠。
useradbpg的使用者名稱。
passwordadbpg的密碼。
instance_idadbpg的執行個體ID。
vpc_idadbpg所在的VPC的ID。

建立MongoDB資料庫

CREATE DATABASE `mongo_test`
WITH DBPROPERTIES (
    catalog = 'mongodb',
    location = 'mongodb://<your-user-name>:<your-password>@dds-bp1694axxxxxxxx.mongodb.rds.aliyuncs.com:3717,dds-bp1694ayyyyyyyy.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=zzzzz',
    database = 'mongo_test',
    vpc_id = 'vpc-aaaaaaa',
    instance_id = 'dds-bbbbbbb'
);
參數名稱參數說明
locationMongoDB的ConnectionString,裡麵包含了你的使用者名稱、密碼、要串連的MongoDB的地址、使用的認證資料庫等等。
databaseMongoDB的底層庫。
vpc_idMongoDB所在的VPC的ID。
instance_idMongoDB的執行個體ID。

建立Redis資料庫

CREATE DATABASE `redis_db`
WITH DBPROPERTIES (
    catalog = 'redis',
    location = 'r-xxxxx.redis.rds.aliyuncs.com:6379/hello_',
    password = 'xxxxx',
    vpc_id = 'vpc-xxxxx',
    instance_id = 'r-xxxxxx'
)
參數名稱參數說明
locationredis伺服器的網域名稱和連接埠。
passwordredis的密碼。
vpc_idredis所在的VPC的ID。
instance_idredis的執行個體ID。