Tablestore:Ler dados

Métodos de consulta

O Tablestore fornece as operações GetRow, BatchGetRow e GetRange para leitura de dados. Antes de ler os dados, selecione o método de consulta adequado com base no cenário real.

Pré-requisitos

• Uma instância do OTSClient foi inicializada. Para mais informações, consulte Inicializar uma instância do OTSClient.

• Uma tabela de dados foi criada e dados foram gravados nela.

Ler uma única linha de dados

Chame a operação GetRow para ler uma única linha de dados. Após chamar a operação GetRow, um dos seguintes resultados pode ser retornado:

• Se a linha existir, as colunas de chave primária e as colunas de atributo da linha serão retornadas.

• Se a linha não existir, nenhuma linha será retornada e nenhum erro será reportado.

Operação de API

// Return a row of data in a table. 
// @param GetRowRequest             Encapsulate the parameters required to call the GetRow operation. 
// @return  GetRowResponse          The content of the response to the GetRow operation. 
GetRow(request *GetRowRequest) (*GetRowResponse, error)                   

Parâmetros

Código de exemplo

O código de exemplo a seguir demonstra como ler uma linha de dados:

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,)
}                   

Para consultar o código de exemplo detalhado, acesse GetRow@GitHub.

Ler várias linhas de dados de uma vez

Chame a operação BatchGetRow para ler várias linhas de dados de uma ou mais tabelas ao mesmo tempo. A operação BatchGetRow consiste em várias operações GetRow. Ao chamar a operação BatchGetRow, o processo de construção de cada operação GetRow é o mesmo do processo de construção ao chamar a operação GetRow individualmente.

Ao chamar a operação BatchGetRow, cada operação GetRow é executada separadamente. O Tablestore retorna a resposta de cada operação GetRow separadamente.

Observações de uso

• Ao chamar a operação BatchGetRow para ler várias linhas de uma vez, a leitura de algumas linhas pode falhar. Nesse caso, o Tablestore não retorna exceções, mas retorna BatchGetRowResponse com as informações das linhas que falharam. Portanto, ao chamar a operação BatchGetRow, verifique os valores retornados para determinar se os dados de cada linha foram lidos com êxito.

• A operação BatchGetRow usa as mesmas configurações de parâmetros para todas as linhas. Por exemplo, se o parâmetro ColumnsToGet estiver definido como [colA], somente o valor da coluna colA será lido de todas as linhas.

• A operação BatchGetRow permite ler no máximo 100 linhas de uma vez.

Parâmetros

Para mais informações sobre parâmetros, consulte a tabela de Parâmetros na seção "Ler uma única linha de dados".

Operação de API

// Return multiple rows of data from a table. 
// @param BatchGetRowRequest             Encapsulate the parameters required to call the BatchGetRow operation. 
// @return  BatchGetRowResponse          The content of the response to the BatchGetRow operation. 
BatchGetRow(request *BatchGetRowRequest) (*BatchGetRowResponse, error)                    

Código de exemplo

O código de exemplo a seguir demonstra como ler 10 linhas de dados de uma vez:

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")
}                    

Para consultar o código de exemplo detalhado, acesse BatchGetRow@GitHub.

Ler dados cujos valores de chave primária estejam em um intervalo específico

Chame a operação GetRange para ler dados cujos valores de chave primária estejam no intervalo especificado.

A operação GetRange permite ler dados cujos valores de chave primária estejam no intervalo especificado na direção progressiva ou regressiva. Também é possível especificar o número de linhas a serem lidas. Se o intervalo for grande e o número de linhas verificadas ou o volume de dados verificados exceder o limite superior, a verificação será interrompida, e as linhas lidas e as informações sobre a chave primária da próxima linha serão retornadas. Inicie uma nova solicitação a partir da posição em que a última operação parou e leia as linhas restantes com base nas informações da chave primária da próxima linha retornadas pela operação anterior.

Observações de uso

A operação GetRange segue o princípio de correspondência mais à esquerda. O Tablestore compara valores sequencialmente, da primeira coluna de chave primária até a última, para ler dados cujos valores de chave primária estejam no intervalo especificado. Por exemplo, a chave primária de uma tabela de dados consiste nas seguintes colunas de chave primária: PK1, PK2 e PK3. Ao ler os dados, o Tablestore primeiro verifica se o valor de PK1 de uma linha está no intervalo especificado para a primeira coluna de chave primária. Se o valor de PK1 estiver no intervalo, o Tablestore para de verificar os valores das demais colunas de chave primária da linha e retorna a linha. Se o valor de PK1 não estiver no intervalo, o Tablestore continua verificando os valores das demais colunas de chave primária da linha da mesma forma que para PK1.

Se uma das condições a seguir for atendida, a operação GetRange poderá parar e retornar dados:

• O volume de dados verificados atinge 4 MB.

• O número de linhas verificadas atinge 5.000.

• O número de linhas retornadas atinge o limite superior.

• O throughput de leitura é insuficiente para ler a próxima linha de dados porque todo o throughput de leitura reservado foi consumido.

Operação de API

// Query multiple rows of data whose primary key values are in the specified range in a table. 
// @param GetRangeRequest            Encapsulate the parameters required to call the GetRange operation. 
// @return GetRangeResponse          The content of the response to the GetRange operation. 
GetRange(request *GetRangeRequest) (*GetRangeResponse,error)                   

Parâmetros

Código de exemplo

O código de exemplo a seguir demonstra como ler dados cujos valores de chave primária estejam no intervalo especificado:

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")

Para consultar o código de exemplo detalhado, acesse GetRange@GitHub.