springboot下配置多数据源的方法

 更新时间:2017年04月19日 10:21:51   作者:十丿四  
本篇文章主要介绍了springboot下配置多数据源的方法,具有一定的参考价值,有兴趣的可以了解一下

一、springboot 简介

SpringBoot使开发独立的,产品级别的基于Spring的应用变得非常简单,你只需"just run"。 我们为Spring平台及第三方库提 供开箱即用的设置,这样你就可以有条不紊地开始。多数Spring Boot应用需要很少的Spring配置。

你可以使用SpringBoot创建Java应用,并使用 java -jar 启动它或采用传统的war部署方式。我们也提供了一个运行"spring 脚本"的命令行工具。

二、传统的DataSource配置

Java的javax.sql.DataSource接口提供了一个标准的使用数据库连接的方法。传统做法是,一个DataSource使用一个URL连

同相应的证书去初始化一个数据库连接。

开发中,一个项目中经常会使用到不知一个数据源,本文主要讲解如何在springboot下整合mybatis配置多数据源。主要对比下传统的xml配置数据源和springboot下的数据源配置。

首先介绍下传统的xml下如何配置多数据源

1、项目结构

使用maven构建的项目中,所有的数据源配置到DAO层,即图中 subscribecore.dal module

2、dal的目录结构

1、数据库对应的java实体类。

2、每个库对应的mapper文件。

3、每个mapper文件对应的到的xml文件。

4、生产环境\测试环境对应的数据源配置文件。

5、每个数据库对应的配置文件。

3、具体的配置文件介绍

以mysql库为例,详细展开对mysql数据配置的介绍

1、java实体类

使用的mysql库中的一张表,通过mybatis自动生成工具,生成了chartconfig类和chartconfigExample类。

2、msyql库的mapper文件

3、mapper文件对应的到的xml文件

4、mysql测试环境对应的数据源配置文件

5、myssql数据库对应的配置文件

<?xml version="1.0" encoding="UTF-8"?> 
<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:cache="http://www.springframework.org/schema/cache" 
    xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans.xsd 
            http://www.springframework.org/schema/context  http://www.springframework.org/schema/context/spring-context.xsd 
            http://www.springframework.org/schema/tx   http://www.springframework.org/schema/tx/spring-tx.xsd 
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd 
            http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd"> 
  <context:component-scan base-package="com.zto.subscribecore"></context:component-scan> 
 
 
 
  <!-- 数据源 --> 
  <bean id="mysqlDataSource" class="com.alibaba.druid.pool.DruidDataSource" 
     init-method="init" destroy-method="close"> 
    <!-- 驱动名称 --> 
    <property name="DriverClassName" value="${mysql.DriverClassName}"/> 
    <!-- JDBC连接串 --> 
    <property name="url" value="${mysql.url}"/> 
    <!-- 数据库用户名称 --> 
    <property name="username" value="${mysql.username}"/> 
    <!-- 数据库密码 --> 
    <property name="password" value="${mysql.password}"/> 
    <!-- 连接池最大使用连接数量 --> 
    <property name="maxActive" value="${mysql.maxActive}"/> 
    <!-- 初始化大小 --> 
    <property name="initialSize" value="${mysql.initialSize}"/> 
    <!-- 获取连接最大等待时间 --> 
    <property name="maxWait" value="${mysql.maxWait}"/> 
    <!-- 连接池最小空闲 --> 
    <property name="minIdle" value="${mysql.minIdle}"/> 
    <!-- 逐出连接的检测时间间隔 --> 
    <property name="timeBetweenEvictionRunsMillis" value="${mysql.timeBetweenEvictionRunsMillis}"/> 
    <!-- 最小逐出时间 --> 
    <property name="minEvictableIdleTimeMillis" value="${mysql.minEvictableIdleTimeMillis}"/> 
    <!-- 测试有效用的SQL Query --> 
    <property name="validationQuery" value="${mysql.validationQuery}"/> 
    <!-- 连接空闲时测试是否有效 --> 
    <property name="testWhileIdle" value="${mysql.testWhileIdle}"/> 
    <!-- 获取连接时测试是否有效 --> 
    <property name="testOnBorrow" value="${mysql.testOnBorrow}"/> 
    <!-- 归还连接时是否测试有效 --> 
    <property name="testOnReturn" value="${mysql.testOnReturn}"/> 
  </bean> 
 
  <bean id="mysqlTransactionManager" 
     class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
    <property name="dataSource" ref="mysqlDataSource"/> 
  </bean> 
 
  <tx:annotation-driven transaction-manager="mysqlTransactionManager"/> 
 
  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> 
    <property name="basePackage" value="com.zto.subscribecore.dal.mapper.mysql"/> 
    <property name="sqlSessionFactoryBeanName" value="mysqlSqlSessionFactory"/> 
  </bean> 
 
  <bean id="mysqlSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 
    <property name="dataSource" ref="mysqlDataSource"/> 
    <property name="mapperLocations" value="classpath*:com/zto/subscribecore/dal/mapper/mysql/*.xml"></property> 
    <property name="typeAliasesPackage" value="com.zto.subscribecore.dal.domain"/> 
  </bean> 
 
