学习的spring boot 2.0的记录（六）：集成mybatis的多数据源（第二种方法）

ゝ一世哀愁。 2021-11-22 13:48 86阅读 0赞

前言：

学习的地址：https://www.majiaxueyuan.com/front/showcoulist   、https://www.bilibili.com/video/av47407342/

SpringBoot的pom依赖（以2.0版本为例的）

当前记录的是集成mybatis的多数据源的设置（第二种方式）

第二种方式是JTA-ATOMIKOS

**目录**

1.添加POM依赖

2.重新改写一下application.properties

3.重新编写config类

4.测试

--------------------

# 1.添加POM依赖 #

在第一种方法方法上，第二种方法再添加一个新的依赖

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

#    2.重新改写一下application.properties #

原本使用的是spring.datasource作为前缀的。现在稍微改成mybatis的

#数据源1
    mysql.datasource.data1.url=jdbc:mysql://localhost:3306/bootdb?useUnicode=true&characterEncoding=utf-8
    mysql.datasource.data1.username=root
    mysql.datasource.data1.password=jy897513;
    mysql.datasource.data1.minPoolSize = 3
    mysql.datasource.data1.maxPoolSize = 25
    mysql.datasource.data1.maxLifetime = 20000
    mysql.datasource.data1.borrowConnectionTimeout = 30
    mysql.datasource.data1.loginTimeout = 30
    mysql.datasource.data1.maintenanceInterval = 60
    mysql.datasource.data1.maxIdleTime = 60
    
    #数据源2
    mysql.datasource.data2.url=jdbc:mysql://localhost:3306/bootdb2?useUnicode=true&characterEncoding=utf-8
    mysql.datasource.data2.username=root
    mysql.datasource.data2.password=jy897513;
    mysql.datasource.data2.minPoolSize = 3
    mysql.datasource.data2.maxPoolSize = 25
    mysql.datasource.data2.maxLifetime = 20000
    mysql.datasource.data2.borrowConnectionTimeout = 30
    mysql.datasource.data2.loginTimeout = 30
    mysql.datasource.data2.maintenanceInterval = 60
    mysql.datasource.data2.maxIdleTime = 60
    
    mybatis.type-aliases-packag=com.zqj.springboot2.mapper
    
    #开启驼峰的
    mybatis.configuration.map-underscore-to-camel-case=true

# 3.重新编写config类 #

第一种方法的config类注释掉

然后创建一个实体去装载application.properties的mybatis参数 第一个数据源参数

@Data
    @ConfigurationProperties(prefix = "mysql.datasource.data1")
    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.data2")
    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;
    }

在实体类装配好后。需要进行数据源的配置

和第一种方式配置流程差不多

1.现在主启动方法上将要扫描的配置包搞进去

@SpringBootApplication
    @EnableConfigurationProperties({DBConfig1.class, DBConfig2.class})
    public class Springboot2Application {
    
        public static void main(String[] args) {
            SpringApplication.run(Springboot2Application.class, args);
        }
    
    }

2.编写修改数据源类（主数据源）

