数据税驱动程序MapAPI

xv8emn3q  于 2022-09-27  发布在  Cassandra
关注(0)|答案(1)|浏览(240)

有人知道Datastax是否已经或正在计划发布对批处理语句的Map/注解支持吗?我喜欢新的Map和注解抽象,但还没有看到批处理语句。

yqyhoc1h

yqyhoc1h1#

您可以通过从注解和Map对象中获取语句并将它们添加到批处理中来实现这一点。
使用@Accessor注解,您可以从Accessor中获取语句,然后将其添加到批处理中
下面是单元测试的一个示例。后访问器。updateCountQuery是@Accessor注解接口中定义的语句:

@Accessor
public interface PostAccessor {
    @Query("UPDATE ks.posts SET content=? WHERE user_id=? AND post_id=?")
    public Statement updateContentQuery(String newContent, UUID userId, UUID postId);
}

然后可以以下列方式生成和使用该语句:

BatchStatement batch = new BatchStatement();
batch.add(postAccessor.updateContentQuery("Something different", p1.getUserId(), p1.getPostId()));
batch.add(postAccessor.updateContentQuery("A different something", p2.getUserId(), p2.getPostId()));
manager.getSession().execute(batch);

对于带有Crud操作的Pojos,您可以简单地调用“mapper”。saveQuery(实体)'以获取语句,然后将其添加到批处理中。
从我获得此信息的用户列表发帖。

相关问题