使用Spring Data JDBC和CrudRepository接口实现多数据源

Question

我有一个重要的问题：

null

这是一个简单的4步过程：

1. 定义属性
2. 定义您的实体
3. 定义扩展CrudRepository和
的接口
4. 使用该接口

但是在使用两个数据库的情况下，有一个5。必须定义@configuration类的步骤。

 <dependencies>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-jdbc</artifactId>
    </dependency>
    <dependency>
      <groupId>com.h2database</groupId>
      <artifactId>h2</artifactId>
      <scope>runtime</scope>
    </dependency>
    <dependency>
      <groupId>org.projectlombok</groupId>
      <artifactId>lombok</artifactId>
      <optional>true</optional>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-test</artifactId>
      <scope>test</scope>
      <exclusions>
        <exclusion>
          <groupId>org.junit.vintage</groupId>
          <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
  </dependencies>

## D1
datasource.db1.driverClassName=...
datasource.db1.username=...
datasource.db1.password=...
datasource.db1.jdbcUrl=...
## D2
datasource.db2.driverClassName=...
datasource.db2.username=...
datasource.db2.password=...
datasource.db2.jdbcUrl=...

@Table("STUDENT_TABLE")
public class Student{
    @Id
    @Column("MAT_NR")
    private BigDecimal matNr;

    @Column("NAME")
    private String name;
}

@Table("TEACHER_TABLE")
public class Teacher{
    @Id
    @Column("EMPLOYEE_NR")
    private BigDecimal employeeNr;

    @Column("NAME")
    private String name;
}

@Repository
public interface StudentRepository extends CrudRepository<Student, BigDecimal> {}

@Repository
public interface TeacherRepository extends CrudRepository<Teacher, BigDecimal> {}

• 您也可以在一门课上同时上两门课，但我是这样做的:

db1config.java

@Configuration
public class Db1Config {
    @Primary
    @Bean("db1DataSource")
    @ConfigurationProperties("datasource.db1")
    public DataSource db1DataSource() {
        return DataSourceBuilder.create().build();
    }
}

java db2config.java

@Configuration
public class Db2Config {
    @Bean("db2DataSource")
    @ConfigurationProperties("datasource.db2")
    public DataSource db2DataSource() {
        return DataSourceBuilder.create().build();
    }
}

@SpringBootApplication
public class Application implements CommandLineRunner {

    @Autowired @Qualifier("studentRepository") StudentRepository studentRepository
    @Autowired @Qualifier("teacherRepository") TeacherRepository teacherRepository 

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        studentRepository.findById(30688).ifPresent(System.out::println); // DB1
        teacherRepository.findById(5).ifPresent(System.out::println); // DB2
    }
}

谢谢你的帮助。

Answer 1

类似于Rimidal，我不相信这行得通。这里的文档表明您需要一个NamedParameterJdbcOperations Bean和一个TransactionManager Bean（可选）。https://docs.spring.io/spring-data/jdbc/docs/current/reference/html" target="_blank">html/#jdbc.java-config

NamedParameterJdbcOperations是CrudRepositories将用于访问数据库的JDBCTemplate。

似乎没有一种方法可以将不同名称的ParameterJDBCOperations/JDBCTemplates与不同的存储库关联起来。在我的测试中，这无论如何都不起作用。无论哪个命名的ParameterJDBCOperations Bean被标记为@Primary都是所有CrudRepository操作都要执行的操作，而不考虑将内容分离到不同的包中，并明确地告诉@Configuration类将哪些包与@EnableJDBCrepositories一起使用。