spring-boot中使用druid连接池

最近因为项目的要求，需要在spring-boot中配置druid连接池，数据库是Oracle，并且是多数据源的连接池，特地写下我的配置经历。
用的框架是spring-boot，数据库是oracle，数据库操作用的是mybatis，数据库连接池用的是druid。

（一）spring和spring-boot

spring-boot相对于spring的改变就是:spring-boot基本所有的配置都是用注解实现的，而spring的配置信息一般都是在.xml文件中配置的。例如，我们定义一个bean，你需要去spring的.xml文件定义一个bean标签，并且指明该bean的信息;但在spring-boot中你只需要在该类的定义前加上@bean标签就行了，所以spring-boot有点像懒人的spring。

(二)配置

我的配置是分两步进行的，因为这个项目的spring-boot不是我配置的，所以我先配置了一个简单的spring-boot不是我配置的，所以我先配置了一个简单的spring-boot demo，然后再在那个demo中加入了druid连接池。这里我也把这两个步骤记录下来。

1.建立spring-boot的demo
我使用的环境是ideal，只需要新建一个java project，然后选中maven项目即可。
然后配置pom.xml文件，把spring-boot需要的依赖包加入进去。（第一步骤中，我只添加了spring-boot依赖包）。

    <!--spring boot父级依赖，指明这是一个spring boot项目--><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.7.RELEASE</version><relativePath/> </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-thymeleaf</artifactId>  <!--包含了spring-boot-starter-logging即logback--></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.1</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

相关依赖包导入成功之后，就可以写spring-boot的核心类了，可以发现该类中有一个main函数，用于启动spring-boot。

package com.code;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class SPApplication {//启动sprint boot项目public static void main(String[] args){SpringApplication.run(SPApplication.class, args);}
}

然后写了一个简单的controller，测试spring-boot 是否配置成功。

package com.code.controller;import com.code.mapper.TestMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@Controller
@RestController
public class TestController {@RequestMapping("/")public String index(){return "hello world";}
}

最后启动那个核心类，然后输入localhost:8080，出现以下页面，说明spring-boot配置成功。

2.配置druid数据库连接池

首先，在pom.xml文件加入相关的依赖包，完整版的，包括了spring-boot的依赖包。

    <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.7.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-thymeleaf</artifactId>  <!--包含了spring-boot-starter-logging即logback--></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.1</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><!-- https://mvnrepository.com/artifact/com.oracle/ojdbc6 --><dependency><groupId>com.oracle</groupId><artifactId>ojdbc6</artifactId><version>11.2.0.4</version></dependency><dependency><groupId>tk.mybatis</groupId><artifactId>mapper-spring-boot-starter</artifactId><version>1.1.4</version></dependency><dependency><groupId>tk.mybatis</groupId><artifactId>mapper-spring-boot-autoconfigure</artifactId><version>1.1.4</version></dependency><dependency><groupId>tk.mybatis</groupId><artifactId>mapper</artifactId><version>3.4.3</version></dependency><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-starter</artifactId><version>1.2.1</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.6</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

然后再配置数据库连接相关的信息，包括连接池的信息，这里用一个properties文件来定义相关的属性。

#druid datasource1 for dw558
spring.datasource.druid.db1.url = jdbc:oracle:thin:@192.10.224.151:1521:dw558
spring.datasource.druid.db1.username = dw558
spring.datasource.druid.db1.password= 36874
spring.datasource.druid.db1.driver-class-name = oracle.jdbc.driver.OracleDriver
#依次为初始连接数，最小连接数，最大连接数，最大等待时间，
spring.datasource.druid.db1.initial-size = 5
spring.datasource.druid.db1.min-idle = 5
spring.datasource.druid.db1.max-active = 10
spring.datasource.druid.db1.max-wait = 60000
spring.datasource.druid.db1.time-between-eviction-runs-millis = 60000
spring.datasource.druid.db1.min-evictable-idle-time-millis = 300000
spring.datasource.druid.db1.validation-query = SELECT 1 FROM dual
spring.datasource.druid.db1.test-while-idle = true
spring.datasource.druid.db1.test-on-borrow = false
spring.datasource.druid.db1.test-on-return = false
spring.datasource.druid.db1.pool-prepared-statements = true
spring.datasource.druid.db1.max-pool-prepared-statement-per-connection-size = 20
spring.datasource.druid.db1.filters = stat, wall#druid datasource2 for dw664
spring.datasource.druid.db2.url = jdbc:oracle:thin:@192.10.220.116:1521:dw664
spring.datasource.druid.db2.username = dw664
spring.datasource.druid.db2.password= 56644
spring.datasource.druid.db2.driver-class-name = oracle.jdbc.driver.OracleDriver
#依次为初始连接数，最小连接数，最大连接数，最大等待时间，
spring.datasource.druid.db2.initial-size = 5
spring.datasource.druid.db2.min-idle = 5
spring.datasource.druid.db2.max-active = 10
spring.datasource.druid.db2.max-wait = 60000
spring.datasource.druid.db2.time-between-eviction-runs-millis = 60000
spring.datasource.druid.db2.min-evictable-idle-time-millis = 300000
spring.datasource.druid.db2.validation-query = SELECT 1 FROM dual
spring.datasource.druid.db2.test-while-idle = true
spring.datasource.druid.db2.test-on-borrow = false
spring.datasource.druid.db2.test-on-return = false
spring.datasource.druid.db2.pool-prepared-statements = true
spring.datasource.druid.db2.max-pool-prepared-statement-per-connection-size = 20
spring.datasource.druid.db2.filters = stat, wall

