Mybatis笔记 - 原始Dao开发方法

使用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+"\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="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("删除成功！");

 	}

 }