Spring Boot + MyBatis + Druid + Redis + Thymeleaf 整合小结

2022-02-18 00:32:11

Spring Boot + MyBatis + Druid + Redis + Thymeleaf 整合小结

这两天闲着没事想利用**Spring Boot**加上阿里的开源数据连接池**Druid**搭建个简单的框架，主要是想了解一下**Druid**的可视化数据监控，无奈水平受限只能一边 Google 一边 整合，后来发现网上的一些整合资源太差强人意，于是我想把我得一些整合思路分享出来，供大家浏览，哪里不合适希望可以提出来，一起进步！

特别感谢一下我的朋友 [@码农界的苦逼猿](https://blog.csdn.net/qq_38011415)

开始

环境：jdk1.8，idea, maven 3.5.0

1、项目结构：

2、pom.xml

<?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>org.yliu</groupId>

    <artifactId>mui</artifactId>

    <version>0.0.1-SNAPSHOT</version>

    <packaging>jar</packaging>

    <name>mui</name>

    <description>org.yliu.mui</description>

    <parent>

        <groupId>org.springframework.boot</groupId>

        <artifactId>spring-boot-starter-parent</artifactId>

        <version>2.0.6.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-data-redis</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>com.github.pagehelper</groupId>

            <artifactId>pagehelper</artifactId>

            <version>5.1.4</version>

        </dependency>

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>druid</artifactId>

            <version>1.1.10</version>

        </dependency>

        <dependency>

            <groupId>com.alibaba</groupId>

            <artifactId>fastjson</artifactId>

            <version>1.2.47</version>

        </dependency>

        <dependency>

            <groupId>redis.clients</groupId>

            <artifactId>jedis</artifactId>

            <version>2.9.0</version>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

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

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-configuration-processor</artifactId>

            <optional>true</optional>

        </dependency>

        <dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-devtools</artifactId>

            <optional>true</optional>

        </dependency>

    </dependencies>

    <build>

        <plugins>

            <plugin>

                <groupId>org.springframework.boot</groupId>

                <artifactId>spring-boot-maven-plugin</artifactId>

            </plugin>

        </plugins>

    </build>

</project>

到了这一步，项目的基本依赖就算结束了。

3、在这个Demo项目中我用的是application.properties，可根据个人喜好改为application.yml

# 访问端口

server.port=2088

# 数据库配置

spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.type=com.alibaba.druid.pool.DruidDataSource

spring.datasource.name=demo

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/demo

spring.datasource.username=root

spring.datasource.password=root

spring.datasource.initialSize=1

spring.datasource.minIdle=3

spring.datasource.maxActive=20

spring.datasource.maxWait=60000

spring.datasource.timeBetweenEvictionRunsMillis=60000

spring.datasource.minEvictableIdleTimeMillis=30000

spring.datasource.validationQuery=select 'x'

spring.datasource.testWhileIdle=true

spring.datasource.testOnBorrow=false

spring.datasource.testOnReturn=false

spring.datasource.poolPreparedStatements=true

spring.datasource.maxPoolPreparedStatementPerConnectionSize=20

spring.datasource.filters=stat,wall,slf4j

spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

spring.datasource.useGlobalDataSourceStat=true

# redis 配置

spring.redis.port=6379

spring.redis.host=127.0.0.1

spring.redis.password=123456

# thymeleaf 配置

spring.thymeleaf.prefix=classpath:/templates/

spring.thymeleaf.suffix=.html

spring.thymeleaf.cache=false

spring.thymeleaf.check-template-location=true

spring.thymeleaf.encoding=UTF-8

# 日志相关

logging.pattern.console=%d --> %msg%n

# 此处配置sql打印

logging.pattern.level=org.yliu.mui.mapper: debug

4、数据库创建sql我就不放出来了，可随意创建数据进行测试

5、创建好表数据可以使用 mybatis generator 自动生成代码，

  假设我有一张 **User** 表，那么生成的相关文件为：

对应数据库的实体：

package org.yliu.mui.pojo.po;

import java.util.Date;

public class MallUserPo {

    private Integer id;

    private String guid;

    private String avatars;

    private String openId;

    private String userName;

    private Integer sex;

    private String phone;

    private String targetPhone;

    private Date createTime;

    private Date updateTime;

    public Integer getId() {

        return id;

    }

    public void setId(Integer id) {

        this.id = id;

    }

    public String getGuid() {

        return guid;

    }

    public void setGuid(String guid) {

        this.guid = guid == null ? null : guid.trim();

    }

    public String getAvatars() {

        return avatars;

    }

    public void setAvatars(String avatars) {

        this.avatars = avatars == null ? null : avatars.trim();

    }

    public String getOpenId() {

        return openId;

    }

    public void setOpenId(String openId) {

        this.openId = openId == null ? null : openId.trim();

    }

    public String getUserName() {

        return userName;

    }

    public void setUserName(String userName) {

        this.userName = userName == null ? null : userName.trim();

    }

    public Integer getSex() {

        return sex;

    }

    public void setSex(Integer sex) {

        this.sex = sex;

    }

    public String getPhone() {

        return phone;

    }

    public void setPhone(String phone) {

        this.phone = phone == null ? null : phone.trim();

    }

    public String getTargetPhone() {

        return targetPhone;

    }

    public void setTargetPhone(String targetPhone) {

        this.targetPhone = targetPhone == null ? null : targetPhone.trim();

    }

    public Date getCreateTime() {

        return createTime;

    }

    public void setCreateTime(Date createTime) {

        this.createTime = createTime;

    }

    public Date getUpdateTime() {

        return updateTime;

    }

    public void setUpdateTime(Date updateTime) {

        this.updateTime = updateTime;

    }

}

持久层接口：

package org.yliu.mui.mapper;

import org.yliu.mui.pojo.po.MallUserPo;

import org.yliu.mui.pojo.po.MallUserPoExample;

import java.util.List;

import org.apache.ibatis.annotations.Param;

public interface MallUserPoMapper {

    int countByExample(MallUserPoExample example);

    int deleteByExample(MallUserPoExample example);

    int deleteByPrimaryKey(Integer id);

    int insert(MallUserPo record);

    int insertSelective(MallUserPo record);

    List<MallUserPo> selectByExample(MallUserPoExample example);

    MallUserPo selectByPrimaryKey(Integer id);

    int updateByExampleSelective(@Param("record") MallUserPo record, @Param("example") MallUserPoExample example);

    int updateByExample(@Param("record") MallUserPo record, @Param("example") MallUserPoExample example);

    int updateByPrimaryKeySelective(MallUserPo record);

    int updateByPrimaryKey(MallUserPo record);

}

映射文件：

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

<mapper namespace="org.yliu.mui.mapper.MallUserPoMapper" >

  <resultMap id="BaseResultMap" type="org.yliu.mui.pojo.po.MallUserPo" >

    <id column="id" property="id" jdbcType="INTEGER" />

    <result column="guid" property="guid" jdbcType="VARCHAR" />

    <result column="avatars" property="avatars" jdbcType="VARCHAR" />

    <result column="open_id" property="openId" jdbcType="VARCHAR" />

    <result column="user_name" property="userName" jdbcType="VARCHAR" />

    <result column="sex" property="sex" jdbcType="INTEGER" />

    <result column="phone" property="phone" jdbcType="VARCHAR" />

    <result column="target_phone" property="targetPhone" jdbcType="VARCHAR" />

    <result column="create_time" property="createTime" jdbcType="TIMESTAMP" />

    <result column="update_time" property="updateTime" jdbcType="TIMESTAMP" />

  </resultMap>

  <sql id="Example_Where_Clause" >

    <where >

      <foreach collection="oredCriteria" item="criteria" separator="or" >

        <if test="criteria.valid" >

          <trim prefix="(" suffix=")" prefixOverrides="and" >

            <foreach collection="criteria.criteria" item="criterion" >

              <choose >

                <when test="criterion.noValue" >

                  and ${criterion.condition}

                </when>

                <when test="criterion.singleValue" >

                  and ${criterion.condition} #{criterion.value}

                </when>

                <when test="criterion.betweenValue" >

                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}

                </when>

                <when test="criterion.listValue" >

                  and ${criterion.condition}

                  <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >

                    #{listItem}

                  </foreach>

                </when>

              </choose>

            </foreach>

          </trim>

        </if>

      </foreach>

    </where>

  </sql>

  <sql id="Update_By_Example_Where_Clause" >

    <where >

      <foreach collection="example.oredCriteria" item="criteria" separator="or" >

        <if test="criteria.valid" >

          <trim prefix="(" suffix=")" prefixOverrides="and" >

            <foreach collection="criteria.criteria" item="criterion" >

              <choose >

                <when test="criterion.noValue" >

                  and ${criterion.condition}

                </when>

                <when test="criterion.singleValue" >

                  and ${criterion.condition} #{criterion.value}

                </when>

                <when test="criterion.betweenValue" >

                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}

                </when>

                <when test="criterion.listValue" >

                  and ${criterion.condition}

                  <foreach collection="criterion.value" item="listItem" open="(" close=")" separator="," >

                    #{listItem}

                  </foreach>

                </when>

              </choose>

            </foreach>

          </trim>

        </if>

      </foreach>

    </where>

  </sql>

  <sql id="Base_Column_List" >

    id, guid, avatars, open_id, user_name, sex, phone, target_phone, create_time, update_time

  </sql>

  <select id="selectByExample" resultMap="BaseResultMap" parameterType="org.yliu.mui.pojo.po.MallUserPoExample" >

    select

    <if test="distinct" >

      distinct

    </if>

    <include refid="Base_Column_List" />

    from mall_user

    <if test="_parameter != null" >

      <include refid="Example_Where_Clause" />

    </if>

    <if test="orderByClause != null" >

      order by ${orderByClause}

    </if>

  </select>

  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >

    select

    <include refid="Base_Column_List" />

    from mall_user

    where id = #{id,jdbcType=INTEGER}

  </select>

  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >

    delete from mall_user

    where id = #{id,jdbcType=INTEGER}

  </delete>

  <delete id="deleteByExample" parameterType="org.yliu.mui.pojo.po.MallUserPoExample" >

    delete from mall_user

    <if test="_parameter != null" >

      <include refid="Example_Where_Clause" />

    </if>

  </delete>

  <insert id="insert" parameterType="org.yliu.mui.pojo.po.MallUserPo" >

    insert into mall_user (id, guid, avatars,

      open_id, user_name, sex,

      phone, target_phone, create_time,

      update_time)

    values (#{id,jdbcType=INTEGER}, #{guid,jdbcType=VARCHAR}, #{avatars,jdbcType=VARCHAR},

      #{openId,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, #{sex,jdbcType=INTEGER},

      #{phone,jdbcType=VARCHAR}, #{targetPhone,jdbcType=VARCHAR}, #{createTime,jdbcType=TIMESTAMP},

      #{updateTime,jdbcType=TIMESTAMP})

  </insert>

  <insert id="insertSelective" parameterType="org.yliu.mui.pojo.po.MallUserPo" >

    insert into mall_user

    <trim prefix="(" suffix=")" suffixOverrides="," >

      <if test="id != null" >

        id,

      </if>

      <if test="guid != null" >

        guid,

      </if>

      <if test="avatars != null" >

        avatars,

      </if>

      <if test="openId != null" >

        open_id,

      </if>

      <if test="userName != null" >

        user_name,

      </if>

      <if test="sex != null" >

        sex,

      </if>

      <if test="phone != null" >

        phone,

      </if>

      <if test="targetPhone != null" >

        target_phone,

      </if>

      <if test="createTime != null" >

        create_time,

      </if>

      <if test="updateTime != null" >

        update_time,

      </if>

    </trim>

    <trim prefix="values (" suffix=")" suffixOverrides="," >

      <if test="id != null" >

        #{id,jdbcType=INTEGER},

      </if>

      <if test="guid != null" >

        #{guid,jdbcType=VARCHAR},

      </if>

      <if test="avatars != null" >

        #{avatars,jdbcType=VARCHAR},

      </if>

      <if test="openId != null" >

        #{openId,jdbcType=VARCHAR},

      </if>

      <if test="userName != null" >

        #{userName,jdbcType=VARCHAR},

      </if>

      <if test="sex != null" >

        #{sex,jdbcType=INTEGER},

      </if>

      <if test="phone != null" >

        #{phone,jdbcType=VARCHAR},

      </if>

      <if test="targetPhone != null" >

        #{targetPhone,jdbcType=VARCHAR},

      </if>

      <if test="createTime != null" >

        #{createTime,jdbcType=TIMESTAMP},

      </if>

      <if test="updateTime != null" >

        #{updateTime,jdbcType=TIMESTAMP},

      </if>

    </trim>

  </insert>

  <select id="countByExample" parameterType="org.yliu.mui.pojo.po.MallUserPoExample" resultType="java.lang.Integer" >

    select count(*) from mall_user

    <if test="_parameter != null" >

      <include refid="Example_Where_Clause" />

    </if>

  </select>

  <update id="updateByExampleSelective" parameterType="map" >

    update mall_user

    <set >

      <if test="record.id != null" >

        id = #{record.id,jdbcType=INTEGER},

      </if>

      <if test="record.guid != null" >

        guid = #{record.guid,jdbcType=VARCHAR},

      </if>

      <if test="record.avatars != null" >

        avatars = #{record.avatars,jdbcType=VARCHAR},

      </if>

      <if test="record.openId != null" >

        open_id = #{record.openId,jdbcType=VARCHAR},

      </if>

      <if test="record.userName != null" >

        user_name = #{record.userName,jdbcType=VARCHAR},

      </if>

      <if test="record.sex != null" >

        sex = #{record.sex,jdbcType=INTEGER},

      </if>

      <if test="record.phone != null" >

        phone = #{record.phone,jdbcType=VARCHAR},

      </if>

      <if test="record.targetPhone != null" >

        target_phone = #{record.targetPhone,jdbcType=VARCHAR},

      </if>

      <if test="record.createTime != null" >

        create_time = #{record.createTime,jdbcType=TIMESTAMP},

      </if>

      <if test="record.updateTime != null" >

        update_time = #{record.updateTime,jdbcType=TIMESTAMP},

      </if>

    </set>

    <if test="_parameter != null" >

      <include refid="Update_By_Example_Where_Clause" />

    </if>

  </update>

  <update id="updateByExample" parameterType="map" >

    update mall_user

    set id = #{record.id,jdbcType=INTEGER},

      guid = #{record.guid,jdbcType=VARCHAR},

      avatars = #{record.avatars,jdbcType=VARCHAR},

      open_id = #{record.openId,jdbcType=VARCHAR},

      user_name = #{record.userName,jdbcType=VARCHAR},

      sex = #{record.sex,jdbcType=INTEGER},

      phone = #{record.phone,jdbcType=VARCHAR},

      target_phone = #{record.targetPhone,jdbcType=VARCHAR},

      create_time = #{record.createTime,jdbcType=TIMESTAMP},

      update_time = #{record.updateTime,jdbcType=TIMESTAMP}

    <if test="_parameter != null" >

      <include refid="Update_By_Example_Where_Clause" />

    </if>

  </update>

  <update id="updateByPrimaryKeySelective" parameterType="org.yliu.mui.pojo.po.MallUserPo" >

    update mall_user

    <set >

      <if test="guid != null" >

        guid = #{guid,jdbcType=VARCHAR},

      </if>

      <if test="avatars != null" >

        avatars = #{avatars,jdbcType=VARCHAR},

      </if>

      <if test="openId != null" >

        open_id = #{openId,jdbcType=VARCHAR},

      </if>

      <if test="userName != null" >

        user_name = #{userName,jdbcType=VARCHAR},

      </if>

      <if test="sex != null" >

        sex = #{sex,jdbcType=INTEGER},

      </if>

      <if test="phone != null" >

        phone = #{phone,jdbcType=VARCHAR},

      </if>

      <if test="targetPhone != null" >

        target_phone = #{targetPhone,jdbcType=VARCHAR},

      </if>

      <if test="createTime != null" >

        create_time = #{createTime,jdbcType=TIMESTAMP},

      </if>

      <if test="updateTime != null" >

        update_time = #{updateTime,jdbcType=TIMESTAMP},

      </if>

    </set>

    where id = #{id,jdbcType=INTEGER}

  </update>

  <update id="updateByPrimaryKey" parameterType="org.yliu.mui.pojo.po.MallUserPo" >

    update mall_user

    set guid = #{guid,jdbcType=VARCHAR},

      avatars = #{avatars,jdbcType=VARCHAR},

      open_id = #{openId,jdbcType=VARCHAR},

      user_name = #{userName,jdbcType=VARCHAR},

      sex = #{sex,jdbcType=INTEGER},

      phone = #{phone,jdbcType=VARCHAR},

      target_phone = #{targetPhone,jdbcType=VARCHAR},

      create_time = #{createTime,jdbcType=TIMESTAMP},

      update_time = #{updateTime,jdbcType=TIMESTAMP}

    where id = #{id,jdbcType=INTEGER}

  </update>

</mapper>

到了这一步和MyBatis整合完成了一半了，下面完成下一半。

6、首先需要配置Druid连接池

package org.yliu.mui.config;

import com.alibaba.druid.support.http.StatViewServlet;

import com.alibaba.druid.support.http.WebStatFilter;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.boot.web.servlet.FilterRegistrationBean;

import org.springframework.boot.web.servlet.ServletRegistrationBean;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import javax.servlet.Filter;

import javax.servlet.Servlet;

/**

 * Druid连接池配置

 */

@Configuration

public class DruidConfiguration {

    private static final Logger LOGGER = LoggerFactory.getLogger(DruidConfiguration.class);

	/**

	 * 访问路径及用户名、密码

	 */

	@Bean

	public ServletRegistrationBean<Servlet> druidConfig() {

        LOGGER.info("init Druid Servlet Configuration ");

		final ServletRegistrationBean<Servlet> srb = new ServletRegistrationBean<Servlet>();

		srb.setServlet(new StatViewServlet());

		srb.addUrlMappings("/druid/*");

		srb.addInitParameter("loginUsername", "admin");

		srb.addInitParameter("loginPassword", "admin");

		return srb;

	}

	/**

	 * 配置过滤器

	 */

    @Bean

    public FilterRegistrationBean filterRegistrationBean() {

        final FilterRegistrationBean<Filter> filterRegistrationBean = new FilterRegistrationBean<Filter>();

		filterRegistrationBean.setFilter(new WebStatFilter());

		filterRegistrationBean.addUrlPatterns("/*");

		filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");

		return filterRegistrationBean;

    }

}

7、配置完连接池，下面为持久层相关配置(分页插件也在此类配置)

package org.yliu.mui.config;

import com.alibaba.druid.pool.DruidDataSource;

import com.github.pagehelper.PageInterceptor;

import org.apache.ibatis.plugin.Interceptor;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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.yliu.mui.properties.DBProperties;

import javax.sql.DataSource;

import java.sql.SQLException;

import java.util.Properties;

/**

 * 持久层相关配置

 */

@Configuration

public class SessionFactoryConfig {

    private static final Logger LOGGER = LoggerFactory.getLogger(SessionFactoryConfig.class);

    private final DBProperties db;

    @Autowired

    public SessionFactoryConfig(DBProperties db) {

        this.db = db;

    }

    /**

     * 创建数据源

     */

    @Bean

    @Primary

    public DataSource dataSource() {

        DruidDataSource datasource = new DruidDataSource();

        datasource.setUrl(db.getUrl());

        datasource.setUsername(db.getUsername());

        datasource.setPassword(db.getPassword());

        datasource.setDriverClassName(db.getDriverClassName());

        datasource.setInitialSize(db.getInitialSize());

        datasource.setMinIdle(db.getMinIdle());

        datasource.setMaxActive(db.getMaxActive());

        datasource.setMaxWait(db.getMaxWait());

        datasource.setTimeBetweenEvictionRunsMillis(db.getTimeBetweenEvictionRunsMillis());

        datasource.setMinEvictableIdleTimeMillis(db.getMinEvictableIdleTimeMillis());

        datasource.setValidationQuery(db.getValidationQuery());

        datasource.setTestOnReturn(db.isTestOnReturn());

        datasource.setPoolPreparedStatements(db.isPoolPreparedStatements());

        datasource.setMaxPoolPreparedStatementPerConnectionSize(db.getMaxPoolPreparedStatementPerConnectionSize());

        datasource.setUseGlobalDataSourceStat(db.isUseGlobalDataSourceStat());

        try {

            datasource.setFilters(db.getFilters());

        } catch (SQLException e) {

            LOGGER.info("druid configuration initialization filter: " + e);

        }

        datasource.setConnectionProperties(db.getConnectionProperties());

        return datasource;

    }

    /**

     * 配置分页插件

     */

    @Bean(name = "pageInterceptor")

    public PageInterceptor pageHelperConfig() {

        PageInterceptor pageInterceptor = new PageInterceptor();

        Properties properties = new Properties();

        properties.setProperty("reasonable", "true");

        properties.setProperty("supportMethodsArguments", "true");

        properties.setProperty("returnPageInfo", "check");

        properties.setProperty("params", "count=countSql");

        pageInterceptor.setProperties(properties);

        return pageInterceptor;

    }

    /**

     * 配置mybatis

     */

    @Bean(name = "sqlSessionFactory")

    public SqlSessionFactory sqlSessionFactory(

            @Qualifier("dataSource") final DataSource dataSource,

            @Qualifier("pageInterceptor") final PageInterceptor pageInterceptor) throws Exception {

        final SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean();

        sqlSessionFactory.setDataSource(dataSource);

        final PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();

        resolver.getResources("classpath*:mapper/**/*.xml");

        sqlSessionFactory.setMapperLocations(resolver.getResources("classpath*:mapper/**/*.xml"));

        // 具体参考自己设置，参考 xml 参数说明或源码注释

        sqlSessionFactory.setPlugins(new Interceptor[]{pageInterceptor});

        return sqlSessionFactory.getObject();

    }

}

这里需要说明一下的是，DBProperties 类是对应 application.properties 配置文件中的数据库相关配置属性

DBProperties.java ：

package org.yliu.mui.properties;

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

import org.springframework.context.annotation.Configuration;

import org.springframework.context.annotation.ImportResource;

@Configuration

@ConfigurationProperties(prefix = "spring.datasource")

public class DBProperties {

    private String url;

    private String username;

    private String password;

    private String driverClassName;

    private int initialSize;

    private int minIdle;

    private int maxActive;

    private int maxWait;

    private int timeBetweenEvictionRunsMillis;

    private int minEvictableIdleTimeMillis;

    private String validationQuery;

    private boolean testWhileIdle;

    private boolean testOnBorrow;

    private boolean testOnReturn;

    private boolean poolPreparedStatements;

    private int maxPoolPreparedStatementPerConnectionSize;

    private String filters;

    private String connectionProperties;

    private boolean useGlobalDataSourceStat;

    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 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 int getMaxWait() {

        return maxWait;

    }

    public void setMaxWait(int maxWait) {

        this.maxWait = maxWait;

    }

    public int getTimeBetweenEvictionRunsMillis() {

        return timeBetweenEvictionRunsMillis;

    }

    public void setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis) {

        this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;

    }

    public int getMinEvictableIdleTimeMillis() {

        return minEvictableIdleTimeMillis;

    }

    public void setMinEvictableIdleTimeMillis(int 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 boolean isPoolPreparedStatements() {

        return poolPreparedStatements;

    }

    public void setPoolPreparedStatements(boolean poolPreparedStatements) {

        this.poolPreparedStatements = poolPreparedStatements;

    }

    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;

    }

    public String getConnectionProperties() {

        return connectionProperties;

    }

    public void setConnectionProperties(String connectionProperties) {

        this.connectionProperties = connectionProperties;

    }

    public boolean isUseGlobalDataSourceStat() {

        return useGlobalDataSourceStat;

    }

    public void setUseGlobalDataSourceStat(boolean useGlobalDataSourceStat) {

        this.useGlobalDataSourceStat = useGlobalDataSourceStat;

    }

}

