SpringBoot整合Mybatis使用Druid数据库连接池

 <!-- spring mybatis -->    <dependency>      <groupId>org.mybatis.spring.boot</groupId>      <artifactId>mybatis-spring-boot-starter</artifactId>      <version>1.1.1</version>    </dependency>    <!-- mysql -->    <dependency>      <groupId>mysql</groupId>      <artifactId>mysql-connector-java</artifactId>      <scope>runtime</scope>    </dependency>    <!-- druid数据库连接池 -->    <dependency>      <groupId>com.alibaba</groupId>      <artifactId>druid</artifactId>      <version>1.0.26</version>    </dependency>

#数据库配置spring.datasource.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8&useSSL=falsespring.datasource.username=adminspring.datasource.password=adminspring.datasource.driver-class-name=com.mysql.jdbc.Driver# 连接池配置# 初始化大小，最小，最大spring.datasource.initialSize=5 spring.datasource.minIdle=5 spring.datasource.maxActive=20 # 配置获取连接等待超时的时间spring.datasource.maxWait=60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒spring.datasource.timeBetweenEvictionRunsMillis=60000 # 配置一个连接在池中最小生存的时间，单位是毫秒spring.datasource.minEvictableIdleTimeMillis=300000# 测试连接是否有效的sqlspring.datasource.validationQuery=select 'x'# 建议配置为true，不影响性能，并且保证安全性# 申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效spring.datasource.testWhileIdle=true# 申请连接时执行validationQuery检测连接是否有效spring.datasource.testOnBorrow=false# 归还连接时执行validationQuery检测连接是否有效spring.datasource.testOnReturn=false# 要启用PSCache，必须配置大于0，当大于0时，poolPreparedStatements自动触发修改为truespring.datasource.maxPoolPreparedStatementPerConnectionSize=20# 属性类型是字符串，通过别名的方式配置扩展插件，常用的插件有：# 监控统计用的filter:stat# 日志用的filter:log4j# 防御sql注入的filter:wallspring.datasource.filters=stat,log4j,wall

