mybatis入门--mapper代理方式开发

时间:2022-07-17 19:16:20

不使用代理开发

之前,我们说了如何搭建mybatis框架以及我们使用mybatis进行简单的增删改查.现在,我们一起来构建一个dao层的完整代码.并用@test来模拟service层对dao层进行一下调用.

其实构建很简单,跟我们之前的差不多.如果不是为了演示其中的弊端,我甚至都懒得再写这些东西了.我们这次用UserDao为大家演示.

首先是导包、创建log4j.properties文件、创建sqlMapConfig.xml文件、创建User类、创建User.xml文件、将User.xml文件配置daosqlMapConfig.xml文件的过程我就不说了。不清楚的可以去看之前的博客。

先是创建一个dao的包,然后创建UserDao的接口,然后创建一个UserDaoImpl的实现类去实现UserDao的接口。为了便于说明问题这里的UserDao中写两个方法。其中,UserDao接口中的代码是这样的:

package cn.itcast.dao;

import java.util.List;

import cn.itcast.pojo.User;

public interface UserDao {

	public User findUserById(Integer id);

	public List<User> findUserByUserName(String userName);
}

UserDaoImpl类的代码如下:

package cn.itcast.dao;

import java.util.List;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory; import cn.itcast.pojo.User; public class UserDaoImpl implements UserDao { private SqlSessionFactory factory; //通过构造方法, 工厂由外部初始化好传入这里
public UserDaoImpl(SqlSessionFactory factory) {
this.factory = factory;
} @Override
public User findUserById(Integer id) {
//创建会话, 会话是线程不安全的, 所以它的最佳使用范围在方法体内
SqlSession openSession = factory.openSession();
User user = openSession.selectOne("test.findUserById", id);
return user;
} @Override
public List<User> findUserByUserName(String userName) {
//创建会话, 会话是线程不安全的, 所以它的最佳使用范围在方法体内
SqlSession openSession = factory.openSession();
List<User> list = openSession.selectList("test.findUserByUserName", userName);
return list;
} }

调用UserDaoImpl的类在调用的时候代码类似于下面的测试代码:

package cn.itcast;

import java.io.InputStream;
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 cn.itcast.dao.UserDao;
import cn.itcast.dao.UserDaoImpl;
import cn.itcast.pojo.User; public class UserDaoTest { private SqlSessionFactory factory; @Before //@Before注解作用就是在执行@Test前执行
public void init() throws Exception{
String resource = "SqlMapConfig.xml";
//通过流将核心配置文件读入
InputStream inputStream = Resources.getResourceAsStream(resource);
//通过核心配置文件输入流, 创建会话工厂
factory = new SqlSessionFactoryBuilder().build(inputStream);
} @Test
public void testFindUserById() throws Exception {
//实例化UserDao
UserDao userDao = new UserDaoImpl(factory); User user = userDao.findUserById(1); System.out.println(user);
} @Test
public void testFindUserByUserName() throws Exception {
//实例化UserDao
UserDao userDao = new UserDaoImpl(factory); List<User> list = userDao.findUserByUserName("王");
System.out.println(list);
}
}

不使用代理开发的弊端及使用代理开发的好处

通过上面的演示,相信有的同学已经发现了,我们的UserDaoImpl类中有很多代码看起来让人感觉很不舒服,如下图所示,方框中的代码看起来有很多都是重复的,而且剩下的代码基本就是一个构造方法。

为了解决上图中的问题,mybatis提供了一个代理类,可以让我们不再用写mybatis类的代码。这样做可以让我们不再用自己写dao层接口的实现类,不过对我们的pojo的配置文件有一些要求。接下来为大家演示如何使用代理mybatis入门--mapper代理方式开发(mapper代理)来开发我们的Userapper。

使用代理开发应该如何配置

为了可以使用我们的mapper代理,我们需要将我们的pojo的配置文件做一些要求。首先就是我们的nameSpace属性。这里我们必须将我们的namespace中的值配置成我们的接口的全路径。然后就是每条sql语句对应的是一个接口中的方法。映射文件中的sql语句的id位置必须配置为接口中的方法名。输入类型对应的是接口中的输入类型,输出类型对应的是接口中的输出类型。接口和配置文件的代码如下:

接口:

package cn.itcast.mapper;

import java.util.List;

