。

在许多情况下#xff0c;我们需要同时操作多个数据库#xff0c;或者需要将不同类型的数据存储在不…1.

仓库地址https://gitee.com/aopmin/multi-datasource-demo

随着项目规模的扩大和业务需求的复杂化单一数据源已经不能满足实际开发中的需求。

在许多情况下我们需要同时操作多个数据库或者需要将不同类型的数据存储在不同的数据库中。

这时多数据源场景成为必不可少的解决方案。

方案1基于Spring框架提供的AbstractRoutingDataSource。

简单易用支持动态切换数据源适用于少量数据源情况。

场景适用于需要动态切换数据源且数据库较少的情况。

文档地址

方案2使用MP提供的Dynamic-datasource多数据源框架。

文档地址https://baomidou.com/guides/dynamic-datasource/#dynamic-datasource

方案3通过自定义注解在方法或类上指定数据源实现根据注解切换数据源的功能。

适用于需要在代码层面进行数据源切换并对数据源切换有精细要求的情况。

方案4使用动态代理技术在运行时动态切换数据源实现多数据源的切换。

灵活性高支持在运行时动态切换数据源适合对数据源切换的逻辑有特殊需求的情况。

场景

1、执行sql脚本(分别创建两个数据库里面都提供一张user表)

创建数据库ds1

parentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion2.7.10/versionrelativePath/

!--

/parentdependencies!--jdbc起步依赖--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-jdbc/artifactId

/dependency!--test起步依赖--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactId/dependency!--mysql驱动--dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.20/version/dependency!--lombok--dependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactId/dependency!--jdbc起步依赖--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-jdbc/artifactId/dependency

/dependencies3、编写实体类

spring:#动态数据源配置datasource:ds1:driverClassName:

com.mysql.cj.jdbc.DriverjdbcUrl:

jdbc:mysql://localhost:3306/ds1?serverTimezoneAsia/ShanghaiuseUnicodetruecharacterEncodingutf8useSSLfalseusername:

rootpassword:

com.mysql.cj.jdbc.DriverjdbcUrl:

jdbc:mysql://localhost:3306/ds2?serverTimezoneAsia/ShanghaiuseUnicodetruecharacterEncodingutf8useSSLfalseusername:

rootpassword:

org.springframework.beans.factory.annotation.Qualifier;

import

org.springframework.boot.context.properties.ConfigurationProperties;

import

org.springframework.boot.jdbc.DataSourceBuilder;

import

org.springframework.context.annotation.Bean;

import

org.springframework.context.annotation.Configuration;

import

org.springframework.jdbc.core.JdbcTemplate;import

import

{//定义数据源1Bean(ds1)ConfigurationProperties(prefix

DataSource

DataSourceBuilder.create().build();}//定义数据源2Bean(ds2)ConfigurationProperties(prefix

DataSource

DataSourceBuilder.create().build();}//定义动态数据源Bean(name

dataSource)public

dynamicDataSource(Qualifier(ds1)

DataSource

HashMap();targetDataSources.put(ds1,

ds1);targetDataSources.put(ds2,

ds2);//2.实例化自定义的DynamicDataSource对象,

dynamicDataSource

DynamicDataSource();dynamicDataSource.setTargetDataSources(targetDataSources);//3.设置默认数据源,未匹配上则使用默认数据源dynamicDataSource.setDefaultTargetDataSource(ds1);return

Beanpublic

jdbcTemplate(Qualifier(dataSource)

DataSource

cn.aopmin.common.DataSourceContextHolder;

import

org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;/***

AbstractRoutingDataSource(抽象的数据源路由器)

当应用程序需要访问数据库的时候,AbstractRoutingDataSource会根据某种匹配规则例如请求参数、用户身份等来选择一个合适的数据源*

public

DataSourceContextHolder.getDataSource();}

package

{contextHolder.set(dataSourceName);}//

static

org.springframework.boot.SpringApplication;

import

org.springframework.boot.autoconfigure.SpringBootApplication;/***

启动类**

{SpringApplication.run(Demo01Application.class,

args);}

cn.aopmin.common.DataSourceContextHolder;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.jdbc.core.JdbcTemplate;

import

org.springframework.stereotype.Service;/***

author

todo:自定义注解SpringAop实现数据源的切换DataSourceContextHolder.setDataSource(ds1);String

sql

values(?,?);jdbcTemplate.update(sql,user.getUsername(),

user.getGender());}

{DataSourceContextHolder.clearDataSource();}}public

void

{DataSourceContextHolder.setDataSource(ds2);String

sql

values(?,?);jdbcTemplate.update(sql,user.getUsername(),

user.getGender());}

{DataSourceContextHolder.clearDataSource();}}

}10、编写测试

org.springframework.boot.test.context.SpringBootTest;import

javax.annotation.Resource;SpringBootTest(classes

public

User();user.setUsername(jack);user.setGender(0);user.setGender(1);userService.insertDs1(user);}Testpublic

void

User();user.setUsername(rose);user.setGender(1);userService.insertDs2(user);}

}最终效果

mp文档https://baomidou.com/guides/dynamic-datasource/#_top

1、创建SpringBoot工程引入Dynamic-datasource依赖

dependencygroupIdcom.baomidou/groupIdartifactIddynamic-datasource-spring-boot-starter/artifactIdversion3.5.2/version

/dependency2、配置数据源

spring:#多数据源配置datasource:dynamic:primary:

master

#是否严格检查动态数据源提供的数据库名datasource:#数据源1master:url:

jdbc:mysql:///ds1?useUnicodetruecharacterEncodingutf-8useSSLfalseserverTimezoneAsia/Shanghaiusername:

rootpassword:

com.mysql.cj.jdbc.Driver#数据源2slave1:url:

jdbc:mysql:///ds2?useUnicodetruecharacterEncodingutf-8useSSLfalseserverTimezoneAsia/Shanghaiusername:

rootpassword:

com.baomidou.dynamic.datasource.annotation.DS;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.jdbc.core.JdbcTemplate;

import

org.springframework.stereotype.Service;/***

author

values(?,?);jdbcTemplate.update(sql,user.getUsername(),

user.getGender());}DS(slave1)public

void

values(?,?);jdbcTemplate.update(sql,user.getUsername(),

user.getGender());}

org.springframework.boot.test.context.SpringBootTest;import

javax.annotation.Resource;SpringBootTest

public

User();user.setUsername(jack);user.setGender(0);user.setGender(1);userService.insertDs1(user);}Testpublic

void

User();user.setUsername(rose);user.setGender(1);userService.insertDs2(user);}