1. 程式人生 > >SpringBoot學習:整合MyBatis,使用Druid連線池

SpringBoot學習:整合MyBatis,使用Druid連線池

專案下載地址:http://download.csdn.NET/detail/aqsunkai/9805821

(一)新增pom依賴:

<!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter -->
    <dependency>
      <groupId>org.mybatis.spring.boot</groupId>
      <artifactId>mybatis-spring-boot-starter</artifactId>
      <version>1.2.0</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>6.0.6</version>
    </dependency>
    <!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>druid</artifactId>
      <version>1.0.29</version>
    </dependency>
(二)專案結構如下:

mapper介面在java目錄下,相應的寫sql語句的xml在resource目錄下,在Application啟動類中加入註解:

@ServletComponentScan
@MapperScan("com.sun.**.mapper") //配置掃描mapper介面的地址
@ServletComponentScan 設定啟動時spring能夠掃描到我們自己編寫的servlet和filter, 用於Druid監控

@MapperScan 用於掃描的mapper介面

在配置檔案中加入:

# mybatis_config
mybatis:
    mapper-locations: classpath:mapper/**/*.xml
#datasource
spring:
    datasource:
        name: era
        url: jdbc:mysql://localhost:3306/spring_boot?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=UTC
        username: root
        password: 123456
        # 使用druid資料來源
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        # 下面為連線池的補充設定,應用到上面所有資料來源中
        # 初始化大小,最小,最大
        initialSize: 5
        minIdle: 5
        maxActive: 20
        # 配置獲取連線等待超時的時間
        maxWait: 60000
        # 配置間隔多久才進行一次檢測,檢測需要關閉的空閒連線,單位是毫秒
        timeBetweenEvictionRunsMillis: 60000
        # 配置一個連線在池中最小生存的時間,單位是毫秒
        minEvictableIdleTimeMillis: 300000
        validationQuery: SELECT 1 FROM DUAL
        testWhileIdle: true
        testOnBorrow: false
        testOnReturn: false
        # 開啟PSCache,並且指定每個連線上PSCache的大小
        poolPreparedStatements: true
        maxPoolPreparedStatementPerConnectionSize: 20
        # 配置監控統計攔截的filters,去掉後監控介面sql無法統計,'wall'用於防火牆
        spring.datasource.filters: stat,wall,log4j
        # 通過connectProperties屬性來開啟mergeSql功能;慢SQL記錄
        connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
        # 合併多個DruidDataSource的監控資料
        #useGlobalDataSourceStat: true

用於掃描mybatis的對映檔案xml,和載入連線池

日誌檔案中加入:

<!--輸出sql語句-->
    <logger name="com.sun" level="debug" />
用於在控制檯列印sql語句

DataSource的配置啟動管理類如下:

package com.sun.configuration;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import com.alibaba.druid.support.spring.stat.DruidStatInterceptor;
import org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator;
import org.springframework.boot.bind.RelaxedPropertyResolver;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.EnvironmentAware;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

@Configuration
@EnableTransactionManagement
/**
 * Druid的DataResource配置類
 * 凡是被Spring管理的類,實現介面 EnvironmentAware 重寫方法 setEnvironment 可以在工程啟動時,
 * 獲取到系統環境變數和application配置檔案中的變數。 還有一種方式是採用註解的方式獲取 @value("${變數的key值}")
 * 獲取application配置檔案中的變數。 這裡採用第一種要方便些
 * Created by sun on 2017-1-20.
 */
public class DruidDataSourceConfig implements EnvironmentAware {

	private RelaxedPropertyResolver propertyResolver;

	public void setEnvironment(Environment env) {
		this.propertyResolver = new RelaxedPropertyResolver(env, "spring.datasource.");
	}

	@Bean
	public DataSource dataSource() {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(propertyResolver.getProperty("url"));
		datasource.setDriverClassName(propertyResolver.getProperty("driver-class-name"));
		datasource.setUsername(propertyResolver.getProperty("username"));
		datasource.setPassword(propertyResolver.getProperty("password"));
		datasource.setInitialSize(Integer.valueOf(propertyResolver.getProperty("initialSize")));
		datasource.setMinIdle(Integer.valueOf(propertyResolver.getProperty("minIdle")));
		datasource.setMaxWait(Long.valueOf(propertyResolver.getProperty("maxWait")));
		datasource.setMaxActive(Integer.valueOf(propertyResolver.getProperty("maxActive")));
		datasource.setMinEvictableIdleTimeMillis(
				Long.valueOf(propertyResolver.getProperty("minEvictableIdleTimeMillis")));
		try {
			datasource.setFilters("stat,wall");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return datasource;
	}

	@Bean
	public ServletRegistrationBean druidServlet() {
		ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean();
		servletRegistrationBean.setServlet(new StatViewServlet());
		servletRegistrationBean.addUrlMappings("/druid/*");
		Map<String, String> initParameters = new HashMap<String, String>();
		// initParameters.put("loginUsername", "druid");// 使用者名稱
		// initParameters.put("loginPassword", "druid");// 密碼
		initParameters.put("resetEnable", "false");// 禁用HTML頁面上的“Reset All”功能
		initParameters.put("allow", "127.0.0.1"); // IP白名單 (沒有配置或者為空,則允許所有訪問)
		// initParameters.put("deny", "192.168.20.38");// IP黑名單
		// (存在共同時,deny優先於allow)
		servletRegistrationBean.setInitParameters(initParameters);
		return servletRegistrationBean;
	}

	@Bean
	public FilterRegistrationBean filterRegistrationBean() {
		FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
		filterRegistrationBean.setFilter(new WebStatFilter());
		filterRegistrationBean.addUrlPatterns("/*");
		filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico,/druid/*");
		return filterRegistrationBean;
	}

	// 按照BeanId來攔截配置 用來bean的監控
	@Bean(value = "druid-stat-interceptor")
	public DruidStatInterceptor DruidStatInterceptor() {
		DruidStatInterceptor druidStatInterceptor = new DruidStatInterceptor();
		return druidStatInterceptor;
	}

	@Bean
	public BeanNameAutoProxyCreator beanNameAutoProxyCreator() {
		BeanNameAutoProxyCreator beanNameAutoProxyCreator = new BeanNameAutoProxyCreator();
		beanNameAutoProxyCreator.setProxyTargetClass(true);
		// 設定要監控的bean的id
		//beanNameAutoProxyCreator.setBeanNames("sysRoleMapper","loginController");
		beanNameAutoProxyCreator.setInterceptorNames("druid-stat-interceptor");
		return beanNameAutoProxyCreator;
	}

}

後臺執行在控制檯上輸出:

2017-04-07 21:25:15.904  INFO 10500 --- [io-8080-exec-10] c.s.p.controller.UserController          : 哈哈哈
2017-04-07 21:25:15.908 DEBUG 10500 --- [io-8080-exec-10] c.s.p.m.UserMapper.selectByPrimaryKey    : ==>  Preparing: select id, nickname, email, pswd, create_time, last_login_time, status from sys_user where id = ? 
2017-04-07 21:25:15.911 DEBUG 10500 --- [io-8080-exec-10] c.s.p.m.UserMapper.selectByPrimaryKey    : ==> Parameters: 1(Integer)
2017-04-07 21:25:15.918 DEBUG 10500 --- [io-8080-exec-10] c.s.p.m.UserMapper.selectByPrimaryKey    : <==      Total: 1
2017-04-07 21:25:15.920  INFO 10500 --- [io-8080-exec-10] c.s.p.controller.UserController          : admin
在頁面上輸入http://localhost:8080/boot/druid/可以看到監控到的sql語句執行情況: