Mybatis笔记

     使用Mybatis开发Dao，通常有两个方法，即原始Dao开发方法和Mapper接口开发方法。原始Dao的开发方式是基于入门程序的基础上，对 控制程序 进行分层开发，程序员需要 编写 Dao接口 和 Dao实现类，但对 SQL映射文件、pojo类、sqlMapConfig.xml等 配置文件 并不做改变。

一、映射文件

1、Emp.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 namespace="test">
	<!-- 根据id获取员工信息 -->
	<select id="findEmpById" parameterType="int" resultType="po.Emp">
		select * from emp where empno = #{empno}
	</select>

	<!-- 自定义条件查询员工列表 -->
	<select id="findEmpByEmpname" parameterType="java.lang.String" resultType="po.Emp">
	   select * from emp  where ename like '%${value}%'
	</select>

	<!-- 添加员工信息 -->
	<insert id="insertEmp" parameterType="po.Emp">
	<selectKey keyProperty="empno" order="AFTER" resultType="java.lang.Integer">
		select LAST_INSERT_ID()
	</selectKey>
	  insert into emp(ename,job) values(#{ename},#{job})
	</insert>

	<!-- 删除员工信息 -->
	<delete id="deleteEmpById" parameterType="int">
		delete from emp where empno=#{empno}
	</delete>

	<!-- 更新员工信息 -->
	<update id="updateEmp" parameterType="po.Emp">
		update emp set ename=#{ename},job=#{job}
			where empno=#{empno}
	</update>
</mapper>

2、pojo类

package po;
//导入相关类
public class Emp {
	private int empno;
	private String ename;
	private String job;
	private int mgr;
	private Date hiredate;
	private double sal;
	private double comm;
	private int deptno;

	@Override
	public String toString() {
		return "编号："+empno+"    姓名："+ename+"    工作："+job+"
";
	}
	set()/get()方法 ...
}

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="com.mysql.jdbc.Driver" />
				<property name="url" value="jdbc:mysql://localhost:3306/
                                                      scott?characterEncoding=utf-8" />
				<property name="username" value="root" />
				<property name="password" value="su486213" />
			</dataSource>
		</environment>
	</environments>

	<!-- 加载映射文件 -->
	<mappers>
		<mapper resource="SqlMap/Emp.xml"/>
	</mappers>
</configuration>

二、Dao层

1、Dao类

package Dao;
//导入相关类
public interface EmpDao {
	public Emp findEmpById(int empno);
	public List<Emp> findEmpByEmpname(String tname);
	public int insertEmp(Emp emp);
	public int deleteEmpById(int empno);
	public int updateEmp(Emp emp);
}

2、DaoImp类

    实现步骤：① 构造方法：在dao实现类的构造方法中注入SqlSessionFactory

                    ② 方法体：在方法体内通过SqlSessionFactory创建SqlSession

package Dao;
//导入相关类
public class EmpDaoImp implements EmpDao {

	private SqlSessionFactory sqlSessionFactory ;
	// 在dao实现类的构造方法中注入注入SqlSessionFactory
	public EmpDaoImp(SqlSessionFactory sqlSessionFactory) {
		this.sqlSessionFactory = sqlSessionFactory;
	}

	@Override
	public Emp findEmpById(int empno) {
		//在方法体内通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		Emp emp = null;
		//使用finally语句，保证释放资源操作必须执行
		try {
			emp = sqlSession.selectOne("test.findEmpById",empno);
		}finally {
			sqlSession.close();
		}
		return emp;
	}

	@Override
	public List<Emp> findEmpByEmpname(String ename) {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		List<Emp> emp = null;
		try {
			 emp = sqlSession.selectList("test.findEmpByEmpname",ename);
		}finally {
			sqlSession.close();
		}
		return emp;
	}

	@Override
	public int insertEmp(Emp emp) {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		int flag = 0;
		try {
			flag = sqlSession.insert("test.insertEmp",emp);
		}finally{
			//必须提交，更新数据
			sqlSession.commit();
			sqlSession.close();
		}
		return flag;
	}

	@Override
	public int deleteEmpById(int empno) {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		int flag = 0;
		try {
			flag = sqlSession.delete("test.deleteEmpById",empno);
		}finally{
			//必须提交，更新数据
			sqlSession.commit();
			sqlSession.close();
		}
		return flag;
	}

	@Override
	public int updateEmp(Emp emp) {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		int flag = 0;
		try {
			flag = sqlSession.update("test.updateEmp",emp);
		}finally{
			//必须提交，更新数据
			sqlSession.commit();
			sqlSession.close();
		}
		return flag;
	}
}

三、测试程序

1、Junit单元测试

package Test;
//导入相关类
public class Mybatis_Dao {

	//使用 单例模式 管理会话工厂
	private SqlSessionFactory sqlSessionFactory;
	@Before
	public void createSqlSessionFactory() throws IOException {
		 // Mybatis配置文件
		String resource = "SqlMapConfig.xml";
		// 得到配置文件流
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 创建会化工厂，传入Mybatis配置文件信息
		sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
	}

	// 根据 id查询部门信息
	@Test
	public void testFindEmpById() {
		EmpDaoImp empDaoImp = new EmpDaoImp(sqlSessionFactory);
		Emp emp = empDaoImp.findEmpById(7369);
		System.out.println(emp);
	}

	// 根据员工姓名模糊查询员工信息
	@Test
	public void testFindEmpByEmpname() {
		EmpDaoImp empDaoImp = new EmpDaoImp(sqlSessionFactory);
		List<Emp> emp = empDaoImp.findEmpByEmpname("th");
		for(Emp e:emp) {
			System.out.println(e);
		}
	}

	// 添加员工信息
	@Test
	public void testInsert() {
		EmpDaoImp empDaoImp = new EmpDaoImp(sqlSessionFactory);
		Emp emp = new Emp();
		emp.setEname("test");
		emp.setJob("test");
		int flag = empDaoImp.insertEmp(emp);
		System.out.println("自增主键值："+emp.getEmpno());
	}

	// 更新员工信息
	@Test
	public void testUpdate() {
		EmpDaoImp empDaoImp = new EmpDaoImp(sqlSessionFactory);
		Emp emp = new Emp();
		emp.setEmpno(7946);
		emp.setEname("test7946");
		emp.setJob("test7946");
		int flag = empDaoImp.updateEmp(emp);
		if(flag == 1)
			System.out.println("更新成功！");
	}

	// 根据id删除员工信息
	@Test
	public void testDelete() {
		EmpDaoImp empDaoImp = new EmpDaoImp(sqlSessionFactory);
		int flag = empDaoImp.deleteEmpById(7946);
		if(flag == 1)
			System.out.println("删除成功！");
	}
}

2、测试结果

（1）根据 id查询部门信息

    

（2）根据员工姓名模糊查询员工信息

   

（3）添加员工信息

   

（4）更新员工信息

   

（5）根据id删除员工信息