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

逃离我推掉我的手 2021-11-22 13:18 126阅读 0赞

前言：

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

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

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

**目录**

1.配置pom文件

2.application.properties 设置参数

3.编写config类

4.测试

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

# 1.配置pom文件 #

配置文件还是需要通过使用mybatis的依赖

<dependency>
        <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
      </dependency>
    
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.1.1</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>

# 2.application.properties 设置参数 #

这里使用的是spring.datasource的前缀去处理（稍后会记录使用mybtais.data的前缀去生成数据源）

#数据源1
    spring.datasource.data1.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.data1.jdbc-url=jdbc:mysql://localhost:3306/bootdb?useUnicode=true&characterEncoding=utf-8
    spring.datasource.data1.username=root
    spring.datasource.data1.password=jy897513;
    
    #数据源2
    spring.datasource.data2.driver-class-name=com.mysql.jdbc.Driver
    spring.datasource.data2.jdbc-url=jdbc:mysql://localhost:3306/bootdb2?useUnicode=true&characterEncoding=utf-8
    spring.datasource.data2.username=root
    spring.datasource.data2.password=jy897513;
    
    #配置驼峰配置
    mybatis.configuration.map-underscore-to-camel-case=true

# 3.编写config类 #

1.针对主源的config类:

@Configuration
    @MapperScan(basePackages = "com.zqj.springboot2.mapper.data1mapper", sqlSessionFactoryRef = "primarySqlSessionFactory")
    public class DataSourcesPrimary {
    
        //生成的dataSource数据源
        @Bean(name = "primaryDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.data1")
        @Primary
        public DataSource dataSourcesPrimary() {
            return DataSourceBuilder.create().build();
        }
    
        //连接数据库的连接工厂 要使用数据源
        @Bean(name = "primarySqlSessionFactory")
        @Primary
        public SqlSessionFactory priamrySqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource)
                throws Exception {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            // bean.setMapperLocations(
            // new
            // PathMatchingResourcePatternResolver().getResources("classpath:/mapping/test1/*.xml"));
            return bean.getObject();
        }
    
        //事务挂历  需要使用数据源
        @Bean(name = "priamryTransactionManager")
        @Primary
        public DataSourceTransactionManager testTransactionManager(@Qualifier("primaryDataSource") DataSource dataSource) {
    		return new DataSourceTransactionManager(dataSource);
    	}
    
        //负责管理sqlSessionFactory
    	@Bean(name = "primarySqlSessionTemplate")
        @Primary
        public SqlSessionTemplate testSqlSessionTemplate(
    			@Qualifier("primarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    
    }

2.设置副源的config类：

@Configuration
    //mapperScan需要扫描包 但是不到具体类,
    @MapperScan(basePackages = "com.zqj.springboot2.mapper.data2mapper", sqlSessionFactoryRef = "sqlSessionFactory2")
    public class DataSources {
    
        @Bean(name = "dataSources2")
        @ConfigurationProperties(prefix = "spring.datasource.data2")
    //    @Primary
        public DataSource createDataSources() {
            return DataSourceBuilder.create().build();
        }
    
        @Bean(name = "sqlSessionFactory2")
    //    @Primary
        public SqlSessionFactory priamrySqlSessionFactory(@Qualifier("dataSources2") DataSource dataSource)
                throws Exception {
            SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
            bean.setDataSource(dataSource);
            // bean.setMapperLocations(
            // new
            // PathMatchingResourcePatternResolver().getResources("classpath:/mapping/test1/*.xml"));
            return bean.getObject();
        }
    
        //事务挂历
        @Bean(name = "transactionManager2")
        public DataSourceTransactionManager testTransactionManager(@Qualifier("dataSources2") DataSource dataSource) {
            return new DataSourceTransactionManager(dataSource);
        }
    
        @Bean(name = "sqlSessionTemplate2")
        public SqlSessionTemplate testSqlSessionTemplate(
                @Qualifier("sqlSessionFactory2") SqlSessionFactory sqlSessionFactory) throws Exception {
            return new SqlSessionTemplate(sqlSessionFactory);
        }

**注意1：副源是没有设置主源的@Primary， 因为这个只能有一个主源 ，所以在副源的配置类上是把@Primary 注释掉的**

**注意2：在类上的@MapperScan的注解中，扫描的basePackages是绑定的mapper接口，但是只是扫描到包而不是到类。（我把自己在这里坑死了）**

# 4.测试 #

我把实体类贴出来先：

@Data
    public class User {
    
        private int id;
        private String name;
        private int age;
    
    }

因为用了lombok

所以也把依赖提出来下把：

<dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>

1.首先把mapper接口的路径创建出来（如下是接口路径，和刚才@MapperScan的扫描路径是一致的）

![20190724162842536.png][]

2.在两个data1mapper中是创建mapper接口，用注解去将sql语句注入

data1Mapper如下：

@Mapper
    @Repository
    public interface Data1UserMapper {
    
        @Select("SELECT * FROM user WHERE name = #{name}")
        public User selectUser(@Param("name") String name);
    
    
        @Select("INSERT INTO user (name, age) VALUES ( #{name}, #{age});")
        public void addUser(@Param("name") String name, @Param("age") Integer age);
    
    
    }

data2Mapper如下：

@Mapper
    @Repository
    public interface Data2UserMapper {
    
        @Select("SELECT * FROM user WHERE name = #{name}")
        public User selectUser(@Param("name") String name);
    
    
        @Select("INSERT INTO user (name, age) VALUES ( #{name}, #{age});")
        public void addUser(@Param("name") String name, @Param("age") Integer age);
    
    
    }

层级目录：

![20190724163819208.png][]

3.mapper接口创建好了后  写个service + 实现类 去简单处理下逻辑

public interface UserService {
    
        public List<User> selectUser(String name);
    
        public void addUser(String name, Integer age);
    
    }

@Service
    public class UserServiceImpl implements UserService {
    
        @Autowired
        private Data1UserMapper data1UserMapper;
    
        @Autowired
        private Data2UserMapper data2UserMapper;
    
        @Override
        public List<User> selectUser(String name) {
            User user = data1UserMapper.selectUser(name);
            User user1 = data2UserMapper.selectUser(name);
            List<User> userList = new LinkedList<>();
            userList.add(user);
            userList.add(user1);
            return userList;
        }
    
        @Override
        @Transactional
        public void addUser(String name, Integer age) {
            data2UserMapper.addUser(name, age);
            data1UserMapper.addUser(name, age);
    
        }

4.写个控制层去和前台做个交互

@RestController
    @RequestMapping("/user")
    public class UserController {
    
    
        @Autowired
        private UserService userService;
    
        @GetMapping("/add")
        public int addUser(@RequestParam("name") String name, @RequestParam("age") Integer age) {
            userService.addUser(name, age);
            return 1;
        }
    
        @GetMapping("/select")
        public String selectUser(@RequestParam("name") String name) {
            List<User> userList = userService.selectUser(name);
            return userList.toString();
        }
    
    }

5.这个时候运行程序：

先添加个数据：

http://localhost:8080/user/add?name=五重樱&age=15

在数据库后台可以看到：

![20190724164356534.png][]![20190724164425145.png][]

两个数据源都有数据插入，大佬NB！

再试试查询数据：

http://localhost:8080/user/select?name=一重樱

可以看到返回的是：

![20190724164620679.png][]

数据源2中的age我设置为14了（可以看上面的截图）

记录如上。

[20190724162842536.png]: /images/20211122/ca61555e1de248fa8cbf40c3457e1768.png
[20190724163819208.png]: /images/20211122/ad107936df4040b3a0d983aa49b01b99.png
[20190724164356534.png]: https://img-blog.csdnimg.cn/20190724164356534.png
[20190724164425145.png]: /images/20211122/9925a20cf01942d58546804a391eda63.png
[20190724164620679.png]: /images/20211122/35390905c02d48ffb661c731398e09ee.png