8、配置完这些，小伙伴不要心急，还有一项重要的配置，那就是扫描 mapper 接口！！！

package org.yliu.mui.config;

import org.mybatis.spring.mapper.MapperScannerConfigurer;

import org.springframework.boot.autoconfigure.AutoConfigureAfter;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

/**

 * 扫描Mybatis接口

 */

@Configuration

// 在持久层相关配置成功注入后加载

@AutoConfigureAfter(SessionFactoryConfig.class)

public class MyBatisMapperScannerConfig {

    @Bean

    public MapperScannerConfigurer mapperScannerConfigurer() {

        MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer();

        mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");

        // 需要扫描的包路径

        mapperScannerConfigurer.setBasePackage("org.yliu.mui.mapper");

        return mapperScannerConfigurer;

    }

}

如果不写扫描配置类，也可以在Spring Boot 入口类main方法上加入 @MapperScan("XX.XXX.mapper")注解进行扫描，个人习惯。

9、redis：(redis这里我没有选用 Spring 提供的 RedisTemplate，还是习惯 jedis )

package org.yliu.mui.config;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

import org.springframework.boot.autoconfigure.AutoConfigureAfter;

import org.springframework.boot.autoconfigure.data.redis.RedisProperties;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import redis.clients.jedis.JedisPool;

