Tablestore:Excluir dados

Excluir uma única linha

• Excluir uma linha

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

  private static void deleteRow(SyncClient client, String pkValue) {
      // Construct the primary key. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
      // Specify the name of the data table. 
      RowDeleteChange rowDeleteChange = new RowDeleteChange("<TABLE_NAME>", primaryKey);
  
      client.deleteRow(new DeleteRowRequest(rowDeleteChange));
  }                    

• Usar uma condição para excluir uma linha

  O código de exemplo a seguir demonstra como excluir uma linha de dados de uma tabela quando a linha existe e o valor da coluna Col0 nessa linha é maior que 100:

  private static void deleteRow(SyncClient client, String pkValue) {
      // Construct the primary key. 
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
      // Specify the name of the data table. 
      RowDeleteChange rowDeleteChange = new RowDeleteChange("<TABLE_NAME>", primaryKey);
  
      // Specify conditions for the DeleteRow operation. In this example, a row is deleted only when the row exists and the value of the Col0 column is greater than 100. 
      Condition condition = new Condition(RowExistenceExpectation.EXPECT_EXIST);
      condition.setColumnCondition(new SingleColumnValueCondition("Col0",
              SingleColumnValueCondition.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100)));
      rowDeleteChange.setCondition(condition);
  
      client.deleteRow(new DeleteRowRequest(rowDeleteChange));
  }                   

Excluir várias linhas

1. Antes de excluir dados, escolha um método para consultar as chaves primárias das linhas que deseja excluir.

   • Para excluir linhas dentro de um intervalo específico de chave primária, use a operação GetRange para recuperar suas chaves primárias. Para mais informações, consulte Ler dados.

   • Para excluir linhas que atendem a critérios específicos, crie um índice de pesquisa. Em seguida, use o índice de pesquisa para consultar os dados e recuperar as chaves primárias das linhas a serem excluídas. Para mais informações, consulte Criar um índice de pesquisa e Usar um SDK para consultar dados com um índice de pesquisa.

2. Com as chaves primárias obtidas, chame a operação BatchWriteRow para excluir as linhas. Para mais informações, consulte Gravar dados em lote.

   O código de exemplo a seguir demonstra como excluir simultaneamente uma linha de dados em que o valor da coluna de chave primária pk é pk de uma tabela de dados e uma linha de dados em que o valor da coluna de chave primária pk1 é pk1 e o valor da coluna de chave primária pk2 é pk2 de outra tabela de dados:

   private static void batchWriteRow(SyncClient client) {    
       BatchWriteRowRequest batchWriteRowRequest = new BatchWriteRowRequest();
   
       // Construct rowDeleteChange1. 
       PrimaryKeyBuilder pk1Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
       pk1Builder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("pk"));
       // Specify the name of the data table. 
       RowDeleteChange rowDeleteChange1 = new RowDeleteChange("<TABLE_NAME1>", pk1Builder.build());
       // Add rowDeleteChange1 to the code of the batch operation. 
       batchWriteRowRequest.addRowChange(rowDeleteChange1);
   
       // Construct rowDeleteChange2. 
       PrimaryKeyBuilder pk2Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
       pk2Builder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pk1"));
       pk2Builder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromString("pk2"));
       // Specify the name of the data table. 
       RowDeleteChange rowDeleteChange2 = new RowDeleteChange("<TABLE_NAME2>", pk2Builder.build());
       // Add rowDeleteChange2 to the code of the batch operation. 
       batchWriteRowRequest.addRowChange(rowDeleteChange2);
   
       BatchWriteRowResponse response = client.batchWriteRow(batchWriteRowRequest);
   
       System.out.println("Whether all operations are successful:" + response.isAllSucceed());
       if (!response.isAllSucceed()) {
           for (BatchWriteRowResponse.RowResult rowResult : response.getFailedRows()) {
               System.out.println("Failed rows:" + batchWriteRowRequest.getRowChange(rowResult.getTableName(), rowResult.getIndex()).getPrimaryKey());
               System.out.println("Cause of failures:" + rowResult.getError());
           }
           /**
            * You can use the createRequestForRetry method to construct another request to retry the operations on failed rows. In this example, only the retry request is constructed. 
            * We recommend that you use the custom retry policy in Tablestore SDKs as the retry method. This feature allows you to retry failed rows after batch operations are performed. After you specify the retry policy, you do not need to add retry code to call the operation. 
            */
           BatchWriteRowRequest retryRequest = batchWriteRowRequest.createRequestForRetry(response.getFailedRows());
       }
   }