在较早的版本中,我会做这样的事情:
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);
但是我想为所有查询设置级别。
[在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
用于轻量级交易;P.S。最好升级到最新版本-昨天发布了4.6.0 ...