java - 如何使用 Cassandra Java Driver 为所有查询设置一致性级别？

Question

在早期版本中我会做这样的事情:

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

我找不到使用 DataStax Java Driver 4.2 执行此操作的方法

我能找到的最接近的是

boundStatement.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE);

但我想为所有查询设置级别。

Answer 1

在 Java 驱动程序 4.x 中，配置是通过其他方式完成的 - 您可以在 application.conf 文件中指定配置选项(首选方法)，或者通过 DriverConfigLoader.programmaticBuilder< 以编程方式指定它(主要用于工具构建者)。参见 driver documentation for details .

对于您的情况，您需要为以下配置参数指定值(有关详细信息，请参阅 configuration reference，也在 source code 中):

• datastax-java-driver.basic.request.consistency 用于“正常”请求；
• datastax-java-driver.basic.request.serial-consistency 用于轻量级事务；

附言最好升级到最新版本 - 昨天发布了 4.6.0...