Tablestore：Gunakan driver Tablestore untuk Go

Catatan penggunaan

Fitur kueri SQL tersedia di wilayah berikut: Tiongkok (Hangzhou), Tiongkok (Shanghai), Tiongkok (Beijing), Tiongkok (Zhangjiakou), Tiongkok (Ulanqab), Tiongkok (Shenzhen), Tiongkok (Chengdu), Tiongkok (Hong Kong), Jepang (Tokyo), Singapura, Malaysia (Kuala Lumpur), Inggris (London), AS (Silicon Valley), Indonesia (Jakarta), Jerman (Frankfurt), SAU (Riyadh - Partner Region), dan AS (Virginia).

Prasyarat

• Jika Anda ingin mengkueri data sebagai pengguna RAM, pastikan pengguna RAM telah dibuat dan semua izin operasi SQL diberikan kepada pengguna tersebut. Anda dapat mengonfigurasi "Action": "ots:SQL*" dalam kebijakan kustom yang dilampirkan pada pengguna RAM untuk memberikan semua izin operasi SQL kepada pengguna tersebut. Untuk informasi lebih lanjut, lihat Gunakan kebijakan RAM untuk memberikan izin kepada pengguna RAM.

• Pasangan AccessKey yang terdiri dari ID AccessKey dan Rahasia AccessKey telah diperoleh. Untuk informasi lebih lanjut, lihat Buat pasangan AccessKey.

• Tabel data telah dibuat, dan tabel pemetaan telah dibuat untuk tabel data tersebut. Untuk informasi lebih lanjut, lihat Prosedur dan Buat tabel pemetaan untuk tabel.

Prosedur

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

// Tentukan pernyataan SQL berdasarkan kebutuhan bisnis Anda. Dalam contoh ini, pernyataan SQL ditentukan untuk mengkueri data di kolom pk1, col1, dan col2 dari tabel test_table. 
rows, err := db.Query("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?", 3)
if err != nil {
    panic(err)    // Tangani kesalahan. 
}
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    err := rows.Scan(&pk1, &col1, &col2)
    if err != nil {
        panic(err)    // Tangani kesalahan. 
    }
}

// Tentukan pernyataan SQL berdasarkan kebutuhan bisnis Anda. Dalam contoh ini, pernyataan SQL ditentukan untuk mengkueri data di kolom pk1, col1, dan col2 dari tabel test_table. 
stmt, err := db.Prepare("SELECT pk1, col1, col2 FROM test_table WHERE pk1 = ?")
if err != nil {
    panic(err)    // Tangani kesalahan. 
}
rows, err := stmt.Query(3)
if err != nil {
    panic(err)    // Tangani kesalahan. 
}
for rows.Next() {
    var pk1 int64
    var col1 float64
    var col2 string
    err := rows.Scan(&pk1, &col1, &col2)
    if err != nil {
        panic(err)    // Tangani kesalahan. 
    }
}

Kode contoh lengkap

Berikut ini adalah kode contoh yang memberikan contoh cara mengkueri semua data dalam tabel bernama test_table di instance myinstance di wilayah Tiongkok (Hangzhou):

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() {
        // Tentukan bahwa semua kolom baris yang memenuhi kondisi kueri dikembalikan. 
        columns, err := rows.Columns()
        if err != nil {
            panic(err)
        }
        // Buat array dan pointer untuk menyimpan data. 
        values := make([]interface{}, len(columns))
        pointers := make([]interface{}, len(columns))
        for i := range values {
            pointers[i] = &values[i]
        }
        // Pindai baris data. 
        err = rows.Scan(pointers...)
        if err != nil {
            panic(err)
        }
        fmt.Println(values...)
    }
    rows.Close()
    db.Close()
}

Item konfigurasi

Anda dapat menggunakan driver Tablestore untuk Go untuk memodifikasi item konfigurasi SDK Tablestore untuk Go. Tabel berikut menjelaskan item konfigurasi umum.

Pemetaan tipe data

Tabel berikut menjelaskan pemetaan tipe data antara bidang Tablestore dan driver Tablestore untuk Go. Jika tipe data bidang dalam Tablestore tidak sesuai dengan tipe data bidang dalam driver Tablestore untuk Go, akan terjadi kesalahan.

Referensi

• Jika Anda ingin mempercepat kueri data dan komputasi dengan mengeksekusi pernyataan SQL, Anda dapat membuat indeks sekunder atau indeks pencarian. Untuk informasi lebih lanjut, lihat Kebijakan Pemilihan Indeks dan Penurunan Komputasi.

• Anda juga dapat menggunakan mesin komputasi seperti MaxCompute, Spark, Hive, HadoopMR, Function Compute, Flink, dan PrestoDB untuk menghitung dan menganalisis data dalam tabel. Untuk informasi lebih lanjut, lihat Ikhtisar.

• Untuk memvisualisasikan data, Anda dapat menggunakan Grafana. Sebagai contoh, Anda dapat menggunakan Grafana untuk menampilkan data Tablestore dalam bentuk grafik. Untuk informasi lebih lanjut, lihat Hubungkan Tablestore ke Grafana.