如果需要了解表格存儲(chǔ)各場(chǎng)景的應(yīng)用案例，請(qǐng)參見(jiàn)快速玩轉(zhuǎn)Tablestore入門(mén)與實(shí)戰(zhàn)。

查詢(xún)方式

表格存儲(chǔ)提供的數(shù)據(jù)讀取接口包括GetRow、BatchGetRow和GetRange。讀取數(shù)據(jù)時(shí)，請(qǐng)根據(jù)實(shí)際查詢(xún)場(chǎng)景使用相應(yīng)查詢(xún)方式讀取數(shù)據(jù)。

前提條件

• 已初始化Client，詳情請(qǐng)參見(jiàn)初始化。
• 已創(chuàng)建數(shù)據(jù)表并寫(xiě)入數(shù)據(jù)。

讀取單行數(shù)據(jù)

調(diào)用GetRow接口讀取一行數(shù)據(jù)。讀取的結(jié)果可能有如下兩種：

• 如果該行存在，則返回該行的各主鍵列以及屬性列。

• 如果該行不存在，則返回中不包含行，并且不會(huì)報(bào)錯(cuò)。

接口

//返回表中的一行數(shù)據(jù)。
// @param GetRowRequest             執(zhí)行GetRow操作所需參數(shù)的封裝。
// @return  GetRowResponse          GetRow操作的響應(yīng)內(nèi)容。
GetRow(request *GetRowRequest) (*GetRowResponse, error)                   

參數(shù)

示例

以下示例用于讀取一行數(shù)據(jù)。

getRowRequest := new(tablestore.GetRowRequest)
criteria := new(tablestore.SingleRowQueryCriteria);
putPk := new(tablestore.PrimaryKey)
putPk.AddPrimaryKeyColumn("pk1", "pk1value1")
putPk.AddPrimaryKeyColumn("pk2", int64(2))
putPk.AddPrimaryKeyColumn("pk3", []byte("pk3"))

criteria.PrimaryKey = putPk
getRowRequest.SingleRowQueryCriteria = criteria
getRowRequest.SingleRowQueryCriteria.TableName = tableName 
getRowRequest.SingleRowQueryCriteria.MaxVersion = 1  
getResp, err := client.GetRow(getRowRequest)
if err != nil {
    fmt.Println("getrow failed with error:", err)
} else {
    fmt.Println("get row col0 result is ",getResp.Columns[0].ColumnName, getResp.Columns[0].Value,)
}                   

詳細(xì)代碼請(qǐng)參見(jiàn)GetRow@GitHub。

批量讀取數(shù)據(jù)

調(diào)用BatchGetRow接口一次請(qǐng)求讀取多行數(shù)據(jù)，也支持一次對(duì)多張表進(jìn)行讀取。BatchGetRow由多個(gè)GetRow子操作組成。構(gòu)造子操作的過(guò)程與使用GetRow接口時(shí)相同。

BatchGetRow的各個(gè)子操作獨(dú)立執(zhí)行，表格存儲(chǔ)會(huì)分別返回各個(gè)子操作的執(zhí)行結(jié)果。

注意事項(xiàng)

• 由于批量讀取可能存在部分行失敗的情況，失敗行的錯(cuò)誤信息在返回的BatchGetRowResponse中，但并不拋出異常。因此調(diào)用BatchGetRow接口時(shí)，需要檢查返回值，判斷每行的狀態(tài)是否成功。

• 批量讀取的所有行采用相同的參數(shù)條件，例如ColumnsToGet=[colA]，表示要讀取的所有行都只讀取colA列。

• BatchGetRow操作單次支持讀取的最大行數(shù)為100行。

參數(shù)

更多信息，請(qǐng)參見(jiàn)讀取單行數(shù)據(jù)參數(shù)。

接口

//返回?cái)?shù)據(jù)表（Table）中的多行數(shù)據(jù)。
// @param BatchGetRowRequest             執(zhí)行BatchGetRow操作所需參數(shù)的封裝。
// @return  BatchGetRowResponse          BatchGetRow操作的響應(yīng)內(nèi)容。
BatchGetRow(request *BatchGetRowRequest) (*BatchGetRowResponse, error)                    

示例

以下示例用于批量一次讀取10行數(shù)據(jù)。

batchGetReq := &tablestore.BatchGetRowRequest{}
mqCriteria := &tablestore.MultiRowQueryCriteria{}

for i := 0; i < 10; i++ {
    pkToGet := new(tablestore.PrimaryKey)
    pkToGet.AddPrimaryKeyColumn("pk1", "pk1value1")
    pkToGet.AddPrimaryKeyColumn("pk2", int64(i))
    pkToGet.AddPrimaryKeyColumn("pk3", []byte("pk3"))
    mqCriteria.AddRow(pkToGet)
    mqCriteria.MaxVersion = 1
}
mqCriteria.TableName = tableName
batchGetReq.MultiRowQueryCriteria = append(batchGetReq.MultiRowQueryCriteria, mqCriteria)
batchGetResponse, err := client.BatchGetRow(batchGetReq)

if err != nil {
    fmt.Println("batchget failed with error:", err)
} else {
    fmt.Println("batchget finished")
}                    

詳細(xì)代碼請(qǐng)參見(jiàn)BatchGetRow@GitHub。

