使用Mybatis开发Dao

使用Mybatis开发Dao，有两个方法，即原始DAO方法和Mapper接口开发方法。

内容总概：

1、原始DAO方法：需要编写接口实现

UserDao userDao = new UserDaoImpl(factory);

2、Mapper接口方法：不需要编写接口的实现，由Mybatis框架根据接口定义创建接口的动态代理对象。

SqlSession openSession = factory.openSession(); //通过getMapper方法来实例化接口 UserMapper mapper = openSession.getMapper(UserMapper.class);

3、现在都是使用注解的方式，直接调用DAO中方法。

 

---------------------------------------------------------------------原文如下-------------------------------------------------------------------

一、【原始Dao开发方法】

1、以上篇为基础，在此架构上编写文件实现原始Dao方法。

2.编写DAO接口和实现方法

UserDao.java:

package com.herry.dao; import java.util.List; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import com.herry.pojo.User; public class UserDaoImpl implements UserDao { private SqlSessionFactory sqlSessionFactory; //通过构造方法注入 public UserDaoImpl(SqlSessionFactory sqlSessionFactory) { this.sqlSessionFactory = sqlSessionFactory; } @Override public User findUserById(Integer id) { //sqlSesion是线程不安全的,所以它的最佳使用范围在方法体内 SqlSession openSession = sqlSessionFactory.openSession(); User user = openSession.selectOne("test.findUserById", id); return user; } @Override public List<User> findUserByUserName(String userName) { SqlSession openSession = sqlSessionFactory.openSession(); List<User> list = openSession.selectList("test.findUserByUserName", userName); return list; } }

 

3.测试程序

UserDaoTest.java:

package mybatis01; 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 com.herry.dao.UserDao; import com.herry.dao.UserDaoImpl; import com.herry.pojo.User; public class UserDaoTest { private SqlSessionFactory factory; //作用:在测试方法前执行这个方法 @Before public void setUp() throws Exception{ String resource = "SqlMapConfig.xml"; //通过流将核心配置文件读取进来 InputStream inputStream = Resources.getResourceAsStream(resource); //通过核心配置文件输入流来创建会话工厂 factory = new SqlSessionFactoryBuilder().build(inputStream); } @Test public void testFindUserById() throws Exception{ //将初始化好的工厂注入到实现类中 UserDao userDao = new UserDaoImpl(factory); User user = userDao.findUserById(1); System.out.println(user); } @Test public void testFindUserByUserName () throws Exception{ //将初始化好的工厂注入到实现类中 UserDao userDao = new UserDaoImpl(factory); List<User> list = userDao.findUserByUserName("王"); System.out.println(list); } }

-------------------------------------------------------------------------------------------------------------------------------------------------------------------------

二、【Mapper接口实现】

Mapper接口开发方法只需要程序员编写Mapper接口，不需要编写接口的实现。由Mybatis框架根据接口定义创建接口的动态代理对象，代理对象的方法体同上边Dao接口实现类方法。

1.映射文件Mapper.xml:

<?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"> <!-- mapper接口代理实现编写规则: 1. 映射文件中namespace要等于接口的全路径名称 2. 映射文件中sql语句id要等于接口的方法名称 3. 映射文件中传入参数类型要等于接口方法的传入参数类型 4. 映射文件中返回结果集类型要等于接口方法的返回值类型 --> <mapper namespace="com.herry.mapper.UserMapper"> <!-- id:sql语句唯一标识 parameterType:指定传入参数类型 resultType:返回结果集类型 #{}占位符:起到占位作用,如果传入的是基本类型(string,long,double,int,boolean,float等),那么#{}中的变量名称可以随意写. --> <select id="findUserById" parameterType="int" resultType="com.herry.pojo.User"> select * from user where id=#{id} </select> <!-- 如果返回结果为集合,可以调用selectList方法,这个方法返回的结果就是一个集合,所以映射文件中应该配置成集合泛型的类型 ${}拼接符:字符串原样拼接,如果传入的参数是基本类型(string,long,double,int,boolean,float等),那么${}中的变量名称必须是value 注意:拼接符有sql注入的风险,所以慎重使用 --> <select id="findUserByUserName" parameterType="string" resultType="user"> select * from user where username like '%${value}%' </select> <!-- #{}:如果传入的是pojo类型,那么#{}中的变量名称必须是pojo中对应的属性.属性.属性..... 如果要返回数据库自增主键:可以使用select LAST_INSERT_ID() --> <insert id="insertUser" parameterType="com.herry.pojo.User" > <!-- 执行 select LAST_INSERT_ID()数据库函数,返回自增的主键 keyProperty:将返回的主键放入传入参数的Id中保存. order:当前函数相对于insert语句的执行顺序,在insert前执行是before,在insert后执行是AFTER resultType:id的类型,也就是keyproperties中属性的类型 --> <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer"> select LAST_INSERT_ID() </selectKey> insert into user (username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address}) </insert> </mapper>

2.接口类

UserMapper.java:

package com.herry.mapper; import java.util.List; import com.herry.pojo.User; public interface UserMapper { public User findUserById(Integer id); //动态代理形势中,如果返回结果集问List,那么mybatis会在生成实现类的使用会自动调用selectList方法 public List<User> findUserByUserName(String userName); }

3.加入SqlMapConfig.xml

<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- 和spring整合后 environments配置将废除--> <environments default="development"> <environment id="development"> <!-- 使用jdbc事务管理--> <transactionManager type="JDBC" /> <!-- 数据库连接池--> <dataSource type="POOLED"> <property name="driver" value="${jdbc.driver}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> </dataSource> </environment> </environments> <mappers> <mapper resource="User.xml"/> <!-- 使用包扫描的方式批量引入Mapper接口 使用规则: 1. 接口的名称和映射文件名称除扩展名外要完全相同 2. 接口和映射文件要放在同一个目录下 --> <package name="cn.itheima.mapper"/> </mappers> </configuration>

4.测试文件

UserMapperTest.java:

package mybatis01; 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.herry.mapper.UserMapper; import com.herry.pojo.User; public class UserMapperTest { private SqlSessionFactory factory; //作用:在测试方法前执行这个方法 @Before public void setUp() 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 testInsertUser() throws Exception{ SqlSession openSession = factory.openSession(); //通过getMapper方法来实例化接口 UserMapper mapper = openSession.getMapper(UserMapper.class); User user = new User(); user.setUsername("老王"); user.setSex("1"); user.setBirthday(new Date()); user.setAddress("北京昌平"); mapper.insertUser(user); openSession.commit(); } }

三、【总结】

 

红色标粗的部分是两种方法在测试类中实现的不同。可以看出mapper接口实现不需要写接口的实现类，而是通过getMapper方法来实例化接口。

原始Daouser.java userDao.java userDaoImpl.java user.xml SqlMapConfig.xml mapper接口user.java userMapper.java userMapper.xml SqlMapConfig.xml

 

Mapper接口开发需要遵循以下规范： 1.Mapper.xml文件中的namespace与mapper接口的类路径相同。 2.Mapper接口方法名和Mapper.xml中定义的每个statement的id相同  3.Mapper接口方法的输入参数类型和mapper.xml中定义的每个sql 的parameterType的类型相同 4.Mapper接口方法的输出参数类型和mapper.xml中定义的每个sql的resultType的类型相同