41,springboot與mybatis通用mapper整合

1,前言使用Mybatis的開發(fā)者哗魂,大多數(shù)都會遇到一個問題,就是要寫大量的SQL在xml文件中漓雅,除了特殊的業(yè)務邏輯SQL之外录别,還有大量結(jié)構(gòu)類似的增刪改查SQL。而且邻吞,當數(shù)據(jù)庫表結(jié)構(gòu)改動時组题,對應的所有SQL以及實體類都需要更改。這工作量和效率的影響或許就是區(qū)別增刪改查程序員和真正程序員的屏障抱冷。這時崔列,通用Mapper便應運而生……什么是通用Mapper通用Mapper就是為了解決單表增刪改查,基于Mybatis的插件。開發(fā)人員不需要編寫SQL赵讯,不需要在DAO中增加方法盈咳,只要寫好實體類,就能支持相應的增刪改查方法边翼。如何使用以MySQL為例鱼响,假設存在這樣一張表:

CREATE TABLE `test_table` (
 `id`  bigint(20)  NOT NULL AUTO_INCREMENT,
 `name` varchar(255) DEFAULT '',
 `create_time` datetime DEFAULT NULL,
 `create_user_id` varchar(32) DEFAULT NULL, 
`update_time` datetime DEFAULT NULL, 
`update_user_id` varchar(32) DEFAULT NULL, 
`is_delete` int(8) DEFAULT NULL, 
PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

2,導入jar

<!--sql-->

<dependencies>

<dependency>

<groupId>mysql</groupId>

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

<version>6.0.6</version>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>fastjson</artifactId>

<version>1.2.6</version>

</dependency>

<!--mybaits-->

<dependency>

<groupId>org.mybatis.spring.boot</groupId>

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

<version>1.3.1</version>

</dependency>

<!--pageHelp分頁代碼-->

<dependency>

<groupId>com.github.pagehelper</groupId>

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

<version>1.2.3</version>

</dependency>

<!--web--->

<dependency>

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

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

</dependency>

 <!--tomact-->

<dependency>

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

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

</dependency>

<dependency>

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

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

<scope>test</scope>

</dependency>

<dependency>

<groupId>com.google.guava</groupId>

<artifactId>guava</artifactId>

<version>25.1-jre</version>

<scope>compile</scope>

</dependency>

<dependency>

<groupId>tk.mybatis</groupId>

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

<version>RELEASE</version>

</dependency>

</dependencies>

3组底,yml配置


spring:
  datasource:
   # type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
   url: jdbc:mysql://localhost:3306/sd_roulette?useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true
    username: root
     password: root
#com.taotao.tongyongmapper.mapper.BaseMapper    基礎mapper接口
#com.taotao.tongyongmapper.pojo 實體類的包路徑
mybatis:
  type-aliases-package: com.taotao.tongyongmapper.pojo
  mapper-locations: classpath:mapper/*.xml
 mapper-mappers: com.taotao.tongyongmapper.mapper.BaseMapper
  mapper-identity: MYSQL
server:
  port: 8080 
 jpa:
    properties:
      hibernate:
        show_sql: true
        format_sql: true
#顯示sql日志
logging:
   level:
     com.taotao.tongyongmapper.mapper: DEBUG    #mapper包路徑

3,實體類

package com.taotao.tongyongmapper.pojo;
import com.alibaba.fastjson.annotation.JSONField;
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
@Table(name = "test_table")
public class TestTablePojo implements Serializable {
    private static final long serialVersionUID=1l;
    @Id
   @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
     private String name;
    @JSONField(format="yyyy-MM-dd HH:mm:ss")
      private Date createTime;
      private String createUserId;
      @JSONField(format="yyyy-MM-dd HH:mm:ss")
      private Date updateTime;
      private  String updateUserId;
      private  Integer isDelete;
...........//省去set丈积,get方法

}

4,枚舉 ResponseCode

package com.taotao.tongyongmapper.enums;
public enum ResponseCode {
    SUCCESS,
    FAILED,
    NO_LOGIN,
    INNER_ERROR,
}

5 ,定義時間格式

package com.taotao.tongyongmapper.model;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializeConfig;
import com.alibaba.fastjson.serializer.SimpleDateFormatSerializer;
import java.util.Date;
public abstract class BaseModel {
    public String toString(){   //定義時間輸出格式
        SerializeConfig sc=new SerializeConfig();
        sc.put(Date.class,new SimpleDateFormatSerializer("yyyy-MM-dd HH:mm:ss")); 
    return JSON.toJSONString(this,sc);
    }
}

6,ResponseModel 類

package com.taotao.tongyongmapper.model;
public class ResponseModel<E,T>extends BaseModel {
    private static final long serialVersionUID = 2761035997605462938L;
    private Long timestamp;
    private E code;
    private T data;
    private  String msg;
    private Long time;
    private  Exception exception;
   private Object datas;
.....//省去set债鸡,get
}

7江滨,基礎mapper 接口 其他的mapper接口繼承這個接口就可以

package com.taotao.tongyongmapper.mapper;
import tk.mybatis.mapper.common.Mapper;
import tk.mybatis.mapper.common.MySqlMapper;
public interface BaseMapper <T> extends Mapper<T>,MySqlMapper<T> {
}

8,,TestTableMapper 繼承BaseMapper 接口 通用mapper

package com.taotao.tongyongmapper.mapper;
import com.taotao.tongyongmapper.pojo.TestTablePojo;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface TestTableMapper extends BaseMapper<TestTablePojo> {
}

9,controller 類

package com.taotao.tongyongmapper.controller;
import com.taotao.tongyongmapper.enums.ResponseCode;
import com.taotao.tongyongmapper.model.ResponseModel;
import com.taotao.tongyongmapper.pojo.TestTablePojo;
import com.taotao.tongyongmapper.service.TestTableService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class TestTableController {
    @Autowired
    private TestTableService testTableService;
    /**
     * 添加
     * @param testTablePojo
     * @return
     */
    @RequestMapping("/insert") public String insert(TestTablePojo testTablePojo) {
        ResponseModel<ResponseCode,Object> responseModel =testTableService.insert(testTablePojo);
        return  responseModel.toString();
  }
   /**
     *  根據(jù)id刪除
     * @param id
     * @return
     */ 

@RequestMapping("/delete")
  public String hello(Long id){
       return testTableService.delete(id).toString();
  }
 /**
     * 修改
     * @param testTablePojo
     * @return
     */ 
 @RequestMapping("/update")
  public String update(TestTablePojo testTablePojo){
       return  testTableService.update(testTablePojo).toString();
  }
/**
     * 模糊查詢和分頁
     * @param keyword
     * @param page
     * @return
     */ 
   @RequestMapping("/search")
    public String search(String keyword,Integer page, Integer pageSize){
        return  testTableService.search(keyword,page,pageSize).toString();
    }

}

