Spring-boot集成通用Mapper(tk.mybatis)

代码之前:
如果你是搜索进来看到这里,那么说明你已经知道通用mapper了。如果你是翻到这里,并不了解通用mapper。你可以先自行百度或者看看https://gitee.com/free/Mapper,这里讲述了通用mapper的内容

接下来我们看看怎样集成通用mapper

step1:引入相关依赖,这里采用springboot 【2.0.2.RELEASE】版本

<?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.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <!--spring-boot 核心依赖-->
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.2.RELEASE</version>
        <relativePath/>
    </parent>

    <dependencies>
        <!--spring-boot mybatis依赖-->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.2</version>
        </dependency>

        <!--mysql依赖-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>

        <!--spring-boot web依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--添加tk-mapper依赖-->
        <dependency>
            <groupId>tk.mybatis</groupId>
            <artifactId>mapper-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>
        <!--druid依赖-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.3</version>
        </dependency>
        <!--lombok依赖-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

step2:application.yml配置文件

server:
  port: 9999

#数据源配置
spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource #Druid连接池
    url: jdbc:mysql://xxx.xxx.xx.xx:3306/Db_Name?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=true
    username: root #数据库用户名
    password: root #数据库密码
    driver-class-name: com.mysql.jdbc.Driver #mysql驱动
    initialSize: 10 #初始化连接池大小
    minIdle: 10 #初始化最小连接池数量
    maxActive: 100 #初始化最大连接池数量
    maxWait: 6000 #配置获取连接等待超时的时间
    timeBetweenEvictionRunsMills: 6000 #配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
    minEvictableIdleTimeMillis: 30000 #配置一个连接在池中最小生存的时间,单位是毫秒
    validationQuery: SELECT 'x' #测试连接

step3:通用mapper配置类

包名自拟,我的是:com.test.config.mapperconfig

package com.test.config.mapperconfig;
import com.test.mapper.base.CrudMapper;
import org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import tk.mybatis.spring.mapper.MapperScannerConfigurer;
import java.util.Properties;
/**
* 通用mapper配置了类
* @author songgt
*/
@Configuration
@AutoConfigureAfter(MybatisAutoConfiguration.class)
public class MapperScannerConfig {
    @Bean
    public MapperScannerConfigurer mapperScannerConfigurer(){
        MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer();
        mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");
        //mapper类的包名--即操作数据库的对应到数据表的Mapper.java类的包名,如果这里的包名配错项目启动报错
        mapperScannerConfigurer.setBasePackage("com.test.mapper.customer");

        //这里properties的相关配置,由于能力有限,暂时还未探究,如果你知道请麻烦告诉我,谢谢
        Properties properties = new Properties();
        properties.setProperty("mappers", CrudMapper.class.getName());
        properties.setProperty("notEmpty","false");
        properties.setProperty("IDENTITY", "MYSQL");
        properties.setProperty("ORDER","BEFORE");
        mapperScannerConfigurer.setProperties(properties);
        return mapperScannerConfigurer;
    }
}

step4:创建mapper

包名自拟,我的包名是:com.test.mapper
注:这里说明下,在mapper包下床架base和【业务mapper】
base包下分别创建:
InsertMapper、DeleteMapper、UpdateMapper、SelectMapper、CrudMapper
InsertMapper--------------------------------------------------------------------------------------

package com.test.mapper.base;

import tk.mybatis.mapper.common.Marker;
import tk.mybatis.mapper.common.MySqlMapper;
import tk.mybatis.mapper.common.base.insert.InsertSelectiveMapper;

/**
 * 基础新增功能mapper
 * @author songgt
 */
public interface InsertMapper<T> extends Marker,
        tk.mybatis.mapper.common.base.BaseInsertMapper<T>,
        InsertSelectiveMapper<T>,
        MySqlMapper<T>{
}

DeleteMapper------------------------------------------------------------------------------------

package com.test.mapper.base;
import tk.mybatis.mapper.common.Marker;
import tk.mybatis.mapper.common.base.delete.DeleteByPrimaryKeyMapper;
import tk.mybatis.mapper.common.condition.DeleteByConditionMapper;
import tk.mybatis.mapper.common.ids.DeleteByIdsMapper;
/**
 * 基础删除功能mapper
 * @author songgt
 */
public interface DeleteMapper<T> extends Marker,
        tk.mybatis.mapper.common.base.delete.DeleteMapper<T>,
        DeleteByPrimaryKeyMapper<T>,
        DeleteByConditionMapper<T>,
        DeleteByIdsMapper<T>{
}

UpdateMapper-----------------------------------------------------------------------------------

package com.test.mapper.base;
import tk.mybatis.mapper.common.Marker;
import tk.mybatis.mapper.common.base.update.UpdateByPrimaryKeyMapper;
import tk.mybatis.mapper.common.base.update.UpdateByPrimaryKeySelectiveMapper;
import tk.mybatis.mapper.common.condition.UpdateByConditionMapper;
import tk.mybatis.mapper.common.condition.UpdateByConditionSelectiveMapper;
import tk.mybatis.mapper.common.example.UpdateByExampleSelectiveMapper;
/**
 * 基础修改功能mapper
 * @author songgt
 */
public interface UpdateMapper<T> extends Marker,
        UpdateByPrimaryKeyMapper<T>,
        UpdateByPrimaryKeySelectiveMapper<T>,
        UpdateByConditionMapper<T>,
        UpdateByConditionSelectiveMapper<T>,
        UpdateByExampleSelectiveMapper<T> {
}

SelectMapper-----------------------------------------------------------------------------------

package com.test.mapper.base;

