データを書き込み、またはクエリするには、データベースを作成する必要があります。このトピックでは、ApsaraDB for SelectDB インスタンスを作成し、データを書き込む方法について説明します。
前提条件
ApsaraDB for SelectDB インスタンスには、MySQL プロトコルを使用して接続します。詳細については、「インスタンスに接続する」をご参照ください。
使用上の注意
各 ApsaraDB for SelectDB インスタンスは、最大 256 個のデータベースをサポートします。
ApsaraDB for SelectDB は標準 SQL 構文に対応しています。詳細については、「SQL リファレンス」をご参照ください。
手順 (CLI)
CREATE DATABASEステートメントを実行して、データベースを作成します。CREATE DATABASE test_db;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;次のサンプルデータを、
data.csvという名前のローカルファイルに保存します。1,0.14,a1,20 2,1.04,b2,21 3,3.14,c3,22 4,4.35,d4,23HTTP 経由でインポートリクエストを送信するストリームロードを使用して、
test_tableテーブルにデータをロードします。 この例では、curlコマンドを使用してリクエストを送信します。 詳細については、「ストリームロード」をご参照ください。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 エンドポイントまたはパブリックエンドポイント。 パブリックエンドポイントを申請するには、「パブリックエンドポイントの申請または解放」をご参照ください。
port: ApsaraDB for SelectDB インスタンスの HTTP ポート番号です。
説明お使いの ApsaraDB for SelectDB インスタンスのエンドポイントと HTTP ポート番号は、インスタンス詳細ページで確認できます。
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 | +------+------+------+------+