登录 注册

Mybatis 通用 Dao 的封装源码与示例

本贴最后更新于 3067 天前，其中的信息可能已经事过境迁

曾将发布过俩篇关于Mybatis封装的文章，当时曾曾承诺过当测试没有问题后阿海会整理一下然后将原代码发布出来。

那么今天正好朋友找我要一份那套mybatis封装的源码，我便整理了一份，想想这么长时间了并没有发现什么明显的bug，于是决定将它发出来。


喜欢的朋友可以在这里下载：

crud-src.rar


关于这个mybatis的封装，我且叫他CRUD框架吧，这样说着还顺口一点。这是一个Maven工程，代码在src/main/java中。配置文件在src/main/resource中，这就不多说了，整个CRUD的源码在com.aiyi.core包中。

QQ截图20160628154905.jpg

喜欢的朋友可以进去瞅瞅，也没有什么高深的技术，就是写了一个公用的Dao并代理了一下dao的实现层。还有就是com.aiyi.base包中，就是你写代码的地方了，里面有一些dao包啦、service包啦、controller包啦之类的。这事我随便写的一些使用的例子，这些根据自己项目结构随便改。

QQ截图20160628155416.jpg

接下来就是一些使用方式什么的，将工程导入到eclipse中后，进入com.aiyi.base.dao包，可以看到两个实体类，这两个实体类对应的是数据库中的两张表。

TestUserPo.java：

package com.aiyi.base.pojo;

import com.aiyi.core.annotation.po.FieldName;

import com.aiyi.core.annotation.po.TableName;

import com.aiyi.core.annotation.po.TempField;

import com.aiyi.core.beans.Po;


//@TableName 用来表示当前实体类对应数据库中的表名

@TableName(name="q_test_table1")

public class TestUserPo extends Po {


 private int id;

 

 //@FieldName 注解是用来标识该字段对应的数据库字段名。假如数据库字段和实体类中的字段一致的话，就不需要这个注解

 @FieldName(name="img_id")

 private int imgId;

 

 private String name;

 

 //@TempField 注解标识 imgUrl 这个字段是一个临时字段，也就是说，在数据库中这个字段是不存在的。

 @TempField

 private String imgUrl;


 public int getId() {

  return id;

 }


 public void setId(int id) {

  this.id = id;

 }


 public int getImgId() {

  return imgId;

 }


 public void setImgId(int imgId) {

  this.imgId = imgId;

 }


 public String getName() {

  return name;

 }


 public void setName(String name) {

  this.name = name;

 }


 public String getImgUrl() {

  return imgUrl;

 }


 public void setImgUrl(String imgUrl) {

  this.imgUrl = imgUrl;

 }

 

 

}

TestImgResourcePo.java：

package com.aiyi.base.pojo;


import com.aiyi.core.annotation.po.TableName;

import com.aiyi.core.beans.Po;


@TableName(name="q_test_table2")

public class TestImgResourcePo extends Po {


 private int id;

 

 private String url;


 public int getId() {

  return id;

 }


 public void setId(int id) {

  this.id = id;

 }


 public String getUrl() {

  return url;

 }


 public void setUrl(String url) {

  this.url = url;

 }

 

 

}

com.aiyi.base.dao 包中，有资格类，分别是 UserDao、ImgResourceDao 以及他们的接口。这里如果你只是单纯的想用 CRUD 做开发的话，

一般情况下是不用写那两个接口类的，也就是说，你只需要写 UserDao、ImgResourceDao 这两个类就好了，但是这里既然是例子，那就说全一点，一般情况下虽然不需要写 dao 的接口类，但是我喜欢二班情况。

若问我为什么要闲着没事儿给他写接口玩儿，是因为我封装的这套 CRUD 支持编程扩展的。也就是说，你可以在开发的时候根据需要扩展他的功能。你可以理解为一种叫做“插件”的东西。待会儿我要在两张表内各插入 3000 条数据，原始的 CRUD 框架虽然可以插入数据，但是他只能一条一条的插入，虽然你可以写个可爱的 for 循环，但是效率摆在那，如果想批量的插入一些数据的话，你或许需要给他增加这么一个功能，也就是说，给他写一个支持批量增加记录的插件。

