首页>代码>springboot+jta+atomikos实现两阶段提交分布式事务的管理>/quanxian-jta-atomikos/src/main/java/com/quanxian/jtaatomikos/demo/datasource/MasterMybatisConfig.java
package com.quanxian.jtaatomikos.demo.datasource; import com.alibaba.druid.pool.xa.DruidXADataSource; import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.jta.atomikos.AtomikosDataSourceBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.Resource; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import javax.sql.DataSource; import java.sql.SQLException; @Configuration @MapperScan(value = {"com.quanxian.jtaatomikos.demo.mapper.master"}, sqlSessionTemplateRef = "masterSqlSessionTemplate") public class MasterMybatisConfig { @Value("${spring.datasource.master.url}") private String url; @Value("${spring.datasource.master.username}") private String username; @Value("${spring.datasource.master.password}") private String password; @Value("${spring.datasource.master.driverClassName}") private String driverClassName; @Bean(name = "masterMybatisDS") public DataSource DataSource() throws SQLException { DruidXADataSource druidXADataSource=new DruidXADataSource(); druidXADataSource.setUrl(url); druidXADataSource.setPassword(password); druidXADataSource.setUsername(username); AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean(); xaDataSource.setXaDataSource(druidXADataSource); xaDataSource.setUniqueResourceName("datasourMaster"); return xaDataSource; } @Bean(name = "masterSqlSessionFactory") public SqlSessionFactory SqlSessionFactory(@Qualifier("masterMybatisDS") DataSource dataSource) throws Exception { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(dataSource); Resource[] resources = new PathMatchingResourcePatternResolver() .getResources("classpath:mapper/master/*.xml"); bean.setMapperLocations(resources); return bean.getObject(); } @Bean(name = "masterSqlSessionTemplate") public SqlSessionTemplate SqlSessionTemplate(@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
最近下载更多
醉code LV17
2020年2月15日
15088605151@139.com LV12
2020年1月26日
best2018 LV46
2020年1月14日
最代码官方 LV167
2020年1月8日