import tk.mybatis.mapper.common.Marker;
import tk.mybatis.mapper.common.base.select.*;
import tk.mybatis.mapper.common.condition.SelectByConditionMapper;
import tk.mybatis.mapper.common.condition.SelectCountByConditionMapper;
import tk.mybatis.mapper.common.example.SelectByExampleMapper;
import tk.mybatis.mapper.common.ids.SelectByIdsMapper;

/**
 * 基础查询功能mapper
 * @author songgt
 */
public interface SelectMapper<T> extends Marker,
        SelectOneMapper<T>,
        tk.mybatis.mapper.common.base.select.SelectMapper<T>,
        SelectAllMapper<T>,
        SelectCountMapper<T>,
        SelectByPrimaryKeyMapper<T>,
        ExistsWithPrimaryKeyMapper<T>,
        SelectByIdsMapper<T>,
        SelectByConditionMapper<T>,
        SelectCountByConditionMapper<T>,
        SelectByExampleMapper<T>
        {
}

CrudMapper--------------------------------------------------------------------------------------

package com.test.mapper.base;
/**
* 基础增删改查功能mapper
* @author songgt
*/
public interface CrudMapper<T> extends InsertMapper<T>,
        DeleteMapper<T>,
        UpdateMapper<T>,
        SelectMapper<T>{
}

step5:创建业务Mapper

在com.test.mapper下创建业务mapper,包名自拟,我只是:com.test.mapper.customer

package com.test.mapper.customer;

import com.test.entity.OmsCustomer;
import com.test.mapper.base.CrudMapper;
import org.apache.ibatis.annotations.Mapper;

/**
* @author songgt
*/
@Mapper
public interface CustomerMapper extends CrudMapper<OmsCustomer> {
    //这里可以定义自己的接口,这样就回到了原始状态,可以根据需要来实现
}

step6:实体类(entity/pojo/bean)

ps:你们管实体类叫什么呢?我从大学开始老师就说这个叫实体类,命名以Entity结尾。习惯了,所以觉得叫着挺顺的。

package com.test.entity;
import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import java.io.Serializable;
/**
 * @author songgt
 */
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
public class OmsCustomer implements Serializable {
    private static final long serialVersionUID = 5447080611171013407L;

    /**
     * ID,自增主键
     **/
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;

    private String customerName;

    private String customerTaxNo;

    private Integer isValid;

    private Integer isPush;

    private String creator;

    private String createTime;

    private String modifier;

    private String modififyTime;
}

step7:重要一步来了

编写controller测试。ps:这里偷懒,没有写Service层,在实际开发中是要写的

package com.test.controller;
import com.test.entity.OmsCustomer;
import com.test.mapper.customer.CustomerMapper;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
/**
* @author songgt
*/
@RestController
public class CustomerController {
    @Resource
    private CustomerMapper customerMapper;

    /**
    * 根据ID查询记录
    */
    @GetMapping(path = "/selectById")
    public OmsCustomer selectById(){
        OmsCustomer omsCustomer = customerMapper.selectByPrimaryKey(25);
        return omsCustomer;
    }

    /**
     * 新增记录
     */
    @GetMapping(path = "/addCustomer")
    public Integer addCustomer(){
        OmsCustomer customer = new OmsCustomer();
        customer.setCustomerName("老宋测试客户");
        customer.setCustomerTaxNo("442568995555555X");
        customer.setIsValid(1);
        customer.setIsPush(0);
        //这里的ID是插入返回的影响数据库行数
        Integer id = customerMapper.insertSelective(customer);
        //插入成功后通过对象getId()可以获取新插入记录的ID
        return customer.getId();
    }

    /**
     * 根据ID删除记录
     */
    @GetMapping(path = "/deleteById")
    public Integer deleteById(){
        return customerMapper.deleteByPrimaryKey(87);
    }

    /**
     * 根据ID更新记录
     */
    @GetMapping(path = "/updteById")
    public Integer updteById(){
        OmsCustomer customer = new OmsCustomer();
        customer.setId(87);
        customer.setIsPush(1);
        customer.setCustomerTaxNo("44444444444444444444");
        //updateByPrimaryKey:不会忽略null值字段(属性)
        return customerMapper.updateByPrimaryKey(customer);
        
        //updateByPrimaryKeySelective:更新是会忽略null值字段(属性)
        //return customerMapper.updateByPrimaryKeySelective(customer);
    }
}

step8:集成通用Mapper后如何实现自定义操作?

在application.yml文件中增加mapper.xml的扫描路径

mybatis:
  mapper-locations: classpath:/mapper/*.xml

在Customer.java中增加自己的操作方法

//自定义查询方法
OmsCustomer selfSelectById(@Param("id") Integer id);

在resource目录下增加customerMapper.xml文件

<?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="com.test.mapper.customer.CustomerMapper">
    <select id="selfSelectById" parameterType="java.lang.Integer" resultType="com.test.entity.OmsCustomer">
        SELECT id,customer_name customerName,
               customer_tax_no customerTaxNo,
               is_valid isValid,
               is_push isPush,
               creator,
               create_time createTime,
               modifier,
               modifify_time modififyTime
        FROM oms_customer WHERE id = #{id};
    </select>
</mapper>

在controller中增加测试方法

//使用自定义方法查询数据库
@GetMapping(path = "/selfSelectByid")
    public OmsCustomer selfSelectByid(){
        Integer id = 25;
        return customerMapper.selfSelectById(id);
    }

后记:上述过程亲测成功,如果你也需要使用到通用mapper,欢迎参考。上述内容呢纯属个人总结,如有错误,欢迎拍砖!

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,530评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 86,403评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,120评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,770评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,758评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,649评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,021评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,675评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,931评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,659评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,751评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,410评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,004评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,969评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,042评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,493评论 2 343

推荐阅读更多精彩内容