Springboot：在同一项目中同时导入spring数据jdbc和spring数据cassandra时出现问题

Question

在我的springboot应用程序中，我想连接到两个数据源，一个cassandra数据库和一个oracle数据库。

因此，我将以下内容添加到我的pom中.xml：

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-cassandra</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jdbc</artifactId>
    </dependency>

这是orOracle DB的存储库：

import org.springframework.data.jdbc.repository.query.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

@Repository
public interface TestRepository extends ReadRepository<TestEntity, String> {

    @Query("select * from test_table where id = :distributorId fetch first 10 rows only")
    List<TestEntity> getResult(@Param("distributorId") String distributorId);
}

ReadRepostory扩展存储库

import org.springframework.data.repository.NoRepositoryBean;
import org.springframework.data.repository.Repository;

@NoRepositoryBean
public interface ReadRepository<T, ID> extends Repository<T, ID> {}

当我注释掉cassandra依赖时，这运行得很好：

<!-- <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-cassandra</artifactId>
</dependency> -->

但是当我添加cassandra依赖关系时，我开始看到这个错误:

***************************
APPLICATION FAILED TO START
***************************

Description:

The bean 'TestRepository', defined in null, could not be registered. A bean with that name has already been defined in null and overriding is disabled.

Action:

Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true

出于调试的目的，我删除了所有与cassandra相关的类（存储库、实体等），这样就不会在项目中的任何地方导入cassandrajar。因此，将其作为根本原因。

我不知道是什么导致了这个问题。从错误日志中，似乎 bean 正在尝试创建两次左右。但这怎么可能呢？

如果我添加属性，我会遇到一个不同的问题，这暗示cassandra import正试图对testRepository做些什么:

spring.main.allow-bean-definition-overriding=true

Error:
org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'testController': Unsatisfied dependency expressed through field 'TestRepository'; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'TestRepository': Cannot resolve reference to bean 'cassandraTemplate' while setting bean property 'cassandraTemplate'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'cassandraTemplate' defined in class path resource [org/springframework/boot/autoconfigure/data/cassandra/CassandraDataAutoConfiguration.class]: Unsatisfied dependency expressed through method 'cassandraTemplate' parameter 0; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'cassandraSession' defined in class path resource [org/springframework/boot/autoconfigure/data/cassandra/CassandraDataAutoConfiguration.class]: Invocation of init method failed; nested exception is com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/0:0:0:0:0:0:0:1:9042 (com.datastax.driver.core.exceptions.TransportException: [localhost/0:0:0:0:0:0:0:1:9042] Cannot connect), localhost/127.0.0.1:9042 (com.datastax.driver.core.exceptions.TransportException: [localhost/127.0.0.1:9042] Cannot connect))

有人可以帮忙吗？提前谢谢。

Answer 1

试试这个

@Configuration
@EnableCassandraRepositories(
  basePackages = "base package where you have kept your cassandra jpa")
public class CassandraConfig extends AbstractCassandraConfiguration {

}

Answer 2

使用 cassandra 依赖项时，您将获得 cassandra java 驱动程序。

驱动程序试图在启动时连接到Cassandra，以获取集群节点(自动发现)、连接池、保持活动、每个节点的哈希键范围等信息。

正如错误所述，您无法连接到本地主机上的 Cassandra 数据库：

nested exception is com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: localhost/0:0:0:0:0:0:0:1:9042
(com.datastax.driver.core.exceptions.TransportException:
[localhost/0:0:0:0:0:0:0:1:9042] Cannot connect), localhost/127.0.0.1:9042 
(com.datastax.driver.core.exceptions.TransportException: [localhost/127.0.0.1:9042] 
Cannot connect))

尝试使用cql客户端连接到您的Cassandra集群：

cqlshlocalhost-u cassandra-p cassandra

如果失败，卡桑德拉可能会离线，您需要启动它：

须藤DSE卡桑德拉-R

有关更多信息，请查看此处：https://docs.datastax.com/en/developer/java-driver/3.0/#troubleshooting