通过 SQL 查询数据

前提条件

• 安装Tablestore Go SDK并初始化客户端。SQL 查询功能需要 1.7.4 及以上版本，建议使用最新版本。

• 已为待操作的数据表或多元索引创建映射关系。

功能说明

调用 SQLQuery 方法执行 SELECT 语句，查询数据表或多元索引映射中的数据。

func (client *TableStoreClient) SQLQuery(request *SQLQueryRequest) (*SQLQueryResponse, error)

以下示例查询 example_table 中分区键为 tenant_id=1 的数据，并按字段类型读取返回值。

request := &tablestore.SQLQueryRequest{Query: `
SELECT tenant_id, pk, name, score
FROM example_table
WHERE tenant_id = 1
LIMIT 10`}

response, err := client.SQLQuery(request)
if err != nil {
    log.Fatalf("SQLQuery failed: %v", err)
}

for response.ResultSet.HasNext() {
    row := response.ResultSet.Next()
    tenantID, err := row.GetInt64ByName("tenant_id")
    if err != nil {
        log.Fatalf("Read tenant_id failed: %v", err)
    }
    pk, err := row.GetStringByName("pk")
    if err != nil {
        log.Fatalf("Read pk failed: %v", err)
    }
    name, err := row.GetStringByName("name")
    if err != nil {
        log.Fatalf("Read name failed: %v", err)
    }
    score, err := row.GetInt64ByName("score")
    if err != nil {
        log.Fatalf("Read score failed: %v", err)
    }
    fmt.Printf("%d, %s, %s, %d\n", tenantID, pk, name, score)
}

参数说明

SQLQueryRequest 包含以下参数。

返回值

SQLQueryResponse 包含以下与查询结果直接相关的字段。