范圍讀取數(shù)據(jù)

調(diào)用GetRange接口讀取一個(gè)范圍內(nèi)的數(shù)據(jù)。

GetRange操作支持按照確定范圍進(jìn)行正序讀取和逆序讀取，可以設(shè)置要讀取的行數(shù)。如果范圍較大，已掃描的行數(shù)或者數(shù)據(jù)量超過(guò)一定限制，會(huì)停止掃描，并返回已獲取的行和下一個(gè)主鍵信息。您可以根據(jù)返回的下一個(gè)主鍵信息，繼續(xù)發(fā)起請(qǐng)求，獲取范圍內(nèi)剩余的行。

注意事項(xiàng)

GetRange操作遵循最左匹配原則，讀取數(shù)據(jù)時(shí)，依次比較第一主鍵列到第四主鍵列。例如表的主鍵包括PK1、PK2、PK3三個(gè)主鍵列，讀取數(shù)據(jù)時(shí)，優(yōu)先比較PK1是否在開(kāi)始主鍵與結(jié)束主鍵的范圍內(nèi)，如果PK1在設(shè)置的主鍵范圍內(nèi)，則不會(huì)再比較其他的主鍵，返回在PK1主鍵范圍內(nèi)的數(shù)據(jù)；如果PK1在設(shè)置的主鍵邊界上，則繼續(xù)比較PK2是否在開(kāi)始主鍵與結(jié)束主鍵的范圍內(nèi)，以此類(lèi)推。關(guān)于范圍查詢(xún)?cè)淼母嘈畔ⅲ?qǐng)參見(jiàn)GetRange范圍查詢(xún)?cè)斀?/a>。

GetRange操作可能在如下情況停止執(zhí)行并返回?cái)?shù)據(jù)。

• 掃描的行數(shù)據(jù)大小之和達(dá)到4 MB。

• 掃描的行數(shù)等于5000。

• 返回的行數(shù)等于最大返回行數(shù)。

• 當(dāng)前剩余的預(yù)留讀吞吐量已全部使用，余量不足以讀取下一條數(shù)據(jù)。

當(dāng)使用GetRange掃描的數(shù)據(jù)量較大時(shí)，表格存儲(chǔ)每次請(qǐng)求僅會(huì)掃描一次（行數(shù)大于5000或者大小大于4 MB停止掃描），超過(guò)限制的數(shù)據(jù)不會(huì)繼續(xù)返回，需要通過(guò)翻頁(yè)繼續(xù)獲取后面的數(shù)據(jù)。

接口

//從表中查詢(xún)一個(gè)范圍內(nèi)的多行數(shù)據(jù)。
// @param GetRangeRequest           執(zhí)行GetRange操作所需參數(shù)的封裝。
// @return GetRangeResponse         GetRange操作的響應(yīng)內(nèi)容。
GetRange(request *GetRangeRequest) (*GetRangeResponse,error)                   

參數(shù)

示例

以下示例用于按照范圍讀取數(shù)據(jù)。

getRangeRequest := &tablestore.GetRangeRequest{}
rangeRowQueryCriteria := &tablestore.RangeRowQueryCriteria{}
rangeRowQueryCriteria.TableName = tableName

startPK := new(tablestore.PrimaryKey)
startPK.AddPrimaryKeyColumnWithMinValue("pk1")
startPK.AddPrimaryKeyColumnWithMinValue("pk2")
startPK.AddPrimaryKeyColumnWithMinValue("pk3")
endPK := new(tablestore.PrimaryKey)
endPK.AddPrimaryKeyColumnWithMaxValue("pk1")
endPK.AddPrimaryKeyColumnWithMaxValue("pk2")
endPK.AddPrimaryKeyColumnWithMaxValue("pk3")
rangeRowQueryCriteria.StartPrimaryKey = startPK
rangeRowQueryCriteria.EndPrimaryKey = endPK
rangeRowQueryCriteria.Direction = tablestore.FORWARD
rangeRowQueryCriteria.MaxVersion = 1
rangeRowQueryCriteria.Limit = 10
getRangeRequest.RangeRowQueryCriteria = rangeRowQueryCriteria

getRangeResp, err := client.GetRange(getRangeRequest)

fmt.Println("get range result is " ,getRangeResp)

for {
    if err != nil {
        fmt.Println("get range failed with error:", err)
    }
    for _, row := range getRangeResp.Rows {
        fmt.Println("range get row with key", row.PrimaryKey.PrimaryKeys[0].Value, row.PrimaryKey.PrimaryKeys[1].Value, row.PrimaryKey.PrimaryKeys[2].Value)
    }
    if getRangeResp.NextStartPrimaryKey == nil {
        break
    } else {
        fmt.Println("next pk is :", getRangeResp.NextStartPrimaryKey.PrimaryKeys[0].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[1].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[2].Value)
        getRangeRequest.RangeRowQueryCriteria.StartPrimaryKey = getRangeResp.NextStartPrimaryKey
        getRangeResp, err = client.GetRange(getRangeRequest)
    }
    fmt.Println("continue to query rows")
}
fmt.Println("range get row finished")

詳細(xì)代碼請(qǐng)參見(jiàn)GetRange@GitHub。