多数据源配置MyBatisPlus(十八)下-阿里云开发者社区

二. MyBatisPlus 多数据源配置

MyBatisPlus 的多数据源配置时，不用像 Jpa或者MyBatis 那样，配置不同的DataSource 和 Factory.与平常的 MyBatisPlus 开发基本一致。

MyBatisPlus 提供了一个插件 dynamic-datasource-spring-boot-starter ，可以方便我们进行多数据源配置。

具体可以见官网文档: MyBatisPlus多数据源

将其与 Druid 进行整合，切换数据源。

二.一 pom.xml 依赖

<!--引入springboot与mybatis-plus整合的依赖。 去掉mybatis的依赖-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.2.6</version>
        </dependency>
        <!-- 引入pagehelper分页插件  注意版本号要与 mybatis-plus 进行匹配到 -->
         <dependency>
            <groupId>com.github.pagehelper</groupId>
            <artifactId>pagehelper-spring-boot-starter</artifactId>
            <version>1.2.12</version>
        </dependency>
        <!--引入动态数据源配置-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
            <version>3.3.2</version>
        </dependency>

二.二 application.yml 配置文件

# 引入 数据库的相关配置
#spring:
#  datasource:
#    driver-class-name: com.mysql.cj.jdbc.Driver
#    url: jdbc:mysql://localhost:3306/springboot?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&useSSL=false&allowMultiQueries=true
#    username: root
#    password: abc123
# 配置成多数据源的形式
spring:
  autoconfigure:
    # 去掉Druid 配置   //第一部分点 
    exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure
  # 自动配置，例外处理
  datasource:
    # 配置数据源类型
    type: com.alibaba.druid.pool.DruidDataSource
    dynamic:
      primary: one #设置默认的数据源或者数据源组,默认值即为master。 为了统一，设置成one 
      strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
      datasource:
        # 配置第一个数据库
        one:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/springboot?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&useSSL=false
          username: root
          password: abc123
        # 配置第二个数据库
        two:
          driver-class-name: com.mysql.cj.jdbc.Driver
          url: jdbc:mysql://localhost:3306/springboot2?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&useSSL=false
          username: root
          password: abc123
    druid:
      # 其他的 Druid 连接池配置信息
      max-active: 30
      min-idle: 5
#整合mybatis时使用的
mybatis-plus:
  # 配置 mapper文件的位置
  mapper-locations: classpath:mybatis/mapper/**/*Mapper.xml
  # 配置日志
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    map-underscore-to-camel-case: true #  配置别名设置
  global-config:
    db-config:
      logic-delete-field: flag   # 逻辑删除的字段
      logic-not-delete-value: 1  # 正常状态下，该字段的值
      logic-delete-value: 0      # 删除后，该字段的值
      table-underline: true # 驼峰方式转换
#分页插件
pagehelper:
  helperDialect: mysql
  reasonable: true
  supportMethodsArguments: true
  params: count=countSql

注意，第一部分的内容，即 spring.autoconfigure.exclude 去掉了 Druid的自动配置。

如果在 yml 配置文件中不去掉的话，那么则需要在启动类时进行去掉。

@MapperScan(value = "top.yueshushu.learn.mapper")
@SpringBootApplication(exclude = {DruidDataSourceAutoConfigure.class})
public class MyBatisApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyBatisApplication.class,args);
        System.out.println("运行 MybatisPlus 多数据源配置文件");
    }
}

注意，在启动类上，加上 @MapperScan 扫描。这个不要忘记了， Mybatis多数据源配置时，需要去掉。

二.三实体配置

在 pojo 包下，分别创建两个包 one 和 two 包。

one 包下面放置所有使用 one 数据库实体的信息， two 包下面放置所有使用two数据库实体的信息

二.三.一 User.java 用户实体

@Data
@NoArgsConstructor
@AllArgsConstructor
@TableName("user")
public class User implements Serializable {
    /**
     * @param id id编号
     * @param name 姓名
     * @param sex 性别
     * @param age 年龄
     * @param description 描述
     */
    @TableId(value = "id",type =IdType.AUTO)
    private Integer id;
    @TableField("name")
    private String name;
    @TableField("sex")
    private String sex;
    @TableField("age")
    private Integer age;
    @TableField("description")
    private String description;
}

