Go语言驱动

注意事项

目前支持SQL查询功能的地域包括华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、中国香港、日本（东京）、新加坡、马来西亚（吉隆坡）、印度尼西亚（雅加达）、德国（法兰克福）、英国（伦敦）、美国（硅谷）、美国（弗吉尼亚）。

前提条件

• 如果要使用RAM用户进行操作，请确保已创建RAM用户，并为RAM用户授予所有SQL操作权限，即在自定义权限策略中配置"Action": "ots:SQL*"。具体操作，请参见通过RAM Policy为RAM用户授权。

• 已获取AccessKey（包括AccessKey ID和AccessKey Secret）。具体操作，请参见创建AccessKey。

• 已创建数据表并为数据表创建映射关系。具体操作，请分别参见创建数据表和创建表的映射关系。

使用流程

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

// 设置SQL语句，此处以查询test_table表中pk1列、col1列和col2列的数据为例介绍，请根据实际需要设置。
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列的数据为例介绍，请根据实际需要设置。
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)    // 处理错误。
    }
}

完整示例

以下示例用于查询华东1（杭州）地域下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语言驱动支持修改Go SDK的配置项。常用配置项的详细说明请参见下表。

数据类型映射

表格存储和Go语言中字段数据类型的对应关系请参见下表。如果字段数据类型不匹配，则会产生错误。

相关文档

• 如果要加速SQL数据查询和计算，您可以通过创建二级索引或者多元索引实现。更多信息，请参见索引选择策略和计算下推。

• 您还可以通过MaxCompute、Spark、Hive或者HadoopMR、函数计算、Flink、PrestoDB等计算引擎实现表中数据的计算与分析。具体操作，请参见计算与分析。

• 如果要以图表等形式可视化展示数据，您可以通过对接Grafana实现。更多信息，请参见对接Grafana。

• 使用宽表模型可以实现元数据、大数据等多种场景的解决方案，例如搭建海量智能元数据管理系统、亿量级订单管理方案、基于多元索引搭建亿量级店铺搜索系统、表格存储结合Spark流批处理实现一体化存储和计算、表格存储结合实时计算Flink进行大数据分析。更多方案介绍，请参见快速玩转Tablestore入门与实战。

• 使用时序模型可以实现设备时序数据开发等方案。更多方案介绍，请参见快速玩转Tablestore入门与实战。

• SQL查询可应用在表格存储物联网存储IoTstore解决方案中作为不同类型数据的统一查询接口。更多信息，请参见物联网存储简介。

  物联网存储IoTstore是表格存储基于物联网场景中多源异构数据存储、高并发吞吐、海量数据高性价比存储、多维度数据处理与分析等需求推出的一站式物联网解决方案，可为物联网设备元数据、消息数据、时序轨迹等海量数据提供存储、查询、检索、分析、同步等能力。