10 service

package com.taotao.tongyongmapper.service;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.google.common.base.Strings;
import com.taotao.tongyongmapper.enums.ResponseCode;
import com.taotao.tongyongmapper.
import com.taotao.tongyongmapper.model.PageBeanModel;
import com.taotao.tongyongmapper.model.ResponseModel;
import com.taotao.tongyongmapper.pojo.TestTablePojo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.
import org.springframework.transaction.annotation.Transactional;
import tk.mybatis.mapper.entity.Example;
import java.util.Date;
import java.util.List;
@Transactional(rollbackFor = { RuntimeException.class, Exception.class })//保證事務一致性厌均,發(fā)生異郴;回滾事務
@Service
public class TestTableService {
    @Autowired
    private TestTableMapper testTableMapper;

  /**
     * 添加

     * @param testTablePojo

     * @return

     */
  public ResponseModel<ResponseCode, Object> insert(TestTablePojo testTablePojo) {
        ResponseModel<ResponseCode, Object> responseModel=new ResponseModel<>();
        testTablePojo.setCreateTime(new Date());
        testTablePojo.setUpdateTime( new Date());
    if(testTableMapper.selectOne(new TestTablePojo().setName(testTablePojo.getName()))==null){  //根據(jù)字段條件查詢方法
                 testTableMapper.selectByPrimaryKey(testTablePojo.getId());//根據(jù)id主鍵來查詢方法
    if ( testTableMapper.insertSelective(testTablePojo)==1){ //添加方法
                  responseModel.setCode(ResponseCode.SUCCESS)
                             .setMsg("添加成功");
              }
   }
          return  responseModel;
    }
    /**
     *  根據(jù)id刪除

     * @param id

     * @return

     */
  public ResponseModel<ResponseCode, Object> delete(Long id) {
       ResponseModel<ResponseCode,Object>responseModel =new ResponseModel<>();
        if(testTableMapper.deleteByPrimaryKey(id)==1){//根據(jù)主鍵刪除
 responseModel.setCode(ResponseCode.SUCCESS)
                          .setMsg("刪除成功");
        }
          return  responseModel;
    }
  /**
     * 修改

     * @param testTablePojo

     * @return

     */

  public ResponseModel<ResponseCode, Object> update(TestTablePojo testTablePojo) {
        ResponseModel<ResponseCode,Object>responseModel =new ResponseModel<>();
            if(testTablePojo==null
   ||testTablePojo.getId()==null
                    || Strings.isNullOrEmpty(testTablePojo.getName())
                    ||Strings.isNullOrEmpty(testTablePojo.getCreateUserId())){
                responseModel.setCode(ResponseCode.FAILED)
      .setMsg("參數(shù)錯誤");
            }else{
                //把name設置為null,代表賬號不能修改
                testTablePojo.setName(null);
                testTablePojo.setCreateTime(new Date());
                testTablePojo.setUpdateTime( new Date());
                if(testTableMapper.updateByPrimaryKeySelective(testTablePojo)==1){
                    responseModel.setCode(ResponseCode.SUCCESS)
                     .setMsg("修改成功");
               }
            }
            return  responseModel;
    }

