Spring Boot中如何配置不同数据源的事务管理?
时间: 2024-09-13 19:18:25 浏览: 50
在Spring Boot中配置不同数据源的事务管理涉及到配置多个DataSource Bean,并且为每个数据源定义一个对应的PlatformTransactionManager。以下是基本步骤:
1. 配置两个或多个DataSource Bean:你需要为每个数据源创建一个DataSource Bean,并配置相应的连接信息。
```java
@Bean
@ConfigurationProperties(prefix="spring.datasource.db1")
public DataSource dataSource1() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix="spring.datasource.db2")
public DataSource dataSource2() {
return DataSourceBuilder.create().build();
}
```
2. 配置相应的EntityManagerFactory:为每个数据源配置EntityManagerFactory。
```java
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory1(EntityManagerFactoryBuilder builder,
@Qualifier("dataSource1") DataSource dataSource1) {
return builder
.dataSource(dataSource1)
.packages("com.example.domain.db1")
.persistenceUnit("db1")
.build();
}
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory2(EntityManagerFactoryBuilder builder,
@Qualifier("dataSource2") DataSource dataSource2) {
return builder
.dataSource(dataSource2)
.packages("com.example.domain.db2")
.persistenceUnit("db2")
.build();
}
```
3. 配置PlatformTransactionManager:为每个数据源配置一个PlatformTransactionManager。
```java
@Bean
public PlatformTransactionManager transactionManager1(EntityManagerFactory entityManagerFactory1) {
return new JpaTransactionManager(entityManagerFactory1);
}
@Bean
public PlatformTransactionManager transactionManager2(EntityManagerFactory entityManagerFactory2) {
return new JpaTransactionManager(entityManagerFactory2);
}
```
4. 使用@Transactional注解时指定相应的事务管理器:在需要事务管理的方法上使用@Transactional注解,并通过transactionManager属性指定使用的事务管理器。
```java
@Transactional("transactionManager1")
public void performActionOnDb1() {
// ...
}
@Transactional("transactionManager2")
public void performActionOnDb2() {
// ...
}
```
5. 在application.properties或application.yml中配置相应的数据源和事务属性。
```yaml
spring:
datasource:
db1:
url: jdbc:mysql://localhost:3306/db1
username: db1user
password: db1pass
db2:
url: jdbc:mysql://localhost:3306/db2
username: db2user
password: db2pass
```
阅读全文