av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

SpringBoot使用Atomikos技術整合多數據源的實現

瀏覽:73日期:2023-03-22 09:27:42

Atomikos是一個為Java平臺提供增值服務的并且開源類事務管理器,如果將事務統一注冊到Atomikos中,則可以統一管理。常用于后臺管理系統的多數據庫操作。

多數據源的劃分方式

方式: a、按包名 b、按注解區分Springboot默認集成事務,只主要在方法上加上@Transactional即可,不需要開啟@EnableTransactionManagement注解如果多個數據庫,則每個方法都需要單獨設置事務管理器@Transactional(transactionManager = 'test2TransactionManager'),如果事務中含多數據源則無效。

Atomikos使用

1.依賴引入

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jta-atomikos</artifactId></dependency>

2.多數據源配置文件

# Mysql 1mysql.datasource.test1.url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8mysql.datasource.test1.username = rootmysql.datasource.test1.password = rootmysql.datasource.test1.minPoolSize = 3mysql.datasource.test1.maxPoolSize = 25mysql.datasource.test1.maxLifetime = 20000mysql.datasource.test1.borrowConnectionTimeout = 30mysql.datasource.test1.loginTimeout = 30mysql.datasource.test1.maintenanceInterval = 60mysql.datasource.test1.maxIdleTime = 60# Mysql 2mysql.datasource.test2.url =jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8mysql.datasource.test2.username =rootmysql.datasource.test2.password =rootmysql.datasource.test2.minPoolSize = 3mysql.datasource.test2.maxPoolSize = 25mysql.datasource.test2.maxLifetime = 20000mysql.datasource.test2.borrowConnectionTimeout = 30mysql.datasource.test2.loginTimeout = 30mysql.datasource.test2.maintenanceInterval = 60mysql.datasource.test2.maxIdleTime = 60

3.配置代碼

@Data@ConfigurationProperties(prefix = 'mysql.datasource.test1')public class DBConfig1 { private String url; private String username; private String password; private int minPoolSize; private int maxPoolSize; private int maxLifetime; private int borrowConnectionTimeout; private int loginTimeout; private int maintenanceInterval; private int maxIdleTime; private String testQuery;}@Data@ConfigurationProperties(prefix = 'mysql.datasource.test2')public class DBConfig2 { private String url; private String username; private String password; private int minPoolSize; private int maxPoolSize; private int maxLifetime; private int borrowConnectionTimeout; private int loginTimeout; private int maintenanceInterval; private int maxIdleTime; private String testQuery;}@Configuration// basePackages 最好分開配置 如果放在同一個文件夾可能會報錯@MapperScan(basePackages = 'com.itmayiedu.test01', sqlSessionTemplateRef = 'testSqlSessionTemplate')public class MyBatisConfig1 { // 配置數據源 @Primary @Bean(name = 'testDataSource') public DataSource testDataSource(DBConfig1 testConfig) throws SQLException { MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource(); mysqlXaDataSource.setUrl(testConfig.getUrl()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); mysqlXaDataSource.setPassword(testConfig.getPassword()); mysqlXaDataSource.setUser(testConfig.getUsername()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean(); xaDataSource.setXaDataSource(mysqlXaDataSource); xaDataSource.setUniqueResourceName('testDataSource'); xaDataSource.setMinPoolSize(testConfig.getMinPoolSize()); xaDataSource.setMaxPoolSize(testConfig.getMaxPoolSize()); xaDataSource.setMaxLifetime(testConfig.getMaxLifetime()); xaDataSource.setBorrowConnectionTimeout(testConfig.getBorrowConnectionTimeout()); xaDataSource.setLoginTimeout(testConfig.getLoginTimeout()); xaDataSource.setMaintenanceInterval(testConfig.getMaintenanceInterval()); xaDataSource.setMaxIdleTime(testConfig.getMaxIdleTime()); xaDataSource.setTestQuery(testConfig.getTestQuery()); return xaDataSource; } @Primary @Bean(name = 'testSqlSessionFactory') public SqlSessionFactory testSqlSessionFactory(@Qualifier('testDataSource') DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Primary @Bean(name = 'testSqlSessionTemplate') public SqlSessionTemplate testSqlSessionTemplate( @Qualifier('testSqlSessionFactory') SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); }}@Configuration@MapperScan(basePackages = 'com.itmayiedu.test02', sqlSessionTemplateRef = 'test2SqlSessionTemplate')public class MyBatisConfig2 { // 配置數據源 @Bean(name = 'test2DataSource') public DataSource testDataSource(DBConfig2 testConfig) throws SQLException { MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource(); mysqlXaDataSource.setUrl(testConfig.getUrl()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); mysqlXaDataSource.setPassword(testConfig.getPassword()); mysqlXaDataSource.setUser(testConfig.getUsername()); mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true); AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean(); xaDataSource.setXaDataSource(mysqlXaDataSource); xaDataSource.setUniqueResourceName('test2DataSource'); xaDataSource.setMinPoolSize(testConfig.getMinPoolSize()); xaDataSource.setMaxPoolSize(testConfig.getMaxPoolSize()); xaDataSource.setMaxLifetime(testConfig.getMaxLifetime()); xaDataSource.setBorrowConnectionTimeout(testConfig.getBorrowConnectionTimeout()); xaDataSource.setLoginTimeout(testConfig.getLoginTimeout()); xaDataSource.setMaintenanceInterval(testConfig.getMaintenanceInterval()); xaDataSource.setMaxIdleTime(testConfig.getMaxIdleTime()); xaDataSource.setTestQuery(testConfig.getTestQuery()); return xaDataSource; } @Bean(name = 'test2SqlSessionFactory') public SqlSessionFactory testSqlSessionFactory(@Qualifier('test2DataSource') DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); return bean.getObject(); } @Bean(name = 'test2SqlSessionTemplate') public SqlSessionTemplate testSqlSessionTemplate( @Qualifier('test2SqlSessionFactory') SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); }}

4.啟動加載配置

@EnableConfigurationProperties(value = { DBConfig1.class, DBConfig2.class })使用還是正常使用@Transactional方式

到此這篇關于SpringBoot使用Atomikos技術整合多數據源的實現的文章就介紹到這了,更多相關SpringBoot Atomikos多數據源內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 亚洲精品视频在线播放 | 中文字幕免费视频 | 久久99深爱久久99精品 | 亚洲三级免费看 | 久久久久久久久久久久久久国产 | 日韩一级一区 | 亚洲人成人一区二区在线观看 | 99爱国产 | 久久久免费电影 | 亚洲一区二区视频 | 亚洲精品视频一区二区三区 | 成人在线观看免费 | 97超碰免费| 亚洲成人日韩 | 久久黄色精品视频 | 日韩免费高清视频 | 成人精品一区二区户外勾搭野战 | 范冰冰一级做a爰片久久毛片 | 欧美精品久久 | 欧美激情网站 | 精品国产一区二区在线 | 久久久久亚洲 | 欧美日韩国产精品一区二区 | 在线色网 | 阿v视频在线观看 | 日本啊v在线 | 天天综合91| 中国一级特黄真人毛片 | 国产精品毛片久久久久久久 | 欧美伊人影院 | 久久中文一区二区 | 久久久久国产精品一区二区 | 黄色在线观看国产 | 亚洲成人免费观看 | 99精品欧美一区二区三区 | 久草久草久草 | 欧美三级免费观看 | 中文字幕成人在线 | 一级片在线视频 | 国产精品中文字幕在线 | 91亚洲国产成人精品一区二三 |