Tablestore:Go 用 Tablestore ドライバーを使用する

使用上の注意

SQL クエリ機能は、中国 (杭州)、中国 (上海)、中国 (北京)、中国 (張家口)、中国 (ウランチャブ)、中国 (深セン)、中国 (成都)、中国 (香港)、日本 (東京)、シンガポール、マレーシア (クアラルンプール)、英国 (ロンドン)、米国 (シリコンバレー)、インドネシア (ジャカルタ)、ドイツ (フランクフルト)、SAU (リヤド - パートナーリージョン)、および米国 (バージニア) の各リージョンでご利用いただけます。

前提条件

• RAM ユーザーとしてデータをクエリする場合、RAM ユーザーが作成され、すべての SQL 操作権限が RAM ユーザーに付与されます。RAM ユーザーにアタッチされているカスタムポリシーで "Action": "ots:SQL*" を設定することで、すべての SQL 操作権限を RAM ユーザーに付与できます。詳細については、「RAM ポリシーを使用して RAM ユーザーに権限を付与する」をご参照ください。

• AccessKey ID と AccessKey シークレットで構成される AccessKey ペアを取得します。詳細については、「AccessKey ペアを作成する」をご参照ください。

• データテーブルを作成し、データテーブルのマッピングテーブルを作成します。詳細については、「ステップ 3: データテーブルを作成する」および「テーブルのマッピングテーブルを作成する」をご参照ください。

手順

go get github.com/aliyun/aliyun-tablestore-go-sql-driver

// ビジネス要件に基づいて SQL 文を指定します。この例では、test_table テーブルの pk1、col1、col2 列のデータをクエリする SQL 文が指定されています。
rows, err := db.Query("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?", 3)
if err != nil {
    panic(err)    // エラーを処理します。
}
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    err := rows.Scan(&pk1, &col1, &col2)
    if err != nil {
        panic(err)    // エラーを処理します。
    }
}

// ビジネス要件に基づいて SQL 文を指定します。この例では、test_table テーブルの pk1、col1、col2 列のデータをクエリする SQL 文が指定されています。
stmt, err := db.Prepare("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?")
if err != nil {
    panic(err)    // エラーを処理します。
}
rows, err := stmt.Query(3)
if err != nil {
    panic(err)    // エラーを処理します。
}
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    err := rows.Scan(&pk1, &col1, &col2)
    if err != nil {
        panic(err)    // エラーを処理します。
    }
}

完全なサンプルコード

次のサンプルコードは、中国 (杭州) リージョンの myinstance インスタンスにある test_table という名前のテーブルのすべてのデータをクエリする方法の例を示しています。

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/aliyun/aliyun-tablestore-go-sql-driver"
)

func main() {
    db, err := sql.Open("ots", "https://************************:********************************@myinstance.cn-hangzhou.ots.aliyuncs.com/myinstance")
    if err != nil {
        panic(err)
    }
    rows, err := db.Query("SELECT * FROM test_table")
    if err != nil {
        panic(err)
    }
    for rows.Next() {
        // クエリ条件を満たす行のすべての列が返されるように指定します。
        columns, err := rows.Columns()
        if err != nil {
            panic(err)
        }
        // データを格納するための配列とポインターを作成します。
        values := make([]interface{}, len(columns))
        pointers := make([]interface{}, len(columns))
        for i := range values {
            pointers[i] = &values[i]
        }
        // データ行をスキャンします。
        err = rows.Scan(pointers...)
        if err != nil {
            panic(err)
        }
        fmt.Println(values...)
    }
    rows.Close()
    db.Close()
}

設定項目

Go 用 Tablestore ドライバーを使用して、Go 用 Tablestore SDK の設定項目を変更できます。次の表に、一般的な設定項目を示します。

データ型のマッピング

次の表に、Tablestore のフィールドと Go 用 Tablestore ドライバーのデータ型のマッピングを示します。Tablestore のフィールドのデータ型が Go 用 Tablestore ドライバーのフィールドのデータ型と一致しない場合、エラーが発生します。

関連情報

• SQL 文を実行してデータクエリと計算を高速化する場合、セカンダリインデックスまたは 多次元インデックス を作成できます。詳細については、「インデックス選択ポリシー」および「プッシュダウンの計算」をご参照ください。

• MaxCompute、Spark、Hive、HadoopMR、Function Compute、Flink、PrestoDB などの計算エンジンを使用して、テーブル内のデータを計算および分析することもできます。詳細については、「概要」をご参照ください。

• データを視覚化するには、Grafana を使用できます。たとえば、Grafana を使用して Tablestore データをグラフに表示できます。詳細については、「Tablestore を Grafana に接続する」をご参照ください。