Mybatis mapper代理开发方法实现增删改查

avatar 2017年08月11日16:59:53 1 3375 views
博主分享免费Java教学视频，B站账号：Java刘哥
接着上一篇文章：Mybatis原生dao开发方法实现增删改查 写

思路

程序员编写 mapper 接口的时候，要遵循一些开发规范，Mybatis 可以自动生成 mapper 接口实现类代理对象。 开发规范： 1、在 mapper.xml 中 namespace 等于 mapper 接口地址   2、mapper.java 接口中的方法名和 mapper.xml 和 statement 的 id 一致   3、mapper.java 接口中方法输入参数类型 和 mapper.xml 中 statement 的parameterType 指定的类型一致   4、mapper.java 接口中方法返回值类型和 mapper.xml 中的 statement 的 resultType 指定的类型一致   总结： 以上规范主要是对下边的代码进行统一生成
  1. User user = sqlSession.selectOne("test.findUserById",2);
  2. List<User> list = sqlSession.selectList("test.findUserByName",username);
  3. sqlSession.insert("test.insertUser",user);
  4. sqlSession.delete("test.deleteUserById",id);
  5. sqlSession.update("test.updateUserById",user);
 

项目准备

同上篇文章基本相同 1、项目结构 ① 新建 Java 项目 ② 在 src 下新建 com.liuyanzhao.mybatis.po 包（用来放持久化类，和数据库对应） 和 com.liuyanzhao.mybatis.mapper 包 （用来放 CURD 实现代码） ③ 在 src 下新建（或者拷贝）Configuration.xml （mybatis全局配置文件）和 UserMapper.xml （映射文件）   2、导入 两个必备的 jar 包
  • mysql-jdbc 驱动包： mysql-connector-java-5.1.41-bin.jar
  • mybatis 包：mybatis-3.4.4.jar
在项目中新建一个 lib 目录，将两个包拷贝到 lib 中，然后将两个包加入环境（build path）中   3、新建数据库和数据表 我这里在本地测试，主机 localhost，数据库用户名root，密码为空 ① 新建数据库：mybatis ② 新建数据表：user表 表结构如下，五个字段（id,username,gender,birthday,address） Mybatis原生dao开发方法实现增删改查  

代码实现

1、Configuration.xml   Mybatis 全局配置文件
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration
  3.     PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  4.     "http://mybatis.org/dtd/mybatis-3-config.dtd">
  6. <configuration>
  8.   <!-- 和Spring整合后，environments配置将废除-->
  9.   <environments default="development">
  10.     <environment id="development">
  11.       <!--使用JDBC事务管理，事务控制由mybatis-->
  12.       <transactionManager type="JDBC">
  13.         <property name="" value=""/>
  14.       </transactionManager>
  15.       <!--数据库连接池-->
  16.       <dataSource type="UNPOOLED">
  17.         <property name="driver" value="com.mysql.jdbc.Driver"/>
  18.         <property name="url" value="jdbc:mysql://localhost:3306/mybatis?useUnicode=true&amp;characterEncoding=utf8"/>
  19.         <property name="username" value="root"/>
  20.         <property name="password" value=""/>
  21.       </dataSource>
  22.     </environment>
  23.   </environments>
  25.   <!--加载映射文件-->
  26.   <mappers>
  27.     <mapper resource="UserMapper.xml" />
  28.   </mappers>
  30. </configuration>
