下面來討論mybatis開發Dao的方法

先來說一下基本架構流程中使用到的幾個類
1.SqlSession使用範圍

1.1SqlSessionFactoryBuilder
 通過SqlSessionFactoryBuilder建立會話工廠SqlSessionFactory
將SqlSessionFactoryBuilder當成一個工具類使用即可，不需要使用單例管理SqlSessionFactoryBuilder。
在需要建立SqlSessionFactory時候，只需要new一次SqlSessionFactoryBuilder即可。

1.2SqlSessionFactory
通過SqlSessionFactory建立SqlSession，使用單例模式管理sqlSessionFactory（工廠一旦建立，使用一個例項）。

將來mybatis和spring整合後，使用單例模式管理sqlSessionFactory。

1.3SqlSession
SqlSession是一個面向使用者（程式設計師）的介面。
SqlSession中提供了很多操作資料庫的方法：如：selectOne(返回單個物件)、selectList（返回單個或多個物件）。

SqlSession是執行緒不安全的，在SqlSesion實現類中除了有介面中的方法（操作資料庫的方法）還有資料域屬性。

SqlSession最佳應用場合在方法體內，定義成區域性變數使用。

接下來就來說說MyBatis的Dao的寫法，分為兩種，一種是原始Dao開發方法，一種是mapper代理方法，我們下面一一討論：

2.原始dao開發方法（程式設計師需要寫dao介面和dao實現類）

2.1思路：程式設計師需要寫dao介面和dao實現類。
需要向dao實現類中注入SqlSessionFactory，在方法體內通過SqlSessionFactory建立SqlSession。

下面實現Dao的場景是基於之前對使用者資料進行增刪改查的需求。

2.2寫Dao介面

package cn.edu.hpu.mybatis.dao;

import cn.edu.hpu.mybatis.PO.User;

//使用者管理的Dao介面
public interface UserDao {
	
	//根據Id查詢使用者資訊
	public User findUserById(int id) throws Exception;
	
	//新增使用者資訊
	public void insertUser(User user) throws Exception;
	
	//刪除使用者資訊
	public void deleteUser(int id) throws Exception;
	
	//修改使用者資訊
	public void updateUser(User user) throws Exception;
}
 

2.3寫Dao的實現

package cn.edu.hpu.mybatis.dao;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;

import cn.edu.hpu.mybatis.PO.User;

public class UserDaoImpl implements UserDao{

	//需要向dao實現類中注入SqlSessionFactory工廠
	//這裡我們暫時沒用spring，我們通過構造方法注入
	private SqlSessionFactory sqlSessionFactory;
	public UserDaoImpl(SqlSessionFactory sqlSessionFactory){
		this.sqlSessionFactory=sqlSessionFactory;
	}
	
	@Override
	public void deleteUser(int id) throws Exception {
		
		SqlSession sqlSession=sqlSessionFactory.openSession();
		
		//傳入id刪除使用者
		sqlSession.delete("test.deleteUser",id);
		
		//提交事務
		sqlSession.commit();
		
		sqlSession.close();
	}


	@Override
	public User findUserById(int id) throws Exception {
		SqlSession sqlSession=sqlSessionFactory.openSession();
		
		User user=sqlSession.selectOne("test.findUserById",id);
		
		//釋放資源
		sqlSession.close();
		return user;
	}


	@Override
	public void insertUser(User user) throws Exception {
		
		SqlSession sqlSession=sqlSessionFactory.openSession();
		
		sqlSession.insert("test.insertUser",user);
		
		//提交事務
		sqlSession.commit();
		
		//釋放資源
		sqlSession.close();
		
	}


	@Override
	public void updateUser(User user) throws Exception {
		
		SqlSession sqlSession=sqlSessionFactory.openSession();
		
		sqlSession.update("test.updateUser",user);
		
		//提交事務
		sqlSession.commit();
		
		sqlSession.close();
		
	}


}
 

測試方法(這裡只測試findUserBiId方法)：

package cn.edu.hpu.mybatis.test;

import java.io.InputStream;

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 cn.edu.hpu.mybatis.PO.User;
import cn.edu.hpu.mybatis.dao.UserDao;
import cn.edu.hpu.mybatis.dao.UserDaoImpl;


public class UserDaoImplTest {


	private SqlSessionFactory sqlSessionFactory;
	
	//註解Before是在執行本類所有測試方法之前先呼叫這個方法
	@Before
	public void setup() throws Exception{
		//建立SqlSessionFactory
		String resource="SqlMapConfig.xml";
		
		//將配置檔案載入成流
		InputStream inputStream = Resources.getResourceAsStream(resource);
		//建立會話工廠，傳入mybatis配置檔案的資訊
		sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
	}
	
	@Test
	public void testFindUserById() throws Exception{
		
		//建立Dao物件
		UserDao userDao=new UserDaoImpl(sqlSessionFactory);
		
		//呼叫UserDao的方法
		User user=userDao.findUserById(1);
		
		System.out.println(user.getUsername());
		
	}
	
}
 

測試結果:
張三

輸出的日誌：

DEBUG [main] - Logging initialized using 'class org.apache.ibatis.logging.slf4j.Slf4jImpl' adapter.
DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
DEBUG [main] - PooledDataSource forcefully closed/removed all connections.
DEBUG [main] - Opening JDBC Connection
DEBUG [main] - Created connection 28970806.
DEBUG [main] - Setting autocommit to false on JDBC Connection [[email protected]]
DEBUG [main] - ==>  Preparing: SELECT * FROM USER WHERE id=? 
DEBUG [main] - ==> Parameters: 1(Integer)
DEBUG [main] - <==      Total: 1
DEBUG [main] - Resetting autocommit to true on JDBC Connection [[email protected]]
DEBUG [main] - Closing JDBC Connection [[email protected]]
DEBUG [main] - Returned connection 28970806 to pool.

2.4總結原始 dao開發問題
1、dao介面實現類方法中存在大量模板方法，設想能否將這些程式碼提取出來，大大減輕程式設計師的工作量。


2、呼叫sqlsession方法時將statement的id硬編碼了


3、呼叫sqlsession方法時傳入的變數，由於sqlsession方法使用泛型，即使變數型別傳入錯誤，在編譯階段也不報錯，不利於程式設計師開發。

下一篇總結我們來使用mapper代理方法來寫Dao，來解決上面我們發現的問題。