JarCastingluava-spring-multidatasource
spring多数据源
如何使用
1. maven引入
<dependency>
<groupId>org.linuxprobe</groupId>
<artifactId>luava-spring-multidatasource</artifactId>
<version>0.0.2.RELEASE</version>
</dependency>
2. yml配置
spring:
datasources:
# master库必须有,下面的从库可以没有
master:
jdbc-url: jdbc:mysql://127.0.0.1:3306/uni?useUnicode=true&characterEncoding=UTF-8&useSSL=false
username: root
password: 123456
driverClassName: com.mysql.cj.jdbc.Driver
# 从库; 从库可以随便起名, 但不能是master
slave:
jdbc-url: jdbc:mysql://192.168.160.2:3306/uni?useUnicode=true&characterEncoding=UTF-8&useSSL=false
username: root
password: 123456
driverClassName: com.mysql.cj.jdbc.Driver
# 从库1
slave1:
jdbc-url: jdbc:mysql://192.168.160.2:3306/uni?useUnicode=true&characterEncoding=UTF-8&useSSL=false
username: root
password: 123456
driverClassName: com.mysql.cj.jdbc.Driver
3. spring boot java bean配置(spring + spring mvc 也可自行转换为xml配置)
import java.util.Map;
import org.liunxprobe.spring.datasource.MultiDataSource;
import org.liunxprobe.spring.datasource.aop.DataSourceAop;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import com.zaxxer.hikari.HikariDataSource;
import lombok.Getter;
import lombok.Setter;
@Configuration
@ConfigurationProperties(prefix = "spring")
@Getter
@Setter
public class DataSourceConfiguration {
private Map<String, HikariDataSource> datasources;
// 配置数据源
@SuppressWarnings("unchecked")
@Bean
public MultiDataSource multiDataSource() {
return new MultiDataSource((Map<Object, Object>) ((Map<?, ?>) datasources));
}
// 配置切面
@Bean
public DataSourceAop dataSourceAop(MultiDataSource multiDataSource) {
return new DataSourceAop(multiDataSource);
}
// 配置事务管理
@Bean
DataSourceTransactionManager transactionManager(MultiDataSource multiDataSource) {
return new DataSourceTransactionManager(multiDataSource);
}
}
4. contoller或service的方法注解(DataSorce)切换数据源
- 当mater为true时, 标记使用主库, 这是默认的;
- 当slave为true时, 标记使用从库, 此时mater的值将失效, 如何有多个从库, 将轮询使用每个从库来达到负载均衡;
- 当value的值不为空时, slave和master的值将失效, 切换到用户指定的数据源.
package org.linuxprobe.universalcrudspringbootdemo.controller;
import org.linuxprobe.crud.core.query.Page;
import org.linuxprobe.universalcrudspringbootdemo.model.Permission;
import org.linuxprobe.universalcrudspringbootdemo.query.PermissionQuery;
import org.linuxprobe.universalcrudspringbootdemo.service.PermissonService;
import org.liunxprobe.spring.datasource.annotation.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/permission")
public class PermissionController {
@Autowired
private PermissonService service;
// 标记从库,会启用负载均衡
@GetMapping("/getPageInfo")
@DataSource(slave = true)
public Page<Permission> getPageInfo(PermissionQuery param) {
return this.service.getPageInfo(param);
}
// 标记主库
@GetMapping("/getPageInfo2")
@DataSource
public Page<Permission> getPageInfo2(PermissionQuery param) {
return this.service.getPageInfo(param);
}
// 标记指定库
@GetMapping("/getPageInfo3")
@DataSource(value = "slave1")
public Page<Permission> getPageInfo3(PermissionQuery param) {
return this.service.getPageInfo(param);
}
}