Tablestore:Veri silme

Tek bir satır silme

• Satır silme

  Aşağıdaki örnek kod, bir tablodan nasıl veri satırı silineceğini göstermektedir:

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

• Koşul kullanarak satır silme

  Aşağıdaki örnek kod, satır mevcut olduğunda ve satırdaki Col0 sütununun değeri 100'den büyük olduğunda bir veri tablosundan nasıl veri satırı silineceğini göstermektedir:

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

Birden çok satır silme

1. Verileri silmeden önce, silmek istediğiniz satırların birincil anahtarlarını sorgulamak için bir yöntem seçin.

   • Belirli bir birincil anahtar aralığındaki satırları silmek için, birincil anahtarlarını almak üzere GetRange işlemini kullanın. Daha fazla bilgi için bkz. Veri okuma.

   • Belirli kriterleri karşılayan satırları silmek için bir arama dizini oluşturun. Ardından, verileri sorgulamak ve silinecek satırların birincil anahtarlarını almak için arama dizinini kullanın. Daha fazla bilgi için bkz. Arama dizini oluşturma ve SDK kullanarak arama diziniyle veri sorgulama.

2. Birincil anahtarlara sahip olduktan sonra, satırları silmek için BatchWriteRow işlemini çağırın. Daha fazla bilgi için bkz. Verileri toplu yazma.

   Aşağıdaki örnek kod, pk birincil anahtar sütununun değeri pk olan bir veri satırını bir veri tablosundan ve pk1 birincil anahtar sütununun değeri pk1 ile pk2 birincil anahtar sütununun değeri pk2 olan bir veri satırını başka bir veri tablosundan aynı anda nasıl sileceğinizi göstermektedir:

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