SpringBoot集成多数据源解析

一，前面我们介绍了springboot的快速启动，大家肯定对springboot也有所了解，下面我们来介绍一下springboot怎么集成多数据源。

在有的项目开发中需要在一个项目中访问多个数据源或者两个项目之间通信（实质上是互相访问对方的数据库），在这里，我们介绍一下在一个项目中如何集成多个数据源（即访问多个不同的数据库），因为在项目中有时会有这种需求，比如在一个大型项目开发中，一个数据库中保存数据的索引，各种使用频繁的数据，另一个数据库中保存其他的数据。

1.下面我们来讨论一个问题，怎么集成多数据源，就是怎么让一个项目访问多个数据库？

有的人会说使用注解，没错，这是一种办法，因为springboot对的最大好处就是避免了繁琐的xml配置文件，大量的使用注解来开发，方便简洁，但是在这里如果集成多数据源使用注解的话会很麻烦，有没有其他的办法呢？答案是肯定的，我们可以分模板来访问多个数据库，也就是分包。

2.如何分包来访问多个数据源？

在这里，我们用一个简单的案例来说明，我们访问新建一个spingboot项目，访问test1,test2这两个数据库，首先，我们先看代码。

首先，我们需要导入相关依赖在pom文件中，这里，因为我的项目已经提前有了父pom，所以不再考虑依赖的版本问题，怎么建立父pom可参考上一篇文章。

<project xmlns="http://maven.apache.org/pom/4.0.0" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xsi:schemalocation="http://maven.apache.org/pom/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelversion>4.0.0</modelversion>

<parent>

<groupid>cn.shinelon.springboot</groupid>

<artifactid>microboot</artifactid>

<version>0.0.1-snapshot</version>

</parent>

<artifactid>springboot-multidatasources</artifactid>

<packaging>war</packaging>

<build>

<plugins>

<plugin>

<groupid>org.apache.maven.plugins</groupid>

<artifactid>maven-war-plugin</artifactid>

<version>2.3</version>

<configuration>

<failonmissingwebxml>false</failonmissingwebxml>

</configuration>

</plugin>

</plugins>

</build>

<dependencies>

<dependency>

<groupid>org.springframework.boot</groupid>

<artifactid>spring-boot-starter-web</artifactid>

</dependency>

<dependency>

<groupid>org.springframework.boot</groupid>

<artifactid>spring-boot-starter-test</artifactid>

<scope>test</scope>

</dependency>

<dependency>

<groupid>org.springframework</groupid>

<artifactid>springloaded</artifactid>

</dependency>

<dependency>

<groupid>org.springframework.boot</groupid>

<artifactid>spring-boot-devtools</artifactid>

</dependency>

<dependency>

<groupid>org.springframework.boot</groupid>

<artifactid>spring-boot-starter-tomcat</artifactid>

</dependency>

<dependency>

<groupid>org.apache.tomcat.embed</groupid>

<artifactid>tomcat-embed-jasper</artifactid>

</dependency>

<dependency>

<groupid>org.mybatis.spring.boot</groupid>

<artifactid>mybatis-spring-boot-starter</artifactid>

<version>1.3.0</version>

</dependency>

<dependency>

<groupid>mysql</groupid>

<artifactid>mysql-connector-java</artifactid>

</dependency>

</dependencies>

</project>

在上面配置的pom文件中，有点要说明，因为要访问数据库，所以我整合了mybatis，还有一个是整合jsp，不过在这个项目中无关，是我之前写代码留下来的，可不必关心。

下面，我们还要在scr/main/sources目录下新建一个application.properties资源文件，注意，这个文件名必须是application，这个是固定的，springboot默认访问该文件，不要自己乱改名称。然后在这个资源文件中配置自定义数据源。

spring.datasource.test1.driverclassname=com.mysql.jdbc.driver

spring.datasource.test1.url=jdbc:mysql://localhost:3306/test1

spring.datasource.test1.username=root

spring.datasource.test1.password=.....

spring.datasource.test2.driverclassname=com.mysql.jdbc.driver

spring.datasource.test2.url=jdbc:mysql://localhost:3306/test2

spring.datasource.test2.username=root

spring.datasource.test2.password=.....

配置好数据源后我们就可以开进行分模块来访问这两个数据源了。首先在src/mian/java目录下创建好各个包，然后开始开发，新建一个datasource包来放置需要访问的两个数据源的代码，然后在新建两个模块包test1和test2，从包名我们就可以看出来这两个包是用来操作这两个数据库，在这两个包下可以分别建立dao层和service层的包，然后建立一个controller控制层。下面是项目的目录树图。

然后我们来写datasource中的代码，其实就是像我们以前在xml文件中配置的sqlsessionfactory和数据源一个原理。

import javax.sql.datasource;

import org.apache.ibatis.session.sqlsessionfactory;

import org.mybatis.spring.sqlsessionfactorybean;

import org.mybatis.spring.sqlsessiontemplate;

import org.mybatis.spring.annotation.mapperscan;

import org.springframework.beans.factory.annotation.qualifier;

import org.springframework.boot.autoconfigure.jdbc.datasourcebuilder;

import org.springframework.boot.context.properties.configurationproperties;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

import org.springframework.context.annotation.primary;

import org.springframework.core.io.support.pathmatchingresourcepatternresolver;

import org.springframework.jdbc.datasource.datasourcetransactionmanager;

@configuration

@mapperscan(basepackages="cn.shinelon.test1",sqlsessionfactoryref="test1sqlsessionfactory")

public class datasource1 {

/**

* 配置test1数据库

* @return

*/

@bean(name="test1datasource")

@configurationproperties(prefix="spring.datasource.test1")

public datasource testdatasource() {

return datasourcebuilder.create().build();

}

/**

* 创建sqlsessionfactory

* @param datasource

* @return

* @throws exception

*/

@bean(name="test1sqlsessionfactory")

public sqlsessionfactory testsqlsessionfactory(@qualifier("test1datasource")datasource datasource)

throws exception {

sqlsessionfactorybean bean=new sqlsessionfactorybean();

bean.setdatasource(datasource);

//如果还有分页等其他事务

// bean.setmapperlocations(new pathmatchingresourcepatternresolver().

// getresources("classpath:mybatis/test1/*.xml"));

return bean.getobject();

}

/**

* 配置事务管理

* @param datasource

* @return

*/

@bean(name="test1transactionmanager")

public datasourcetransactionmanager testtransactionmanager(

@qualifier("test1datasource")datasource datasource) {

return new datasourcetransactionmanager(datasource);

}

@bean(name="test1sqlsessiontemplate")

public sqlsessiontemplate testsqlsessiontemplate(@qualifier("test1sqlsessionfactory")

sqlsessionfactory sqlsessionfactory) {

return new sqlsessiontemplate(sqlsessionfactory);

}

上面的是访问的test1数据库的配置，需要注意的是@configurationproperties(prefix=”spring.datasource.test1”)这个配置中的属性prefix的值必须和资源文件中的前缀是一样的，否则是访问不到的，还有@primary ，如果不加这个注解，启动将会报错，因为服务器先要有一个默认不知道默认要先访问的数据源是哪个，必须指明，下面是test2数据库的配置，和上面一样的。

SpringBoot集成多数据源解析

相关文章

快网idc优惠网

相关文章

微信

快网idc优惠网

QQ交流群