import redis.clients.jedis.JedisPoolConfig;

/**

 * Redis配置

 */

@Configuration

// RedisProperties 为Spring内部默认提供的关于redis配置的属性绑定类

@AutoConfigureAfter(RedisProperties.class)

public class RedisConfig {

    private static final Logger LOGGER = LoggerFactory.getLogger(RedisConfig.class);

    private final RedisProperties redisProperties;

    @Autowired

    public RedisConfig(RedisProperties redisProperties) {

        this.redisProperties = redisProperties;

    }

    @Bean

    public JedisPool redisPoolFactory(){

        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();

        int port = redisProperties.getPort();

        String host = redisProperties.getHost();

        int timeout = 2000;

        String password = redisProperties.getPassword();

        JedisPool jedisPool = new JedisPool(jedisPoolConfig,host,port,timeout,password);

        LOGGER.info("JedisPool注入成功！");

        LOGGER.info("redis地址：" + host + ":" + port);

        return  jedisPool;

    }

}

我封装了一个 JedisClient 的接口，方面操作和后期增加新命令。

package org.yliu.mui.redis;

import java.util.List;

public interface JedisClient {

    String set(String key, String value);

    String get(String key);

    Boolean exists(String key);

    Long expire(String key, int seconds);

    Long ttl(String key);

