AnalyticDB:外部テーブルの作成

前提条件

• AnalyticDB for MySQL Data Lakehouse Editionクラスターが作成されます。

• AnalyticDB for MySQLクラスターのマイナーバージョンは3.1.8.0以降です。

  説明

  AnalyticDB for MySQLのマイナーバージョンを照会するには Data Lakehouse Editionクラスターで、SELECT adb_version(); 文を実行します。 クラスターのマイナーバージョンを更新するには、テクニカルサポートにお問い合わせください。

• 外部データベースが作成されます。 詳細については、「外部データベースの作成」をご参照ください。

使用上の注意

Alibaba Cloudアカウント全体で外部テーブルを作成することはできません。

OSS外部テーブル

構文

CREATE EXTERNAL TABLE [IF NOT EXISTS] table_name
(column_name column_type[, ...])
[PARTITIONED BY (column_name column_type[, ...])]
ROW FORMAT DELIMITED FIELDS TERMINATED BY ','
STORED AS {TEXTFILE|ORC|PARQUET|JSON|RCFIL|HUDI}
LOCATION 'OSS_LOCATION';
[TBLPROPERTIES (
 'type' = 'cow|mor'
 'auto.create.location' = 'true|false')]

パラメーター

例

例1: パーティション分割されていない外部テーブルの作成

• ファイルストレージ形式をTEXTFILEに設定して、パーティション分割されていない外部テーブルを作成します。

  存在しない場合は

  CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.osstest1
  (id int,
  name string,
  age int,
  city string)
  ROW FORMAT DELIMITED FIELDS TERMINATED BY  ','
  STORED AS TEXTFILE
  LOCATION  'oss://testBucketName/osstest/p1=hangzhou/p2=2023-06-13/data.csv';

• ファイルストレージ形式をHUDIに設定して、パーティション分割されていない外部テーブルを作成します。

  存在しない場合は

  CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.osstest2
  (id int,
  name string,
  age int,
  city string)
  STORED AS HUDI
  LOCATION  'oss://testBucketName/osstest/test'
  TBLPROPERTIES ('type' = 'cow');

  重要

  Hudi外部テーブルを作成すると、_hoodie_commit_time、_hoodie_commit_seqno、_hoodie_record_key、_hoodie_partition_path、および _hoodie_file_name列が自動的に作成されます。

• ファイルストレージ形式をPARQUETに設定して、パーティション分割されていない外部テーブルを作成します。

  存在しない場合は

  CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.osstest3
  (
  A STRUCT < var1:string, var2:int >
  ) 
  STORED AS PARQUET 
  LOCATION 'oss://testBucketName/osstest/Parquet';

例2: パーティション化外部テーブルの作成

存在しない場合は

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.osstest4
(id int,
name string,
age int,
city string)
PARTITIONED BY (p2 string)
ROW FORMAT DELIMITED FIELDS TERMINATED BY  ','
STORED AS TEXTFILE
LOCATION  'oss://testBucketName/osstest/p1=hangzhou/';

例3: マルチレベルパーティション外部テーブルの作成

存在しない場合は

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.osstest5
(id int,
name string,
age int,
city string)
PARTITIONED BY (p1 string,p2 string)
ROW FORMAT DELIMITED FIELDS TERMINATED BY  ','
STORED AS TEXTFILE
LOCATION  'oss://testBucketName/osstest/';

ApsaraDB RDS for MySQL外部テーブル

構文

CREATE EXTERNAL TABLE [IF NOT EXISTS] table_name
(column_name column_type[, ...])
ENGINE='MYSQL'
TABLE_PROPERTIES='{  
	"url":"mysql_vpc_address",  
	"tablename":"mysql_table_name",  
	"username":"mysql_user_name",  
	"password":"mysql_user_password"
	[,"charset":"{gbk|utf8|utf8mb4}"]
  }';

パラメーター

例

adb_external_demo.mysqltestが存在しない場合は

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.mysqltest (
	id int,
	name varchar(1023),
	age int
 ) ENGINE = 'MYSQL'
 TABLE_PROPERTIES = '{
   "url":"jdbc:mysql://rm-bp1gx6h1tyd04****.mysql.rds.aliyuncs.com:3306/test_adb",
   "tablename":"person",
   "username":"testUserName",
   "password":"testUserPassword",
   "charset":"utf8"
}';

ApsaraDB for MongoDB外部テーブル

構文

CREATE EXTERNAL TABLE [IF NOT EXISTS] table_name
(column_name column_type[, ...])
ENGINE='MONGODB'
TABLE_PROPERTIES = '{
	"mapped_name":"table",
  "location":"location",
  "username":"user",
  "password":"password",
}';

Parameters

例

CREATE EXTERNAL TABLE adb_external_demo.person (
  id int,
  name string,
  age int
) ENGINE = 'MONGODB' TABLE_PROPERTIES ='{
"mapped_name":"person",
"location":"mongodb://testuser:****@dds-bp113d414bca8****.mongodb.rds.aliyuncs.com:3717,dds-bp113d414bca8****.mongodb.rds.aliyuncs.com:3717/test_mongodb",
"username":"testuser",
"password":"password",
}';

Tablestore外部テーブル

構文

CREATE EXTERNAL TABLE [IF NOT EXISTS] table_name
(column_name column_type[, ...])
ENGINE='OTS'
TABLE_PROPERTIES = '{
	"mapped_name":"table_name",
	"location":"tablestore_vpc_address"
}';

パラメーター

例

adb_external_demo.otstestが存在しない場合は

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.otstest (
	id int,
	name string,
	age int
) ENGINE = 'OTS' 
TABLE_PROPERTIES = '{
	"mapped_name":"person",
	"location":"https://w0****la.cn-hangzhou.vpc.tablestore.aliyuncs.com"
}';

MaxCompute外部テーブル

構文

CREATE EXTERNAL TABLE [IF NOT EXISTS] table_name
(column_name column_type[, ...])
ENGINE='ODPS'
TABLE_PROPERTIES='{
	"endpoint":"endpoint",
	"accessid":"accesskey_id",
	"accesskey":"accesskey_secret",
	["partition_column":"partition_column"],
	"project_name":"project_name",
	"table_name":"table_name"
}'; 

パラメーター

例

adb_external_demo.mctestが存在しない場合は

CREATE EXTERNAL TABLE IF NOT EXISTS adb_external_demo.mctest (
	id int,
	name varchar(1023),
	age int,
	dt string
) ENGINE='ODPS'
TABLE_PROPERTIES='{
	"accessid":"LTAILd4****",
	"endpoint":"http://service.cn-hangzhou.maxcompute.aliyun.com/api",
	"accesskey":"4A5Q7ZVzcYnWMQPysX****",
	"partition_column":"dt",
	"project_name":"test_adb",
	"table_name":"person"
}';

関連ドキュメント

• OSS外部テーブル: 外部テーブルを使用してdata Lakehouse Editionにデータをインポート

• ApsaraDB RDS for MySQL外部テーブル: 外部テーブルを使用してdata Lakehouse Editionにデータをインポート

• ApsaraDB for MongoDB外部テーブル: ApsaraDB for MongoDBからのデータのインポート

• Tablestore外部テーブル: Tablestoreからデータをインポート

• MaxCompute外部テーブル: 外部テーブルを使用してdata Lakehouse Editionにデータをインポート