在Java的MyBatis框架中建立接口进行CRUD操作的方法

作者：mobiledu2402851173 | 2022-10-27 16:02

这篇文章主要介绍了在Java的MyBatis框架中建立接口进行CRUD操作的方法,CRUD是指在做计算处理时的增加(Create)、重新取得数据(Retrieve)、更新(Update)和删除(Delete)几个单词的首字母简写,需要的朋友可以参考下

以接口操作的方式编程
一般来讲，我们建立映射SQL接口的类时通常会这样：

 public static void testBasicQuery(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    try {
      /*
       * 此处的david.mybatis.demo.IVisitorOperation.basicQuery必须和下图中配置里面的namespace对应
       */
      Visitor visitor = (Visitor) session.selectOne("david.mybatis.demo.IVisitorOperation.basicQuery", id);
      MybatisUtils.closeSession(session);
      System.out.println(visitor);
    } catch (Exception e) {
      // TODO: handle exception
    }
  }

这样其实在真正的开发过程中如果两边的名字一不小心没有对应上，就会出现异常。为了避免这样的情况我们可以采取接口的方式来进行相应的操作，下面我们来修改这段东西。

首先我们在包名为david.mybatis.demo的下面新建一个IVisitOperation类，表示今后将要操作数据库所有方法的接口，如下所示：

package david.mybatis.demo;

import java.util.List;

import david.mybatis.model.PagenateArgs;
import david.mybatis.model.Visitor;

public interface IVisitorOperation {  
  /*
   * 基础查询
   */
  public Visitor basicQuery(int id);
}

  public static void testBasicQueryByInterfaceWay(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    try {
      IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
      Visitor visitor = vOperation.basicQuery(id);
      MybatisUtils.closeSession(session);
      System.out.println(visitor);
    } catch (Exception e) {
      // TODO: handle exception
    }
  }

这样就大功告成了，这样我们就不必为手动书写方法名可能导致的不匹配而烦恼了。

CRUD操作
下面将讲解创建基于单表操作的CRUD与GetList操作，为了创建一点测试数据我们先弄个Add方法吧

继续在上次的IVisitorOperation接口类中添加add，delete，update，query与getList接口方法，如下所示：

  /*
   * 基础查询
   */
  public Visitor basicQuery(int id);

  /*
   * 添加访问者
   */
  public int add(Visitor visitor);
  
  /*
   * 删除访问者
   */
  public int delete(int id);
  
  /*
   * 更新访问者
   */
  public int update(Visitor visitor);
  
  /*
   * 查询访问者
   */
  public Visitor query(int id);
  
  /*
   * 查询访问者List
   */
  public List getList();

对于相应的CRUD操作，在VisitorMapper.xml的节点下分别对应insert，update，delete，select节点，具体配置详情参数说明课参照官网 http://mybatis.github.io/mybatis-3/sqlmap-xml.html
这个示例中要的配置如下，传递的参数用#{parameter_name}，当然也可直接用${parameter_name}，

