你的位置:首页 > Java教程

[Java教程]mybatis入门基础(二)


  承接上一篇 mybatis入门基础(一)

  看过上一篇的朋友,肯定可以看出,里面的MybatisService中存在大量的重复代码,看起来不是很清楚,但第一次那样写,是为了解mybatis的执行步骤,先苦后甜嘛!

一:原始dao开发方法

  概要:1.在上篇中搭建好的框价中编写dao接口和dao实现类

     2.向dao接口实现类中注入SqlSessionFactory,在方法体内通过SqlSessionFactory创建sqlSession.

  • DAO接口类UserDAO.java  
package com.mybatis.dao;import java.util.List;import com.mybatis.entity.User;/** * * @ClassName: UserDAO * @Description: TODO(用户管理DAO接口) * @author warcaft * @date 2015-6-27 下午10:23:42 * */public interface UserDAO {  /** 根据ID查询用户信息*/  public User findUserById(Integer id);  /**根据用户名称模糊查询用户信息*/  public List<User> findUserByName(String username);  /** 添加用户*/  public void insertUser(User user);  /** 根据ID删除用户*/  public void deleteUser(Integer id);  /** 根据ID更新用户*/  public void updateUser(User user);}

  • dao实现类UserDaoImpl.java 
package com.mybatis.dao;import java.util.List;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import com.mybatis.entity.User;/** * * @ClassName: UserDaoImpl * @Description: TODO(用户管理接口的实现类) * @author warcaft * @date 2015-6-27 下午10:29:35 * */public class UserDaoImpl implements UserDAO {  private SqlSessionFactory sqlSessionFactory;  // 需要向dao实现类中注入SqlSessionFactory  // 通过构造方法注入  public UserDaoImpl(SqlSessionFactory sqlSessionFactory) {    this.sqlSessionFactory = sqlSessionFactory;  }  @Override  public User findUserById(Integer id) {    SqlSession sqlSession = sqlSessionFactory.openSession();    User user = sqlSession.selectOne("test.findUserById", id);    // 释放资源    sqlSession.close();    return user;  }  @Override  public List<User> findUserByName(String username) {    SqlSession sqlSession = sqlSessionFactory.openSession();    List<User> list = sqlSession        .selectList("test.findUserByName", username);    // 提交事务    sqlSession.commit();    // 释放资源    sqlSession.close();    return list;  }  @Override  public void insertUser(User user) {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 执行插入操作    sqlSession.insert("test.insertUser", user);    // 提交事务    sqlSession.commit();    // 释放资源    sqlSession.close();  }  @Override  public void deleteUser(Integer id) {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 执行插入操作    sqlSession.delete("test.deleteUser", id);    // 提交事务    sqlSession.commit();    // 释放资源    sqlSession.close();  }  @Override  public void updateUser(User user) {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 执行插入操作    sqlSession.update("test.updateUser", user);    // 提交事务    sqlSession.commit();    // 释放资源    sqlSession.close();  }}

  • JunitTest测试UserDaoImplTest.java
package com.mybatis.dao.test;import java.io.InputStream;import java.util.Date;import java.util.List;import org.apache.ibatis.io.Resources;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;import org.junit.Before;import org.junit.Test;import com.mybatis.dao.UserDaoImpl;import com.mybatis.entity.User;public class UserDaoImplTest {  private SqlSessionFactory sqlSessionFactory;  @Before  public void setUp() throws Exception {    String resource = "SqlMapConfig.;    InputStream inputStream = Resources.getResourceAsStream(resource);    sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);  }  @Test  public void findUserByIdTest() {    UserDaoImpl userDao = new UserDaoImpl(sqlSessionFactory);    User user = userDao.findUserById(1);    System.out.println(user);  }  @Test  public void findUserByNameTest() {    UserDaoImpl userDao = new UserDaoImpl(sqlSessionFactory);    List<User> list = userDao.findUserByName("小");    System.out.println(list);  }  @Test  public void insertUserTest() {    UserDaoImpl userDao = new UserDaoImpl(sqlSessionFactory);    User user = new User();    user.setUsername("张三丰");    user.setSex("1");    user.setBirthday(new Date());    user.setAddress("武当山");    userDao.insertUser(user);  }  @Test  public void deleteUserTest() {    UserDaoImpl userDao = new UserDaoImpl(sqlSessionFactory);    userDao.deleteUser(8);  }  @Test  public void updateUserTest() {    UserDaoImpl userDao = new UserDaoImpl(sqlSessionFactory);    User user = new User();    user.setId(1);    user.setUsername("王六");    user.setSex("2");    user.setAddress("天津");    user.setBirthday(new Date());    userDao.updateUser(user);  }}

才上面的代码可以看出,比起之前那个MybatisService.java类里面的内容稍微清晰了点吧。但依然存在以下几个问题:

  1.dao接口中存在大量模版方法,能否把这些代码提出来,减少我们的工作量

  2.调用sqlSession方法时将statement的id硬编码了

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

所以我们带着这几个问题看看mapper代理开发的方法,是否能解决这些问题呢?

二:mapper代理方法(只需要mapper接口,相当于dao接口)

1.概要:(1).编写XXXmapper.

    (2).编写mapper接口需要遵循一些开发规范,mybatis可以自动生成mapper接口实现类代理对象。

2.开发规范:

  (1).在XXXmapper.

  

      (2).XXXmapper.java接口中的方法和mapper.

  (3).mapper.java接口中的方法输入参数和mapper.

  (4).mapper.java接口中的方法的返回值类型和mapper.

  

  

小结:以上的开发规范主要是对下面的代码进行统一生成 

  SqlSession sqlSession = sqlSessionFactory.openSession();  User user = sqlSession.selectOne("test.findUserById", id);
  ......

3.UserMapper.java类代码

package com.mybatis.mapper;import java.util.List;import com.mybatis.entity.User;/** * * @ClassName: UserDAO * @Description: TODO(用户管理mapper接口) * @author warcaft * @date 2015-6-27 下午10:23:42 * */public interface UserMapper {  /** 根据ID查询用户信息 */  public User findUserById(int id);  /** 根据用户名称模糊查询用户信息 */  public List<User> findUserByName(String username);  /** 添加用户 */  public void insertUser(User user);  /** 根据ID删除用户 */  public void deleteUser(Integer id);  /** 根据ID更新用户 */  public void updateUser(User user);}

View Code

4.将原来的User.

<!-- namespace命名空间,作用就是对sql进行分类化的管理,理解为sql隔离  注意:使用mapper代理开发时,namespace有特殊作用,namespace等于mapper接口地址 --><mapper namespace="com.mybatis.mapper.UserMapper">

5.在SqlMapConfig.

<!-- 加载映射文件 -->  <mappers>    <mapper resource="sqlmap/User./>    <mapper resource="mapper/UserMapper./>  </mappers>

6.Junit测试UserMapperTest.java

package com.mybatis.dao.test;import java.io.InputStream;import java.util.Date;import java.util.List;import org.apache.ibatis.io.Resources;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;import org.junit.Before;import org.junit.Test;import com.mybatis.entity.User;import com.mybatis.mapper.UserMapper;public class UserMapperTest {  private SqlSessionFactory sqlSessionFactory;  // 此方法是在执行findUserByIdTest之前执行  @Before  public void setUp() throws Exception {    String resource = "SqlMapConfig.;    InputStream inputStream = Resources.getResourceAsStream(resource);    // 创建SqlSessionFcatory    sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);  }  @Test  public void testFindUserById() {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 创建Usermapper对象,mybatis自动生成mapper代理对象    UserMapper mapper = sqlSession.getMapper(UserMapper.class);    User user = mapper.findUserById(1);    System.out.println(user);    sqlSession.close();  }  @Test  public void testFindUserByName() {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 创建Usermapper对象,mybatis自动生成mapper代理对象    UserMapper mapper = sqlSession.getMapper(UserMapper.class);    List<User> list = mapper.findUserByName("小");    System.out.println(list);    sqlSession.close();  }  @Test  public void testDeleteUser() {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 创建Usermapper对象,mybatis自动生成mapper代理对象    UserMapper mapper = sqlSession.getMapper(UserMapper.class);    mapper.deleteUser(6);    sqlSession.commit();    sqlSession.close();  }    @Test  public void testInsertUser() {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 创建Usermapper对象,mybatis自动生成mapper代理对象    User user = new User();    user.setUsername("者别");    user.setSex("1");    user.setAddress("蒙古乞颜部落");    user.setBirthday(new Date());    UserMapper mapper = sqlSession.getMapper(UserMapper.class);    mapper.insertUser(user);    sqlSession.commit();    sqlSession.close();  }    @Test  public void testUpdateUser() {    SqlSession sqlSession = sqlSessionFactory.openSession();    // 创建Usermapper对象,mybatis自动生成mapper代理对象    User user = new User();    user.setId(11);//必须设置Id    user.setUsername("神箭手者别");    user.setSex("1");    user.setAddress("蒙古乞颜部落");    user.setBirthday(new Date());    UserMapper mapper = sqlSession.getMapper(UserMapper.class);    mapper.updateUser(user);    sqlSession.commit();    sqlSession.close();  }}

View Code

7.小结

  (1).代理对象内部调用selectOne()和selectList():如果mapper对象返回单个pojo对象(非集合对象)代理对象内部通过selectOne查询数据库,如果mapper方法返回集合对象,代理对象内部通过selectList查询数据库。

  (2).mapper接口中的方法参数只能有一个是否影响系统开发:

  mapper接口方法参数只能有一个,系统是否不利于维护?

  回答:系统框架中,dao层的代码是被业务层公用的。机试mapper接口只有一个参数,可以使用包装类型的pojo满足不同的业务方法的需求。