JPA多源資料庫配置（達夢資料庫）
- 1.準備作業
- 2.創建JPA配置
- 3.創建物體類
- 4.創建Repository
- 5.注解+切面實作兩個資料源事物統一
- 6.創建Service
- 7.創建Controller
本篇文章主要介紹SpringBoot框架實作Jpa多源資料庫的配置，本次使用國產資料庫達夢資料庫做為資料源，
1.準備作業
在pom.xml檔案中引入Spring Data Jpa依賴：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
在application.yml中添加資料庫的相關配置：
spring:
datasource:
one:
driver-class-name: dm.jdbc.driver.DmDriver
url: jdbc:dm://127.0.0.1:5236/TESTONE
username: TESTONE
password: 1234567890
type: com.alibaba.druid.pool.DruidDataSource
two:
driver-class-name: dm.jdbc.driver.DmDriver
url: jdbc:dm://127.0.0.1:5237/TESTTWO
username: TESTTWO
password: 1234567890
type: com.alibaba.druid.pool.DruidDataSource
jpa:
properties:
hibernate.dialect: org.hibernate.dialect.Oracle10gDialect
show-sql: ture
撰寫DataSourceConfig組態檔：
@Configuration
public class DataSourceConfig {
@Bean
@ConfigurationProperties("spring.datasource.one")
@Primary
DataSource dsOne(){
return DruidDataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties("spring.datasource.two")
DataSource dsTwo(){
return DruidDataSourceBuilder.create().build();
}
}
2.創建JPA配置
根據配置好的資料源創建兩個不同的JPA配置，代碼如下（示例）：
第一個jpa配置：
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "org.xiaoyang.dao1",//持久層路徑
entityManagerFactoryRef = "entityManagerFactoryBeanOne",
transactionManagerRef = "platformTransactionManagerOne")
public class JpaConfigOne {
@Resource(name = "dsOne")
DataSource dsOne;
@Autowired
JpaProperties jpaProperties;
@Bean
@Primary
LocalContainerEntityManagerFactoryBean entityManagerFactoryBeanOne(EntityManagerFactoryBuilder builder){
return builder.dataSource(dsOne)
.properties(jpaProperties.getProperties())
.packages("org.xiaoyang.entity")//物體類路徑
.persistenceUnit("pu1")
.build();
}
@Bean
PlatformTransactionManager platformTransactionManagerOne(EntityManagerFactoryBuilder builder){
LocalContainerEntityManagerFactoryBean factoryOne = entityManagerFactoryBeanOne(builder);
return new JpaTransactionManager(factoryOne.getObject());
}
}
第二個jpa配置：
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = "org.xiaoyang.dao2",//持久層路徑
entityManagerFactoryRef = "entityManagerFactoryBeanTwo",
transactionManagerRef = "platformTransactionManagerTwo")
public class JpaConfigOne {
@Resource(name = "dsTwo")
DataSource dsTwo;
@Autowired
JpaProperties jpaProperties;
@Bean
LocalContainerEntityManagerFactoryBean entityManagerFactoryBeanTwo(EntityManagerFactoryBuilder builder){
return builder.dataSource(dsTwo)
.properties(jpaProperties.getProperties())
.packages("org.xiaoyang.entity")//物體類路徑
.persistenceUnit("pu1")
.build();
}
@Bean
PlatformTransactionManager platformTransactionManagerTwo(EntityManagerFactoryBuilder builder){
LocalContainerEntityManagerFactoryBean factoryOne = entityManagerFactoryBeanTwo(builder);
return new JpaTransactionManager(factoryOne.getObject());
}
}
3.創建物體類
在org.xiaoyang.entity包（包路徑一定要和JPA配置類中的路徑相同）創建物體類User：
@Entity(name="t_user")
public class User{
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
private String name;
private String age;
//省略getter/setter方法
}
4.創建Repository
分別在org.xiaoyang.dao1包和org.xiaoyang.dao2包（包路徑一定要和JPA配置類中的路徑相同）創建Repository：
UserDao1代碼如下：
public interface UserDao1 extends JpaRepository<User,Integer>{}
UserDao2代碼如下：
public interface UserDao2 extends JpaRepository<User,Integer>{}
5.注解+切面實作兩個資料源事物統一
撰寫獲取事務管理器陣列的注解：
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface MultiDataSourceTransactional {
/**
* 事務管理器陣列
*/
String[] transactionManagers();
}
撰寫通過注解+切面實作兩個資料源事物統一的配置類：
/**
* 注解+切面實作兩個資料源事物統一
*/
@Component
@Aspect
public class MultiDataSourceTransactionAspect {
/**
* 執行緒本地變數：為什么使用堆疊？※為了達到后進先出的效果※
*/
private static final ThreadLocal<Stack<Pair<JpaTransactionManager, TransactionStatus>>> THREAD_LOCAL = new ThreadLocal<>();
/**
* 用于獲取事務管理器
*/
@Autowired
private ApplicationContext applicationContext;
/**
* 事務宣告
*/
private DefaultTransactionDefinition def = new DefaultTransactionDefinition();
{
// 非只讀模式
def.setReadOnly(false);
// 事務隔離級別：采用資料庫的
def.setIsolationLevel(TransactionDefinition.ISOLATION_DEFAULT);
// 事務傳播行為
def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
}
/**
* 切面
* 路徑必須和撰寫獲取事務管理器陣列的注解路徑相同
*/
@Pointcut("@annotation(org.xiaoyang.anotations.MultiDataSourceTransactional)")
public void pointcut() {
}
/**
* 宣告事務
*
* @param transactional 注解
*/
@Before("pointcut() && @annotation(transactional)")
public void before(MultiDataSourceTransactional transactional) {
// 根據設定的事務名稱按順序宣告，并放到ThreadLocal里
String[] transactionManagerNames = transactional.transactionManagers();
Stack<Pair<JpaTransactionManager, TransactionStatus>> pairStack = new Stack<>();
for (String transactionManagerName : transactionManagerNames) {
JpaTransactionManager transactionManager = applicationContext.getBean(transactionManagerName, JpaTransactionManager.class);
TransactionStatus transactionStatus = transactionManager.getTransaction(def);
pairStack.push(new Pair(transactionManager, transactionStatus));
}
THREAD_LOCAL.set(pairStack);
System.out.println("====pairStack size========");
}
/**
* 提交事務
*/
@AfterReturning("pointcut()")
public void afterReturning() {
// ※堆疊頂彈出（后進先出）
Stack<Pair<JpaTransactionManager, TransactionStatus>> pairStack = THREAD_LOCAL.get();
while (!pairStack.empty()) {
Pair<JpaTransactionManager, TransactionStatus> pair = pairStack.pop();
pair.getKey().commit(pair.getValue());
}
THREAD_LOCAL.remove();
}
/**
* 回滾事務
*/
@AfterThrowing(value = "pointcut()")
public void afterThrowing() {
// ※堆疊頂彈出（后進先出）
Stack<Pair<JpaTransactionManager, TransactionStatus>> pairStack = THREAD_LOCAL.get();
while (!pairStack.empty()) {
Pair<JpaTransactionManager, TransactionStatus> pair = pairStack.pop();
pair.getKey().rollback(pair.getValue());
}
THREAD_LOCAL.remove();
}
}
6.創建Service
通過Service呼叫Dao層并配置注解實作業務邏輯：
UserService代碼如下：
public interface UserService {
//兩個庫同時增加資料
void addUser(User user);
//資料庫一增加資料
void addUserOne(User user);
//資料庫二增加資料
void addUserTwo(User user);
}
UserServiceImpl代碼如下：
@Service
public class UserServiceImpl implements UserService {
@Autowired
private UserDao1 userDao1;
@Autowired
private UserDao2 userDao2;
//同時操作兩個資料庫需要呼叫自定義注解添加事務組
@Override
@MultiDataSourceTransactional(transactionManagers = {"platformTransactionManagerOne","platformTransactionManagerTwo"})
public void addUser(User user) {
try {
user.setName("小洋同學");
user.setAge("23");
userDao1.save(user);
userDao2.save(user);
} catch (Exception e) {
e.printStackTrace();
}
}
//單獨操作資料庫需要標明事務的名稱
@Override
@Transactional("platformTransactionManagerOne")
public void addUserOne(User user) {
try {
user.setName("小洋同學111");
user.setAge("23");
userDao1.save(user);
} catch (Exception e) {
e.printStackTrace();
}
}
//單獨操作資料庫需要標明事務的名稱
@Override
@Transactional("platformTransactionManagerTwo")
public void addUserTwo(User user) {
try {
user.setName("小洋同學222");
user.setAge("23");
userDao2.save(user);
} catch (Exception e) {
e.printStackTrace();
}
}
}
7.創建Controller
通過Controller呼叫Service層實作介面功能，代碼如下：
@RestController
public class UserController {
@Autowired
private UserService userService;
@RequestMapping("/adduser")
public void addUser() {
User user= new User();
userService.addUser(user);
}
@RequestMapping("/adduserone")
public void addUserOne() {
User user= new User();
userService.addUserOne(user);
}
@RequestMapping("/addusertwo")
public void addUserTwo() {
User user= new User();
userService.addUserTwo(user);
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/199090.html
標籤：其他
上一篇：約瑟夫環