通用DAO之MyBatis封装，封装通用的增删改查（三）

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

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

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

http://aiyiupload.oss-cn-beijing.aliyuncs.com/blog/img/2016/06/28/15/6d69ad50-ab53-4f4f-b4e7-1fed010bfdb9.rar

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

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

接下来就是一些使用方式什么的，将工程导入到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 [email protected]
 *
 */
public interface UserDaoInterface {

 int add(List<TestUserPo> list);
}

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

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

<?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.aiyi.base.dao.UserDaoInterface">

    <!-- 重载Add -->
 <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})
  </foreach>

 </insert>

</mapper>

接下来建立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 [email protected]
 *
 */
@Repository
public class UserDao extends DaoImpl<TestUserPo, Integer> implements UserDaoInterface /*UserDaoInterface这个接口是一个插件实现的演示。他完善了爱易CRUD的批量添加方案*/ {

 @Resource
 private SqlSessionTemplate sqlSessionTemplateASS;

 /**
  * 重载Add方法，批量添加
  * @param list
  * @return
  */
 public int add(List<TestUserPo> 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<TestUserPo> users = new ArrayList<>();
  List<TestImgResourcePo> 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<TestUserPo> 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<TestUserPo> 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;

另外，GIT地址：https://git.coding.net/shengkai/crud.git

如果在使用过程中遇到问题，欢迎提交解决方案！以及代码的完善！

OK！到此，真的再见了！

时间： 2024-10-16 07:30:09

通用DAO之MyBatis封装，封装通用的增删改查（三）的相关文章

Mybatis实现简单的数据库增删改查操作

Mybatis实现简单的数据库增删改查操作 框架:mybatis(3.5.2) 数据库:mysql 工具:idea 1.新建一个maven项目,在pom文件中添加mybatis依赖及MySQL依赖 <!-- mybatis核心依赖 --> <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis --> <dependency> <groupId>org.mybatis</groupId&g

SpringBoot + MyBatis 实现对员工的增删改查

SpringBoot + MyBatis 实现对员工的增删改查 一.使用idea新建SpringBoot项目 File-->New-->Project-->Spring Assistant-->Next-->修改报名,项目名等信息-->Next-->在web中选中web,在SQL中选中MySQL.JDBS.MyBatis-->Next-->Finish 二.修改pom.xml文件[之前的操作已经导入了springboot.mysql.jdbc.myba

MyBatis框架入门小案例（关于用mybatis框架对数据库的增删改查）

1.新建一个maven项目,建好相对应的包,在https://mvnrepository.com中导入MyBatis需要的依赖,复制到配置文件中 2.在resources文件下添加mybatis-config.xml文件和mapper文件夹,mybatis-config.xml是连接mysql的主要配置,mapper文件夹存放的是对数据库增删改查的映射 mybatis-config.xml配置如下: <?xml version="1.0" encoding="utf-8

Mybatis使用之简单的增删改查

Mybatis使用之简单的增删改查 一:简介 主要记录最简单的数据的增删改查.下一章会有各个操作详细一点的配置说明.以Author表为例(见上一博客).Author表没有关联任何其他表.也没有特殊字段. 二:映射规则 2.1.映射文件中的sql方法与对应的XxxMapper接口中的方法映射规则: a)映射文件的namespace的值是XxxMapper接口的全限定名.即包名+接口名称 b)映射文件中表示增删改查的标签(select.insert.delete.update)的id的值是接口中方法

Mybatis简单的入门之增删改查

一般的步骤如下 1.添加Mybatis所需要的包,和连接数据库所需的包 2.配置mybatis-config.xml文件 3.配置与pojo对应的映射文件 mybatis-config,xml <?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http:/

(原理篇)基于SQLite3轻量级封装,一行代码实现增删改查

最近写的项目中有用到数据库,写了不少蛋疼的sql语句,每次都是好几行代码,而且每次都是重复的没有一点技术含量的代码,虽然也有不少基于sqlite的封装,不过用起来还是感觉不够面向对象! 为了不再写重复的代码,花了几天时间,基于SQLite3简单封装了下,实现了一行代码解决增删改查等常用的功能!并没有太过高深的知识,主要用了runtime和KVC: 首先我们创建个大家都熟悉的Person类,并声明两个属性,下面将以类此展开分析 @interface Person : NSObject @prope

mybatis 的 sql 映射文件增删改查的学习

在 sql 映射文件中配置增删改查的操作:     1.增: 在 sql 映射文件中添加 insert 标签,并且增加对应的 sql 语句.(在之前博文示例的基础上添加)在 对应的接口中添加 对应的方法,方法名与 sql 映射文件中 insert 标签中的 id 属性值一致. 注:可以看到,在测试方法 test03 中更新成功.但是在 openSession 对象需要手动提交事务.(sqlSessionFactory.openSession 方法的得到的 openSession 对象,使用 sq

【Mybatis】Mybatis接口编程方式实现增删改查

林炳文Evankaka原创作品.转载请注明出处http://blog.csdn.net/evankaka 前面一章[Mybatis]Mybatis入门概述及第一个Mybatis实例实现增删改查,已经搭建好了eclipse,mybatis,mysql的环境,并且实现了一个简单的查询.请注意,这种方式是用SqlSession实例来直接执行已映射的SQL语句: session.selectOne("com.mucfc.model.EmployeerMapper.findEmployeerByID&qu

MyBatis学习系列二之增删改查

数据库的经典操作:增删改查. 在这一章我们主要说明一下简单的查询和增删改,并且对程序接口做了一些调整,以及对一些问题进行了解答. 1.调整后的结构图: 2.连接数据库文件配置分离: 一般的程序都会把连接数据库的配置单独放在.properties 文件中,然后在XML文件中引用,示例如下: config.properties: driver=oracle.jdbc.OracleDriver url=jdbc:oracle:thin:@127.0.0.1:1521:orcl username=pho

MyBatis之二：简单增删改查

这一篇在上一篇的基础上简单讲解如何进行增删改查操作. 一.在mybatis的配置文件conf.xml中注册xml与注解映射 <!-- 注册映射文件 --> <mappers> <!-- 通过xml方式映射 --> <mapper resource="com/mybatis/crud/userMapper.xml" /> <!-- 通过注解方式映射 --> <mapper class="com.mybatis.c