我有一个不简单的问题:
我的情况:
- 使用Spring Data JDBC
- 使用两个数据库
- 的使用
CrudRepository
正如您在Spring Data JDBC中看到的那样,您可以使用Spring开箱即用地获得所有 Crud 操作 - 无需显式实现!extends CrudRepository
这是一个简单的 4 步过程:
- 定义你的属性
- 定义你的实体
- 定义一个扩展 CrudRepository 的接口和
- 使用该接口
但是在使用两个数据库的情况下,有一个 5. 必须定义一个@Configuration
类的步骤。
我做了这5个步骤如下:
0.Pom.xml
<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>
1. 定义你的属性
应用程序属性
## 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=...
2.定义您的实体(每个数据库一个)
Student.java // 用于 db1
@Table("STUDENT_TABLE")
public class Student{
@Id
@Column("MAT_NR")
private BigDecimal matNr;
@Column("NAME")
private String name;
}
Teacher.java // 用于 db2
@Table("TEACHER_TABLE")
public class Teacher{
@Id
@Column("EMPLOYEE_NR")
private BigDecimal employeeNr;
@Column("NAME")
private String name;
}
3. 定义您的存储库(每个数据库一个)
StudentRepository.java // 用于 DB1
@Repository
public interface StudentRepository extends CrudRepository<Student, BigDecimal> {}
TeacherRepository.java // 对于 DB2
@Repository
public interface TeacherRepository extends CrudRepository<Teacher, BigDecimal> {}
4. 定义您的@Configuration 类(每个数据库一个)
- 你也可以在一门课上两门课,但我是这样做的:
Db1Config.java
@Configuration
public class Db1Config {
@Primary
@Bean("db1DataSource")
@ConfigurationProperties("datasource.db1")
public DataSource db1DataSource() {
return DataSourceBuilder.create().build();
}
}
Db2Config.java
@Configuration
public class Db2Config {
@Bean("db2DataSource")
@ConfigurationProperties("datasource.db2")
public DataSource db2DataSource() {
return DataSourceBuilder.create().build();
}
}
5.利用你的接口存储库
应用程序.java
@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
}
}
这些工作正常!
这里的问题是,TeacherRepository
不是查询 DB2,而是查询 DB1。
这会导致错误:[...]: Unknown table name:TEACHER
。
有谁知道我如何配置 TeacherRepository 使用 DB2 作为 DataSource ?
# 回答前请注意:
这里我使用的是Spring Data JDBC而不是Spring Data JPA。我知道它可以在Spring Data JPA中工作,如此处所述https://www.baeldung.com/spring-data-jpa-multiple-databases。我也知道我可以利用这些JdbcTemplate
。但是这样,我必须自己编写这些 CRUD 操作,这些操作在这里描述,这不是需要的。
一个答案当然会很好。
谢谢你的帮助。