全部产品
云市场

CREATE SCHEMA

更新时间:2020-06-15 11:16:09

语法

  1. CREATE SCHEMA [IF NOT EXISTS] db_name
  2. with dbproperties (
  3. CATALOG = <catalog>,
  4. LOCATION = <endpoint>
  5. )
  • CATALOG:DATABASE的类型,目前支持如下类型:
    • hive
    • mysql
    • sqlserver
    • postgresql
    • oracle
    • ots
    • ads (ADB2.0)
    • adb3 (ADB3.0)
    • adbpg
    • mongodb
    • redis
    • elasticsearch
    • druid
  • LOCATION:连接信息。Schema的类型不同,LOCATION格式稍有不同。

示例

以下示例创建一个OSS Schema,location指定OSS文件的存储位置,需要以/结尾,表示目录。

创建OSS数据库

  1. CREATE DATABASE oss_log_schema with DBPROPERTIES(
  2. catalog='oss',
  3. location = 'oss://analyticdb-bucket/log/'
  4. );

创建MySQL/SQLServer/Postgresql/Oracle数据库

MySQL:

  1. CREATE SCHEMA mysql_db WITH DBPROPERTIES (
  2. CATALOG = 'mysql',
  3. LOCATION = 'jdbc:mysql://rm-2zer0vg58mfofake.mysql.rds.aliyuncs.com:3306/dla_test',
  4. USER = 'dla_test',
  5. PASSWORD = 'the-fake-password',
  6. VPC_ID = 'vpc-2zeij924vxd303kwifake',
  7. INSTANCE_ID = 'rm-2zer0vg58mfo5fake'
  8. );
  • vpc_id: RDS所在的VPC的ID。
  • instance_id: RDS的实例ID。

SQLServer:

  1. CREATE SCHEMA `sqlserver_db` WITH DBPROPERTIES
  2. (
  3. CATALOG = 'sqlserver',
  4. LOCATION = 'jdbc:sqlserver://rm-bp15g1r5jf90hfake.sqlserver.rds.aliyuncs.com:3433;DatabaseName=dla_test',
  5. USER='dla_test1',
  6. PASSWORD='this-is-not-a-real-password',
  7. INSTANCE_ID = 'rm-bp15g1r5jf90fake',
  8. VPC_ID = 'vpc-bp1adypqlcn535yrdfake'
  9. );
  • LOCATION要指定数据库的名字,指定的方式跟 MySQL 不一样, 是通过 DatabaseName=dla_test 的方式来指定。这是 SQLServer JDBC URL 定义的,不是DLA定义的。

PostgreSQL:

和MySQL类似

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

Oracle:

  1. CREATE DATABASE `oracle_db`
  2. WITH DBPROPERTIES (
  3. catalog = 'oracle',
  4. location = 'jdbc:oracle:thin:@//127.0.0.01:1521/XE',
  5. instance = 'HR',
  6. user = 'hello',
  7. password = 'world'
  8. )

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。

创建OTS数据库

  1. create database ots_db with dbproperties (
  2. catalog = 'ots',
  3. location = 'https://hz-tpch-1x-vol.cn-hangzhou.vpc.tablestore.aliyuncs.com',
  4. instance = 'hz-tpch-1x-vol'
  5. );
  • location: ots的endpoint
  • instance: 指定instance名,因为endpoint可以不带实例名;最终映射到DLA的schema

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。

创建ADB2.0数据库

  1. CREATE DATABASE `ads2_db`
  2. WITH DBPROPERTIES (
  3. catalog = 'ads',
  4. location = 'jdbc:mysql://adb-xxx-vpc.cn-beijing-f.ads.aliyuncs.com:10001/xxx',
  5. instance = 'adb_tongguan_test_52265',
  6. user = 'user001',
  7. password = 'pass001'
  8. )
  • location: ADB2.0服务器的域名和端口。
  • user: ADB2.0的用户名。
  • password: ADB2.0的密码。
  • instance: ADB2.0的实例。

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。

创建ADB3.0数据库

  1. CREATE DATABASE `adb3_db`
  2. WITH DBPROPERTIES (
  3. catalog = 'adb3',
  4. location = 'jdbc:mysql://am-bp15huqy8t1118x4590650.ads.aliyuncs.com/adb3_it_db',
  5. user = 'dla_test',
  6. password = 'openanalytics@2018',
  7. vpc_id = 'vpc-bp1ll9szezdnbrob9auhs',
  8. instance_id = 'am-bp15huqy8t1118x45'
  9. );
  • location: ADB3.0服务器的域名和端口。
  • user: ADB3.0的用户名。
  • password: ADB3.0的密码。
  • vpc_id: ADB3.0所在的VPC的ID。
  • instance_id: ADB3.0的实例ID。

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。

创建ADBPG数据库

  1. CREATE SCHEMA dla_adbpg_test_db
  2. WITH DBPROPERTIES (
  3. CATALOG = 'adbpg',
  4. LOCATION = 'jdbc:postgresql://gp-bp13******.gpdb.rds.aliyuncs.com:3432/db-name',
  5. USER = 'user-name',
  6. PASSWORD = 'password',
  7. INSTANCE_ID = 'gp-bp*******',
  8. VPC_ID = 'vpc-bp********'
  9. );
  • location: adbpg服务器的域名和端口。
  • user: adbpg的用户名。
  • password: adbpg的密码。
  • vpc_id: adbpg所在的VPC的ID。
  • instance_id: adbpg的实例ID。ss

创建MongoDB数据库

  1. CREATE DATABASE `mongo_test`
  2. WITH DBPROPERTIES (
  3. catalog = 'mongodb',
  4. location = 'mongodb://<your-user-name>:<your-password>@dds-bp1694axxxxxxxx.mongodb.rds.aliyuncs.com:3717,dds-bp1694ayyyyyyyy.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=zzzzz',
  5. database = 'mongo_test',
  6. vpc_id = 'vpc-aaaaaaa',
  7. instance_id = 'dds-bbbbbbb'
  8. );
  • location: MongoDB的 ConnectionString, 里面包含了你的用户名、密码、要连接的MongoDB的地址、使用的认证数据库等等。
  • database: MongoDB底层的库。
  • vpc_id: MongoDB所在的VPC的ID。
  • instance_id: MongoDB的实例ID。

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。

创建Redis数据库

  1. CREATE DATABASE `redis_db`
  2. WITH DBPROPERTIES (
  3. catalog = 'redis',
  4. location = 'r-xxxxx.redis.rds.aliyuncs.com:6379/hello_',
  5. password = 'xxxxx',
  6. vpc_id = 'vpc-xxxxx',
  7. instance_id = 'r-xxxxxx'
  8. )
  • location: redis服务器的域名和端口。
  • password: redis的密码。
  • vpc_id: redis所在的VPC的ID。
  • instance_id: redis的实例ID。

这里展示的只是语法,各种数据库需要做一些类似配置白名单之类的辅助的事情,详情请参考相关的文章。