Tag: spring data cassandra

使用Cassandra 3.x驱动程序进行Spring Boot: 我使用Spring boot 1.3.8.RELEASE 。要使用cassandra 3.x驱动程序，我尝试了类似下面的内容; org.springframework.boot spring-boot-starter-data-cassandra org.springframework.data spring-data-cassandra org.springframework.data spring-data-cassandra 1.4.0.RELEASE com.datastax.cassandra cassandra-driver-core com.datastax.cassandra cassandra-driver-dse com.datastax.cassandra cassandra-driver-core 3.1.0 但我得到错误; Caused by: java.lang.NoSuchMethodError: com.datastax.driver.core.DataType.asJavaClass()Ljava/lang/Class; at org.springframework.data.cassandra.mapping.CassandraSimpleTypeHolder.(CassandraSimpleTypeHolder.java:62) ~[spring-data-cassandra-1.4.0.RELEASE.jar:?] 我在https://github.com/spring-projects/spring-boot/issues/5835尝试了这个原因，有一个post; 在Spring Data Cassandra 1.5（Ingalls）中采用Cassandra 3更改并不会对Spring Boot进行重大更改。使用Boot 1.3.3和1.4.0-SNAPSHOT测试升级。它不应该像上面那样吗？我哪里错了？注意：我正在尝试这个例子： https ： //github.com/spring-projects/spring-boot/tree/master/spring-boot-samples/spring-boot-sample-data-cassandra

如何在同一个Spring启动应用程序中配置neo4j和cassandra存储库: 我使用spring-data分别使用spring boot配置了neo4j和cassandra存储库。但是，当我尝试在同一个项目中使用两个存储库时，它无法按预期工作。这是我的文件夹结构。 —– org.test.project —–controller BarController FooController —–models —–dao —–cassandra BarDAO FooDAO —–neo4j BarDAO FooDAO —–repositories —–cassandra BarRepository FooRepository —–neo BarRepository FooRepository —–services CassandraService (Has cassandra repositories @Autowired) NeoService(Has neo repositories @Autowired) TestApp.java 请注意，所有存储库都使用相应的DAO扩展相应的spring-datarepository。当我使用此配置运行时，它会出现以下错误。 Field airportRepository in org.test.project.TestApp required a bean of type ‘org.test.project.repositories.cassandra.BarRepository’ that could not be found. 我尝试更改存储库名称。然后它开始工作。第一个问题是，我们不能在不同的包装中使用相同的名称并开始工作 […]

使用带有jodatime对象的cassandra实体时构建中断: 我正在使用spring-data-cassandra设置一个带弹簧启动的小项目。当我在@Table对象上有joda time Datetime时，我意识到我的测试中断了。堆栈显示如下错误： Caused by: org.springframework.data.cassandra.mapping.VerifierMappingExceptions: org.joda.time.Chronology: Cassandra entities must have the @Table, @Persistent or @PrimaryKeyClass Annotation 我的配置如下： @Configuration @EnableCassandraRepositories(basePackages =”com.myproject.cassandra.repository”) @ComponentScan(basePackages = “com.myproject.cassandra”) @EnableAutoConfiguration class CassandraConfiguration { private static ConfigContext confitConfig = ConfigContext.lookup(); //private static AdminContext confitAdmin = AdminContext.lookup(); DataSource cassandraDataSource static { confitConfig.register(DataSource.class); } Collection dataSources = confitConfig.list(DataSource.class) CassandraConfiguration() { cassandraDataSource […]

带有Spring Data和Cassandra @Query的IN子句: 我正在尝试使用IN子句和Spring Data中的@Query注释来查询Cassandra表。我有一个表，其分区键为last_name，聚类键为first_name。我有这个查询工作 @Query(“SELECT * FROM people WHERE last_name=?0”) public List findByLastName(String lastName); 我想做点什么 @Query(“SELECT * FROM people WHERE last_name=?0 AND first_name IN ?1”) public List findByLastName(String lastName, String[] firstName); 我有它正在使用 CassandraOperations.select(“SELECT * FROM people WHERE last_name=” + lastName + ” AND first_name IN (” + concatinatedNameList + “)”, People.class); 但由于一些原因（代码风格，测试，我发誓还有更多）我更喜欢使用@Query。有任何想法吗？编辑更多信息！传入一个数组，设置或列表返回Caused […]

Spark与Cassandra输入/输出: 想象一下以下场景：Spark应用程序（Java实现）正在使用Cassandra数据库加载，转换为RDD并处理数据。该应用程序还从数据库中蒸出新数据，这些数据也由自定义接收器处理。流处理的输出存储在数据库中。该实现使用Spring Data Cassandra与数据库集成。 CassandraConfig： @Configuration @ComponentScan(basePackages = {“org.foo”}) @PropertySource(value = { “classpath:cassandra.properties” }) public class CassandraConfig { @Autowired private Environment env; @Bean public CassandraClusterFactoryBean cluster() { CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean(); cluster.setContactPoints(env.getProperty(“cassandra.contactpoints”)); cluster.setPort(Integer.parseInt(env.getProperty(“cassandra.port”))); return cluster; } @Bean public CassandraMappingContext mappingContext() { return new BasicCassandraMappingContext(); } @Bean public CassandraConverter converter() { return new […]