Tablestore:データの削除

単一行の削除

• 行の削除

  次のサンプルコードは、テーブルから 1 行のデータを削除する方法の例です。

  private static void deleteRow(SyncClient client, String pkValue) {
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
      // データテーブルの名前を指定します。
      RowDeleteChange rowDeleteChange = new RowDeleteChange("<TABLE_NAME>", primaryKey);
  
      client.deleteRow(new DeleteRowRequest(rowDeleteChange));
  }                    

• 条件を使用した行の削除

  次のサンプルコードは、行が存在し、かつその行の Col0 列の値が 100 より大きい場合にのみ、データテーブルから 1 行のデータを削除する方法の例です。

  private static void deleteRow(SyncClient client, String pkValue) {
      // プライマリキーを構築します。
      PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
      primaryKeyBuilder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString(pkValue));
      PrimaryKey primaryKey = primaryKeyBuilder.build();
      // データテーブルの名前を指定します。
      RowDeleteChange rowDeleteChange = new RowDeleteChange("<TABLE_NAME>", primaryKey);
  
      // DeleteRow 操作の条件を指定します。この例では、行が存在し、かつ Col0 列の値が 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));
  }                   

複数行の削除

1. データを削除する前に、削除対象の行のプライマリキーを取得する方法を選択します。

   • 特定のプライマリキー範囲内の行を削除するには、GetRange 操作を使用して、それらのプライマリキーを取得します。詳細については、「データの読み取り」をご参照ください。

   • 特定の条件を満たす行を削除するには、検索インデックスを作成します。次に、その検索インデックスを使用してデータをクエリし、削除対象の行のプライマリキーを取得します。詳細については、「検索インデックスの作成」と「SDK を使用した検索インデックスによるデータのクエリ」をご参照ください。

2. プライマリキーを取得したら、BatchWriteRow 操作を呼び出して、これらの行を削除します。詳細については、「データのバッチ書き込み」をご参照ください。

   次のサンプルコードは、あるデータテーブルから pk プライマリキー列の値が pk である行を削除し、別のデータテーブルから pk1 プライマリキー列の値が pk1、pk2 プライマリキー列の値が pk2 である行を同時に削除する方法の例です。

   private static void batchWriteRow(SyncClient client) {    
       BatchWriteRowRequest batchWriteRowRequest = new BatchWriteRowRequest();
   
       // rowDeleteChange1 を構築します。
       PrimaryKeyBuilder pk1Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
       pk1Builder.addPrimaryKeyColumn("pk", PrimaryKeyValue.fromString("pk"));
       // データテーブルの名前を指定します。
       RowDeleteChange rowDeleteChange1 = new RowDeleteChange("<TABLE_NAME1>", pk1Builder.build());
       // バッチ操作のコードに rowDeleteChange1 を追加します。
       batchWriteRowRequest.addRowChange(rowDeleteChange1);
   
       // rowDeleteChange2 を構築します。
       PrimaryKeyBuilder pk2Builder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
       pk2Builder.addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("pk1"));
       pk2Builder.addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromString("pk2"));
       // データテーブルの名前を指定します。
       RowDeleteChange rowDeleteChange2 = new RowDeleteChange("<TABLE_NAME2>", pk2Builder.build());
       // バッチ操作のコードに rowDeleteChange2 を追加します。
       batchWriteRowRequest.addRowChange(rowDeleteChange2);
   
       BatchWriteRowResponse response = client.batchWriteRow(batchWriteRowRequest);
   
       System.out.println("すべての操作が成功したかどうか:" + response.isAllSucceed());
       if (!response.isAllSucceed()) {
           for (BatchWriteRowResponse.RowResult rowResult : response.getFailedRows()) {
               System.out.println("失敗した行:" + batchWriteRowRequest.getRowChange(rowResult.getTableName(), rowResult.getIndex()).getPrimaryKey());
               System.out.println("失敗の原因:" + rowResult.getError());
           }
           /**
            * createRequestForRetry メソッドを使用して、失敗した行に対する別のリクエストを構築し、操作を再試行できます。この例では、再試行リクエストの構築のみを行っています。
            * バッチ操作後に失敗した行を再試行できる Tablestore SDK のカスタムリトライポリシーを使用することを推奨します。リトライポリシーを指定すれば、操作を呼び出すために再試行コードを追加する必要がなくなります。
            */
           BatchWriteRowRequest retryRequest = batchWriteRowRequest.createRequestForRetry(response.getFailedRows());
       }
   }