Tablestore:Eliminar datos

Eliminar una sola fila

• Eliminar una fila

  El siguiente código de ejemplo muestra cómo eliminar una fila de datos de una tabla:

  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 una condición para eliminar una fila

  El siguiente código de ejemplo muestra cómo eliminar una fila de datos de una tabla cuando la fila existe y el valor de la columna Col0 es mayor 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));
  }                   

Eliminar varias filas

1. Antes de eliminar los datos, elija un método para consultar las claves primarias de las filas que desea borrar.

   • Si necesita eliminar filas dentro de un rango específico de claves primarias, use la operación GetRange para obtener dichas claves. Para obtener más información, consulte Read data.

   • Si va a eliminar filas que cumplen criterios específicos, cree un índice de búsqueda. Luego, utilícelo para consultar los datos y obtener las claves primarias de las filas por eliminar. Para obtener más información, consulte Create a search index y Use an SDK to query data with a search index.

2. Una vez que tenga las claves primarias, llame a la operación BatchWriteRow para eliminar las filas. Para obtener más información, consulte Batch write data.

   El siguiente código de ejemplo muestra cómo eliminar simultáneamente una fila de datos donde el valor de la columna de clave primaria pk es pk en una tabla, y otra fila donde el valor de la columna de clave primaria pk1 es pk1 y el de pk2 es pk2 en una segunda tabla:

   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());
       }
   }