然后再定义数据库连接工厂，当中包括了数据源的定义，工厂定义，事务定义和SqlSessionTemplate定义。

数据库1的工厂类:

package com.hd.jq.configs.druid;import org.apache.ibatis.annotations.Mapper;
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.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;@Configuration                         //读取配置信息的注解
//扫描的mapper包，使用的是mybatis
@MapperScan(basePackages = "com.hd.jq.mapper.db1", sqlSessionTemplateRef = "db1SqlSessionTemplate")
public class DruidDataSource1 {/**   dataSource是用来提供数据库配置的相关信息，读取配置文件，获得相关系数*/@Bean(name = "db1DataSource")@ConfigurationProperties(prefix = "spring.datasource.druid.db1")             //该前缀对应的配置信息，在application.properties文件中@Primarypublic DataSource druid1DataSource(){return DataSourceBuilder.create().build();}/**   SqlSessionFactory用dataSource中提供的参数来构建工厂类，因为工厂需要根据url,*   用户名,密码等信息用于连接数据库，并且设置一些连接池属性*/@Bean(name = "db1SqlSessionFactory")@Primarypublic SqlSessionFactory duird1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws  Exception{SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);return bean.getObject();}/**   事务管理器*/@Bean(name = "db1TransactionManager")@Primarypublic DataSourceTransactionManager db1TransactionManager(@Qualifier("db1DataSource") DataSource dataSource){return new DataSourceTransactionManager(dataSource);}/**   提供一个线程安全的SqlSession接口*/@Bean(name = "db1SqlSessionTemplate")@Primarypublic SqlSessionTemplate db1SqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}}

数据库2的工厂类：

package com.hd.jq.configs.druid;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.jdbc.datasource.DataSourceTransactionManager;import javax.sql.DataSource;@Configuration
@MapperScan(basePackages = "com.hd.jq.mapper.db2", sqlSessionTemplateRef = "db2SqlSessionTemplate")
public class DruidDataSource2 {/*
*   dataSource是用来提供数据库配置的相关信息，读取配置文件，获得相关系数
*/@Bean(name = "db2DataSource")@ConfigurationProperties(prefix = "spring.datasource.druid.db2")             //该前缀对应的配置信息，在application.properties文件中public DataSource druid2DataSource(){return DataSourceBuilder.create().build();}/**   SqlSessionFactory用dataSource中提供的参数来构建工厂类，因为工厂需要根据url,*   用户名,密码等信息用于连接数据库，并且设置一些连接池属性*/@Bean(name = "db2SqlSessionFactory")public SqlSessionFactory duird2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws  Exception{SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(dataSource);return bean.getObject();}/**   事务管理器*/@Bean(name = "db2TransactionManager")public DataSourceTransactionManager db2TransactionManager(@Qualifier("db2DataSource") DataSource dataSource){return new DataSourceTransactionManager(dataSource);}/**   提供一个线程安全的SqlSession接口*/@Bean(name = "db2SqlSessionTemplate")public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory){return new SqlSessionTemplate(sqlSessionFactory);}
}

注意上面两个数据库的工厂类中，有一个加上了@primary标签，这个标签指明哪个是主要的数据库工厂类，不指明的话，就会由于多数据源而产生冲突！！！

然后就是在指定的map扫描路径下建立一个测试的mapper，代码如下：

package com.hd.jq.mapper.db1;import org.apache.ibatis.annotations.Select;public interface TestMapper {@Select("select bt from xm_jjjl where jjdd = #{jjdd}")String getStrByJjxh(Integer jjdd);
}

最后就是建立一个测试用的controller，测试连接和查询结果：

package com.code.controller;import com.code.mapper.TestMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@Controller
@RestController
public class TestController {@AutowiredTestMapper testMapper;                      //依赖注入mapper@RequestMapping("/")public String index(){String value = testMapper.getStrByJjxh(16047075);System.out.println(value);return value;}
}

可以发现连接成功！！！