Tablestore:Go 用 Tablestore ドライバーを使用して SQL ステートメントを実行してデータをクエリする

使用上の注意

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

前提条件

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

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

• データテーブルを作成し、データテーブルのマッピングテーブルを作成します。詳細については、手順 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 ドライバーのフィールドのデータ型と一致しない場合、エラーが発生します。

参考資料

• Tablestore コンソール、Tablestore CLI、Tablestore SDK、または Java Database Connectivity (JDBC) を使用して Tablestore にアクセスできます。詳細については、Tablestore コンソールで SQL クエリ機能を使用する、Tablestore CLI で SQL クエリ機能を使用する、Tablestore SDK を使用して SQL クエリ機能を使用する、JDBC を使用して Tablestore にアクセスする、Hibernate を使用して SQL ステートメントを実行してデータをクエリする、および MyBatis を使用して SQL ステートメントを実行してデータをクエリする を参照してください。

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

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

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