设为首页收藏本站
开启辅助访问

在路上

 找回密码
 立即注册
在路上 › 站点首页 ›学习 › 查看内容

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

2016-7-29 15:41| 发布者: zhangjf| 查看: 635| 评论: 0

摘要: 以接口操作的方式编程 一般来讲，我们建立映射SQL接口的类时通常会这样： public static void testBasicQuery(int id) { SqlSession session = MybatisUtils.getSqlSession(); try { /* * 此处的 ...

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

  2. public static void testBasicQuery(int id) {
  3. SqlSession session = MybatisUtils.getSqlSession();
  4. try {
  5. /*
  6. * 此处的david.mybatis.demo.IVisitorOperation.basicQuery必须和下图中配置里面的namespace对应
  7. */
  8. Visitor visitor = (Visitor) session.selectOne("david.mybatis.demo.IVisitorOperation.basicQuery", id);
  9. MybatisUtils.closeSession(session);
  10. System.out.println(visitor);
  11. } catch (Exception e) {
  12. // TODO: handle exception
  13. }
  14. }
复制代码
  2. <!-- 此处namespace对应的就是你所传的String参数 -->
  3. <mapper namespace="david.mybatis.demo.IVisitorOperation">
  4. <!-- 此处的resultType就是对应刚刚你在typeAlias节点里面规定的别名 -->
  5. <select id="basicQuery" parameterType="int" resultType="Visitor">
  6. select * from visitor where id=#{id} and
  7. Status>0 order by Id
  8. </select>
  9. </mapper>
复制代码

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

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

  2. package david.mybatis.demo;
  4. import java.util.List;
  6. import david.mybatis.model.PagenateArgs;
  7. import david.mybatis.model.Visitor;
  9. public interface IVisitorOperation {
  10. /*
  11. * 基础查询
  12. */
  13. public Visitor basicQuery(int id);
  14. }
  16. public static void testBasicQueryByInterfaceWay(int id) {
  17. SqlSession session = MybatisUtils.getSqlSession();
  18. try {
  19. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  20. Visitor visitor = vOperation.basicQuery(id);
  21. MybatisUtils.closeSession(session);
  22. System.out.println(visitor);
  23. } catch (Exception e) {
  24. // TODO: handle exception
  25. }
  26. }
