您现在的位置是:首页 >其他 >springboot整合mybatisplus使用多数据源网站首页其他
springboot整合mybatisplus使用多数据源
简介springboot整合mybatisplus使用多数据源
本篇文章主要讲解的是使用多数据源,至于springboot与mybatisplus的整合这里只做简单介绍
springboot整合mybatisplus(非本文重点)
在pom文件中引入如下的依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.1</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
就这么简单了,哈哈,其他的就不多说了哈,至于整合后mapper文件放在哪里就不用我多说了吧。
如何使用多数据源(重点)
①引入依赖
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.16</version>
</dependency>
<!-- 导入多数据源依赖-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.6.1</version>
</dependency>
②配置yml
server:
# 设置项目的端口号
port: 8888
# servlet:
# context-path: /demo
spring:
mvc:
pathmatch:
# 加这个的原因是为了更好的使用swagger
matching-strategy: ant_path_matcher
jackson:
date-format: yyyy-MM-dd
time-zone: GMT+8
datasource:
dynamic:
primary: master
strict: false
datasource:
master:
username: root
password: 1230
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/mybatis_plus?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
slave1:
username: root
password: 1230
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/basic-project?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&rewriteBatchedStatements=true
type: com.alibaba.druid.pool.DruidDataSource
mybatis-plus:
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
③如何从主从数据库获取我们要的东西呢
我们的主数据库有个user表
从数据库中有个student表
④定义各自的实体类
package com.summer.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @date 2023-05-31 07:39
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {
@TableId(type =IdType.ASSIGN_ID)
private Long id;
private String name;
private String email;
private String gender;
}
package com.summer.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @date 2023-06-03 22:38
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Student {
@TableId(type = IdType.ASSIGN_ID)
private String id;
private String name;
}
⑤定义各自的mapper接口
package com.summer.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.summer.domain.User;
/**
* @date 2023-05-31 07:39
*/
//@Repository
public interface UserMapper extends BaseMapper<User> {
}
package com.summer.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.summer.domain.Student;
/**
* @date 2023-06-03 22:39
*/
public interface StudentMapper extends BaseMapper<Student> {
}
⑥定义各自的Service以及实现类
package com.summer.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.summer.domain.Student;
/**
* @date 2023-06-03 22:40
*/
public interface StudentService extends IService<Student> {
}
package com.summer.service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.summer.domain.Student;
import com.summer.mapper.StudentMapper;
import org.springframework.stereotype.Service;
/**
* @date 2023-06-03 22:40
*/
@Service
public class StudentServiceImpl extends ServiceImpl<StudentMapper, Student> implements StudentService {
}
package com.summer.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.summer.domain.User;
import java.util.List;
/**
* @date 2023-05-31 08:25
*/
public interface UserService extends IService<User> {
}
package com.summer.service;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.summer.domain.User;
import com.summer.mapper.UserMapper;
import org.springframework.stereotype.Service;
/**
* @date 2023-05-31 08:26
*/
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
}
⑦开始编写
我们上面讲过,user表是在我们的主数据库master里,student是在我们从数据库slave1里,那么我们在开发的时候如何区分他们呢?
这就需要我们使用一个注解@DS 来进行区分,我们在各自的Service类上添加注解
⑧测试
我写了一个接口来进行测试
@RestController
@RequestMapping("/adminApi/dynamic")
@RequiredArgsConstructor
public class DemoController {
private final UserService userService;
private final StudentService studentService;
@GetMapping("/hello")
public String hello(){
List<User> list =
userService.list();
System.out.println("user:"+list.size());
List<Student> list1 = studentService.list();
System.out.println("student:"+list1.size());
return "success";
}
如果我们主表和从表中的表的名字一样,比如都将user怎么办?
我们的DS注解现在是写在我们的Service类上的,这个注解可以写在我们指定的方法上,如果是写在类上的话比如
@DS("slave1") 那么这个类中的所有方法的操作都是从slave1对应的表中取得
如果写在方法上,那么这个方法对应的操作就是从slave1中取。
风语者!平时喜欢研究各种技术,目前在从事后端开发工作,热爱生活、热爱工作。