</beans> 

配制文件步骤分解:

1、注入数据源,即 bean id为mysqlDatasource的配置文件,该配置可以从jdbc-dev.properties文件中读取到对应到数据库配置文件。

2、声明DataSourceTransactionManager 即 bean id为 mysqlTransactionManager 的配置文件,该配置 为事务管理,在spring中是对JdbcTemplate进行事务管理

3、自动扫描包,即 bean class 为 org.mybatis.spring.mapper.MapperScannerConfigurer的配置文件。该配置 将mapper接口生成的代理注入到spring。可以自动扫描该包名下的所有的文件,即 实体类,mapper接口类,和mapper接口对应的xml文件。

4、创建seesion,即bean id为 mysqlSqlSessionFactory 的配置文件,该配置中指定了对应mysql库的xml文件和对应的实体类的路径。一个sqlSeesionFactory代表了一个数据源。(就相当于产生连接池)

至此完成了mysql库的配置。

三、springboot下的datasource配置

通过上面的配置文件,了解到数据源的相关配置,下面描述下如何在springboot下完成多数据源的配置工作。

1、目录结构

同样,使用maven构建多module的工程,但是取消了jdbc-properties,数据连接配置卸载写在application.yml中。dao层的文件

配置的dal module中。

application.yml的内容:

1、注入数据源,使用@Configuration注解,springboot在启动时,会自动加载该类,和xml声明类似。(同 <beans></beans),@Bean 注入一个类。@Value 注解,使用${} 从application.yml读取配置。

DruidConfiguration类

@Configuration 
public class DruidConfiguration { 
  @Bean(name = "vip", initMethod = "init", destroyMethod = "close") 
  public DataSource compare1DataSource( 
      @Value("${spring.datasource.vip.driver-class-name}") String driver, 
      @Value("${spring.datasource.vip.url}") String url, 
      @Value("${spring.datasource.vip.username}") String username, 
      @Value("${spring.datasource.vip.password}") String password, 
      @Value("${spring.datasource.vip.minIdle}") int minIdle, 
      @Value("${spring.datasource.vip.maxActive}") int maxActive, 
      @Value("${spring.datasource.vip.initialSize}") int initialSize, 
      @Value("${spring.datasource.vip.timeBetweenEvictionRunsMillis}") long timeBetweenEvictionRunsMillis, 
      @Value("${spring.datasource.vip.minEvictableIdleTimeMillis}") long minEvictableIdleTimeMillis, 
      @Value("${spring.datasource.vip.validationQuery}") String validationQuery, 
      @Value("${spring.datasource.vip.testWhileIdle}") boolean testWhileIdle, 
      @Value("${spring.datasource.vip.testOnBorrow}") boolean testOnBorrow, 
      @Value("${spring.datasource.vip.testOnReturn}") boolean testOnReturn) { 
    DruidDataSource druidDataSource = new DruidDataSource(); 
    druidDataSource.setDriverClassName(driver); 
    druidDataSource.setUrl(url); 
    druidDataSource.setUsername(username); 
    druidDataSource.setPassword(password); 
    druidDataSource.setMinIdle(minIdle); 
    druidDataSource.setMaxActive(maxActive); 
    druidDataSource.setInitialSize(initialSize); 
    druidDataSource 
        .setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis); 
    druidDataSource 
        .setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis); 
    druidDataSource.setValidationQuery(validationQuery); 
    druidDataSource.setTestWhileIdle(testWhileIdle); 
    druidDataSource.setTestOnBorrow(testOnBorrow); 
    druidDataSource.setTestOnReturn(testOnReturn); 
    return druidDataSource; 
  } 
 
} 

2、指定domain类、mapper接口,xml配件文件的路径,并指定映射关系

@MapperScan 注解,扫描该包名下的所有文件。

