如何使用cassandrajava驱动程序为所有查询设置一致性级别?

c6ubokkw  于 2021-06-13  发布在  Cassandra
关注(0)|答案(1)|浏览(405)

在早期版本中,我会这样做:

QueryOptions queryOptions = new QueryOptions();
queryOptions.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE)
cluster = Cluster.builder()
        .withQueryOptions(queryOptions)
        ...
        .build();

我找不到用DataStaxJava驱动程序4.2实现这一点的方法
我能找到的最接近的就是 boundStatement.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE); 但我想为所有查询设置级别。

50few1ms

50few1ms1#

在JavaDriver4.x中,配置是以另一种方式完成的—您可以在 application.conf 文件(首选方法),或通过 DriverConfigLoader.programmaticBuilder (主要用于工具生成器)。有关详细信息,请参阅驱动程序文档。
对于您的情况,需要为以下配置参数指定值(有关详细信息,请参阅源代码中的配置参考): datastax-java-driver.basic.request.consistency 对于“正常”请求; datastax-java-driver.basic.request.serial-consistency 对于轻量级事务;
p、 最好升级到最新版本-昨天发布了4.6.0。。。

相关问题