    Long incr(String key);

    Long hset(String key, String field, String value);

    String hget(String key, String field);

    Long hdel(String key, String... field);

    Boolean hexists(String key, String field);

    List<String> hvals(String key);

    Long del(String key);

}

JedisClient 实现类

package org.yliu.mui.redis.impl;

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

import org.springframework.context.annotation.Configuration;

import org.yliu.mui.redis.JedisClient;

import redis.clients.jedis.Jedis;

import redis.clients.jedis.JedisPool;

import java.util.List;

/**

 * Redis实现

 */

@Configuration

public class JedisClientPool implements JedisClient {

    private final JedisPool jedisPool;

    @Autowired

    public JedisClientPool(JedisPool jedisPool) {

        this.jedisPool = jedisPool;

    }

    @Override

    public String set(String key, String value) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.set(key, value);

        jedis.close();

        return result;

    }

    @Override

    public String get(String key) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.get(key);

        jedis.close();

        return result;

    }

    @Override

    public Boolean exists(String key) {

        Jedis jedis = jedisPool.getResource();

        Boolean result = jedis.exists(key);

        jedis.close();

        return result;

    }

    @Override

    public Long expire(String key, int seconds) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.expire(key, seconds);

        jedis.close();

        return result;

    }

    @Override

    public Long ttl(String key) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.ttl(key);

        jedis.close();

        return result;

    }

    @Override

    public Long incr(String key) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.incr(key);

        jedis.close();

        return result;

    }

    @Override

    public Long hset(String key, String field, String value) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.hset(key, field, value);

        jedis.close();

        return result;

    }

    @Override

    public String hget(String key, String field) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.hget(key, field);

        jedis.close();

        return result;

    }

    @Override

    public Long hdel(String key, String... field) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.hdel(key, field);

        jedis.close();

        return result;

    }

    @Override

    public Boolean hexists(String key, String field) {

        Jedis jedis = jedisPool.getResource();

        Boolean result = jedis.hexists(key, field);

        jedis.close();

        return result;

    }

    @Override

    public List<String> hvals(String key) {

        Jedis jedis = jedisPool.getResource();

        List<String> result = jedis.hvals(key);

        jedis.close();

        return result;

    }

    @Override

    public Long del(String key) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.del(key);

        jedis.close();

        return result;

    }

}

