场景
dynamic-datasource-spring-boot-starter实现动态数据源Mysql和Sqlserver：
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/117356693
SpringBoot中整合MybatisPlus快速实现Mysql增删改查和条件构造器：
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/135646024
在上面的基础上实现同时连接mysql和postgresql多数据源。
注：
博客：
https://blog.csdn.net/badao_liumang_qizhi
实现
1、添加依赖
添加postgresql的依赖
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
添加mysql驱动
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
添加多数据源dynamic-datasource的依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.2.1</version>
</dependency>
添加mybatisplus的依赖
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.1</version>
</dependency>
完整pom依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<!--MySQL驱动-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.5.1</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>dynamic-datasource-spring-boot-starter</artifactId>
<version>3.2.1</version>
</dependency>
2、修改application.yml配置文件，添加多数据源的配置
spring:
datasource:
dynamic:
primary: master
#设置默认的数据源或者数据源组,默认值即为master
strict: false
#严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
datasource:
master:
url:jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
driver-class-name:
com.mysql.jdbc.Driver
dbcp2:
min-idle: 5 #
数据库连接池的最小维持连接数
initial-size:
5 # 初始化连接数
max-total: 5 # 最大连接数
max-wait-millis: 150 #
等待连接获取的最大超时时间
pg:
url:
jdbc:postgresql://127.0.0.1:5432/test
username: postgres
password: 123456
driver-class-name: org.postgresql.Driver
dbcp2:
min-idle: 5 # 数据库连接池的最小维持连接数
initial-size: 5 #
初始化连接数
max-total:
5 # 最大连接数
max-wait-millis: 150 # 等待连接获取的最大超时时间
3、postgresql中新建表t_student
并新建实体类
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Builder;
import
lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value
= "t_student")
public class Student implements
Serializable {
private static final long serialVersionUID = -5514139686858156155L;
private Integer id;
private String name;
private Integer age;
private String address;
}
4、新建student的mapper
import com.badao.demo.config.DataSourceOfPG;
import com.badao.demo.entity.Student;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springframework.stereotype.Repository;
@Repository
@DataSourceOfPG
public interface StudentMapper extends
BaseMapper<Student> {
}
注意这里的@DataSourceOfPG是自定义注解，你也可以直接使用
@DS("pg")
这里的pg与上面yml中数据源名称对应，为防止pg修改导致多处修改，这里的dynamic datasource的 @DS注解使用
自定义注解实现。
import com.baomidou.dynamic.datasource.annotation.DS;
import java.lang.annotation.*;
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@DS("pg")
public @interface DataSourceOfPG {
}
关于自定义注解可以参考其他文章
Java中通过反射+自定义注解判断对象中部分属性是否为空，返回为空字段的名称或自定义含义：
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/127847218SpringBoot中通过自定义Jackson注解实现接口返回数据脱敏：
https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/131749770
user表参考上面博客
实体类
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
@TableName(value
= "t_user")
public class User implements Serializable
{
private static final long serialVersionUID = -5514139686858156155L;
private Integer id;
private Integer userId;
private String name;
private Integer age;
@TableField(exist = false)
private String address;
}
mapper为
@Repository
public interface
UserMapper extends BaseMapper<User> {
}
5、编写单元测试测试从两个数据源中获取数据
@SpringBootTest
class PGTest
{
@Autowired
private
StudentMapper studentMapper;
@Autowired
private
UserMapper userMapper;
@Test
void test1() {
List<Student> students =
studentMapper.selectList(new LambdaQueryWrapper<>());
System.out.println(students);
List<User> users = userMapper.selectList(new
LambdaQueryWrapper<>());
System.out.println(users);
}
}
单元测试运行结果
