Cassandra Spring 数据多租户

Question

因此，我即将将多租户（每个租户一个键空间）方面与 spring-boot-starter-data-cassandra-reactive 集成，我尝试找到一种解决方案来访问正确的键空间，我发现了这种使用查询构建器：

Select select = QueryBuilder.select().from(tenantId,"counter");
select.where(QueryBuilder.eq("id", 1));
Mono<Counter> flux = reactiveCassandraOperations.selectOne(select.toString(), Counter.class);

我发现它在开发时间方面成本高昂，特别是如果我们有插入请求.. 根据您的经验，有一个实用的解决方案，我可以使用 ReactiveCassandraRepository 方法（保存、更新、findById ..）插入键空间名称，

请您支持并提前致谢。

Answer 1

不是 Cassandra 或 Spring 专家，但我被告知您应该使用 ReactiveCqlTemplate （或 ReactiveCqlOperations）而不是 ReactiveCassandraTemplate （或 ReactiveCassandraOperations）。请参阅此链接 https://github.com/spring-projects/spring -data-cassandra/issues/1218 并点击此页面中的链接。

从链接中，您可以从 CassandraTemplate 获取 CqlOperations，如下所示

private final ReactiveCqlOperations cqlOps;
private final YourRepository repository;

@Autowired
public YourService(YourRepository repository, ReactiveCassandraTemplate reactiveCassandraTemplate){
    this.repository = repository;
    this.cqlOps = reactiveCassandraTemplate.getReactiveCqlOperations();
}

然后在您的存储库中

public interface YourRepository extends ReactiveCassandraRepository<YourData, Long> {

default Flux<YourData> getCQL(ReactiveCqlOperations cqlOps, YourData yourData) {
    return cqlOps.query("SELECT * FROM genericdatadb.YourData WHERE val0 = ? AND val1 = ?;",
            YourRepository.YourDataMapper.INSTANCE,
            yourData.getVal0(),
            yourData.getVal1());
}

在查询中 genericdatadb 是键空间，YourData 是表。从这里，您可以添加“？”其中 genericdatadb 是或使用 String.format 语句创建查询字符串。也许 Cassandra 专家有更好的解决方案？