AnalyticDB for MySQL:外部テーブルの作成

前提条件

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

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

  説明

  クラスターのマイナーバージョンをクエリする方法については、AnalyticDB for MySQLクラスターのバージョンを照会するにはどうすればよいですか? クラスターのマイナーバージョンを更新するには、テクニカルサポートにお問い合わせください。

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

使用上の注意

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

OSS外部テーブル

構文

CREATE EXTERNAL TABLE [存在しない場合] table_name
(column_name column_type[, ...])
[PARTITIONED BY (column_name column_type[, ...])]
'、' によって終了するROW FORMAT DELIMITED FIELDS
{TEXTFILE | ORC | PARQUET | JSON | RCFIL | HUDI} として保存
ロケーション 'OSS_ロケーション ';
[TBLPROPERTIES ()
 'type' = 'cow | mor'
 'auto.create.location' = 'true | false') 

パラメーター

例

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

• ファイルの保存形式をTEXTFILEに設定します。

  存在しない場合は

  外部テーブルを作成するadb_external_demo.osstest1
  (id int,
  名前文字列,
  年齢int,
  都市文字列)
  '、' によって終了するROW FORMAT DELIMITED FIELDS
  テキストファイルとして保存
  LOCATION 'oss:// testBucketName/osstest/p1=hangzhou/p2=2023-06-13/data.csv '; 

• ファイルの保存形式をHUDIに設定します。

  存在しない場合は

  外部テーブルを作成するadb_external_demo.osstest2
  (id int,
  名前文字列,
  年齢int,
  都市文字列)
  HUDIとして保存
  ロケーション 'oss:// testBucketName/osstest/test'
  TBLPROPERTIES ('type' = 'cow'); 

  重要

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

• ファイルの保存形式をPARQUETに設定します。

  存在しない場合は

  外部テーブルを作成するadb_external_demo.osstest3
  (
  STRUCT < var1:string, var2:int>
  )
  PARQUETとして保存
  ロケーション 'oss:// testBucketName/osstest/Parquet'; 

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

外部テーブルを作成するadb_external_demo.osstest4
(id int,
名前文字列,
年齢int,
都市文字列)
PARTITIONED BY (p2文字列)
'、' によって終了するROW FORMAT DELIMITED FIELDS
テキストファイルとして保存
LOCATION 'oss:// testBucketName/osstest/p1=hangzhou/'; 

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

外部テーブルを作成するadb_external_demo.osstest5
(id int,
名前文字列,
年齢int,
都市文字列)
PARTITIONED BY (p1文字列、p2文字列)
'、' によって終了するROW FORMAT DELIMITED FIELDS
テキストファイルとして保存
ロケーション 'oss:// testBucketName/osstest/'; 

ApsaraDB RDS for MySQL外部テーブル

構文

CREATE EXTERNAL TABLE [存在しない場合] table_name
(column_name column_type[, ...])
エンジン='MYSQL'
TABLE_PROPERTIES='{
"url":"mysql_vpc_address" 、"tablename":"mysql_table_name" 、"username":"mysql_user_name" 、"password":"mysql_user_password"
[,"charset":"{gbk | utf8 | utf8mb4}"]
  }';

パラメーター

例

外部テーブルを作成します (
id int,
名前varchar(1023) 、年齢int
 ) エンジン='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 [存在しない場合] table_name
(column_name column_type[, ...])
エンジン='モンゴル'
TABLE_PROPERTIES = '{
"mapped_name":"テーブル" 、
  "location":"location" 、
  "username":"user" 、
  "password":"password" 、} '; 

Parameters

例

外部テーブルの作成adb_external_demo.person (
  id int,
  名前文字列,
  年齢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 [存在しない場合] table_name
(column_name column_type[, ...])
エンジン='OTS'
TABLE_PROPERTIES = '{
"mapped_name":"table_name" 、"location":"tablestore_vpc_address"
} '; 

パラメーター

例

外部テーブルを作成します (
id int,
名前文字列,
年齢int
) エンジン='OTS'
TABLE_PROPERTIES = '{
"mapped_name":"person" 、"location":"https:// w0 **** la.cn-hangzhou.vpc.tablestore.aliyuncs.com"
} '; 

MaxCompute外部テーブル

構文

CREATE EXTERNAL TABLE [存在しない場合] table_name
(column_name column_type[, ...])
エンジン='ODPS'
TABLE_PROPERTIES='{
"endpoint":"endpoint" 、"accessid":"accesskey_id" 、"accesskey":"accesskey_secret" 、["partition_column":"partition_column"] 、"project_name":"project_name" 、"table_name":"table_name"
} '; 

パラメーター

例

外部テーブルを作成します (
id int,
名前varchar(1023) 、年齢int,
dtストリング
) エンジン='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からAnalyticDB for MySQLへのデータのインポート

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

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