Tablestore:Contador atômico

Pré-requisitos

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

• Tabela de dados criada com dados gravados.

Observações de uso

• Contadores atômicos são suportados apenas em colunas do tipo INTEGER.

• Se a coluna definida como contador atômico não existir durante a gravação de dados, seu valor padrão será 0. Se a coluna especificada não for do tipo INTEGER, ocorrerá o erro OTSParameterInvalid.

• Atualize o contador atômico com valores positivos ou negativos, mas evite estouro de inteiro. Em caso de estouro, o sistema retornará o erro OTSParameterInvalid.

• Por padrão, a resposta à solicitação de atualização de linha não retorna o valor do contador atômico. Especifique o retorno do valor atualizado do contador atômico conforme necessário.

• Não defina uma coluna como contador atômico e a atualize na mesma solicitação. Por exemplo, se você definir a Coluna A como contador atômico, não poderá executar outras operações, como sobrescrita e exclusão, nessa coluna simultaneamente.

• Envie uma solicitação BatchWriteRow para realizar múltiplas operações de atualização na mesma linha. No entanto, ao executar uma operação de contador atômico em uma linha, realize apenas uma operação de atualização nessa linha por solicitação BatchWriteRow.

• Atualize apenas o valor da versão mais recente do contador atômico. Não é possível atualizar o valor de uma versão específica. Após a conclusão da operação de atualização, uma nova versão dos dados é inserida no contador atômico da linha.

Operações de API

Parâmetros

Exemplos

func UpdateRowWithIncrement(client *tablestore.TableStoreClient, tableName string) {
    fmt.Println("begin to update row")
    updateRowRequest := new(tablestore.UpdateRowRequest)
    updateRowChange := new(tablestore.UpdateRowChange)
    // Specify the name of the data table. 
    updateRowChange.TableName = tableName
    updatePk := new(tablestore.PrimaryKey)
    updatePk.AddPrimaryKeyColumn("pk1", "pk1increment")
    updatePk.AddPrimaryKeyColumn("pk2", int64(2))
    updatePk.AddPrimaryKeyColumn("pk3", []byte("pk3"))
    updateRowChange.PrimaryKey = updatePk
    // Specify that the value of the col2 column on which operations are performed to implement atomic counter is increased by 30. Do not specify timestamps. 
    updateRowChange.IncrementColumn("col2", int64(30))
    // Return the values of the column on which operations are performed to implement atomic counter. 
    updateRowChange.SetReturnIncrementValue()
    updateRowChange.SetCondition(tablestore.RowExistenceExpectation_IGNORE)
    updateRowChange.AppendIncrementColumnToReturn("col2")
    updateRowRequest.UpdateRowChange = updateRowChange

    resp, err := client.UpdateRow(updateRowRequest)
    if err != nil {
        fmt.Println("update failed with error:", err)
        return
    } else {
        fmt.Println("update row finished")
        fmt.Println(len(resp.Columns))
        fmt.Println(resp.Columns[0].ColumnName)
        fmt.Println(resp.Columns[0].Value)
        fmt.Println(resp.Columns[0].Timestamp)
    }
}