Cassandra Datastax saveQuery 与轻量级事务

Question

我正在尝试通过 BatchStatement 将对象持久化到 cassandra

import com.datastax.driver.mapping.Mapper;

batch.add(mapper.saveQuery(itr.next()));

而且我想有 IF NOT EXISTS 子句像

INSERT INTO customer_account (customerID, customer_email) 
VALUES (‘LauraS’, ‘lauras@gmail.com’)
IF NOT EXISTS;

我应该如何通过 saveQuery 实现 IF NOT EXISTS？

Answer 1

不幸的是，映射 API 仅支持简单的 CRUD 操作，因此在这种情况下，轻量级事务是不可能的。您可以使用两种方法来解决此问题：

1. 使用映射访问器，那么您的代码将如下所示 访问接口：

   @Accessor
   public interface UserAccessor {
       @Query("INSERT INTO sandbox.user (user_id, name) VALUES (:userId, :name) IF NOT EXISTS")
       Statement insertUser(@Param("userId") UUID userId, @Param("name") String name);
   }
   

   代码中的某处：

   Statement statement = userAccessor.insertUser(user.getUserId(), user.getName());
   

   然后你可以把声明放在BatchStatement

2. 使用查询生成器：

   Insert insert = new QueryBuilder(cluster).insertInto("sundbox", "user")
           .value("user_id", user.getUserId())
           .value("name", user.getName())
           .ifNotExists();
   

   Insert 是Statement 的子类型，因此您也可以将它放在BatchStatement 中。注意，我用的是Driver 2.2.0，所以我用new QueryBuilder(cluster).insertInto(...，如果你用较低的驱动版本，你应该用QueryBuilder.insertInto(...