Mybatis-Plus的多數(shù)據(jù)源你了解嗎

更新時間：2022年03月23日 17:17:52 作者：禿頭的英才

這篇文章主要為大家詳細介紹了Mybatis-Plus的多數(shù)據(jù)源，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助

多數(shù)據(jù)源

創(chuàng)建數(shù)據(jù)庫

CREATE DATABASE mybatis_plus_1;
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)
);

刪除表

USE mybatis_plus;
DROP TABLE IF EXISTS product;

插入數(shù)據(jù)

INSERT INTO product (id, NAME, price) VALUES (1, '外星人', 100);

新建個工程。步驟和之前的一樣

導入依賴

<dependency>
	<groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.5.0</version>
</dependency>

修改application.yml

spring:
  # 配置數(shù)據(jù)源信息
  datasource:
    dynamic:
      # 設置默認的數(shù)據(jù)源或數(shù)據(jù)源組，默認值即為master
      primary: master
      # 嚴格匹配數(shù)據(jù)源，默認false，true未匹配到指定數(shù)據(jù)源時拋異常，false使用默認數(shù)據(jù)源
      strict: false
      datasource:
        master:
          url: jdbc:mysql://localhost:3306/mybatis_plus?useSSL=false&serverTimezone=GMT%2B8
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: "011012"
        save_1:
          url: jdbc:mysql://localhost:3306/mybatis_plus_1?useSSL=false&serverTimezone=GMT%2B8
          driver-class-name: com.mysql.cj.jdbc.Driver
          username: root
          password: "011012"

創(chuàng)建文件包pojo

package com.example.pojo;
import lombok.Data;
@Data
public class Product {
    private Integer id;
    private  String name;
    private Integer price;
    private Integer version;
}

package com.example.pojo;
import com.baomidou.mybatisplus.annotation.*;
import lombok.*;
//所有無參構造和get方法和set方法還有哈希庫方法注解（lombok）
//有參構造方法注解(@AllArgsConstructor)
@Data
@TableName("t_user")
public class User {
    //將該屬性對應的字段指定為主鍵
    @TableId(value = "uid",type = IdType.AUTO)
    private Long id;
    private String name;
    private Integer age;
    private String email;
    private Integer sex;
}

創(chuàng)建文件包mapper(都是接口)

package com.example.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.Product;
import org.springframework.stereotype.Repository;
@Repository
public interface ProductMapper extends BaseMapper<Product> {
}

package com.example.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.pojo.User;
import org.springframework.stereotype.Repository;
@Repository
public interface UserMapper extends BaseMapper<User> {
}

創(chuàng)建文件包Service

package com.example.Sevice;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.pojo.Product;
public interface ProductService extends IService<Product> {
}

package com.example.Sevice;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.pojo.User;
public interface UserService extends IService<User> {
}

在這個包下創(chuàng)建文件包impl

package com.example.Sevice.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.mapper.UserMapper;
import com.example.pojo.User;
import org.springframework.stereotype.Service;
@Service
@DS("master")
public class UserService  extends ServiceImpl<UserMapper, User> implements com.example.Sevice.UserService {
}

package com.example.Sevice.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.Sevice.ProductService;
import com.example.mapper.ProductMapper;
import com.example.pojo.Product;
import lombok.Data;
import org.springframework.stereotype.Service;
@Service
@DS("save_1")
public class ProductServiceImpl extends ServiceImpl<ProductMapper, Product> implements ProductService {
}

寫測試文件

@Autowired
    private UserService userService;
    @Autowired
    private ProductService productService;
    @Test
    public void test1(){
        System.out.println(userService.getById(1));
        System.out.println(productService.getById(1));
    }

在這里插入圖片描述