MyBatis-Plus多数据源配置

@toc

1、场景说明

多数据源适用于多种场景:纯粹多库、读写分离、一主多从、混合模式等等。

在这里我们模拟一个纯粹多库的场景,其他场景类似。我们创建两个库,分别为Mybatis_plus(里面有张user表)和mybatis_plus_1(里面有张product表),通过一个测试用例分别获取用户数据和商品数据,如果获取到说明多库模拟成功。

2、创建数据库和表

 CREATE DATABASE `mybatis_plus` /*!40100 DEFAULT CHARACTER SET utf8mb4 */;
 use `mybatis_plus`;
 CREATE TABLE `user` (
 `id` bigint(20) NOT NULL COMMENT '主键ID',
 `name` varchar(30) DEFAULT NULL COMMENT '姓名',
 `age` int(11) DEFAULT NULL COMMENT '年龄',
 `email` varchar(50) DEFAULT NULL COMMENT '邮箱',
 PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 
 INSERT INTO user (id, name, age, email) VALUES
 (1, 'Jone', 18, 'test1@baomidou.com'),
 (2, 'Jack', 20, 'test2@baomidou.com'),
 (3, 'Tom', 28, 'test3@baomidou.com'),
 (4, 'Sandy', 21, 'test4@baomidou.com'),
 (5, 'Billie', 24, 'test5@baomidou.com');

MyBatis-Plus多数据源配置

 CREATE DATABASE `mybatis_plus_1` /*!40100 DEFAULT CHARACTER SET utf8mb4 */;
 use `mybatis_plus_1`;
 CREATE TABLE product
 (
 id BIGINT(20) NOT NULL COMMENT '主键ID',
 name VARCHAR(30) NULL DEFAULT NULL COMMENT '商品名称',
 price INT(11) DEFAULT 0 COMMENT '价格',
 version INT(11) DEFAULT 0 COMMENT '乐观锁版本号',
 PRIMARY KEY (id)
 );
 
 INSERT INTO product (id, NAME, price) VALUES (1, '外星人笔记本', 100);

MyBatis-Plus多数据源配置

3、在SpringBoot工程中添加依赖

  <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
         <dependency>
             <groupId>com.baomidou</groupId>
             <artifactId>mybatis-plus-boot-starter</artifactId>
             <version>3.5.1</version>
         </dependency>
         <dependency>
             <groupId>com.baomidou</groupId>
             <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
             <version>3.5.0</version>
         </dependency>
 
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-devtools</artifactId>
             <scope>runtime</scope>
             <optional>true</optional>
         </dependency>
         <dependency>
             <groupId>MySQL</groupId>
             <artifactId>mysql-connector-Java</artifactId>
             <scope>runtime</scope>
         </dependency>
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
             <optional>true</optional>
         </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
     </dependencies>

4、配置多数据源

在项目的application.yml文件中配置如下:

这里数据库配置有差别的话根据你自己的情况修改就行。

 spring:
 # 配置数据源信息
  datasource:
    dynamic:
       # 设置默认的数据源或者数据源组,默认值即为master
      primary: master
       # 严格匹配数据源,默认false.true未匹配到指定数据源时抛异常,false使用默认数据源
      strict: false
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf-8&useSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: 123456
        slave_1:
          url: jdbc:mysql://localhost:3306/mybatis_plus_1?characterEncoding=utf-8&useSSL=false
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: 123456

5、POJO

 @Data
 @TableName("user")
 public class User {
 
     @TableId
     private Integer id;
 
     private String name;
 
     private Integer age;
 
     private String email;
 
 }
 @Data
 @TableName("product")
 public class Product {
 
     @TableId
     private Integer id;
 
     private String name;
 
     private Integer price;
 
     private Integer version;
 
 }

6、Service

 public interface ProductService extends IService<Product> {
 }
 public interface UserService extends IService<User> {
 
 }
@DS("slave_1")//指定所操作的数据源
@Service
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product>
implements ProductService {
}
@DS("master") //指定所操作的数据源
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {

}

7、mapper

@Repository
public interface UserMapper extends BaseMapper<User> {

}
@Repository
public interface ProductMapper extends BaseMapper<Product> {
}

8、测试

别忘记在启动类上面加扫描mapper的注解

MyBatis-Plus多数据源配置

测试类如下:

@SpringBootTest
class DatasourceApplicationTests {
@Autowired
private UserService userService;
@Autowired
private ProductService productService;

@Test
public void testDynamicDataSource(){
//从master(mybatis_plus)库查
System.out.println(userService.getById(1L));
//从slave_1(mybatis_plus_1)库查
System.out.println(productService.getById(1L));
}

}

执行结果如下:

MyBatis-Plus多数据源配置

可以看到,都能获取到对象,测试多数据源成功。

其他也类似,如果要实现读写分离的话,在写操作的方法上加上主库的数据源,读操作方法上加上从库的数据源,这样就能实现读写分离了。

至于多主多从的负载均衡配置等,后面找个时间详细介绍下。



原文始发于微信公众号(全栈开发那些事):MyBatis-Plus多数据源配置

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由半码博客整理,本文链接:https://www.bmabk.com/index.php/post/91679.html

(0)
小半的头像小半

相关推荐

发表回复

登录后才能评论
半码博客——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!