OBKV-Tableへのデータ書き込み

@Test
public void testSingleInsert() throws Exception {
    try {
        // データの挿入
        // パーティションキー c1 の値は setPartitionKey を使用して設定する必要があります。
        // c1 の値は addMutateColVal を使用して設定する必要もあります。
        MutationResult result = client.insert("test")
            .setPartitionKey(row(colVal("c1", 1000L)))
            .addMutateColVal(colVal("c1", 1000L), colVal("c2", "test1"), colVal("c3", 3000L))
            .execute();

        assertEquals("Insert should affect 1 row", 1, result.getAffectedRows());
        System.out.println("Single insert successful: " + result + " row affected");
    } finally {
        // データのクリア
        truncateTable();
    }
}

@Test
public void testSingleInsertOrUpdate1() throws Exception {
    try {
        // データの挿入
        // パーティションキー c1 の値を setPartitionKey で設定する必要があります。
        // また、c1 の値は addMutateColVal で設定する必要があります。
        MutationResult result = client.insertOrUpdate(tableName)
            .setPartitionKey(row(colVal("c1", 1000L)))
            .addMutateColVal(colVal("c1", 1000L), colVal("c2", "test1"), colVal("c3", 3000L))
            .execute();

        assertEquals("Insert should affect 1 row", 1, result.getAffectedRows());
        System.out.println("Single insertOrUpdate successful: " + result + " row affected");
    } finally {
        // データのクリア
        truncateTable();
    }
}

@Test
public void testSingleReplace1() throws Exception {
    try {
        // データの挿入
        // パーティションキー c1 の値は setPartitionKey で設定する必要があります。
        // c1 の値は addMutateColVal でも設定する必要があります。
        MutationResult result = client.replace(tableName)
            .setPartitionKey(row(colVal("c1", 1000L)))
            .addMutateColVal(colVal("c1", 1000L), colVal("c2", "test1"), colVal("c3", 3000L))
            .execute();

        assertEquals("Insert should affect 1 row", 1, result.getAffectedRows());
        System.out.println("Single replace successful: " + result + " row affected");
    } finally {
        // データのクリア
        truncateTable();
    }
}

@Test
public void testBatchInsert() throws Exception {
    try {
        // BatchOperationを使用したバッチ挿入
        BatchOperation batch = client.batchOperation("test");

        // 複数の挿入操作を追加
        // パーティションキー c1 の値は setPartitionKey を使用して設定する必要があることに注意してください。
        // c1 の値は addMutateColVal を使用しても設定する必要があります。
        for (int i = 1; i <= 3; i++) {
            Insert insert = new Insert();
            insert.setPartitionKey(row(colVal("c1", (long)(1000 + i))))
                .addMutateColVal(colVal("c1", (long)(1000 + i)), colVal("c2", "batch_test" + i), colVal("c3", (long)(3000 + i)));
            batch.addOperation(insert);
        }

        batch.execute();
        System.out.println("Batch insert successful: 3 operations executed");
    } finally {
        // データのクリア
        truncateTable();
    }
}

@Test
public void testBatchInsertOrUpdate1() throws Exception {
    try {
        // BatchOperationを使用した一括挿入
        BatchOperation batch = client.batchOperation(tableName);

        // 複数の挿入操作を追加
        // パーティションキーc1の値をsetPartitionKeyで設定する必要があります。
        // 同様に、addMutateColValを使用してc1の値も設定する必要があります。
        for (int i = 1; i <= 3; i++) {
            InsertOrUpdate insertOrUpdate = new InsertOrUpdate();
            insertOrUpdate.setPartitionKey(row(colVal("c1", (long)(1000 + i))))
                .addMutateColVal(colVal("c1", (long)(1000 + i)), colVal("c2", "batch_test" + i), colVal("c3", (long)(3000 + i)));
            batch.addOperation(insertOrUpdate);
        }

        batch.execute();
        System.out.println("Batch insertOrUpdate successful: 3 operations executed");
    } finally {
        // データのクリア
        truncateTable();
    }
}

@Test
public void testBatchReplace1() throws Exception {
    try {
        // BatchOperationを使用した一括挿入
        BatchOperation batch = client.batchOperation(tableName);

        // 複数のreplace操作を追加
        // パーティションキーc1の値はsetPartitionKeyで設定する必要があります。
        // c1の値はaddMutateColValでも設定する必要があります。
        for (int i = 1; i <= 3; i++) {
            Replace replace = new Replace();
            replace..setPartitionKey(row(colVal("c1", (long)(1000 + i))))
                .addMutateColVal(colVal("c1", (long)(1000 + i)), colVal("c2", "batch_test" + i), colVal("c3", (long)(3000 + i)));
            batch.addOperation(replace);
        }

        batch.execute();
        System.out.println("Batch replace successful: 3 operations executed");
    } finally {
        // データのクリア
        truncateTable();
    }
}