import cn.itcast.pojo.QueryVo;
import cn.itcast.pojo.User; public interface UserMapper { public User findUserById(Integer id); public List<User> findUserByUserName(String userName); public List<User> findUserByVo (QueryVo vo); public Integer findUserCount(); public List<User> findUserByUserNameAdnSex(User user );
}

映射文件:

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--
mybatis动态代理方式开发规范:
1) 映射文件中的namespace必须等于接口的全路径名称
2) 映射文件中sql语句的id必须等于接口中方法的方法名
3) 映射文件中传入参数parameterType指定的类型必须等于接口方法的传入参数类型
4) 映射文件中返回的结果集类型必须等于接口方法的返回值类型
-->
<mapper namespace="cn.itcast.mapper.UserMapper"> <select id="findUserById" parameterType="int" resultType="cn.itcast.pojo.User">
SELECT * FROM user where id=#{id}
</select> <select id="findUserByUserName" parameterType="string" resultType="cn.itcast.pojo.User">
SELECT * FROM user where username like '%${value}%'
</select>
<select id="findUserByVo" parameterType="cn.itcast.pojo.QueryVo" resultType="cn.itcast.pojo.User">
select * from user where username like'%${user.username}%' and sex =#{user.sex}
</select>
<select id="findUserCount" parameterType="cn.itcast.pojo.QueryVo" resultType="int">
select count(id) from user
</select>
<select id="findUserByUserNameAdnSex" parameterType="cn.itcast.pojo.User" resultType="cn.itcast.pojo.User">
select * from user
<where>
<if test="username != null and username != ''">
and username like'%${username}%'
</if>
<if test="sex != null and sex != ''">
and sex =#{sex}
</if> </where>
</select>
</mapper>

因为不再有具体的实体类了,所以service层需要调用我们的代理类的对象,那么如何获得代理对象呢?在会话session中有个方法getMapper。在这个方法中,我们把我们的接口类型的字节码对象传入,然后获得接口的实现类的对象。通过操作这个对象的方法,实现对数据库的增删改查,代码如下:

package cn.itcast;

import static org.junit.Assert.*;

import java.io.InputStream;
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 cn.itcast.mapper.UserMapper;
import cn.itcast.pojo.QueryVo;
import cn.itcast.pojo.User; public class UserMapperTest { private SqlSessionFactory factory; @Before //@Before注解作用就是在执行@Test前执行
public void init() throws Exception{
String resource = "SqlMapConfig.xml";
//通过流将核心配置文件读入
InputStream inputStream = Resources.getResourceAsStream(resource);
//通过核心配置文件输入流, 创建会话工厂
factory = new SqlSessionFactoryBuilder().build(inputStream);
} @Test
public void testFindUserById() throws Exception {
//通过工厂创建会话
SqlSession openSession = factory.openSession();
//通过会话的getMapper方法来实例化 接口
UserMapper mapper = openSession.getMapper(UserMapper.class); User user = mapper.findUserById(1);
System.out.println(user);
} @Test
public void testFindUserByUserName() throws Exception {
//通过工厂创建会话
SqlSession openSession = factory.openSession();
//通过会话的getMapper方法来实例化 接口
UserMapper mapper = openSession.getMapper(UserMapper.class); List<User> list = mapper.findUserByUserName("王"); System.out.println(list);
} @Test
public void testFindUserCount() throws Exception {
//通过工厂创建会话
SqlSession openSession = factory.openSession();
//通过会话的getMapper方法来实例化 接口
UserMapper mapper = openSession.getMapper(UserMapper.class); Integer count = mapper.findUserCount(); System.out.println(count);
} @Test
public void testfindUserByVo() throws Exception {
//通过工厂创建会话
SqlSession openSession = factory.openSession();
//通过会话的getMapper方法来实例化 接口
UserMapper mapper = openSession.getMapper(UserMapper.class); QueryVo vo = new QueryVo(); User user= new User();
//user.setUsername("张");
user.setSex("1"); vo.setUser(user); List<User> list = mapper.findUserByVo(vo); System.out.println(list);
}
@Test
public void testFindUserByUserNameAdnSex() throws Exception {
//通过工厂创建会话
SqlSession openSession = factory.openSession();
//通过会话的getMapper方法来实例化 接口
UserMapper mapper = openSession.getMapper(UserMapper.class);
User user= new User();
//user.setUsername("张");
//user.setSex("1"); List<User> list = mapper.findUserByUserNameAdnSex(user); System.out.println(list);
} }