  /**

     * 模糊查詢和分頁   通用mapper的example 方法

     * @param keyword

     * @param page

     * @return

     */

   public ResponseModel<ResponseCode, PageBeanModel<TestTablePojo>> search(String keyword, Integer page, int pageSize) {
        ResponseModel<ResponseCode,PageBeanModel<TestTablePojo>> responseModel=new ResponseModel<>();
 keyword=(keyword==null?"": keyword.trim());
        page=(page==null ?1:page);
        try {
    PageHelper.startPage(page, pageSize);  //一行代碼實現(xiàn)分頁
            //創(chuàng)建條件查詢對象
            Example example =new Example(TestTablePojo.class);
             Example.Criteria criteria =example.createCriteria();
              criteria.orLike("name","%"+keyword+"%")
               .orLike("createUserId","%"+keyword+"%"); //模糊查詢
              example.setOrderByClause("id desc");
  List<TestTablePojo> testTablePojoList =testTableMapper.selectByExample(example);
     for (TestTablePojo testTablePojo:testTablePojoList)testTablePojo.setName(null);//設置name為空(當不需要再前臺出現(xiàn)的數(shù)據(jù)都可以這樣設置)
  PageInfo<TestTablePojo> pojoPageInfo =new PageInfo<>(testTablePojoList); //裝填數(shù)據(jù)
            responseModel.setCode(ResponseCode.SUCCESS)
                           .setMsg("用戶查詢成功")
                            .setDatas(pojoPageInfo);
        }catch (Exception e){
   e.getStackTrace();
             responseModel.setCode(ResponseCode.INNER_ERROR)
                     .setMsg("內(nèi)部錯誤")
                     .setException(e);
        }
        return responseModel;
    }

}

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末莫秆,一起剝皮案震驚了整個濱河市间雀,隨后出現(xiàn)的幾起案子悔详,更是在濱河造成了極大的恐慌镊屎,老刑警劉巖,帶你破解...
    沈念sama閱讀 222,946評論 6 518
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件茄螃,死亡現(xiàn)場離奇詭異缝驳,居然都是意外死亡,警方通過查閱死者的電腦和手機归苍,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,336評論 3 399
  • 文/潘曉璐 我一進店門用狱,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人拼弃,你說我怎么就攤上這事夏伊。” “怎么了吻氧?”我有些...
    開封第一講書人閱讀 169,716評論 0 364
  • 文/不壞的土叔 我叫張陵溺忧,是天一觀的道長。 經(jīng)常有香客問我盯孙,道長鲁森,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 60,222評論 1 300
  • 正文 為了忘掉前任振惰,我火速辦了婚禮歌溉,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘骑晶。我一直安慰自己痛垛,他們只是感情好草慧,可當我...
    茶點故事閱讀 69,223評論 6 398
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著匙头,像睡著了一般冠蒋。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上乾胶,一...
    開封第一講書人閱讀 52,807評論 1 314
  • 那天抖剿,我揣著相機與錄音,去河邊找鬼识窿。 笑死斩郎,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的喻频。 我是一名探鬼主播缩宜,決...
    沈念sama閱讀 41,235評論 3 424
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼甥温!你這毒婦竟也來了锻煌?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 40,189評論 0 277
  • 序言:老撾萬榮一對情侶失蹤姻蚓,失蹤者是張志新(化名)和其女友劉穎宋梧,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體狰挡,經(jīng)...
    沈念sama閱讀 46,712評論 1 320
  • 正文 獨居荒郊野嶺守林人離奇死亡捂龄,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,775評論 3 343
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了加叁。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片倦沧。...
    茶點故事閱讀 40,926評論 1 353
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖它匕,靈堂內(nèi)的尸體忽然破棺而出展融,到底是詐尸還是另有隱情,我是刑警寧澤豫柬,帶...
    沈念sama閱讀 36,580評論 5 351
  • 正文 年R本政府宣布告希,位于F島的核電站,受9級特大地震影響轮傍,放射性物質(zhì)發(fā)生泄漏暂雹。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 42,259評論 3 336
  • 文/蒙蒙 一创夜、第九天 我趴在偏房一處隱蔽的房頂上張望杭跪。 院中可真熱鬧,春花似錦、人聲如沸涧尿。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,750評論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽姑廉。三九已至缺亮,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間桥言,已是汗流浹背萌踱。 一陣腳步聲響...
    開封第一講書人閱讀 33,867評論 1 274
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留号阿,地道東北人并鸵。 一個月前我還...
    沈念sama閱讀 49,368評論 3 379
  • 正文 我出身青樓,卻偏偏與公主長得像扔涧,于是被迫代替她去往敵國和親园担。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 45,930評論 2 361

推薦閱讀更多精彩內(nèi)容