在進行資料寫入和查詢前,您需要先建立資料庫。本文介紹如何為ApsaraDB for SelectDB執行個體建立資料庫並寫入資料。
前提條件
已通過MySQL協議串連ApsaraDB for SelectDB執行個體。具體操作,請參見串連執行個體。
注意事項
每個ApsaraDB for SelectDB執行個體最多可以建立256個資料庫。
ApsaraDB for SelectDB相容標準的SQL文法。SQL文法的詳細資料,請參見SQL手冊。
操作步驟
執行
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,23
通過Stream Load方式寫入資料至表
test_table
中,語句如下。Stream Load通過HTTP協議提交匯入請求,這裡通過本地的curl
命令展示如何提交匯入。詳細資料,請參見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地址或公網地址。申請公網的具體操作,請參見申請和釋放公網地址。
port:ApsaraDB for SelectDB執行個體的HTTP協議連接埠號碼。
說明您可以在ApsaraDB for SelectDB的執行個體詳情頁面,查看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 | +------+------+------+------+