Mybatis-Plus的多数据源你了解吗

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;

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 >

spring:

   # 配置数据源信息

   datasource:

     dynamic:

       # 设置默认的数据源或数据源组，默认值即为master

       primary: master

       # 严格匹配数据源，默认false，true未匹配到指定数据源时抛异常，false使用默认数据源

       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"

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;

}

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> {

}

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> {

}

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 ));

     }