至此，整合完毕。。。

结果如何？

我分别贴上 Controller 、UserService 、UserServiceImpl 这里不一一细说了。

Controller :

package org.yliu.mui.controller;

import com.github.pagehelper.PageInfo;

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

import org.springframework.web.bind.annotation.PutMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import org.yliu.mui.pojo.po.MallUserPo;

import org.yliu.mui.pojo.response.ResponseData;

import org.yliu.mui.service.MallUserService;

@RestController

public class DemoController {

    private final MallUserService mallUserService;

    @Autowired

    public DemoController(MallUserService userService) {

        this.mallUserService = userService;

    }

    @RequestMapping("/get/user/all")

    ResponseData<PageInfo<MallUserPo>> getUserAll() {

        return ResponseData.success("success", mallUserService.findAll());

    }

}

UserService ：

package org.yliu.mui.service;

import com.github.pagehelper.PageInfo;

import org.yliu.mui.pojo.po.MallUserPo;

public interface MallUserService {

	// 使用分页插件提供的PageInfo包装一下结果集

    PageInfo<MallUserPo> findAll();

}

UserServiceImpl :

package org.yliu.mui.service.impl;

import com.alibaba.fastjson.JSON;

import com.github.pagehelper.PageHelper;

import com.github.pagehelper.PageInfo;

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

