Mybatis原生dao开发方法实现增删改查

avatar 2017年08月11日15:08:01 1 3240 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此

思路


程序员需要写 dao 接口和 dao 实现类

需要向 dao 实现类中注入 SqlSessionFactory，在方法体内通过 SqlSessionFactory


项目准备


1、项目结构

① 新建 Java 项目

② 在 src 下新建 com.liuyanzhao.mybatis.po 包（用来放持久化类，和数据库对应）

和 com.liuyanzhao.mybatis.dao 包 （用来放 CURD 实现代码）

③ 在 src 下新建（或者拷贝）Configuration.xml （mybatis全局配置文件）和 userDao.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实现简单的增删改查


代码实现


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="userDao.xml" />
  28.   </mappers>
  30. </configuration>



2、userDao.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="test">
  12.     <!--在映射文件中配置很多sql语句-->
  13.     <!--
  14.     id：表示映射文件中的sql
  15.     将sql语句封装到mappedStatement对象中，所以称id为Statement的id
  16.     parameterType:指定输入参数的类型
  17.     resultType:指定就是单条记录所映射的java对象类型
  18.     #{}表示占位符，相当于?
  19.     #{id} 其中id表示接受输入的参数，参数名就是id，如果输入的参数是简单类型，#{}中的参数可以任意，可以value或者其他名称
  20.     ${}：表示拼接sql串，将接受到的参数的内容不加任何修饰直接拼接在sql中
  21.     ${}安全隐患：使用${}拼接sql，引起sql注入
  22.     ${value}:接受输入参数的内容，如果传入类型是简单类型，${}中只有使用value
  24.     -->
  25.     <select id="findUserById" parameterType="int" resultType="com.liuyanzhao.mybatis.po.User">
  26.         SELECT * FROM user WHERE id=#{value}
  27.     </select>
  29.     <!--根据用户名称模糊查询,可能返回多条-->
  30.     <select id="findUserByName" parameterType="java.lang.String" resultType="com.liuyanzhao.mybatis.po.User">
  31.         SELECT * FROM user WHERE username LIKE '%${value}%'
  32.     </select>
  35.     <!--#{}指定pojo的属性名，接收到pojo对象的属性值，Mybatis通过OGNL获取对象的属性值-->
  36.     <!--添加用户-->
  37.     <insert id="insertUser" parameterType="com.liuyanzhao.mybatis.po.User">
  39.      <!--
  40.         将插入数据的主键返回，返回到user对象中
  41.         SELECT LAST_INSERT_ID(); 得到insert进去的主键值，只适用自增主键
  42.     -->
  43.         <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
  44.             SELECT LAST_INSERT_ID()
  45.         </selectKey>
  46.         INSERT INTO user(username,birthday,gender,address) VALUE(#{username},#{birthday},#{gender},#{address})
  47.     </insert>
  49.     <!--删除用户,根据id-->
  50.     <delete id="deleteUserById" parameterType="java.lang.Integer">
  51.         DELETE FROM user WHERE id=#{id}
  52.     </delete>
  54.     <!--更新用户,根据id
  55.     需要传入用户信息
  56.     parameterType指定user对象，包括id和更新信息。注意：id必须存在
  57.     #{id}:从输入的user对象中获取id的属性值
  59.     -->
  60.     <update id="updateUserById" parameterType="com.liuyanzhao.mybatis.po.User">
  61.         UPDATE user SET username=#{username},birthday=#{birthday},gender=#{gender},address=#{address} WHERE id=#{id}
  62.     </update>
  64. </mapper>



3、UserDao.java   dao接口
  1. package com.liuyanzhao.mybatis.dao;
  3. import com.liuyanzhao.mybatis.po.User;
  5. import java.util.List;
  7. /**
  8.  * Created by 言曌 on 2017/8/10.
  9.  */
  10. public interface UserDao {
  11.     //根据id查询用户信息
  12.     public User findUserById(int id) throws Exception;
  14.     //根据username查询用户信息
  15.     public List<User> findUserByName(String username) throws Exception;
  17.     //添加用户信息
  18.     public void insertUser(User user) throws Exception;
  20.     //删除用户信息
  21.     public void deleteUser(int id) throws Exception;
  23.     //更新用户信息
  24.     public void updateUser(User user) throws Exception;
  26. }



4、UserDaoImpl.java  dao接口的实现类
  1. package com.liuyanzhao.mybatis.dao;
  3. import com.liuyanzhao.mybatis.po.User;
  4. import org.apache.ibatis.session.SqlSession;
  5. import org.apache.ibatis.session.SqlSessionFactory;
  7. import java.util.List;
  9. /**
  10.  * Created by 言曌 on 2017/8/10.
  11.  */
  12. public class UserDaoImpl implements UserDao{
  13.     //向dao实现类注入SqlSessionFactory
  14.     //这里通过构造方法注入
  15.     private SqlSessionFactory sqlSessionFactory;
  16.     public UserDaoImpl(SqlSessionFactory sqlSessionFactory) {
  17.         this.sqlSessionFactory = sqlSessionFactory;
  18.     }
  20.     @Override
  21.     public User findUserById(int id) throws Exception {
  22.         SqlSession sqlSession = sqlSessionFactory.openSession();
  23.          //执行查询操作，赋值给user对象
  24.         User user = sqlSession.selectOne("test.findUserById",id);
  25.         //释放资源
  26.         sqlSession.close();
  27.         return user;
  28.     }
  30.     @Override
  31.     public List<User> findUserByName(String username) throws Exception {
  32.         SqlSession sqlSession = sqlSessionFactory.openSession();
  33.         //执行查询操作，存储到list中
  34.         List<User> list = sqlSession.selectList("test.findUserByName",username);
  35.         //释放资源
  36.         sqlSession.close();
  37.         return list;
  38.     }
  40.     @Override
  41.     public void insertUser(User user) throws Exception {
  42.         SqlSession sqlSession = sqlSessionFactory.openSession();
  43.         //执行插入操作
  44.         sqlSession.insert("test.insertUser",user);
  45.         //提交事务
  46.         sqlSession.commit();
  47.         //释放资源
  48.         sqlSession.close();
  49.     }
  51.     @Override
  52.     public void deleteUser(int id) throws Exception {
  53.         SqlSession sqlSession = sqlSessionFactory.openSession();
  54.         //执行删除操作
  55.         sqlSession.delete("test.deleteUserById",id);
  56.         //提交事务
  57.         sqlSession.commit();
  58.         //释放资源
  59.         sqlSession.close();
  60.     }
  62.     @Override
  63.     public void updateUser(User user) throws Exception {
  64.         SqlSession sqlSession = sqlSessionFactory.openSession();
  65.         //执行更新操作
  66.         sqlSession.update("test.updateUserById",user);
  67.         //提交事务
  68.         sqlSession.commit();
  69.         //释放资源
  70.         sqlSession.close();
  71.     }
  72. }



5、测试类 UserDaoImplTest.java
  1. package com.liuyanzhao.mybatis.test;
  3. import com.liuyanzhao.mybatis.dao.UserDao;
  4. import com.liuyanzhao.mybatis.dao.UserDaoImpl;
  5. import com.liuyanzhao.mybatis.po.User;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.apache.ibatis.io.Resources;
  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 Liu_Yanzhao on 2017/8/10.
  18.  */
  19. public class UserDaoImplTest {
  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.         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
  35.         User user = userDao.findUserById(10);
  36.         System.out.println(user);
  37.     }
  39.     //测试，根据username查询用户
  40.     @Test
  41.     public void testFindUserByName() throws Exception {
  42.         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
  43.         List<User> list = userDao.findUserByName("小明");
  44.         System.out.println(list);
  45.     }
  47.     //测试,添加信息
  48.     @Test
  49.     public void testInsertUser() throws Exception {
  50.         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
  51.         //创建User对象,存储用户信息
  52.         User user = new User();
  53.         user.setUsername("龙小云");
  54.         user.setGender("女");
  55.         user.setBirthday(new Date());
  56.         user.setAddress("江西南昌");
  57.         //执行添加操作
  58.         userDao.insertUser(user);
  59.     }
  62.     //测试，删除信息
  63.     @Test
  64.     public void testDeleteUserByUser() throws Exception {
  65.         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
  66.         //执行删除操作
  67.         userDao.deleteUser(10);
  68.     }
  70.     //测试，更新用户信息
  71.     @Test
  72.     public void testUpdateUser() throws Exception {
  73.         UserDao userDao = new UserDaoImpl(sqlSessionFactory);
  74.         //创建User对象，存储用户信息
  75.         User user = new User();
  76.         user.setId(8);
  77.         user.setUsername("令小冲");
  78.         user.setGender("男");
  79.         user.setBirthday(new Date());
  80.         user.setAddress("华山");
  81.         //执行更新操作
  82.         userDao.updateUser(user);
  83.     }
  85. }


总结原生 dao 开发问题


1、dao 接口实现类方法中存在大量模板方法，设想是否能将这些代码提取出来，从而减少程序员的工作量。



2、调用 sqlSession 方法时将 statement 的 id 硬编码（硬编码是指将可变变量用一个固定值来代替的方法）了。

如：
  1. User user = sqlSession.selectOne("test.findUserById",id);

在根据id查询用户的方法里，这句里的 "test.findUserById" 是一个固定的值。



3、调用 sqlSession 方法时传入的变量，由于 sqlSession 方法使用泛型，即使变量类型传入错误，在编译阶段也不会报错，不利于 程序员开发

如：
  1. User user = sqlSession.selectOne("test.findUserById",id);

还是 2  中的那一行代码，id 处接受一个对象值，但是我们要求是 一个整数，所以当我输入其他的，如字符串类型时，编译时不会报错，运行时才会有。



本文链接：https://liuyanzhao.com/5782.html
历史上的今天
八月
11日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

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

  

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