一）開發前準備

mybatis-3.4.6.jar

mysql-connector-java-5.1.34-bin.jar

說明：在本章末尾有原始碼下載地址，裡面已包含jar

二）Mybatis開發環境搭建

1） 建立一個Dynamic Web Project，名稱為：xm-mybatis-one，專案結構圖如下：

2）建立員工實體檔案EmployeeEntity.java

package com.xm.mybatis.entity;

/**
 * 員工表 entity
 * @author ouyangjun
 *
 */
public class EmployeeEntity {
	
	private Integer empId;
	
	private String empName;
	
	private String empNO;
	
	private Long createDate;

	public Integer getEmpId() {
		return empId;
	}

	public void setEmpId(Integer empId) {
		this.empId = empId;
	}

	public String getEmpName() {
		return empName;
	}

	public void setEmpName(String empName) {
		this.empName = empName;
	}

	public String getEmpNO() {
		return empNO;
	}

	public void setEmpNO(String empNO) {
		this.empNO = empNO;
	}

	public Long getCreateDate() {
		return createDate;
	}

	public void setCreateDate(Long createDate) {
		this.createDate = createDate;
	}
	
}
 

3）建立員工實體對映檔案EmployeeEntity.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="com.xm.mybatis.dao.EmployeeDAO">

	<insert id="addEmployee">
		insert into employee(emp_id,emp_name,emp_no,create_date)
		values(#{empId}, #{empName}, #{empNO}, #{createDate})
	</insert>
	
	<select id="getEmployeeByEmpId" parameterType="java.lang.String" resultType="employeeEntity">
		select 
			emp_id as empId,
			emp_name as empName,
			emp_no as empNO,
			create_date as createDate
		 from employee where emp_id = #{empId}
	</select>
	
	<update id="updateEmployee">
		
	</update>
	
	<!-- 
		foreach元素的屬性主要有 item，index，collection，open，separator，close。
		item表示集合中每一個元素進行迭代時的別名，
		index指 定一個名字，用於表示在迭代過程中，每次迭代到的位置，
		open表示該語句以什麼開始，
		separator表示在每次進行迭代之間以什麼符號作為分隔 符，
		close表示以什麼結束。
		collection
			1. 如果傳入的是單引數且引數型別是一個List的時候，collection屬性值為list, parameterType="java.util.List"
			2. 如果傳入的是單引數且引數型別是一個array陣列的時候，collection的屬性值為array, parameterType="java.util.ArrayList"
			3. 如果傳入的引數是多個的時候，我們就需要把它們封裝成一個Map了，當然單引數也可, parameterType="java.util.HashMap"
	 -->
	<delete id="deleteEmployeeEntityByEmpId" parameterType="java.util.ArrayList">
		delete from employee where 1=1
		and emp_Id in 
		<foreach collection="array" index="index" item="item" open="(" separator="," close=")">
			#{item}
		</foreach>
	</delete>
  	
</mapper>
 

4）建立員工介面檔案EmployeeDAO.java

package com.xm.mybatis.dao;

import com.xm.mybatis.entity.EmployeeEntity;

public interface EmployeeDAO {

	/**
	 * 根據empId獲取員工資訊
	 * @param empId
	 * @return
	 */
	EmployeeEntity getEmployeeByEmpId(String empId);
	
	/**
	 * 新增員工
	 * @param entity
	 * @return
	 */
	int addEmployee(EmployeeEntity entity);
	
	/**
	 * 根據empId修改使用者資訊
	 * @param empId
	 * @return
	 */
	int updateEmployee(EmployeeEntity entity);
	
	/**
	 * 根據empId刪除使用者
	 */
	int deleteEmployeeEntityByEmpId(String[] empIds);
	
}
 

5）建立mybatis核心配置檔案mybatis.cfg.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>
	
	<!-- 給全限定類名命個別名，減少xml實體類引用程式碼 -->
	<typeAliases>
		<!-- 方式一：給單個實體類名一個別名,在對應的xml中引用別名即可
		<typeAlias alias="employeeEntity" type="com.xm.mybatis.entity.EmployeeEntity"></typeAlias>
		-->
		
		<!-- 方式二：當有多個實體類的時候,引用實體類包名,實體類別人首字母預設小寫(如: employeeEntity)。如果實體類上有註解別名,以註解為準! -->
		<package name="com.xm.mybatis.entity"/>
	</typeAliases>

	<environments default="development">
		<environment id="development">
			<!-- type="JDBC" 表示使用JDBC的提交和回滾管理事務 -->
			<transactionManager type="JDBC" />
			
			<!-- mybatis提供了3種資料來源型別，分別是：POOLED,UNPOOLED,JNDI -->
			<!-- POOLED 表示支援JDBC資料來源連線池 -->
			<!-- UNPOOLED 表示不支援資料來源連線池 -->
			<!-- JNDI 表示支援外部資料來源連線池 -->
			<dataSource type="POOLED">
				<property name="driver" value="com.mysql.jdbc.Driver" />
				<property name="url" value="jdbc:mysql://localhost:3306/xm" />
				<property name="username" value="root" />
				<property name="password" value="admin" />
			</dataSource>
		</environment>
	</environments>
	
	<mappers>
		<mapper resource="com/xm/mybatis/entity/EmployeeEntity.xml" />
	</mappers>
	
</configuration>

6）建立獲取SqlSessionFactory的工具類SessionUtils.java。通過單列模式實現。

package com.xm.mybatis.utils;

import java.io.IOException;
import java.io.Reader;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class SessionUtils {
	
	/**
	 * 內部類單列模式實現讀取mybatis配置檔案
	 * @author ouyangjun
	 */
	private static class LasyHolder {
		
		private static Reader READER = getReader();
		
		public static Reader getReader() {
			try {
				System.out.println("==>讀取mybatis.cfg.xml檔案中的配置!");
				// 讀取mybatis配置檔案
				return Resources.getResourceAsReader("mybatis.cfg.xml");
			} catch (IOException e) {
				System.out.println("==>讀取mybatis.cfg.xml檔案中的配置錯誤 error!");
				e.printStackTrace();
			}
			return null;
		}
	}
	
	/**
	 * 獲取配置檔案物件
	 * @return
	 */
	public static Reader getReader() {
		return LasyHolder.READER;
	}
	
	/**
	 * 執行緒本地配置宣告
	 */
	public static ThreadLocal<SqlSessionFactory> threadLocal = new ThreadLocal<SqlSessionFactory>();
	
	/**
	 * ThreadLocal獲取SqlSessionFactory
	 * @return
	 */
	public static SqlSessionFactory getSqlSessionFactory() {
		// 獲取sqlSessionFactory
		SqlSessionFactory sqlSessionFactory = threadLocal.get();
		
		System.out.println("sqlSessionFactory: " + sqlSessionFactory);
		if (sqlSessionFactory == null) {
			System.out.println("sqlSessionFactory is null 重新獲取SqlSessionFactory!");
			// 讀取mybatis配置檔案
			Reader reader = SessionUtils.getReader();
			
			// 重新建立SqlSessionFactory
			sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
			
			// 把sqlSessionFactory新增到ThreadLocal中
			threadLocal.set(sqlSessionFactory);
		}
		
		// 返回
		return sqlSessionFactory;
	}

}

7）新增員工新增測試類AddEmployeeTest.java，執行該方法之後可自行到mysql資料庫檢視。

package com.xm.mybatis.test;

import java.util.Date;

import org.apache.ibatis.session.SqlSession;

import com.xm.mybatis.dao.EmployeeDAO;
import com.xm.mybatis.entity.EmployeeEntity;
import com.xm.mybatis.utils.SessionUtils;

public class AddEmployeeTest {

	public static void main(String[] args) {
		// 獲取SqlSession
		SqlSession sqlSession = null;
		
		try {
			sqlSession = SessionUtils.getSqlSessionFactory().openSession();
			
			// 初始化介面
			EmployeeDAO employeeDAO = sqlSession.getMapper(EmployeeDAO.class);
			
			EmployeeEntity emp = new EmployeeEntity();
			emp.setEmpId(100000);
			emp.setEmpName("ouyangjun");
			emp.setEmpNO("333333");
			emp.setCreateDate(new Date().getTime());
			
			// 持久化
			employeeDAO.addEmployee(emp);
			
			emp = new EmployeeEntity();
			emp.setEmpId(200000);
			emp.setEmpName("xm");
			emp.setEmpNO("888888");
			emp.setCreateDate(new Date().getTime());
			
			// 持久化
			employeeDAO.addEmployee(emp);
			
			// 提交事務
			sqlSession.commit();
			
			System.out.println("==>員工資料持久化成功!");
		} catch (Exception e){
			e.printStackTrace();
			sqlSession.rollback();
			
			System.out.println("==>員工資料持久化失敗!");
		} finally {
			sqlSession.close();
			
			System.out.println("==>事務關閉!");
		}
	}

}

8）新增員工查詢測試類GetEmployeeTest.java

package com.xm.mybatis.test;

import java.io.IOException;

import org.apache.ibatis.session.SqlSession;

import com.xm.mybatis.dao.EmployeeDAO;
import com.xm.mybatis.entity.EmployeeEntity;
import com.xm.mybatis.utils.SessionUtils;

public class GetEmployeeTest {

	public static void main(String[] args) throws IOException {
		
		// 獲取SqlSession
		SqlSession sqlSession = SessionUtils.getSqlSessionFactory().openSession();
		
		// 初始化介面
		EmployeeDAO employeeDAO = sqlSession.getMapper(EmployeeDAO.class);
		
		EmployeeEntity entity = employeeDAO.getEmployeeByEmpId("100000");
		if(entity!=null){
			System.out.println(entity.getEmpId()+" "+entity.getEmpName()+" "+entity.getEmpNO());
		} else {
			System.out.println("根據empId未查詢到資料!");
		}
		
		System.out.println("----------測試SqlSessionFactory單列----------");
		
		sqlSession = SessionUtils.getSqlSessionFactory().openSession();
		// 初始化介面
		employeeDAO = sqlSession.getMapper(EmployeeDAO.class);
		entity = employeeDAO.getEmployeeByEmpId("100000");
		if(entity!=null){
			System.out.println(entity.getEmpId()+" "+entity.getEmpName()+" "+entity.getEmpNO());
		} else {
			System.out.println("根據empId未查詢到資料!");
		}
		
		sqlSession.close();
	}

}

查詢效果圖如下：

9）新增員工刪除測試類DeleteEmployeeTest.java

package com.xm.mybatis.test;

import java.io.IOException;

import org.apache.ibatis.session.SqlSession;

import com.xm.mybatis.dao.EmployeeDAO;
import com.xm.mybatis.utils.SessionUtils;

public class DeleteEmployeeTest {

	public static void main(String[] args) throws IOException {
		
		// 獲取SqlSession
		SqlSession sqlSession = null;
		
		try {
			sqlSession = SessionUtils.getSqlSessionFactory().openSession();
			
			// 初始化介面
			EmployeeDAO employeeDAO = sqlSession.getMapper(EmployeeDAO.class);
			
			String[] empIds = {"100000","200000"};
			employeeDAO.deleteEmployeeEntityByEmpId(empIds);
			
			sqlSession.commit();
			
			System.out.println("==>員工資料刪除成功!");
		} catch (Exception e){
			e.printStackTrace();
			sqlSession.rollback();
			
			System.out.println("==>員工資料刪除失敗!");
		} finally {
			sqlSession.close();
			
			System.out.println("==>事務關閉!");
		}
	}

}

本章完結，待續！

                      碼雲賬戶: [email protected]     密碼: [email protected]

                      請勿惡意操作，謝謝！

本文說明：該文章屬於原創，如需轉載，請標明文章轉載來源