5

我正在使用 spring-data-cassandra (1.3.1.RELEASE) 连接到 cassandra 数据库。有没有办法改变 spring-data-cassandra 中的一致性级别。默认情况下它是 1级（spring-data-cassandra 中的默认一致性级别是什么？）。但是如何改变呢？

谢谢！

4

7 回答 7

6

您现在可以通过在 application.properties 文件中设置以下属性来在 Spring Boot 中设置此级别。

spring.data.cassandra.consistency-level=quorum
spring.data.cassandra.serial-consistency-level=quorum
于 2017-04-11T14:17:34.667 回答
3

使用 spring-data-cassandra 的 CrudRepository 接口时，无法设置自定义一致性级别。有一个未解决的问题https://jira.spring.io/browse/DATACASS-14。原因是实现接口方法的 SimpleCassandraRepository 调用了没有 WriteOptions 参数的 CassandraOperations 方法。

我的解决方案：我编写了一个自定义 crudrepository 实现，在此我可以自己设置一致性级别。

于 2015-11-30T07:32:45.097 回答
2

文档说您可以将其设置为注释https://docs.spring.io/spring-data/cassandra/docs/current/reference/html/#cassandra.repositories.queries.options。

IMO，控制每个请求而不是每个应用程序的一致性级别总是更好。存储库：

public interface PersonRepository extends CrudRepository<Person, String> {

    @Consistency(ConsistencyLevel.LOCAL_ONE)
    List<Person> findByLastname(String lastname);

    List<Person> findByFirstname(String firstname, QueryOptions options);
}

Cassandra模板：

cassandraTemplate.insert(myEntity, new WriteOptions().builder()
                    .consistencyLevel(ConsistencyLevel.QUORUM).build())
于 2017-10-30T13:21:27.307 回答
1

这些是现在定义的一致性级别：
ANY、ONE、TWO、THREE、QUORUM、ALL、LOCAL_QUORUM、EACH_QUORUM、SERIAL、LOCAL_SERIAL、LOCAL_ONE。
如果您正在谈论使用除这些之外的其他方法，我认为现在没有可插入的解决方案，您可以在其中定义将参与断言所需一致性的节点数量。
如果您想使用任何上述定义的一致性，
例如： 

        Select s = QueryBuilder.select().from("employee");
        s.where(QueryBuilder.eq("id", "234"));
        s.setConsistencyLevel(ConsistencyLevel.QUORUM) ;
于 2015-11-26T15:24:54.910 回答
1

我不确定“如果您不使用引导并且想在全局范围内设置它，请试一试”是什么意思我使用了弹簧靴，这很有效

@Configuration     
public class CassandraConfig extends AbstractCassandraConfiguration {




@Override
public QueryOptions getQueryOptions() {
    QueryOptions queryOptions = new QueryOptions();
    queryOptions.setConsistencyLevel(ConsistencyLevel.TWO);
    return queryOptions;
}

@Override
protected String getKeyspaceName() {
    return keyspaceName;
}

@Override
public CassandraCqlClusterFactoryBean cluster() {
    CassandraCqlClusterFactoryBean cluster = super.cluster();
    cluster.setContactPoints(contactPoints);
    cluster.setPort(port);
    cluster.setUsername(username);
    cluster.setPassword(password);
    return cluster;
}
//Also added @Import to Main class

@Import(CassandraConfig.class)
@EnableJpaRepositories(basePackageClasses = Vexxxxxxy.class)
@EnableCassandraRepositories(basePackageClasses = Txxxxxry.class)
@EntityScan(basePackageClasses = { Entity.class, Vxxxxity.class })
@SpringBootApplication(scanBasePackages = "com.xx.xxx")
public class DrixxxxxxxxMain`
于 2018-08-16T14:57:48.203 回答
0

从spring-data-cassandra 1.5 版开始，一致性级别已经是可配置的（参见org.springframework.cassandra.core.QueryOptions#setConsistencyLevel(org.springframework.cassandra.core.ConsistencyLevel))

它可以通过 指定为QueryOptions单个查询的一部分，也可以通过 指定org.springframework.cassandra.core.CqlOperations#execute(java.lang.String, org.springframework.cassandra.core.QueryOptions)为所有类型的查询的一部分org.springframework.cassandra.core.CqlTemplate#addQueryOptions

也可以通过设置一致性级别WriteOptions，然后将它们传递给org.springframework.data.cassandra.core.CassandraOperations#insert(T, org.springframework.cassandra.core.WriteOptions)

于 2017-03-31T11:08:16.710 回答
0

一种可能性是在 application.properties 文件中设置它：spring.data.cassandra.consistency-level=LOCAL_QUORUM

于 2016-03-08T16:13:57.510 回答