Mybatis筆記 - Mapper動態代理

       使用Mybatis開發Dao，通常有兩個方法，即原始Dao開發方法和Mapper接口開發方法。 Mapper接口開發方式是基於入門程序的基礎上，對 控制程序 進行分層開發，程序員只需要 編寫mapper接口 和 Mappe.xml 配置文件即可，程序員編寫mapper接口需要遵循一些開發規范，mybatis可以自動生成mapper接口實現類代理對象。

一、SQL配置文件

1、EmpMapper.xml

        使用Mapper動態代理的方式開發時， 映射文件的namespace 必須為  Mapper接口文件 的全名。

<?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="Mapper.EmpMapper">
	<!-- 根據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+"\n";
	}
	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="Mapper/EmpMapper.xml"/>
	</mappers>
</configuration>

二、Dao層

1、開發規范

      程序員編寫mapper接口需要遵循一些開發規范，mybatis可以自動生成mapper接口實現類代理對象。相關的開發規范如下：

            ① 在mapper.xml中namespace等於mapper接口地址

            ② 接口中的方法名和mapper.xml中statement的id一致

            ③ 接口中的方法輸入參數類型和mapper.xml中statement的parameterType指定的類型一致

            ④ 接口中的方法返回值類型和mapper.xml中statement的resultType指定的類型一致

     總結：以上開發規范主要是對下邊的代碼進行統一生成：

//在方法體內通過SqlSessionFactory創建SqlSession
SqlSession sqlSession = sqlSessionFactory.openSession();
//業務操作語句
Emp emp = sqlSession.selectOne("test.findEmpById",empno);

2、Mapper接口

package Mapper;
//導入相關類
public interface EmpMapper {
	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);
}

三、測試程序

1、Junit單元測試

package Test;
//導入相關類
public class Mybatis_Mapper {

	//使用 單例模式 管理會話工廠
	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() {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		//創建EmpMapper對象，mybatis自動生成mapper代理對象
		EmpMapper empMapper = sqlSession.getMapper(EmpMapper.class);
		Emp emp = null;

		try {
			//調用empMapper的方法
			emp = empMapper.findEmpById(7900);
		}finally {
			sqlSession.close();
		}

		System.out.println(emp);
	}

	// 根據員工姓名模糊查詢員工信息
	@Test
	public void testFindEmpByEmpname() {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		EmpMapper empMapper = sqlSession.getMapper(EmpMapper.class);
		List<Emp> emp = null;

		try {
			//調用empMapper的方法
			emp = empMapper.findEmpByEmpname("th");
		}
		finally {
			sqlSession.close();
		}

		for(Emp e:emp) {
			System.out.println(e);
		}
	}

	// 添加員工信息
	@Test
	public void testInsert() {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		EmpMapper empMapper = sqlSession.getMapper(EmpMapper.class);
		Emp emp = new Emp();
		emp.setEname("admin");
		emp.setJob("admin");

		int flag = 0;
		try {
			flag =  empMapper.insertEmp(emp);
		}finally {
			sqlSession.commit();
			sqlSession.close();
		}

		if(flag == 1) {
			System.out.println("自增主鍵值："+emp.getEmpno());
		}
	}

	// 更新員工信息
	@Test
	public void testUpdate() {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		EmpMapper empMapper = sqlSession.getMapper(EmpMapper.class);
		Emp emp = new Emp();
		emp.setEmpno(7950);
		emp.setEname("test7950");
		emp.setJob("test7950");

		int flag = 0;
		try {
			flag = empMapper.updateEmp(emp);
		}finally {
			sqlSession.commit();
			sqlSession.close();
		}

		if(flag == 1) {
			System.out.println("更新成功！");
		}
	}

	// 根據id刪除員工信息
	@Test
	public void testDelete() {
		SqlSession sqlSession = sqlSessionFactory.openSession();
		EmpMapper empMapper = sqlSession.getMapper(EmpMapper.class);

		int flag = 0;
		try {
			flag = empMapper.deleteEmpById(7950);
		}finally {
			sqlSession.commit();
			sqlSession.close();
		}

		if(flag == 1) {
			System.out.println("刪除成功！");
		}
	}
}

2、測試結果

（1）根據 id查詢部門信息

   

（2）根據員工姓名模糊查詢員工信息

   

（3）添加員工信息

   

（4）更新員工信息

   

（5）根據id刪除員工信息

    -