spring boot多数据源动态切换代码实例

这篇文章主要介绍了spring boot多数据源动态切换代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

当项目中存在多数据源时，就涉及到数据源的动态切换，通过研究，特此记录一下。

1、maven依赖

com.oracleojdbc611.2.0.4runtime com.alibaba druid-spring-boot-starter 1.1.10 org.springframework.boot spring-boot-starter-jdbc org.springframework.boot spring-boot-starter-aop

2、多数据源信息配置

#多数据源测试 spring: datasource: druid: master: driver-class-name: oracle.jdbc.driver.OracleDriver username: test password: test url: jdbc:oracle:thin:@//ip1:1521/orcl slave: driver-class-name: oracle.jdbc.driver.OracleDriver username: test password: test url: jdbc:oracle:thin:@//ip2:1521/orcl

3、数据源配置信息转换成实体类

@ConfigurationProperties(prefix = "spring.datasource.druid") @Data @Component public class DataSourceProperties { private Mapmaster; private Mapslave; }

4、动态数据源切换类

public class DynamicDataSource extends AbstractRoutingDataSource { private static final ThreadLocal contextHolder = new ThreadLocal(); public DynamicDataSource(DataSource defaultTargetDataSource, Map targetDataSources) { super.setDefaultTargetDataSource(defaultTargetDataSource); super.setTargetDataSources(targetDataSources); super.afterPropertiesSet(); } @Override protected Object determineCurrentLookupKey() { return getDataSource(); } public static void setDataSource(String dataSource) { contextHolder.set(dataSource); } public static String getDataSource() { return contextHolder.get(); } public static void clearDataSource() { contextHolder.remove(); } }

5、多数据源配置类

@Configuration public class DynamicDataSourceConfig { @Bean public DataSource master(@Autowired DataSourceProperties dataSourceProperties){ DruidDataSource druidDataSource = new DruidDataSource(); Map master = dataSourceProperties.getMaster(); druidDataSource.setUsername(master.get("username")); druidDataSource.setPassword(master.get("password")); druidDataSource.setUrl(master.get("url")); //其他参数配置省略 return druidDataSource; } @Bean public DataSource slave(@Autowired DataSourceProperties dataSourceProperties){ DruidDataSource druidDataSource = new DruidDataSource(); Map slave = dataSourceProperties.getSlave(); druidDataSource.setUsername(slave.get("username")); druidDataSource.setPassword(slave.get("password")); druidDataSource.setUrl(slave.get("url")); //其他参数配置省略 return druidDataSource; } @Bean @Primary public DynamicDataSource dataSource(DataSource master,DataSource slave){ Mapmap = new HashMap(4); map.put("master",master); map.put("slave",slave); return new DynamicDataSource(master,map); } }

6、自定义@DataSource注解

@Target(ElementType.METHOD) @Retention(RetentionPolicy.RUNTIME) public @interface DataSource { String name() default "master"; }

7、Aop切面类配置

@Component @Aspect public class DataSourceAspect { @pointcut("@annotation(com.zxgeo.sso.muiltDatasource.anons.DataSource)") public void dataSourcepointcut(){} @Around(value = "dataSourcepointcut()") public Object around(ProceedingJoinPoint point) throws Throwable { MethodSignature signature = (MethodSignature) point.getSignature(); Method method = signature.getmethod(); DataSource dataSource = method.getAnnotation(DataSource.class); if(dataSource == null){ DynamicDataSource.setDataSource("master"); }else { DynamicDataSource.setDataSource(dataSource.name()); } try { return point.proceed(); } finally { DynamicDataSource.clearDataSource(); } } }

8、启动配置注解信息，重要（不然运行会报错）

@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})

9、测试

（1）、service层（此处没有使用mybatis）

@Service public class TestService { @Autowired private javax.sql.DataSource dataSource; @DataSource public Map getMasterDataSource() throws sqlException { Connection connection = dataSource.getConnection(); Map map; try (PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM AA WHERE A=10001")) { ResultSet resultSet = preparedStatement.executeQuery(); map = new HashMap(); while (resultSet.next()){ map.put("A",resultSet.getString("A")); map.put("B",resultSet.getString("B")); map.put("C",resultSet.getString("C")); } } return map; } @DataSource(name = "slave") public Map getSlaveDataSource() throws sqlException { Connection connection = dataSource.getConnection(); Map map; try (PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM AA WHERE A=10002")) { ResultSet resultSet = preparedStatement.executeQuery(); map = new HashMap(); while (resultSet.next()){ map.put("A",resultSet.getString("A")); map.put("B",resultSet.getString("B")); map.put("C",resultSet.getString("C")); } } return map; } }

（2）、单元测试

@SpringBoottest @RunWith(springrunner.class) class SsoApplicationTests { @Autowired private TestService testService; @Test public void muliDatasorce() throws sqlException { Map masterDataSourceUrl = testService.getMasterDataSource(); System.out.println(masterDataSourceUrl); Map slaveDataSourceUrl = testService.getSlaveDataSource(); System.out.println(slaveDataSourceUrl); } }

（3）、结果：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持html中文网。

您可能感兴趣的文章:Spring Boot 动态数据源示例（多数据源自动切换）spring boot + mybatis实现动态切换数据源实例代码SpringBoot Mybatis动态数据源切换方案实现过程spring boot动态切换数据源的实现详细聊聊SpringBoot中动态切换数据源的方法

上一篇：java实现图片滑动验证(包含前端代码)下一篇：Java--Socket通信（客户端服务端双向）热门搜索：

多数据源动态切换

动态数据源切换

多数据源切换

动态数据源

Spring boot