二.三.二 Dept.java 部门实体

@Data
@TableName("dept")
public class Dept implements Serializable {
    /**
     * @param id id编号
     * @param name 部门名称
     */
    @TableId(value = "id",type = IdType.AUTO)
    private Integer id;
    @TableField("name")
    private String name;
}

二.四 mapper 和其映射文件配置

在 mapper 包下，创建 one 包和 two包

one 包下面放置所有使用 one 数据库的信息， two 包下面放置所有使用two数据库的信息

二. 四.一 UserMapper 和其映射文件

二.四.一.一 UserMapper.java 接口

//扫描由启动类进行扫描配置
public interface UserMapper extends BaseMapper<User> {
    //一个走 xml的方法
    void batchAdd(@Param("userList") List<User> userList);
}

二.四.一.二 UserMapper.xml 映射文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="top.yueshushu.learn.mapper.mapper1.UserMapper">
    <insert id="batchAdd">
        insert into user(name,sex,age,description) values
        <foreach collection="userList" item="user" open="" close="" separator=",">
            (#{user.name},#{user.sex},#{user.age},#{user.description})
        </foreach>
    </insert>
</mapper>

二.四.二 DeptMapper 和其映射文件

二.四.二.一 DeptMapper.java 接口

//扫描由启动类进行扫描配置
public interface DeptMapper extends BaseMapper<Dept> {
    //走 xml 的配置
    void batchAdd(@Param("deptList") List<Dept> deptList);
}

二.四.二.二 DeptMapper.xml 映射文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="top.yueshushu.learn.mapper.mapper2.DeptMapper">
    <insert id="batchAdd">
        insert into dept(name) values
        <foreach collection="deptList" item="user" open="" close="" separator=",">
            (#{user.name})
        </foreach>
    </insert>
</mapper>

二.五接口及其实现

注意，在实现类上或者实现类的方法上，添加 @DS(“数据库的别名”) 的注解信息

二.五.一 UserService接口和其实现类

UserService.java

public interface UserService {
    void batchAddUser(List<User> userList);
    List<User> listUser();
    //查询 springboot2 数据库的方法
    List<Dept> listDept();
}

UserServiceImpl.java 实现类

@Service
//在类上添加注解，表示类中所有的方法都走这个数据源。
@DS("one")
public class UserServiceImpl implements UserService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private DeptMapper deptMapper;
    @Override
    public void batchAddUser(List<User> userList) {
        userMapper.batchAdd(userList);
    }
    @Override
    public List<User> listUser() {
       return userMapper.selectList(null);
    }
    //在方法上添加注解，表示这个方法走定义的数据源
    @DS("two")
    @Override
    public List<Dept> listDept() {
        return deptMapper.selectList(null);
    }
}

@DS(“数据库别名”）注解到类上，表示这个类中的所有的方法都默认走这个数据库。如果不填写的话，表示走默认配置的那个数据库。

注解到方法上，表示这个方法单独走自定义的数据库。优先级比类上的注解高。

二.五.二 DeptService接口和其实现类

DeptService.java

public interface DeptService {
    void batchAddDept(List<Dept> deptList);
    List<Dept> listDept();
    //走 springboot 数据库的方法
    List<User> listUser();
}

DeptServiceImpl.java

@Service
//采用 springboot2 的数据库
@DS("two")
public class DeptServiceImpl implements DeptService {
    @Autowired
    private DeptMapper deptMapper;
    @Autowired
    private UserMapper userMapper;
    @Override
    public void batchAddDept(List<Dept> deptList) {
        deptMapper.batchAdd(deptList);
    }
    @Override
    public List<Dept> listDept() {
       return deptMapper.selectList(null);
    }
    //单独另外采用 springboot 的数据库
    @DS("one")
    @Override
    public List<User> listUser() {
        return userMapper.selectList(null);
    }
}

二.六测试

二.六. 一测试类编写

@SpringBootTest
@RunWith(SpringJUnit4ClassRunner.class)
@Log4j2
public class MyBatisPlusTests {
    @Autowired
    private UserService userService;
    @Autowired
    private DeptService deptService;
    @Test
    public void addUserTest(){
        //1. 构建对象
        User user=new User();
        user.setName("小欢欢");
        user.setAge(22);
        user.setSex("女");
        user.setDescription("一个小坏蛋");
        User user1=new User();
        user1.setName("小泽霖");
        user1.setAge(25);
        user1.setSex("男");
        user1.setDescription("一个大坏蛋");
        //这是修改的操作,id=2已经存在这条记录了。
        User user2=new User();
        user2.setName("岳泽霖");
        user2.setAge(25);
        user2.setSex("男性");
        user2.setDescription("一个快乐的程序员");
        //2. 放置到集合里面
        List<User> userList=new ArrayList<>();
        userList.add(user);
        userList.add(user1);
        userList.add(user2);
        userService.batchAddUser(userList);
    }
    @Test
    public void listUserTest(){
        System.out.println("User实现类:>>>>>>>>>>>查询员工");
        List<User> userList=userService.listUser();
        userList.forEach(n->log.info(n));
        System.out.println("User实现类:>>>>>>>>>>>>查询部门");
        List<Dept> deptList=userService.listDept();
        deptList.forEach(n->log.info(n));
    }
    @Test
    public void addDeptTest(){
        //1. 构建对象
        Dept dept=new Dept();
        dept.setName("信息管理部");
        Dept dept1=new Dept();
        dept1.setName("研发部");
        Dept dept2=new Dept();
        dept2.setName("测试部");
        //2. 放置到集合里面
        List<Dept> deptList=new ArrayList<>();
        deptList.add(dept);
        deptList.add(dept1);
        deptList.add(dept2);
        deptService.batchAddDept(deptList);
        log.info("添加部门成功");
    }
    @Test
    public void listDeptTest(){
        System.out.println("Dept实现类:>>>>>>>查询部门");
        List<Dept> deptList=deptService.listDept();
        deptList.forEach(n->log.info(n));
        System.out.println("Dept实现类:>>>>>>>>>>>查询员工");
        List<User> userList=deptService.listUser();
        userList.forEach(n->log.info(n));
    }
    /**
     * 数据源切换配置
     */
    @Test
    public void allDataSourceTest(){
        addUserTest();
        listDeptTest();
        addDeptTest();
        listUserTest();
    }
}

二.六.二测试

员工的批量添加和部门的批量添加

员工 addUserTest

对应的数据库里面有相应的信息:

部门 addDeptTest

对应的数据库里面的信息

进行查询

User实现类进行查询 listUserTest

Dept实现类进行查询 listDeptTest

同时切换数据源 allDataSourceTest

也是成功的，数据表里面也有相应的数据。

多数据源配置MyBatisPlus(十八)下

二. MyBatisPlus 多数据源配置

二.一 pom.xml 依赖

二.二 application.yml 配置文件

二.三实体配置

二.三.一 User.java 用户实体

二.三.二 Dept.java 部门实体

二.四 mapper 和其映射文件配置

二. 四.一 UserMapper 和其映射文件

二.四.一.一 UserMapper.java 接口

二.四.一.二 UserMapper.xml 映射文件

二.四.二 DeptMapper 和其映射文件

二.四.二.一 DeptMapper.java 接口

二.四.二.二 DeptMapper.xml 映射文件

二.五接口及其实现

二.五.一 UserService接口和其实现类

二.五.二 DeptService接口和其实现类

二.六测试

二.六. 一测试类编写

二.六.二测试

热门文章

最新文章

相关课程

相关电子书

多数据源配置MyBatisPlus(十八)下

二. MyBatisPlus 多数据源配置

二.一 pom.xml 依赖

二.二 application.yml 配置文件

二.三 实体配置

二.三.一 User.java 用户实体

二.三.二 Dept.java 部门实体

二.四 mapper 和其映射文件 配置

二. 四.一 UserMapper 和其映射文件

二.四.一.一 UserMapper.java 接口

二.四.一.二 UserMapper.xml 映射文件

二.四.二 DeptMapper 和其映射文件

二.四.二.一 DeptMapper.java 接口

二.四.二.二 DeptMapper.xml 映射文件

二.五 接口及其实现

二.五.一 UserService接口和其实现类

二.五.二 DeptService接口和其实现类

二.六 测试

二.六. 一 测试类编写

二.六.二 测试

热门文章

最新文章

相关课程

相关电子书

二.三实体配置

二.四 mapper 和其映射文件配置

二.五接口及其实现

二.六测试

二.六. 一测试类编写

二.六.二测试