Tablestore:Kueri data dengan driver Go

Prasyarat

• Pasangan Kunci Akses dengan izin ots:SQL* (wajib untuk pengguna RAM).

• Sebuah tabel data dan tabel pemetaan. Untuk informasi selengkapnya, lihat Operasi DDL.

Prosedur

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

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

// Tetapkan nama driver Go dan nama sumber data Tablestore.
db, err := sql.Open("ots", "https://access_key_id:access_key_secret@endpoint/instance_name")
if err != nil {
    panic(err)    // Tangani error.
}

rows, err := db.Query("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?", 3)
if err != nil {
    panic(err)
}
defer rows.Close()
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    if err := rows.Scan(&pk1, &col1, &col2); err != nil {
        panic(err)
    }
    fmt.Println(pk1, col1, col2)
}

stmt, err := db.Prepare("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?")
if err != nil {
    panic(err)
}
defer stmt.Close()
rows, err := stmt.Query(3)
if err != nil {
    panic(err)
}
defer rows.Close()
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    if err := rows.Scan(&pk1, &col1, &col2); err != nil {
        panic(err)
    }
    fmt.Println(pk1, col1, col2)
}

Contoh lengkap

Contoh berikut menghubungkan ke instans Tablestore dan melakukan kueri terhadap semua data dari 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)
    }
    defer db.Close()

    rows, err := db.Query("SELECT * FROM test_table")
    if err != nil {
        panic(err)
    }
    defer rows.Close()

    columns, _ := rows.Columns()
    for rows.Next() {
        values := make([]interface{}, len(columns))
        pointers := make([]interface{}, len(columns))
        for i := range values {
            pointers[i] = &values[i]
        }
        if err := rows.Scan(pointers...); err != nil {
            panic(err)
        }
        fmt.Println(values...)
    }
}

Opsi konfigurasi

Konfigurasikan driver Go dengan menambahkan parameter kueri ke DSN.

https://ak:sk@endpoint/instance?retryTimes=3&requestTimeout=10s

Opsi berbasis waktu menggunakan format durasi Go, seperti 15s dan 500ms.

Pemetaan tipe data

Tipe data Tablestore dipetakan ke tipe data Go. Ketidaksesuaian tipe akan menyebabkan error.