如何在CqlSessionBuilder中以编程方式设置DcInferringLoadBalancingPolicy

Question

我使用的是4.4.0 datastax-java-driver。在我的方案中，我必须在连接到远程群集时提供联系人位置。如果我这样做，我会得到以下错误- Since you provided explicit contact points, the local DC must be explicitly set.我也没有选择来明确提供这一点，因为我是连接到不同的集群按需，这可能是在不同的数据中心。我找到了将DcInferringLoadBalancingPolicy设置为推断数据中心的选项，但我不确定如何在CqlSessionBuilder中设置此选项。请帮我弄一下这个。

Answer 1

你需要非常小心--它主要是为那些正在构建工具的人准备的，比如IDE等。对于应用程序本身，最好显式地传递数据中心名称-- either via config file, or via Java system property。

简而言之，可以这样做：

ProgrammaticDriverConfigLoaderBuilder configBuilder = 
     DriverConfigLoader.programmaticBuilder();
configBuilder.withClass(DefaultDriverOption.LOAD_BALANCING_POLICY_CLASS,
     DcInferringLoadBalancingPolicy.class);
DriverConfigLoader loader = configBuilder.endProfile().build();
CqlSessionBuilder clusterBuilder = CqlSession.builder()
            .addContactPoints(hosts);
CqlSession session = clusterBuilder.withConfigLoader(loader).build();