记得添加 映射文件   2、UserMapper.xml
  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  6. <!--namespace命名空间，作用是对sql进行分类话管理，理解sql，理解sql隔离
  7.     注意：使用mapper代理方法开发，namespace有着特殊的作用
  8. -->
  11. <mapper namespace="com.liuyanzhao.mybatis.mapper.UserMapper">
  13.     <!--在映射文件中配置很多sql语句-->
  14.     <!--
  15.     id：表示映射文件中的sql
  16.     将sql语句封装到mappedStatement对象中，所以称id为Statement的id
  17.     parameterType:指定输入参数的类型
  18.     resultType:指定就是单条记录所映射的java对象类型
  19.     #{}表示占位符，相当于?
  20.     #{id} 其中id表示接受输入的参数，参数名就是id，如果输入的参数是简单类型，#{}中的参数可以任意，可以value或者其他名称
  21.     ${}：表示拼接sql串，将接受到的参数的内容不加任何修饰直接拼接在sql中
  22.     ${}安全隐患：使用${}拼接sql，引起sql注入
  23.     ${value}:接受输入参数的内容，如果传入类型是简单类型，${}中只有使用value
  25.     -->
  26.     <select id="findUserById" parameterType="int" resultType="com.liuyanzhao.mybatis.po.User">
  27.         SELECT * FROM user WHERE id=#{value}
  28.     </select>
  30.     <!--根据用户名称模糊查询,可能返回多条-->
  31.     <select id="findUserByName" parameterType="java.lang.String" resultType="com.liuyanzhao.mybatis.po.User">
  32.         SELECT * FROM user WHERE username LIKE '%${value}%'
  33.     </select>
  36.     <!--#{}指定pojo的属性名，接收到pojo对象的属性值，Mybatis通过OGNL获取对象的属性值-->
  37.     <!--添加用户-->
  38.     <insert id="insertUser" parameterType="com.liuyanzhao.mybatis.po.User">
  40.      <!--
  41.         将插入数据的主键返回，返回到user对象中
  42.         SELECT LAST_INSERT_ID(); 得到insert进去的主键值，只适用自增主键
  43.     -->
  44.         <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
  45.             SELECT LAST_INSERT_ID()
  46.         </selectKey>
  47.         INSERT INTO user(username,birthday,gender,address) VALUE(#{username},#{birthday},#{gender},#{address})
  48.     </insert>
  50.     <!--删除用户,根据id-->
  51.     <delete id="deleteUserById" parameterType="java.lang.Integer">
  52.         DELETE FROM user WHERE id=#{id}
  53.     </delete>
  55.     <!--更新用户,根据id
  56.     需要传入用户信息
  57.     parameterType指定user对象，包括id和更新信息。注意：id必须存在
  58.     #{id}:从输入的user对象中获取id的属性值
  60.     -->
  61.     <update id="updateUserById" parameterType="com.liuyanzhao.mybatis.po.User">
  62.         UPDATE user SET username=#{username},birthday=#{birthday},gender=#{gender},address=#{address} WHERE id=#{id}
  63.     </update>
  65. </mapper>
修改 namespace 的值，其他的不变   3、UserMapper.java
  1. package com.liuyanzhao.mybatis.mapper;
  3. import com.liuyanzhao.mybatis.po.User;
  5. import java.util.List;
  7. /**
  8.  * Created by Liu_Yanzhao on 2017/8/10.
  9.  */
  10. public interface UserMapper {
  11.     //根据id查询用户信息
  12.     public User findUserById(int id) throws Exception;
  14.     //根据username模糊查询用户信息
  15.     public List<User> findUserByName(String name) throws Exception;
  17.     //添加用户信息
  18.     public void insertUser(User user) throws Exception;
  20.     //删除用户信息
  21.     public void deleteUserById(int id) throws Exception;
  23.     //更新用户信息
  24.     public void updateUserById(User user) throws  Exception;
  26. }
和 UserDao.java 代码一样   4、测试类 UserMapper.java
  1. package com.liuyanzhao.mybatis.test;
  3. import com.liuyanzhao.mybatis.mapper.UserMapper;
  4. import com.liuyanzhao.mybatis.po.User;
  5. import org.apache.ibatis.io.Resources;
  6. import org.apache.ibatis.session.SqlSession;
  7. import org.apache.ibatis.session.SqlSessionFactory;
  8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  9. import org.junit.Before;
  10. import org.junit.Test;
  12. import java.io.InputStream;
  13. import java.util.Date;
  14. import java.util.List;
  16. /**
  17.  * Created by 言曌 on 2017/8/10.
  18.  */
  19. public class UserMapperImplTest {
  21.     private SqlSessionFactory sqlSessionFactory;
  23.     @Before
  24.     public void setUp() throws Exception {
  25.         String resource = "Configuration.xml";
  26.         InputStream inputStream = Resources.getResourceAsStream(resource);
  27.         sqlSessionFactory = new SqlSessionFactoryBuilder()
  28.             .build(inputStream);
  29.     }
  31.     //测试 根据id查询用户
  32.     @Test
  33.     public void testFindUserById() throws Exception {
  34.         SqlSession sqlSession = sqlSessionFactory.openSession();
  35.         //创建UserMapper对象,mybatis自动生成mapper代理对象
  36.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  37.         //调用userMapper方法
  38.         User user = userMapper.findUserById(6);
  39.         System.out.println(user);
  40.     }
  42.     //测试 根据username查询用户
  43.     @Test
  44.     public void testFindUserByName() throws Exception {
  45.         SqlSession sqlSession = sqlSessionFactory.openSession();
  46.         //创建UserMapper对象，mybatis自动生成mapper代理对象
  47.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  48.         //调用usermapper对象
  49.         List<User> list = userMapper.findUserByName("明");
  50.         System.out.println(list);
  51.     }
  53.     //添加用户信息
  54.     @Test
  55.     public void testInsertUser() throws Exception {
  56.         SqlSession sqlSession = sqlSessionFactory.openSession();
  57.         //获得UserMapper对象
  58.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  59.         //创建对象，存储信息
  60.         User user = new User();
  61.         //
  62.         user.setUsername("李小成");
  63.         user.setGender("男");
  64.         user.setBirthday(new Date());
  65.         user.setAddress("陕西榆林");
  66.         userMapper.insertUser(user);
  67.         sqlSession.commit();
  68.     }
  71.     //测试，根据id删除用户
  72.     @Test
  73.     public void testDeleteUserById() throws Exception {
  74.         SqlSession sqlSession = sqlSessionFactory.openSession();
  75.         //获得UserMapper对象
  76.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  77.         //删除操作
  78.         userMapper.deleteUserById(1);
  79.         //提交事务
  80.         sqlSession.commit();
  81.     }
  83.     //测试，根据id更新用户
  84.     @Test
  85.     public void testUpdateUserById() throws Exception {
  86.         SqlSession sqlSession = sqlSessionFactory.openSession();
  87.         //获得UserMapper对象
  88.         UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
  89.         //创建对象，存储信息
  90.         User user = new User();
  91.         user.setId(2);
  92.         user.setUsername("岳小飞");
  93.         user.setGender("男");
  94.         user.setBirthday(new Date());
  95.         user.setAddress("河南安阳");
  96.         //更新用户
  97.         userMapper.updateUserById(user);
  98.         //提交事务
  99.         sqlSession.commit();
  100.     }
  102. }
  本文链接：https://liuyanzhao.com/5789.html  
历史上的今天
八月
11日
  • 微信
  • 交流学习，有偿服务
  • weinxin
  • 博客/Java交流群
  • 资源分享，问题解决，技术交流。群号：590480292
  • weinxin
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0