复制代码

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

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

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

  2. /*
  3. * 基础查询
  4. */
  5. public Visitor basicQuery(int id);
  7. /*
  8. * 添加访问者
  9. */
  10. public int add(Visitor visitor);
  12. /*
  13. * 删除访问者
  14. */
  15. public int delete(int id);
  17. /*
  18. * 更新访问者
  19. */
  20. public int update(Visitor visitor);
  22. /*
  23. * 查询访问者
  24. */
  25. public Visitor query(int id);
  27. /*
  28. * 查询访问者List
  29. */
  30. public List<Visitor> 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'。

  2. <?xml version="1.0" encoding="UTF-8"?>
  3. <!DOCTYPE mapper
  4. PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  5. "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  6. <mapper namespace="david.mybatis.demo.IVisitorOperation">
  7. <!--
  8. useGeneratedKeys="true"代表是否使用自增长序列,
  9. keyProperty="Id"指定自增长列是哪一列,
  10. parameterType="Visitor"指定IVisitorOperation接口类中定义中所传的相应类型
  11. resultType 表示返回的类型，例如query中的visitor
  12. resultMap 自定义的返回类型，是返回复杂类型是的最佳首选，也是mybatis里最强大的武器
  13. -->
  14. <insert id="add" parameterType="Visitor" useGeneratedKeys="true"
  15. keyProperty="Id">
  16. insert into Visitor (Name, Email, Status, CreateTime)
  17. values (#{name}, #{email}, #{status}, #{createTime})
  18. </insert>
  19. <delete id="delete" parameterType="int">
  20. delete from Visitor where
  21. status>0 and id = #{id}
  22. </delete>
  23. <update id="update" parameterType="Visitor">
  24. update Visitor set Name =
  25. #{name}, Email=#{email}, Status=#{status} where id=#{id} and Status>0;
  26. </update>
  27. <select id="query" parameterType="int" resultType="Visitor">
  28. select Id,
  29. Name, Email, Status, CreateTime from visitor where id=#{id} and
  30. Status>0 order by Id
  31. </select>
  32. <select id="basicQuery" parameterType="int" resultType="Visitor">
  33. select * from visitor where id=#{id} and
  34. Status>0 order by Id
  35. </select>
  36. <select id="getList" resultMap="visitorRs">
  37. <include refid="getListSql" />
  38. </select>
  39. <resultMap type="Visitor" id="visitorRs">
  40. <id column="Id" property="id" />
  41. <result column="Name" property="name" />
  42. <result column="Email" property="email" />
  43. <result column="Status" property="status" />
  44. <result column="CreateTime" property="createTime" />
  45. </resultMap>
  46. <sql id="getListSql">
  47. select * from Visitor where
  48. status>0
  49. </sql>
  50. </mapper>
复制代码

此处注意的一点是：操作节点中的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中的驼峰命名方式配置如下。

  2. <settings>
  3. <setting name="mapUnderscoreToCamelCase" value="false" />
  4. </settings>
复制代码

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

  2. <mapper namespace="david.mybatis.demo.IVisitorOperation">
  3. <sql id="getListSql">
  4. select id as visitor_id, name, email, status, createtime from Visitor where
  5. status>0
  6. </sql>
  7. <select id="getList" resultMap="visitorRs">
  8. <include refid="getListSql" />
  9. </select>
  10. <!--
  11. 这里指的注意的地方是property属性，里面的字段一定要和你在实体里面定义的属性一样，此处区分大小写
  12. 否则会出现默认setter为属性赋值的时候找不到相应属性的异常，大家可以试下
  13. column属性对应于查询语句返回结果集的名字，如果有为相应字段起过别名例如吧id变为了visitor_id
  14. 那么相应的column名字也要对应上
  15. -->
  16. <resultMap type="Visitor" id="visitorRs">
  17. <id column="visitor_id" property="id" />
  18. <result column="Name" property="name" />
  19. <result column="Email" property="email" />
  20. <result column="Status" property="status" />
  21. <result column="CreateTime" property="createTime" />
  22. </resultMap>
  23. </mapper>
复制代码

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

  2. package david.mybatis.demo;
  4. import java.util.Arrays;
  5. import java.util.List;
  6. import org.apache.ibatis.session.SqlSession;
  7. import david.mybatis.model.BasicQueryArgs;
  8. import david.mybatis.model.CRUD_Enum;
  9. import david.mybatis.model.Channel;
  10. import david.mybatis.model.PagenateArgs;
  11. import david.mybatis.model.Visitor;
  12. import david.mybatis.model.Website;
  14. public class DemoRun {
  16. public static void testBasicQuery(int id) {
  17. SqlSession session = MybatisUtils.getSqlSession();
  18. try {
  19. /*
  20. * 此处的david.mybatis.demo.IVisitorOperation.basicQuery必须和下图中配置里面的namespace对应
  21. */
  22. Visitor visitor = (Visitor) session.selectOne("david.mybatis.demo.IVisitorOperation.basicQuery", id);
  23. MybatisUtils.closeSession(session);
  24. System.out.println(visitor);
  25. } catch (Exception e) {
  26. // TODO: handle exception
  27. e.printStackTrace();
  28. }
  29. }
  31. public static void testBasicQueryByInterfaceWay(int id) {
  32. SqlSession session = MybatisUtils.getSqlSession();
  33. try {
  34. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  35. Visitor visitor = vOperation.basicQuery(id);
  36. MybatisUtils.closeSession(session);
  37. System.out.println(visitor);
  38. } catch (Exception e) {
  39. // TODO: handle exception
  40. e.printStackTrace();
  41. }
  42. }
  44. /*
  45. * 批量添加访问者记录
  46. */
  47. public static void addVisitors() {
  48. SqlSession session = MybatisUtils.getSqlSession();
  49. List<Visitor> visitors = Arrays.asList(new Visitor[] { new Visitor("mongodb", "mongodb@gmail.com"),
  50. new Visitor("redis", "redis@gmail.com"), new Visitor("memcached", "memcached@gmail.com"),
  51. new Visitor("CouchDB", "CouchDB@gmail.com"), new Visitor("HBase", "HBase@gmail.com"),
  52. new Visitor("Bigtable", "Bigtable@gmail.com"), new Visitor("Hive", "Hive@gmail.com"),
  53. new Visitor("MapReduce", "MapReduce@gmail.com"), });
  55. for (Visitor visitor : visitors) {
  56. addVisitor(visitor, session);
  57. }
  58. MybatisUtils.closeSession(session);
  59. MybatisUtils.showMessages(CRUD_Enum.List, visitors.size());
  60. }
  62. /*
  63. * 添加访问者信息
  64. */
  65. @SuppressWarnings("unused")
  66. private static void addVisitor(Visitor visitor, SqlSession session) {
  67. if (session == null)
  68. session = MybatisUtils.getSqlSession();
  69. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  70. int recordCount = vOperation.add(visitor);
  71. session.commit();
  72. if (session == null)
  73. MybatisUtils.closeSession(session);
  74. MybatisUtils.showMessages(CRUD_Enum.Add, recordCount);
  75. }
  77. /*
  78. * 重载添加访问者
  79. */
  80. public static void addVisitor(Visitor visitor) {
  81. addVisitor(visitor, null);
  82. }
  84. /*
  85. * 删除访问者信息
  86. */
  87. public static void deleteVisitor(int id) {
  88. SqlSession session = MybatisUtils.getSqlSession();
  89. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  90. int recordCount = vOperation.delete(id);
  91. session.commit();
  92. MybatisUtils.closeSession(session);
  93. MybatisUtils.showMessages(CRUD_Enum.Delete, recordCount);
  94. }
  96. /*
  97. * 更新访问者信息
  98. */
  99. public static void updateVisitor(int id) {
  100. SqlSession session = MybatisUtils.getSqlSession();
  101. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  102. Visitor visitor = vOperation.query(id);
  103. System.out.println("原始对象：" + visitor);
  104. String name = visitor.getName();
  105. if (name.contains("updated")) {
  106. visitor.setName(name.substring(0, name.indexOf("updated")));
  107. } else {
  108. visitor.setName(name + "updated");
  109. }
  110. int recordCount = vOperation.update(visitor);
  111. session.commit();
  112. MybatisUtils.closeSession(session);
  113. MybatisUtils.showMessages(CRUD_Enum.Update, recordCount);
  114. System.out.println("更新后对象：" + visitor);
  115. }
  117. /*
  118. * 查询访问者信息
  119. */
  120. public static void queryVisitor(int id) {
  121. SqlSession session = MybatisUtils.getSqlSession();
  122. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  123. Visitor visitor = vOperation.query(id);
  124. MybatisUtils.closeSession(session);
  125. MybatisUtils.showMessages(CRUD_Enum.Query, 1);
  126. System.out.println(visitor);
  127. }
  129. /*
  130. * 查询访问者列表
  131. */
  132. public static void queryVisitorList() {
  133. SqlSession session = MybatisUtils.getSqlSession();
  134. IVisitorOperation vOperation = session.getMapper(IVisitorOperation.class);
  135. List<Visitor> visitors = vOperation.getList();
  136. for (Visitor visitor : visitors) {
  137. System.out.println(visitor);
  138. }
  139. MybatisUtils.closeSession(session);
  140. MybatisUtils.showMessages(CRUD_Enum.List, visitors.size());
  141. }
  142. }
复制代码

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

201646145447423.png (741×644)

收藏 邀请
上一篇：详解DES加密算法及在Java程序中的使用示例下一篇：Java的MyBatis框架中对数据库进行动态SQL查询的教程

最新评论

相关分类

小黑屋|在路上 ( 蜀ICP备15035742号-1 )  

;

GMT+8, 2025-5-6 09:24

Copyright 2015-2025 djqfx

返回顶部