ApsaraDB for SelectDB:データベースを作成し、データベースにデータを書き込む

前提条件

MySQLプロトコルを介して ApsaraDB for SelectDB インスタンスに接続していること。詳細については、「インスタンスへの接続」をご参照ください。

使用上の注意

• 1 つの ApsaraDB for SelectDB インスタンスに対して最大 256 個のデータベースを作成できます。

• ApsaraDB for SelectDB は標準 SQL 構文と互換性があります。詳細については、「SQL リファレンス」をご参照ください。

手順

1. CREATE DATABASE ステートメントを実行して、test_db という名前のデータベースを作成します。

   CREATE DATABASE test_db;

2. 次のステートメントを実行して、test_db データベースに test_table という名前のテーブルを作成します。

   USE test_db;
   
   CREATE TABLE test_table
   (
       k1 TINYINT,
       k2 DECIMAL(10, 2) DEFAULT "10.05",
       k3 CHAR(10) COMMENT "文字列型の列", // string column
       k4 INT NOT NULL DEFAULT "1" COMMENT "整数型の列" // int column
   )
   COMMENT "最初のテーブル" // my first table
   DISTRIBUTED BY HASH(k1) BUCKETS 16;

3. 次のサンプルデータをローカルファイルとして保存し、data.csv という名前を付けます。

   1,0.14,a1,20
   2,1.04,b2,21
   3,3.14,c3,22
   4,4.35,d4,23

4. Stream Load を使用してデータを test_table テーブルに書き込むには、次のステートメントを実行します。 Stream Load は HTTP プロトコルを介してインポートリクエストを送信します。この例では、オンプレミスデバイスで curl コマンドを実行してインポートリクエストを送信します。詳細については、「Import data by using Stream Load」をご参照ください。

   curl --location-trusted -u admin:admin_123 -H "label:123" -H "column_separator:," -T data.csv http://host:port/api/test_db/test_table/_stream_load

   パラメーター：

   host：ApsaraDB for SelectDB インスタンスの仮想プライベートクラウド (VPC) エンドポイントまたはパブリックエンドポイント。パブリックエンドポイントの申請方法については、「Apply for or release a public endpoint」をご参照ください。

   port：ApsaraDB for SelectDB インスタンスの HTTP ポート番号。

   説明

   ApsaraDB for SelectDB コンソールのインスタンス詳細ページで、ApsaraDB for SelectDB インスタンスのエンドポイントと HTTP ポート番号 を表示できます。

5. test_table テーブルのデータをクエリするには、次のステートメントを実行します。

   SELECT * FROM test_table;

   次の結果が返されます。

   +------+------+------+------+
   | k1   | k2   | k3   | k4   |
   +------+------+------+------+
   |    1 | 0.14 | a1   |   20 |
   |    2 | 1.04 | b2   |   21 |
   |    3 | 3.14 | c3   |   22 |
   |    4 | 4.35 | d4   |   23 |
   +------+------+------+------+