前者的方式，Mybatis会把它转化为参数化的形式例如 insert into table (name) values (#{name}) => insert into table (name) values ( ? ) (Mysql情况下)

后者的方式，Mybatis会原封不动的不做任何操作把参数传过来，例如 insert into table (name) values (${name}) => insert into table (name) values ( [你所传的值] )，传aa，这里就是aa，传'aa'这里就是'aa'。

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


  
  
    insert into Visitor (Name, Email, Status, CreateTime)
    values (#{name}, #{email}, #{status}, #{createTime})
  
  
    delete from Visitor where
    status>0 and id = #{id}
  
  
    update Visitor set Name =
    #{name}, Email=#{email}, Status=#{status} where id=#{id} and Status>0;
  
  
  
  
  
    
    
    
    
    
  
  
    select * from Visitor where
    status>0

此处注意的一点是：操作节点中的ID要对应接口定义中的接口名字,参数类型也要相应对应，例如接口里是add（Visitor visitor），那么在配置insert节点的时候id="add"，parameterType="Visitor"

否则会报相应的异常，例如id节点不对应接口名称会出现如下异常：

201646145316272.png (1228×153)

大家可以注意到在VisitorMapper.xml这个配置文件中在获取list的时候，使用的是resultMap，使用resultMap的情况下你可以指定你自己的sql语句与哪些字段相映射，因为有时候你可以不需要那么多列，那你在配置映射的时候也不需要配置那么多映射，或者说你的列有起过别名，那么就不能直接使用resultType="Visitor"的方式进行映射，因为Mybatis默认映射方式是通过Javabean的属性名与表的字段是否一致来匹配的，也可以通过配置节点下的属性值来控制是否映射的时候以Javabean中的驼峰命名方式配置如下。

具体其他修改Mapper的其他配置可以通过 http://mybatis.github.io/mybatis-3/configuration.html#settings 查看。
对于Visitor的Mapper类如下：


  
    select id as visitor_id, name, email, status, createtime from Visitor where
    status>0

这里要大家还会注意到有一个节点节点，这个的用处就是提取公用的sql语句或者说字段，以便其他地方复用，其他详细说明用法可以参照 http://mybatis.github.io/mybatis-3/sqlmap-xml.html。
剩下的就是和刚刚一样的操作了，大家可以在demo程序里建立一个DemoRun的类存放各类测试方法，如下：

package david.mybatis.demo;

import java.util.Arrays;
import java.util.List;
import org.apache.ibatis.session.SqlSession;
import david.mybatis.model.BasicQueryArgs;
import david.mybatis.model.CRUD_Enum;
import david.mybatis.model.Channel;
import david.mybatis.model.PagenateArgs;
import david.mybatis.model.Visitor;
import david.mybatis.model.Website;

public class DemoRun {

  public static void testBasicQuery(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    try {
      /*
       * 此处的david.mybatis.demo.IVisitorOperation.basicQuery必须和下图中配置里面的namespace对应
       */
      Visitor visitor = (Visitor) session.selectOne("david.mybatis.demo.IVisitorOperation.basicQuery", id);
      MybatisUtils.closeSession(session);
      System.out.println(visitor);
    } catch (Exception e) {
      // TODO: handle exception
      e.printStackTrace();
    }
  }
  
  public static void testBasicQueryByInterfaceWay(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    try {
      IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
      Visitor visitor = vOperation.basicQuery(id);
      MybatisUtils.closeSession(session);
      System.out.println(visitor);
    } catch (Exception e) {
      // TODO: handle exception
      e.printStackTrace();
    }
  }

  /*
   * 批量添加访问者记录
   */
  public static void addVisitors() {
    SqlSession session = MybatisUtils.getSqlSession();
    List visitors = Arrays.asList(new Visitor[] { new Visitor("mongodb", "mongodb@gmail.com"),
        new Visitor("redis", "redis@gmail.com"), new Visitor("memcached", "memcached@gmail.com"),
        new Visitor("CouchDB", "CouchDB@gmail.com"), new Visitor("HBase", "HBase@gmail.com"),
        new Visitor("Bigtable", "Bigtable@gmail.com"), new Visitor("Hive", "Hive@gmail.com"),
        new Visitor("MapReduce", "MapReduce@gmail.com"), });

    for (Visitor visitor : visitors) {
      addVisitor(visitor, session);
    }
    MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.List, visitors.size());
  }

  /*
   * 添加访问者信息
   */
  @SuppressWarnings("unused")
  private static void addVisitor(Visitor visitor, SqlSession session) {
    if (session == null)
      session = MybatisUtils.getSqlSession();
    IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
    int recordCount = vOperation.add(visitor);
    session.commit();
    if (session == null)
      MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.Add, recordCount);
  }

  /*
   * 重载添加访问者
   */
  public static void addVisitor(Visitor visitor) {
    addVisitor(visitor, null);
  }

  /*
   * 删除访问者信息
   */
  public static void deleteVisitor(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
    int recordCount = vOperation.delete(id);
    session.commit();
    MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.Delete, recordCount);
  }

  /*
   * 更新访问者信息
   */
  public static void updateVisitor(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
    Visitor visitor = vOperation.query(id);
    System.out.println("原始对象：" + visitor);
    String name = visitor.getName();
    if (name.contains("updated")) {
      visitor.setName(name.substring(0, name.indexOf("updated")));
    } else {
      visitor.setName(name + "updated");
    }
    int recordCount = vOperation.update(visitor);
    session.commit();
    MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.Update, recordCount);
    System.out.println("更新后对象：" + visitor);
  }

  /*
   * 查询访问者信息
   */
  public static void queryVisitor(int id) {
    SqlSession session = MybatisUtils.getSqlSession();
    IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
    Visitor visitor = vOperation.query(id);
    MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.Query, 1);
    System.out.println(visitor);
  }

  /*
   * 查询访问者列表
   */
  public static void queryVisitorList() {
    SqlSession session = MybatisUtils.getSqlSession();
    IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
    List visitors = vOperation.getList();
    for (Visitor visitor : visitors) {
      System.out.println(visitor);
    }
    MybatisUtils.closeSession(session);
    MybatisUtils.showMessages(CRUD_Enum.List, visitors.size());
  }  
}

