mybatisPlus与多数据源怎么在springboot中使用
创始人
2024-12-27 09:23:11
0次

项目结构:

mybatisPlus与多数据源怎么在springboot中使用

一、创建表以及测试数据

CREATE TABLE user
(
	id VARCHAR(32) NOT NULL COMMENT '主键ID',
	name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名',
	age INT(11) NULL DEFAULT NULL COMMENT '年龄',
	email VARCHAR(50) NULL DEFAULT NULL COMMENT '邮箱',
	PRIMARY KEY (id)
);


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

二、引入项目依赖,加入配置,修改启动类,编写实体类和mapper对象(读者可以根据自动生成工具生成这块代码)

1.引入依赖

pom.xml



  4.0.0
  
    org.springframework.boot
    spring-boot-starter-parent
    2.1.4.RELEASE
     
  
  com.example
  mybatisplus-springboot
  0.0.1-SNAPSHOT
  mybatisplus-springboot
  Demo project for Spring Boot

  
    1.8
    6.0.6
    3.1.0
    1.1.10
    2.5.4
  

  
    
      org.springframework.boot
      spring-boot-starter-web
    

    
      org.projectlombok
      lombok
      true
    

    
      mysql
      mysql-connector-java
      ${mysql.version}
    

    
      com.baomidou
      mybatis-plus-boot-starter
      ${mybatisplus.boot.version}
    

    
      org.projectlombok
      lombok
      true
    

    
      com.alibaba
      druid-spring-boot-starter
      ${druid.version}
    

    
      com.baomidou
      dynamic-datasource-spring-boot-starter
      ${dynamic.datasource.boot.version}
    

    
      org.springframework.boot
      spring-boot-starter-test
      test
    
  


  
    
      
        org.springframework.boot
        spring-boot-maven-plugin
      
    
  

2.编写配置

application.yml

spring:
 autoconfigure:
  exclude: com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure # 为了某些版本的springboot @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) 无法生效
 datasource:
  dynamic:
   primary: master #设置默认的数据源或者数据源组,默认值即为master,如果读者只是单数据源只需要注释掉slave相关配置即可,这里为了方便演示master与slave保持相同
   datasource:
    master:
     url: jdbc:mysql://localhost:3306/test?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false # serverTimezone=Hongkong 需要填上时区
     username: root
     password: 111111
     driverClassName: com.mysql.cj.jdbc.Driver
    slave:
     url: jdbc:mysql://localhost:3306/test?serverTimezone=Hongkong&allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false # serverTimezone=Hongkong 需要填上时区
     username: root
     password: 111111
     driverClassName: com.mysql.cj.jdbc.Driver
   initial-size: 10 # 以下是连接池配置
   max-active: 100
   min-idle: 10
   max-wait: 60000
   pool-prepared-statements: true
   max-pool-prepared-statement-per-connection-size: 20
   time-between-eviction-runs-millis: 60000
   min-evictable-idle-time-millis: 300000
   #validation-query: SELECT 1
   test-while-idle: true
   test-on-borrow: false
   test-on-return: false
   stat-view-servlet:
    enabled: true
    url-pattern: /druid/*
    login-username: druid
    login-password: 123456
   filter:
    stat:
     log-slow-sql: true
     slow-sql-millis: 1000
     merge-sql: false
    wall:
     config:
      multi-statement-allow: true



#mybatis plus
mybatis-plus:
 mapper-locations: classpath:mapper/**/*.xml
 #实体扫描,多个package用逗号或者分号分隔
 typeAliasesPackage: com.example.mybatisplus.entity
 check-config-location: true
 configuration:
  #是否开启自动驼峰命名规则(camel case)映射
  map-underscore-to-camel-case: true
  #全局地开启或关闭配置文件中的所有映射器已经配置的任何缓存
  cache-enabled: false
  call-setters-on-nulls: true
  #配置JdbcTypeForNull, oracle数据库必须配置
  jdbc-type-for-null: 'null'
  #MyBatis 自动映射时未知列或未知属性处理策略 NONE:不做任何处理 (默认值), WARNING:以日志的形式打印相关警告信息, FAILING:当作映射失败处理,并抛出异常和详细信息
  auto-mapping-unknown-column-behavior: warning
 global-config:
  banner: false
  db-config:
   #主键类型 0:"数据库ID自增", 1:"未设置主键类型",2:"用户输入ID (该类型可以通过自己注册自动填充插件进行填充)", 3:"全局唯一ID (idWorker), 4:全局唯一ID (UUID), 5:字符串全局唯一ID (idWorker 的字符串表示)";
   id-type: UUID
   #字段验证策略 IGNORED:"忽略判断", NOT_NULL:"非NULL判断", NOT_EMPTY:"非空判断", DEFAULT 默认的,一般只用于注解里(1. 在全局里代表 NOT_NULL,2. 在注解里代表 跟随全局)
   field-strategy: NOT_EMPTY
   #数据库大写下划线转换
   capital-mode: true
   #逻辑删除值
   logic-delete-value: 0
   #逻辑未删除值
   logic-not-delete-value: 1

server:
 port: 7000

3.修改启动类

MybatisplusSpringbootApplication.java

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;

@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class}) //去掉springboot 默认的数据源配置
@MapperScan("com.example.mybatisplus.mapper") //扫描mapper的包,或者读者可以在对应的mapper上加上@Mapper的注解
public class MybatisplusSpringbootApplication {

  public static void main(String[] args) {
    SpringApplication.run(MybatisplusSpringbootApplication.class, args);
  }
}

4.编写实体

4.1 user.java

import lombok.Data;
/**
 * user 实体类
 */
@Data
public class User {
  private String id;
  private String name;
  private Integer age;
  private String email;
}

注:读者请自行在开发工具安装lombok插件,或者去掉@data注解换成setter getter方法即可

4.2 UserMapper.java

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.mybatisplus.entity.User;

/**
 * 用户mapper
 */
@DS("slave") //这里是配置数据源注解,默认是master
public interface UserMapper extends BaseMapper {
}

三、编写测试用例

import com.example.mybatisplus.entity.User;
import com.example.mybatisplus.mapper.UserMapper;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

/**
 * 简单的测试增删改查
 */
@RunWith(SpringRunner.class)
@SpringBootTest
public class MybatisplusSpringbootApplicationTests {


  @Autowired
  private UserMapper userMapper;

  @Test
  public void addUser() {
    User user = new User();
    user.setAge(200);
    user.setEmail("belonghuang@outlook.com");
    user.setName("belongHuang");
    userMapper.insert(user);
  }

  @Test
  public void updateUser() {
    User user = userMapper.selectById(1);
    user.setAge(300);
    int i = userMapper.updateById(user);
    if (i>0) {
      System.out.println("修改成功");
    }else {
      System.out.println("修改失败");
    }
  }

  @Test
  public void deleteUser() {
    int i = userMapper.deleteById(1);
    if (i>0) {
      System.out.println("删除成功");
    }else {
      System.out.println("删除失败");
    }
  }
  @Test
  public void selectUser() {
    List users = userMapper.selectList(null);
    users.stream().map(User::getName).forEach(System.out::println);//打印出所用用户名字
  }
}

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...