我可以为Cassandra异步插入使用Spring Data 存储库接口吗?

edqdpe6u  于 2022-09-18  发布在  Cassandra
关注(0)|答案(1)|浏览(153)
@Repository
public interface RoundRepository extends CassandraRepository<Round, String> {
    List<Round> findByInstanceId(String instanceId, Pageable pageable);

    Round findByInstanceIdAndRound(String instanceId, long round);

    long countByInstanceId(String instanceId);
}

我有这样的储存库。我想用它们来执行异步插入和同步其他所有操作。我可以通过AsyncCassandraTemplate在没有本机查询的情况下以这种方式进行吗?我没有找到任何提示

yi0zb3m4

yi0zb3m41#

是的,Spring有一个关于通过自定义存储库方法获取异步查询结果的文档。基本上,您可以使用@Async注解,然后用*Future类型之一 Package 返回类型。

因此,在您的示例中,countByInstanceId可能如下所示:

@Async
ListenableFuture<long> countByInstanceId(String instanceId);

相关问题