@Autowired+@Qualifier 注入 上面已经声明的 datasource 类

@Configuration 
@MapperScan(basePackages = { "com.zto.merchantPlatform.mapper.vip" }, sqlSessionFactoryRef = "vipSqlSessionFactory") 
public class VipMybatisConfiguration { 
 
  @Autowired 
  @Qualifier("vip") 
  private DataSource dataSource; 
   
  @Bean(name = "vipSqlSessionFactory") 
  public SqlSessionFactoryBean sqlSessionFactory(@Value("${mybatis.vip.mapperLocations}") String mapperLocations,  
      @Value("${mybatis.vip.typeAliasesPackage}")String typeAliasesPackage) throws Exception { 
    SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean(); 
    sessionFactoryBean.setDataSource(dataSource); 
    sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations)); 
    sessionFactoryBean.setTypeAliasesPackage(typeAliasesPackage); 
    return sessionFactoryBean; 
  } 
 
  @Bean(name = "vipTransactionManager") 
  public DataSourceTransactionManager transactionManager() { 
    return new DataSourceTransactionManager(dataSource); 
  } 
} 

3、mapper接口对应的xml文件

4、数据源配置文件

5、指定mybatis下的mapper和xml文件的之间的映射关系。

6、mapper接口(即该库下的所有表)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Python动态类型实现原理及过程解析

    Python动态类型实现原理及过程解析

    这篇文章主要介绍了Python动态类型实现原理及过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • SpringBoot集成Druid配置(yaml版本配置文件)详解

    SpringBoot集成Druid配置(yaml版本配置文件)详解

    这篇文章主要介绍了SpringBoot集成Druid配置(yaml版本配置文件),本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-12-12
  • spring 如何将配置信息注入静态变量的方法

    spring 如何将配置信息注入静态变量的方法

    本篇文章主要介绍了spring 如何将配置信息注入静态变量的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-06-06
  • Java中的值传递和引用传递区别解析

    Java中的值传递和引用传递区别解析

    这篇文章主要介绍了Java中的值传递和引用传递区别解析,引用类型的变量保存引用值,“引用值”指向内存空间的地址,代表了某个对象的引用,而不是对象本身,对象本身存放在该引用值所表示的地址的位置,包含:数组、类、接口,需要的朋友可以参考下
    2023-11-11
  • mybatis selectKey赋值未生效的原因分析

    mybatis selectKey赋值未生效的原因分析

    这篇文章主要介绍了mybatis selectKey赋值未生效的原因分析,selectKey 会将 SELECT LAST_INSERT_ID()的结果放入到传入的实体类的主键里面,文中通过代码示例给大家讲解非常详细,需要的朋友可以参考下
    2024-02-02
  • 解决SpringBoot配置文件项目重启出现乱码的问题

    解决SpringBoot配置文件项目重启出现乱码的问题

    最近在创建了SpringBoot项目后往配置文件中写了相关的系统配置,并且在上面加了中文注释,但是在重启项目或开机重启后遇到了注释乱码的情况,下面这篇文章主要给大家介绍一下如何解决SpringBoot配置文件项目重启出现乱码的问题,需要的朋友可以参考下
    2023-06-06
  • Java中多线程同步类 CountDownLatch

    Java中多线程同步类 CountDownLatch

    本篇文章主要介绍了Java中多线程同步类 CountDownLatch的相关知识,具有很好的参考价值。下面跟着小编一起来看下吧
    2017-05-05
  • SpringBoot整合ShardingSphere5.x实现数据加解密功能(最新推荐)

    SpringBoot整合ShardingSphere5.x实现数据加解密功能(最新推荐)

    这篇文章主要介绍了SpringBoot整合ShardingSphere5.x实现数据加解密功能,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-06-06
  • 微服务搭建集成Spring Cloud Turbine详解

    微服务搭建集成Spring Cloud Turbine详解

    Spring Cloud是一系列框架的有序集合。它利用Spring Boot的开发便利性巧妙地简化了分布式系统基础设施的开发,最终给开发者留出了一套简单易懂、易部署和易维护的分布式系统开发工具包。下面我们来详细了解一下吧
    2019-06-06
  • AsyncHttpClient的ConnectionSemaphore方法源码流程解读

    AsyncHttpClient的ConnectionSemaphore方法源码流程解读

    这篇文章主要为大家介绍了AsyncHttpClient的ConnectionSemaphore方法源码流程解读,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-12-12

最新评论