Tablestore:Local transactions

Simple scenarios: Read and write data

Use os dois métodos a seguir para executar operações de leitura, modificação e gravação (RMW). Cada método possui limitações específicas.

• Atualização condicional: processa apenas uma solicitação que envolve uma única linha por vez. Não é possível usar este método para processar solicitações que envolvem múltiplas linhas de dados ou múltiplas operações de gravação. Para mais informações, consulte Conditional updates.

• Contador atômico: processa apenas uma solicitação que envolve uma única linha por vez e oferece suporte somente ao incremento de valores de colunas. Para mais informações, consulte Use the atomic counter feature.

Para contornar as limitações descritas acima, crie uma local transaction e execute operações RMW nos dados dentro do intervalo especificado pelo valor da chave de partição.

1. Chame a operação StartLocalTransaction para criar uma local transaction com base no valor da chave de partição especificado e obtenha o ID da local transaction.

2. Chame a operação GetRow ou GetRange para ler os dados. A solicitação deve conter o ID da local transaction.

3. Modifique os dados no cliente.

4. Chame a operação PutRow, UpdateRow, DeleteRow ou BatchWriteRow para gravar os dados modificados. A solicitação deve conter o ID da local transaction.

5. Chame a operação CommitTransaction para confirmar a local transaction.

Complex scenario: mailbox scenario

Crie uma local transaction para executar operações atômicas nos e-mails de um usuário específico.

Para usar o recurso de local transaction corretamente, crie duas tabelas de índice em uma tabela de dados. A tabela a seguir lista as colunas de chave primária dessas tabelas. Na tabela, a coluna Type distingue a tabela de dados das tabelas de índice. Cada linha de índice usa a coluna IndexField para armazenar um campo com significado específico, enquanto a tabela de dados não contém a coluna IndexField.

Com o recurso de local transaction, você pode executar as seguintes operações nos e-mails.

Use the local transaction feature to write a data row

O exemplo a seguir cria uma local transaction para um valor de chave de partição especificado de uma tabela e grava uma linha dentro da local transaction.

String tableName = "local_tx_demo";

// 1. Start a local transaction for the specified partition key value and obtain the transaction ID.
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. Write a row within the transaction. You must specify the full primary key and include the transaction ID.
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

RowPutChange rowPutChange = new RowPutChange(tableName, rowKey);
rowPutChange.addColumn(new Column("col1", ColumnValue.fromString("colvalue")));
rowPutChange.addColumn(new Column("col2", ColumnValue.fromLong(10)));

PutRowRequest putRequest = new PutRowRequest(rowPutChange);
putRequest.setTransactionId(txnId);
client.putRow(putRequest);

// 3. Commit the transaction to make all writes take effect. To discard changes, call abortTransaction() instead.
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

Use the local transaction feature to read a data row

O exemplo a seguir cria uma local transaction para um valor de chave de partição especificado de uma tabela e lê uma linha dentro da local transaction.

String tableName = "local_tx_demo";

// 1. Start a local transaction for the specified partition key value.
PrimaryKeyBuilder pkBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
pkBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
PrimaryKey partitionKey = pkBuilder.build();

StartLocalTransactionRequest startRequest =
        new StartLocalTransactionRequest(tableName, partitionKey);
String txnId = client.startLocalTransaction(startRequest).getTransactionID();

// 2. Read a row within the transaction. You must specify the full primary key and include the transaction ID.
PrimaryKeyBuilder rowKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
rowKeyBuilder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pkvalue"));
rowKeyBuilder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(10001));
PrimaryKey rowKey = rowKeyBuilder.build();

SingleRowQueryCriteria criteria = new SingleRowQueryCriteria(tableName, rowKey);
criteria.setMaxVersions(1);

GetRowRequest getRequest = new GetRowRequest(criteria);
getRequest.setTransactionId(txnId);
GetRowResponse getResponse = client.getRow(getRequest);

// 3. Commit or abort the transaction. For a read-only transaction, both have the same effect and release the transaction.
CommitTransactionRequest commitRequest = new CommitTransactionRequest(txnId);
client.commitTransaction(commitRequest);

Row row = getResponse.getRow();
System.out.println(row);