全部產品
Search
文件中心

ApsaraDB for SelectDB:建立資料庫並寫入資料

更新時間:Jul 06, 2024

在進行資料寫入和查詢前,您需要先建立資料庫。本文介紹如何為ApsaraDB for SelectDB執行個體建立資料庫並寫入資料。

前提條件

已通過MySQL協議串連ApsaraDB for SelectDB執行個體。具體操作,請參見串連執行個體

注意事項

  • 每個ApsaraDB for SelectDB執行個體最多可以建立256個資料庫。

  • ApsaraDB for SelectDB相容標準的SQL文法。SQL文法的詳細資料,請參見SelectDB SQL手冊

操作步驟

  1. 執行CREATE DATABASE語句建立資料庫。

    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命令展示如何提交匯入。詳細資料,請參見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

    參數說明如下。

    hostApsaraDB for SelectDB執行個體的VPC地址或公網地址。申請公網的具體操作,請參見申請和釋放公網地址

    portApsaraDB 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 |
    +------+------+------+------+