package com.liao.mybatis;import com.alibaba.druid.pool.DruidDataSource;import org.mybatis.spring.annotation.MapperScan;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.PropertySource;import org.springframework.stereotype.Component;import javax.sql.DataSource;import java.sql.SQLException;/** * 数据源 * * @author hongyangliao * @ClassName: DataSourceConfig * @Date 18-1-2 下午8:56 */@Configuration@MapperScan("com.liao.**.dao")public class DataSourceConfig {  private static final Logger logger = LoggerFactory.getLogger(DataSourceConfig.class);  @Autowired  private JdbcConfig jdbcConfig;  @Bean  @Primary //在同样的DataSource中，首先使用被标注的DataSource  public DataSource dataSource() {    DruidDataSource druidDataSource = new DruidDataSource();    druidDataSource.setUrl(jdbcConfig.getUrl());    druidDataSource.setUsername(jdbcConfig.getUserName());    druidDataSource.setPassword(jdbcConfig.getPassword());    druidDataSource.setInitialSize(jdbcConfig.getInitialSize());    druidDataSource.setMinIdle(jdbcConfig.getMinIdle());    druidDataSource.setMaxActive(jdbcConfig.getMaxActive());    druidDataSource.setTimeBetweenEvictionRunsMillis(jdbcConfig.getTimeBetweenEvictionRunsMillis());    druidDataSource.setMinEvictableIdleTimeMillis(jdbcConfig.getMinEvictableIdleTimeMillis());    druidDataSource.setValidationQuery(jdbcConfig.getValidationQuery());    druidDataSource.setTestWhileIdle(jdbcConfig.isTestWhileIdle());    druidDataSource.setTestOnBorrow(jdbcConfig.isTestOnBorrow());    druidDataSource.setTestOnReturn(jdbcConfig.isTestOnReturn());    druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(jdbcConfig.getMaxPoolPreparedStatementPerConnectionSize());    try {      druidDataSource.setFilters(jdbcConfig.getFilters());    } catch (SQLException e) {      if (logger.isInfoEnabled()) {        logger.info(e.getMessage(), e);      }    }    return druidDataSource;  }  /**   * Jdbc配置类   *   * @author hongyangliao   * @ClassName: JdbcConfig   * @Date 18-1-2 下午9:00   */  @PropertySource(value = "classpath:jdbc.properties")  @Component  public static class JdbcConfig {    /**     * 数据库用户名     */    @Value("${spring.datasource.username}")    private String userName;    /**     * 驱动名称     */    @Value("${spring.datasource.driver-class-name}")    private String driverClass;    /**     * 数据库连接url     */    @Value("${spring.datasource.url}")    private String url;    /**     * 数据库密码     */    @Value("${spring.datasource.password}")    private String password;    /**     * 数据库连接池初始化大小     */    @Value("${spring.datasource.initialSize}")    private int initialSize;    /**     * 数据库连接池最小最小连接数     */    @Value("${spring.datasource.minIdle}")    private int minIdle;    /**     * 数据库连接池最大连接数     */    @Value("${spring.datasource.maxActive}")    private int maxActive;    /**     * 获取连接等待超时的时间     */    @Value("${spring.datasource.maxWait}")    private long maxWait;    /**     * 多久检测一次     */    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")    private long timeBetweenEvictionRunsMillis;    /**     * 连接在池中最小生存的时间     */    @Value("${spring.datasource.minEvictableIdleTimeMillis}")    private long minEvictableIdleTimeMillis;    /**     * 测试连接是否有效的sql     */    @Value("${spring.datasource.validationQuery}")    private String validationQuery;    /**     * 申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，检测连接是否有效     */    @Value("${spring.datasource.testWhileIdle}")    private boolean testWhileIdle;    /**     * 申请连接时,检测连接是否有效     */    @Value("${spring.datasource.testOnBorrow}")    private boolean testOnBorrow;    /**     * 归还连接时,检测连接是否有效     */    @Value("${spring.datasource.testOnReturn}")    private boolean testOnReturn;    /**     * PSCache大小     */    @Value("${spring.datasource.maxPoolPreparedStatementPerConnectionSize}")    private int maxPoolPreparedStatementPerConnectionSize;    /**     * 通过别名的方式配置扩展插件     */    @Value("${spring.datasource.filters}")    private String filters;    public String getUserName() {      return userName;    }    public void setUserName(String userName) {      this.userName = userName;    }    public String getDriverClass() {      return driverClass;    }    public void setDriverClass(String driverClass) {      this.driverClass = driverClass;    }    public String getUrl() {      return url;    }    public void setUrl(String url) {      this.url = url;    }    public String getPassword() {      return password;    }    public void setPassword(String password) {      this.password = password;    }    public int getInitialSize() {      return initialSize;    }    public void setInitialSize(int initialSize) {      this.initialSize = initialSize;    }    public int getMinIdle() {      return minIdle;    }    public void setMinIdle(int minIdle) {      this.minIdle = minIdle;    }    public int getMaxActive() {      return maxActive;    }    public void setMaxActive(int maxActive) {      this.maxActive = maxActive;    }    public long getMaxWait() {      return maxWait;    }    public void setMaxWait(long maxWait) {      this.maxWait = maxWait;    }    public long getTimeBetweenEvictionRunsMillis() {      return timeBetweenEvictionRunsMillis;    }    public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {      this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;    }    public long getMinEvictableIdleTimeMillis() {      return minEvictableIdleTimeMillis;    }    public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {      this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;    }    public String getValidationQuery() {      return validationQuery;    }    public void setValidationQuery(String validationQuery) {      this.validationQuery = validationQuery;    }    public boolean isTestWhileIdle() {      return testWhileIdle;    }    public void setTestWhileIdle(boolean testWhileIdle) {      this.testWhileIdle = testWhileIdle;    }    public boolean isTestOnBorrow() {      return testOnBorrow;    }    public void setTestOnBorrow(boolean testOnBorrow) {      this.testOnBorrow = testOnBorrow;    }    public boolean isTestOnReturn() {      return testOnReturn;    }    public void setTestOnReturn(boolean testOnReturn) {      this.testOnReturn = testOnReturn;    }    public int getMaxPoolPreparedStatementPerConnectionSize() {      return maxPoolPreparedStatementPerConnectionSize;    }    public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize) {      this.maxPoolPreparedStatementPerConnectionSize = maxPoolPreparedStatementPerConnectionSize;    }    public String getFilters() {      return filters;    }    public void setFilters(String filters) {      this.filters = filters;    }  }}

package com.liao.mybatis;import java.io.IOException;import javax.sql.DataSource;import org.mybatis.spring.SqlSessionFactoryBean;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.core.io.ClassPathResource;import org.springframework.transaction.annotation.EnableTransactionManagement;@Configuration@EnableTransactionManagement // 启注解事务管理，等同于xml配置方式的 <tx:annotation-driven />public class SessionFactoryConfig { /**  * mybatis 配置路径  */ private static String MYBATIS_CONFIG = "mybatis-config.xml"; @Autowired private DataSource dataSource; /***  * 创建sqlSessionFactoryBean  * 并且设置configtion 如驼峰命名.等等  * 设置mapper 映射路径  * 设置datasource数据源  *  * @Title: createSqlSessionFactoryBean  * @author: hongyangliao  * @Date: 18-1-3 上午9:52  * @param  * @return org.mybatis.spring.SqlSessionFactoryBean sqlSessionFactoryBean实例  * @throws  */ @Bean(name = "sqlSessionFactory") public SqlSessionFactoryBean createSqlSessionFactoryBean() throws IOException {  SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean();  // 设置mybatis configuration 扫描路径  sqlSessionFactory.setConfigLocation(new ClassPathResource(MYBATIS_CONFIG));  // 设置datasource  sqlSessionFactory.setDataSource(dataSource);  return sqlSessionFactory; }}