DemoRun类
运行一下后一个简单的基于单表CRUD，DEMO就完成啦

201646145447423.png (741×644)

推荐阅读

程序员
Appinvite_styles.xml:5:错误将Google Play服务库包含在eclipse中

如何解决《Appinvite_styles.xml:5:错误将GooglePlay服务库包含在eclipse中》经验，为你挑选了0个好方法。 ... [详细]
程序员
Tensorflow教程:输入管道中的重复混洗

如何解决《Tensorflow教程:输入管道中的重复混洗》经验，为你挑选了1个好方法。 ... [详细]
程序员
g ++和clang ++ - 删除由重载转换运算符歧义获取的指针

如何解决《g++和clang++-删除由重载转换运算符歧义获取的指针》经验，为你挑选了1个好方法。 ... [详细]
程序员
django,属性更新模型实例

如何解决《django,属性更新模型实例》经验，为你挑选了0个好方法。 ... [详细]
程序员
使用JavaScript进行多项左手分配,真的是正确的关联吗？

如何解决《使用JavaScript进行多项左手分配,真的是正确的关联吗？》经验，为你挑选了2个好方法。 ... [详细]
程序员
在Rails中为link_to方法发送特定变量值

如何解决《在Rails中为link_to方法发送特定变量值》经验，为你挑选了1个好方法。 ... [详细]
程序员
如何区分火花中的操作是转换还是动作？

如何解决《如何区分火花中的操作是转换还是动作？》经验，为你挑选了1个好方法。 ... [详细]
程序员
企业服务总线与BPM

如何解决《企业服务总线与BPM》经验，为你挑选了1个好方法。 ... [详细]
程序员
RStudio shiny runApp在工作目录中失败

如何解决《RStudioshinyrunApp在工作目录中失败》经验，为你挑选了1个好方法。 ... [详细]
程序员
AsyncStorage数据在Android设备上的物理位置在哪里？

如何解决《AsyncStorage数据在Android设备上的物理位置在哪里？》经验，为你挑选了2个好方法。 ... [详细]
程序员
Android.mk应该在哪里？

如何解决《Android.mk应该在哪里？》经验，为你挑选了0个好方法。 ... [详细]
程序员
为SSL配置SSRS

如何解决《为SSL配置SSRS》经验，为你挑选了1个好方法。 ... [详细]
程序员
查找表 - 自然或代理键作为主键？

如何解决《查找表-自然或代理键作为主键？》经验，为你挑选了1个好方法。 ... [详细]
程序员
ATMEGA168A-F_CPU警告

如何解决《ATMEGA168A-F_CPU警告》经验，为你挑选了1个好方法。 ... [详细]
程序员
使用F#在类/接口中动态定义多个成员

如何解决《使用F#在类/接口中动态定义多个成员》经验，为你挑选了1个好方法。 ... [详细]
程序员
如何重新启动pyqt应用程序？

如何解决《如何重新启动pyqt应用程序？》经验，为你挑选了1个好方法。 ... [详细]
程序员
代码合同.net - 替代品

如何解决《代码合同.net-替代品》经验，为你挑选了1个好方法。 ... [详细]
程序员
从std :: enable_shared_from_this和抽象基类派生是否可以？

如何解决《从std::enable_shared_from_this和抽象基类派生是否可以？》经验，为你挑选了0个好方法。 ... [详细]
程序员
不能在Rust文档测试中使用依赖包

如何解决《不能在Rust文档测试中使用依赖包》经验，为你挑选了1个好方法。 ... [详细]
程序员
只有在Symfony 2.8中进行单元测试时,Service Class中的Twig_Environment才会导致DIC RuntimeExtension

如何解决《只有在Symfony2.8中进行单元测试时,ServiceClass中的Twig_Environment才会导致DICRuntimeExtension》经验，为你挑选了1个好方法。 ... [详细]

mobiledu2402851173

这个屌丝很懒，什么也没留下！

关注作者

Tags | 热门标签

RankList | 热门文章