版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_25484147/article/details/82862298
1. 介绍
介绍如何在spring boot项目中使用整合mybatis,druid,多数据源和在多数据源的情况下使用事务。
2. 引入pom 文件
<?xml version="1.0" encoding="UTF-8"?>
<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>
<groupId>com.bobo.shopping</groupId>
<artifactId>manage</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>manage</name>
<description>商城项目的后台管理系统</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.5.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- alibaba的druid数据库连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.0</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.datatype</groupId>
<artifactId>jackson-datatype-joda</artifactId>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.module</groupId>
<artifactId>jackson-module-parameter-names</artifactId>
</dependency>
<!--FastJson-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<!--lang3包-->
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.0</version>
</dependency>
<!--日志处理-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/resources</directory>
</resource>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.xml</include>
</includes>
<filtering>true</filtering>
</resource>
</resources>
</build>
</project>
3.引入数据源
#---------------------------------------------------------
#Shopping数据源
spring.datasource.shopping.url=jdbc:mysql://localhost:3306/shopping?characterEncoding=UTF-8
spring.datasource.shopping.username=root
spring.datasource.shopping.password=123456
spring.datasource.shopping.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.shopping.maxActive=20
spring.datasource.shopping.initialSize=5
spring.datasource.shopping.minIdle=5
spring.datasource.shopping.maxWait=6000
spring.datasource.shopping.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.shopping.timeBetweenEvictionRunsMillis=60000
spring.datasource.shopping.minEvictableIdleTimeMillis=300000
spring.datasource.shopping.poolPreparedStatements=true
#---------------------------------------------------------
#shopping_cms数据源
spring.datasource.shoppingcms.url=jdbc:mysql://localhost:3306/shopping_cms?characterEncoding=UTF-8
spring.datasource.shoppingcms.username=root
spring.datasource.shoppingcms.password=123456
spring.datasource.shoppingcms.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.shoppingcms.maxActive=20
spring.datasource.shoppingcms.initialSize=5
spring.datasource.shoppingcms.minIdle=5
spring.datasource.shoppingcms.maxWait=6000
spring.datasource.shoppingcms.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.shoppingcms.timeBetweenEvictionRunsMillis=60000
spring.datasource.shoppingcms.minEvictableIdleTimeMillis=300000
spring.datasource.shoppingcms.poolPreparedStatements=true
4.映射多数据源
package com.bobo.shopping.manage.config.entity.datasource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
* 配置文件中关于shopping数据库配置
*
* @author [email protected]
* @create 2018-09-23 17:15
**/
@ConfigurationProperties(prefix = "spring.datasource.shoppingcms")
@Component
public class ShoppingCMSDataSourceProperties {
public String url;
public String username;
public String password;
public String driverClassName;
public Integer maxActive;
public Integer initialSize;
public Integer minIdle;
public Integer maxWait;
public Integer maxPoolPreparedStatementPerConnectionSize;
public Integer timeBetweenEvictionRunsMillis;
public Integer minEvictableIdleTimeMillis;
public Boolean poolPreparedStatements;
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getDriverClassName() {
return driverClassName;
}
public void setDriverClassName(String driverClassName) {
this.driverClassName = driverClassName;
}
public Integer getMaxActive() {
return maxActive;
}
public void setMaxActive(Integer maxActive) {
this.maxActive = maxActive;
}
public Integer getInitialSize() {
return initialSize;
}
public void setInitialSize(Integer initialSize) {
this.initialSize = initialSize;
}
public Integer getMinIdle() {
return minIdle;
}
public void setMinIdle(Integer minIdle) {
this.minIdle = minIdle;
}
public Integer getMaxWait() {
return maxWait;
}
public void setMaxWait(Integer maxWait) {
this.maxWait = maxWait;
}
public Integer getMaxPoolPreparedStatementPerConnectionSize() {
return maxPoolPreparedStatementPerConnectionSize;
}
public void setMaxPoolPreparedStatementPerConnectionSize(Integer maxPoolPreparedStatementPerConnectionSize) {
this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
}
public Integer getTimeBetweenEvictionRunsMillis() {
return timeBetweenEvictionRunsMillis;
}
public void setTimeBetweenEvictionRunsMillis(Integer timeBetweenEvictionRunsMillis) {
this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
}
public Integer getMinEvictableIdleTimeMillis() {
return minEvictableIdleTimeMillis;
}
public void setMinEvictableIdleTimeMillis(Integer minEvictableIdleTimeMillis) {
this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
}
public Boolean getPoolPreparedStatements() {
return poolPreparedStatements;
}
public void setPoolPreparedStatements(Boolean poolPreparedStatements) {
this.poolPreparedStatements = poolPreparedStatements;
}
}
package com.bobo.shopping.manage.config.entity.datasource;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
/**
* 配置文件中关于shopping数据库配置
*
* @author [email protected]
* @create 2018-09-23 17:15
**/
@ConfigurationProperties(prefix = "spring.datasource.shopping")
@Component
public class ShoppingDataSourceProperties {
public String url;
public String username;
public String password;
public String driverClassName;
public Integer maxActive;
public Integer initialSize;
public Integer minIdle;
public Integer maxWait;
public Integer maxPoolPreparedStatementPerConnectionSize;
public Integer timeBetweenEvictionRunsMillis;
public Integer minEvictableIdleTimeMillis;
public Boolean poolPreparedStatements;
public String getUrl() {
return url;
}
public void setUrl(String url) {
this.url = url;
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getDriverClassName() {
return driverClassName;
}
public void setDriverClassName(String driverClassName) {
this.driverClassName = driverClassName;
}
public Integer getMaxActive() {
return maxActive;
}
public void setMaxActive(Integer maxActive) {
this.maxActive = maxActive;
}
public Integer getInitialSize() {
return initialSize;
}
public void setInitialSize(Integer initialSize) {
this.initialSize = initialSize;
}
public Integer getMinIdle() {
return minIdle;
}
public void setMinIdle(Integer minIdle) {
this.minIdle = minIdle;
}
public Integer getMaxWait() {
return maxWait;
}
public void setMaxWait(Integer maxWait) {
this.maxWait = maxWait;
}
public Integer getMaxPoolPreparedStatementPerConnectionSize() {
return maxPoolPreparedStatementPerConnectionSize;
}
public void setMaxPoolPreparedStatementPerConnectionSize(Integer maxPoolPreparedStatementPerConnectionSize) {
this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;
}
public Integer getTimeBetweenEvictionRunsMillis() {
return timeBetweenEvictionRunsMillis;
}
public void setTimeBetweenEvictionRunsMillis(Integer timeBetweenEvictionRunsMillis) {
this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
}
public Integer getMinEvictableIdleTimeMillis() {
return minEvictableIdleTimeMillis;
}
public void setMinEvictableIdleTimeMillis(Integer minEvictableIdleTimeMillis) {
this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
}
public Boolean getPoolPreparedStatements() {
return poolPreparedStatements;
}
public void setPoolPreparedStatements(Boolean poolPreparedStatements) {
this.poolPreparedStatements = poolPreparedStatements;
}
}
5. 配置数据源
package com.bobo.shopping.manage.config.datasource;
import com.alibaba.druid.pool.DruidDataSource;
import com.bobo.shopping.manage.config.entity.datasource.ShoppingCMSDataSourceProperties;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import javax.sql.DataSource;
/**
* cms数据库
*
* @author [email protected]
* @create 2018-09-23 17:20
**/
@Configuration
@MapperScan(basePackages = CMSConfig.PACKAGE, sqlSessionFactoryRef = "cmsSqlSessionFactory")
public class CMSConfig {
static final String PACKAGE = "com.bobo.shopping.manage.dao.cms.mapper";
static final String MAPPER_LOCATION = "classpath:mapper/cms/*.xml";
@Bean(name = "cmsDataSource")
public DataSource configurationDataSource() {
DruidDataSource dataSource = new DruidDataSource();
//设置数据源的属性
setDruidProperties(dataSource);
return dataSource;
}
/**
* 注入数据源配置信息
*/
@Autowired
ShoppingCMSDataSourceProperties cmsConfig;
/**
* 设置数据源的属性的方法
* @param dataSource
*/
private void setDruidProperties(DruidDataSource dataSource) {
dataSource.setUrl(cmsConfig.url);
dataSource.setUsername(cmsConfig.username);
dataSource.setPassword(cmsConfig.password);
dataSource.setDriverClassName(cmsConfig.driverClassName);
dataSource.setMaxActive(cmsConfig.maxActive);
dataSource.setInitialSize(cmsConfig.initialSize);
dataSource.setMinIdle(cmsConfig.minIdle);
dataSource.setMaxWait(cmsConfig.maxWait);
dataSource.setMaxPoolPreparedStatementPerConnectionSize(cmsConfig.maxPoolPreparedStatementPerConnectionSize);
dataSource.setTimeBetweenEvictionRunsMillis(cmsConfig.timeBetweenEvictionRunsMillis);
dataSource.setMinEvictableIdleTimeMillis(cmsConfig.minEvictableIdleTimeMillis);
dataSource.setPoolPreparedStatements(cmsConfig.poolPreparedStatements);
}
@Bean(name = "cmsTransactionManager")
public DataSourceTransactionManager clusterTransactionManager() {
return new DataSourceTransactionManager(configurationDataSource());
}
@Bean(name = "cmsSqlSessionFactory")
public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("cmsDataSource") DataSource clusterDataSource)
throws Exception {
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(clusterDataSource);
sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(CMSConfig.MAPPER_LOCATION));
return sessionFactory.getObject();
}
}
package com.bobo.shopping.manage.config.datasource;
import com.alibaba.druid.pool.DruidDataSource;
import com.bobo.shopping.manage.config.entity.datasource.ShoppingDataSourceProperties;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
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;
import javax.sql.DataSource;
/**
* shopping数据库
*
* @author [email protected]
* @create 2018-09-23 17:20
**/
@Configuration
@MapperScan(basePackages = ShoppingConfig.PACKAGE, sqlSessionFactoryRef = "shoppingSqlSessionFactory")
public class ShoppingConfig {
static final String PACKAGE = "com.bobo.shopping.manage.dao.shopping.mapper";
static final String MAPPER_LOCATION = "classpath:mapper/shopping/*.xml";
@Bean(name = "shoppingDataSource")
public DataSource configurationDataSource() {
DruidDataSource dataSource = new DruidDataSource();
//设置数据源的属性
setDruidProperties(dataSource);
return dataSource;
}
/**
* 注入数据源配置信息
*/
@Autowired
ShoppingDataSourceProperties config;
/**
* 设置数据源的属性的方法
* @param dataSource
*/
private void setDruidProperties(DruidDataSource dataSource) {
dataSource.setUrl(config.url);
dataSource.setUsername(config.username);
dataSource.setPassword(config.password);
dataSource.setDriverClassName(config.driverClassName);
dataSource.setMaxActive(config.maxActive);
dataSource.setInitialSize(config.initialSize);
dataSource.setMinIdle(config.minIdle);
dataSource.setMaxWait(config.maxWait);
dataSource.setMaxPoolPreparedStatementPerConnectionSize(config.maxPoolPreparedStatementPerConnectionSize);
dataSource.setTimeBetweenEvictionRunsMillis(config.timeBetweenEvictionRunsMillis);
dataSource.setMinEvictableIdleTimeMillis(config.minEvictableIdleTimeMillis);
dataSource.setPoolPreparedStatements(config.poolPreparedStatements);
}
@Bean(name = "shoppingTransactionManager")
@Primary
public DataSourceTransactionManager clusterTransactionManager() {
DataSourceTransactionManager dataSourceTransactionManager =
new DataSourceTransactionManager(configurationDataSource());
return dataSourceTransactionManager;
}
@Bean(name = "shoppingSqlSessionFactory")
@Primary
public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("shoppingDataSource") DataSource clusterDataSource)
throws Exception {
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(clusterDataSource);
sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(ShoppingConfig.MAPPER_LOCATION));
return sessionFactory.getObject();
}
}
6. 在service中使用事务
@Service
@Slf4j
@Transactional(transactionManager = "shoppingTransactionManager",rollbackFor = Exception.class)
public class TestService extends BaseService {}