所以请看好，接下来的相信在实际开发中经常会遇到，我给他添加批量新增的支持，就先建立一个接口类并给他生命一个 add 方法用来批量添加数据：

package com.aiyi.base.dao;


import java.util.List;


import com.aiyi.base.pojo.TestUserPo;


/**

 * UserDao 的接口类，也属于爱易 CRUD 的插件扩展类。这个类一般情况下不用创建。当需要重载或者新增 REUD 框架的一些方法时，可以声明接口类

 * 本接口类重载了 add()方法，使 add 方法可以一次性插入多条数据，极大的提高了数据批量增加的效率

 * @author 郭胜凯

 * @time 2016 年 6 月 28 日下午 12:51:29

 * @email 719348277@qq.com

 *

 */

public interface UserDaoInterface {


 int add(List list);

}

接口类建立了以后，我需要写一个 mapper 映射文件，将它执行的 sql 映射一下，那么我建立一个 com.aiyi.base.mapper.userDaoMapper.xml：

并将它的 namespace 指向咱们先前写的这个接口：com.aiyi.base.dao.UserDaoInterface




<mapper namespace="com.aiyi.base.dao.UserDaoInterface">


    

 <insert id="user_addList" useGeneratedKeys="true" parameterType="java.util.List">

  insert into q_test_table1 (img_id, name)

  values

  <foreach collection="list" item="item" index="index"

   separator=",">

   (#{item.imgId}, #{item.name})

  


 

 

接下来建立 UserDao.java，并继承 DaoImpl，DaoImpl 有两个泛型，第一个是当前 Dao 对应的实体类，第二个是当前实体类中的主键类型。这个时候，你的这个 UserDao 就已经拥有通用的增删改查方法了但是我希望他拥有批量新增的方法，所以我在让他实现之前的 UserDaoInterface 这个类。

package com.aiyi.base.dao;


import java.util.List;


import javax.annotation.Resource;


import org.mybatis.spring.SqlSessionTemplate;

import org.springframework.stereotype.Repository;


import com.aiyi.base.pojo.TestUserPo;

import com.aiyi.core.dao.impl.DaoImpl;


/**

 * UserDao 的实现类，该类继承了公共 Dao 的原始方法。当你要给爱易 REUD 框架增加新功能时，不用去改源码，爱易 CRUD 提供了可编程式插件接口的方案。

 * 你可以编写一个接口类并实现他，以此来扩展爱易 CRUD

 * @author 郭胜凯

 * @time 2016 年 6 月 28 日下午 12:56:42

 * @email 719348277@qq.com

 *

 */

@Repository

public class UserDao extends DaoImpl<TestUserPo, Integer> implements UserDaoInterface /UserDaoInterface 这个接口是一个插件实现的演示。他完善了爱易 CRUD 的批量添加方案/ {


 @Resource

 private SqlSessionTemplate sqlSessionTemplateASS;

 

 /**

  * 重载 Add 方法，批量添加

  * @param list

  * @return

  */

 public int add(List list){

  

  long startId = nextId();

  

  for (int i = 0; i < list.size(); i++) {

   list.get(i).setId(Integer.valueOf(startId + i + ""));

  }

  

  //注意了，这里的“user_addList”对应的是 userDaoMapper.xml 中的 insertSQL 块的 Id

  return sqlSessionTemplateASS.insert("user_addList", list);

 }

}

好了，这么一个批量新增的扩展类已经编写完成了！你只需要调用 userDao.add()方法的时候，传入一个 list 进去，他就会以最短的时间吧 list 中的元素插入到数据库中！

接下来吧 imgDao 页添加一个批量新增的功能，以上面一样，所以我就不再贴代码了！看我写个 Service 来测试一下！

package com.aiyi.base.service.impl;


import java.util.ArrayList;

import java.util.List;


import javax.annotation.Resource;


import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Isolation;

import org.springframework.transaction.annotation.Transactional;


import com.aiyi.base.dao.ImgDao;

import com.aiyi.base.dao.UserDao;

import com.aiyi.base.pojo.TestImgResourcePo;

import com.aiyi.base.pojo.TestUserPo;

import com.aiyi.base.service.TestService;

import com.aiyi.core.beans.Method;

import com.aiyi.core.sql.where.C;

import com.aiyi.core.util.Formatter;

import com.aiyi.core.util.FormatterSql;


@Service

public class TestServiceImpl implements TestService {

 

 @Resource

 private ImgDao imgDao;

 

 @Resource

 private UserDao userDao;


 //批量新增 User 和 Img 各 3000 条，速度嗖嗖的

 @Override

 @Transactional(isolation = Isolation.SERIALIZABLE)

 public int addList() {

  // TODO Auto-generated method stub

  

  List users = new ArrayList<>();

  List imgs = new ArrayList<>();

  

  for (int i = 0; i < 3000; i++) {

   TestImgResourcePo imgResourcePo = new TestImgResourcePo();

   imgResourcePo.setUrl("http://imgresource.com/url/" + i + ".jpg");

   imgs.add(imgResourcePo);

  }

  int add = imgDao.add(imgs);

  

  for (int i = 0; i < 3000; i++) {

   TestUserPo testUserPo = new TestUserPo();

   testUserPo.setImgId(imgs.get(i).getId());

   testUserPo.setName("用户" + i);

   users.add(testUserPo);

  }

  add += userDao.add(users);

  

  

  return add;

 }


 //联表查询，之前说了 user 实体类的 imgUrl 是一个临时字段，他的真正的值在 img 表的 url 字段里，user 中的 imgId 对应的就是 img 表中的 Id

 @Override

 public List listUser() {

  // TODO Auto-generated method stub

  

  Formatter fmt = new FormatterSql();

  fmt.addFmt("imgUrl", "url", TestImgResourcePo.class, Method.where("[fmt.R].id", C.EQ, "[fmt.L].img_id"));

  

  return userDao.listFormat(Method.createDefault(), fmt);

 }

}

写个 Controller 跑一下：

package com.aiyi.base.controller;


import java.util.HashMap;

import java.util.List;

import java.util.Map;


import javax.annotation.Resource;


import org.springframework.stereotype.Controller;

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

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


import com.aiyi.base.pojo.TestUserPo;

import com.aiyi.base.service.TestService;


@Controller

public class TestController {


 @Resource

 private TestService testService;

 

 /**

  * 添加测试

  * @return

  /

 @RequestMapping("testAdd")

 @ResponseBody

 public Object testAddList(){

  

  long t = System.currentTimeMillis();

  int n = testService.addList();

  long tT = System.currentTimeMillis();

  

  double s = (tT - t) / 1000;

  

  return "共添加" + n + "条数据，用时" + s + "秒";

 }

 

 /*

  * 查询测试

  * @return

  /

 @RequestMapping("testSelect")

 @ResponseBody

 public Object testSelectFmt(){

  

  long t = System.currentTimeMillis();

  List listUser = testService.listUser();

  long tT = System.currentTimeMillis();

  

  double s = (tT - t) / 1000;

  

  Map<String, Object> map = new HashMap<>();

  

  map.put("msg", "共查询" + listUser.size() + "条记录,用时" + s + "秒");

  map.put("oData", listUser);

  

  return map;

  

 }

}

以上就是这个样子，更多的东西可以从我以前的文章中看到，或者自己下载源码摸索一下，这里就介绍这么多了至此，再见！

呃。。等等，还有个事儿给忘了，数据库在/crud2/src/main/resources/jdbc.properties 下面配置成自己的。

下面是 Mysql 的两张测试表：

/

Navicat MySQL Data Transfer


Source Server         : aiyi_web

Source Server Version : 50518

Source Host           : rm-bp1995mscsm3q9bus.mysql.rds.aliyuncs.com:3306

Source Database       : rz4m1ulg3q


Target Server Type    : MYSQL

Target Server Version : 50518

File Encoding         : 65001


Date: 2016-06-28 16:38:37

*/


SET FOREIGN_KEY_CHECKS=0;


-- ----------------------------

-- Table structure for q_test_table1

-- ----------------------------

DROP TABLE IF EXISTS q_test_table1;

CREATE TABLE q_test_table1 (

  id int(11) NOT NULL AUTO_INCREMENT,

  name varchar(255) DEFAULT NULL,

  img_id int(11) DEFAULT NULL,

  PRIMARY KEY (id)

) ENGINE=InnoDB AUTO_INCREMENT=12001 DEFAULT CHARSET=utf8;


-- ----------------------------

-- Table structure for q_test_table2

-- ----------------------------

DROP TABLE IF EXISTS q_test_table2;

CREATE TABLE q_test_table2 (

  id int(11) NOT NULL AUTO_INCREMENT,

  url varchar(255) DEFAULT NULL,

  PRIMARY KEY (id)

) ENGINE=InnoDB AUTO_INCREMENT=21001 DEFAULT CHARSET=utf8;

OK！到此，真的再见了！

  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis，2010 年这个项目由 Apache 软件基金会迁移到了 google code，并且改名为 MyBatis ，2013 年 11 月再次迁移到了 GitHub。

    170 引用 • 414 回帖 • 386 关注
北京 位置
7 回帖
7
2.6k 15 355 806 140 240 16 134 825

相关帖子

7 回帖
Mybatis 通用 Dao 的封装源码与示例

欢迎来到这里！

我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。

注册 关于
请输入回帖内容 ...
请输入回帖内容 ...
shengkai
北京
回帖
5
 帖子
10
 积分
2025

近期热议

推荐标签 标签

  • Sym

    Sym 是一款用 Java 实现的现代化社区（论坛/BBS/社交网络/博客）系统平台。

    下一代的社区系统，为未来而构建

    524 引用 • 4601 回帖 • 700 关注
  • PWL

    组织简介

    用爱发电 (Programming With Love) 是一个以开源精神为核心的民间开源爱好者技术组织，“用爱发电”象征开源与贡献精神，加入组织，代表你将遵守组织的“个人开源爱好者”的各项条款。申请加入：用爱发电组织邀请帖。
    用爱发电组织官网：https://programmingwithlove.stackoverflow.wiki/

    用爱发电组织的核心驱动力：

    • 遵守开源守则，体现开源&贡献精神：以分享为目的，拒绝非法牟利。
    • 自我保护：使用适当的 License 保护自己的原创作品。
    • 尊重他人：不以各种理由、各种漏洞进行未经允许的抄袭、散播、洩露；以礼相待，尊重所有对社区做出贡献的开发者；通过他人的分享习得知识，要留下足迹，表示感谢。
    • 热爱编程、热爱学习：加入组织，热爱编程是首当其要的。我们欢迎热爱讨论、分享、提问的朋友，也同样欢迎默默成就的朋友。
    • 倾听：正确并恳切对待、处理问题与建议，及时修复开源项目的 Bug ，及时与反馈者沟通。不抬杠、不无视、不辱骂。
    • 平视：不诋毁、轻视、嘲讽其他开发者，主动提出建议、施以帮助，以和谐为本。只要他人肯努力，你也可能会被昔日小看的人所超越，所以请保持谦虚。
    • 乐观且活跃：你的努力决定了你的高度。不要放弃，多年后回头俯瞰，才会发现自己已经成就往日所仰望的水平。积极地将项目开源，帮助他人学习、改进，自己也会获得相应的提升、成就与成就感。
    1 引用 • 487 回帖
  • OnlyOffice
    4 引用 • 3 关注
  • TextBundle

    TextBundle 文件格式旨在应用程序之间交换 Markdown 或 Fountain 之类的纯文本文件时，提供更无缝的用户体验。

    1 引用 • 2 回帖 • 48 关注
  • Mobi.css

    Mobi.css is a lightweight, flexible CSS framework that focus on mobile.

    1 引用 • 6 回帖 • 733 关注
  • 书籍

    宋真宗赵恒曾经说过：“书中自有黄金屋，书中自有颜如玉。”

    77 引用 • 390 回帖
  • Sublime

    Sublime Text 是一款可以用来写代码、写文章的文本编辑器。支持代码高亮、自动完成，还支持通过插件进行扩展。

    10 引用 • 5 回帖
  • CloudFoundry

    Cloud Foundry 是 VMware 推出的业界第一个开源 PaaS 云平台，它支持多种框架、语言、运行时环境、云平台及应用服务，使开发人员能够在几秒钟内进行应用程序的部署和扩展，无需担心任何基础架构的问题。

    5 引用 • 18 回帖 • 167 关注
  • OpenShift

    红帽提供的 PaaS 云，支持多种编程语言，为开发人员提供了更为灵活的框架、存储选择。

    14 引用 • 20 回帖 • 633 关注
  • 爬虫

    网络爬虫（Spider、Crawler），是一种按照一定的规则，自动地抓取万维网信息的程序。

    106 引用 • 275 回帖
  • Telegram

    Telegram 是一个非盈利性、基于云端的即时消息服务。它提供了支持各大操作系统平台的开源的客户端，也提供了很多强大的 APIs 给开发者创建自己的客户端和机器人。

    5 引用 • 35 回帖 • 1 关注
  • Kubernetes

    Kubernetes 是 Google 开源的一个容器编排引擎，它支持自动化部署、大规模可伸缩、应用容器化管理。

    110 引用 • 54 回帖
  • C

    C 语言是一门通用计算机编程语言，应用广泛。C 语言的设计目标是提供一种能以简易的方式编译、处理低级存储器、产生少量的机器码以及不需要任何运行环境支持便能运行的编程语言。

    85 引用 • 165 回帖 • 1 关注
  • 职场

    找到自己的位置，萌新烦恼少。

    127 引用 • 1705 回帖 • 1 关注
  • Markdown

    Markdown 是一种轻量级标记语言，用户可使用纯文本编辑器来排版文档，最终通过 Markdown 引擎将文档转换为所需格式（比如 HTML、PDF 等）。

    167 引用 • 1513 回帖
  • 开源

    Open Source, Open Mind, Open Sight, Open Future!

    408 引用 • 3574 回帖
  • 阿里云

    阿里云是阿里巴巴集团旗下公司，是全球领先的云计算及人工智能科技公司。提供云服务器、云数据库、云安全等云计算服务，以及大数据、人工智能服务、精准定制基于场景的行业解决方案。

    89 引用 • 345 回帖
  • Mac

    Mac 是苹果公司自 1984 年起以“Macintosh”开始开发的个人消费型计算机，如：iMac、Mac mini、Macbook Air、Macbook Pro、Macbook、Mac Pro 等计算机。

    166 引用 • 595 回帖
  • FFmpeg

    FFmpeg 是一套可以用来记录、转换数字音频、视频，并能将其转化为流的开源计算机程序。

    23 引用 • 32 回帖
  • SendCloud

    SendCloud 由搜狐武汉研发中心孵化的项目，是致力于为开发者提供高质量的触发邮件服务的云端邮件发送平台，为开发者提供便利的 API 接口来调用服务，让邮件准确迅速到达用户收件箱并获得强大的追踪数据。

    2 引用 • 8 回帖 • 483 关注
  • 架构

    我们平时所说的“架构”主要是指软件架构，这是有关软件整体结构与组件的抽象描述，用于指导软件系统各个方面的设计。另外还有“业务架构”、“网络架构”、“硬件架构”等细分领域。

    142 引用 • 442 回帖
  • Windows

    Microsoft Windows 是美国微软公司研发的一套操作系统，它问世于 1985 年，起初仅仅是 Microsoft-DOS 模拟环境，后续的系统版本由于微软不断的更新升级，不但易用，也慢慢的成为家家户户人们最喜爱的操作系统。

    222 引用 • 473 回帖
  • 脑图

    脑图又叫思维导图，是表达发散性思维的有效图形思维工具 ，它简单却又很有效，是一种实用性的思维工具。

    26 引用 • 84 回帖
  • 旅游

    希望你我能在旅途中找到人生的下一站。

    90 引用 • 899 回帖
  • Flume

    Flume 是一套分布式的、可靠的，可用于有效地收集、聚合和搬运大量日志数据的服务架构。

    9 引用 • 6 回帖 • 629 关注
  • 安装

    你若安好，便是晴天。

    132 引用 • 1184 回帖
  • BAE

    百度应用引擎（Baidu App Engine）提供了 PHP、Java、Python 的执行环境，以及云存储、消息服务、云数据库等全面的云服务。它可以让开发者实现自动地部署和管理应用，并且提供动态扩容和负载均衡的运行环境，让开发者不用考虑高成本的运维工作，只需专注于业务逻辑，大大降低了开发者学习和迁移的成本。

    19 引用 • 75 回帖 • 641 关注

最新标签