import org.springframework.stereotype.Service;

import org.yliu.mui.mapper.MallUserPoMapper;

import org.yliu.mui.pojo.po.MallUserPo;

import org.yliu.mui.pojo.po.MallUserPoExample;

import org.yliu.mui.redis.JedisClient;

import org.yliu.mui.service.MallUserService;

import java.util.Date;

import java.util.List;

import java.util.UUID;

@Service

public class MallUserServiceImpl implements MallUserService {

    private final MallUserPoMapper userMapper;

	// 注入Jedis接口用来操作缓存

    private final JedisClient jedisClient;

    @Autowired

    public MallUserServiceImpl(MallUserPoMapper userMapper, JedisClient jedisClient) {

        this.userMapper = userMapper;

        this.jedisClient = jedisClient;

    }

    @Override

    public PageInfo<MallUserPo> findAll() {

        PageHelper.startPage(0, 20);

        MallUserPoExample userExample = new MallUserPoExample();

        List<MallUserPo> mallUserPos = userMapper.selectByExample(userExample);

        // 测试Jedis是否正常

        jedisClient.set("user_info", JSON.toJSONString(mallUserPos));

        return new PageInfo<>(mallUserPos);

    }

}

ok，到了这里可以把项目启动了，run......

项目运行成功后输入 http://127.0.0.1:2088/druid

如果阿里的Druid连接池监控登录页面会呈现在你电脑屏幕上，恭喜~ 输入用户名、密码，去登录尝鲜吧。

下一步就是测试持久层和 redis 了

访问 http://127.0.0.1:2088/get/user/all

如果响应数据带有分页信息的json数据的话，恭喜你~整合已经完成了。

再看redis：

OK，一切正常。

注意：如果中间出现什么问题的话，不要着急，有点耐心，仔细排除一下错误。

可以在下方留言，积极讨论

可以关注微信个人公众号对我私信（下方二维码

码农公寓

相关文章