@Configuration
    @MapperScan(basePackages = "com.zqj.springboot2.mapper.data1mapper",sqlSessionTemplateRef = "primarySqlSessionTemplate")
    public class MyBatisPrimaryConfig {
    
        @Bean(name = "primaryDataSource")
        @Primary
        public DataSource primaryDataSource(DBConfig1 dbConfig1) throws SQLException {
            //配置数据库参数
            MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();
            mysqlXaDataSource.setUrl(dbConfig1.getUrl());
            mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);
            mysqlXaDataSource.setPassword(dbConfig1.getPassword());
            mysqlXaDataSource.setUser(dbConfig1.getUsername());
            AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();
    		xaDataSource.setXaDataSource(mysqlXaDataSource);
    		xaDataSource.setUniqueResourceName("test1DataSource");
    		xaDataSource.setMinPoolSize(dbConfig1.getMinPoolSize());
    		xaDataSource.setMaxPoolSize(dbConfig1.getMaxPoolSize());
    		xaDataSource.setMaxLifetime(dbConfig1.getMaxLifetime());
    		xaDataSource.setBorrowConnectionTimeout(dbConfig1.getBorrowConnectionTimeout());
    		xaDataSource.setLoginTimeout(dbConfig1.getLoginTimeout());
    		xaDataSource.setMaintenanceInterval(dbConfig1.getMaintenanceInterval());
    		xaDataSource.setMaxIdleTime(dbConfig1.getMaxIdleTime());
    		xaDataSource.setTestQuery(dbConfig1.getTestQuery());
    		return xaDataSource;
        }
    
        @Primary
    	@Bean(name = "pariamrySqlSessionFactory")
    	public SqlSessionFactory testSqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource)
    			throws Exception {
    		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    		bean.setDataSource(dataSource);
    		return bean.getObject();
    	}
    
        @Primary
    	@Bean(name = "primarySqlSessionTemplate")
    	public SqlSessionTemplate testSqlSessionTemplate(
    			@Qualifier("pariamrySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    }

副数据源的配置：

@Configuration
    @MapperScan(basePackages = "com.zqj.springboot2.mapper.data2mapper",sqlSessionTemplateRef = "subSqlSessionTemplate")
    public class MybatisSubConfig {
    
        @Bean(name = "subDataSource")
        public DataSource primaryDataSource(DBConfig2 dbConfig2) throws SQLException {
            //配置数据库参数
            MysqlXADataSource mysqlXaDataSource = new MysqlXADataSource();
            mysqlXaDataSource.setUrl(dbConfig2.getUrl());
            mysqlXaDataSource.setPinGlobalTxToPhysicalConnection(true);
            mysqlXaDataSource.setPassword(dbConfig2.getPassword());
            mysqlXaDataSource.setUser(dbConfig2.getUsername());
            AtomikosDataSourceBean xaDataSource = new AtomikosDataSourceBean();
            xaDataSource.setXaDataSource(mysqlXaDataSource);
            xaDataSource.setUniqueResourceName("subDataSource");
    
            xaDataSource.setMinPoolSize(dbConfig2.getMinPoolSize());
            xaDataSource.setMaxPoolSize(dbConfig2.getMaxPoolSize());
            xaDataSource.setMaxLifetime(dbConfig2.getMaxLifetime());
            xaDataSource.setBorrowConnectionTimeout(dbConfig1.getBorrowConnectionTimeout());
            xaDataSource.setLoginTimeout(dbConfig2.getLoginTimeout());
            xaDataSource.setMaintenanceInterval(dbConfig2.getMaintenanceInterval());
            xaDataSource.setMaxIdleTime(dbConfig2.getMaxIdleTime());
            xaDataSource.setTestQuery(dbConfig2.getTestQuery());
            return xaDataSource;
        }
    
        @Bean(name = "subSqlSessionFactory")
        public SqlSessionFactory testSqlSessionFactory(@Qualifier("subDataSource") DataSource dataSource)
                throws Exception {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            return bean.getObject();
        }
    
        @Bean(name = "subSqlSessionTemplate")
        public SqlSessionTemplate testSqlSessionTemplate(
                @Qualifier("subSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
            return new SqlSessionTemplate(sqlSessionFactory);
        }
    }

注意副数据源没有主数据源的@Primary

# 4.测试 #

我就直接上截图啦！邹大佬比较牛逼哟！

http://localhost:8080/user/add?name=六重樱&age=16

![20190724180224963.png][]![2019072418023120.png][]

![20190724180108341.png][]

[20190724180224963.png]: https://img-blog.csdnimg.cn/20190724180224963.png
[2019072418023120.png]: /images/20211122/c78a43df6cbe4623bfa2f8d76d31744e.png
[20190724180108341.png]: /images/20211122/3ebf37ab069d4490b099cd156e79f32b.png