springboot下配置多数据源的方法

2025-05-29 0 56

一、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、项目结构

springboot下配置多数据源的方法

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

2、dal的目录结构

springboot下配置多数据源的方法

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

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

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

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

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

3、具体的配置文件介绍

springboot下配置多数据源的方法

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

1、java实体类

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

2、msyql库的mapper文件

springboot下配置多数据源的方法

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

springboot下配置多数据源的方法

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

springboot下配置多数据源的方法

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

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66
<?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、目录结构

springboot下配置多数据源的方法

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

配置的dal module中。

application.yml的内容:

springboot下配置多数据源的方法springboot下配置多数据源的方法

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

DruidConfiguration类

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37
@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 类

?

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23
@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接口(即该库下的所有表)
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持快网idc。

原文链接:http://blog.csdn.net/wangqingqi20005/article/details/52613055

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

快网idc优惠网 建站教程 springboot下配置多数据源的方法 https://www.kuaiidc.com/117392.html

相关文章

发表评论
暂无评论