@
使用MyBatis開發Dao，通常有兩個方法，即原始Dao開發方法和Mapper動態代理開發方法。原始Dao開發中存在以下問題：
Dao方法體存在重復代碼：通過SqlSessionFactory創建SqlSession，調用SqlSession的數據庫操作方法
調用sqlSession的數據庫操作方法需要指定statement的id，這里存在硬編碼，不得於開發維護。
而動態代理開發中Mapper接口開發方法只需要程序員編寫Mapper接口（相當於Dao接口），由
Mybatis框架根據接口定義創建接口的動態代理對象，代理對象的方法體同上邊Dao接口實現類方法。
使用mapper代理的方法來開發dao時，程序員只需要干兩件事即可：
1、編寫mapper.xml映射文件
2、編寫mapper接口（相當於dao接口）
Mapper接口開發需要遵循以下四個規范(建議初學者結合下圖理解)：
1、Mapper.xml文件中的namespace與mapper接口的類路徑相同。
2、Mapper接口方法名和Mapper.xml中定義的每個statement的id相同
3、Mapper接口方法的輸入參數類型和mapper.xml中定義的每個sql 的parameterType的類型相同
4、Mapper接口方法的輸出參數類型和mapper.xml中定義的每個sql的resultType的類型相同
咳咳...初學者看文字（Mapper接口開發四個規范）屬實有點費勁，博主我就廢了點勁做了如下圖，方便理解：
原始Dao開發方式
原始Dao開發方法需要程序員編寫Dao接口和Dao實現類。
1. 編寫映射文件
編寫映射文件如下：（也可以使用入門程序完成的映射文件）
<?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">
<!-- namespace：命名空間，用於隔離sql，還有一個很重要的作用，后面會講 -->
<mapper namespace="test">
<!-- 根據id查詢用戶 -->
<select id="queryUserById" parameterType="int"
resultType="com.gx.mybatis.pojo.User">
select * from user where id = #{id}
</select>
<!-- 根據username模糊查詢用戶 -->
<select id="queryUserByUsername" parameterType="string"
resultType="com.gx.mybatis.pojo.User">
select * from user where username like '%${value}%'
</select>
<!-- 保存用戶 -->
<insert id="saveUser" parameterType="com.gx.mybatis.pojo.User">
<selectKey keyProperty="id" keyColumn="id" order="AFTER"
resultType="int">
SELECT LAST_INSERT_ID()
</selectKey>
insert into user(username,birthday,sex,address)
values(#{username},#{birthday},#{sex},#{address})
</insert>
</mapper>
2. 編寫Dao接口
先進行DAO的接口開發，編碼如下：
public interface UserDao {
/**
* 根據id查詢用戶
*
* @param id
* @return
*/
User queryUserById(int id);
/**
* 根據用戶名模糊查詢用戶
*
* @param username
* @return
*/
List<User> queryUserByUsername(String username);
/**
* 保存用戶
*
* @param user
*/
void saveUser(User user);
}
3.編寫Dao實現類
編寫的Dao實現類如下
public class UserDaoImpl implements UserDao {
private SqlSessionFactory sqlSessionFactory;
public UserDaoImpl(SqlSessionFactory sqlSessionFactory) {
super();
this.sqlSessionFactory = sqlSessionFactory;
}
@Override
public User queryUserById(int id) {
// 創建SqlSession
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 執行查詢邏輯
User user = sqlSession.selectOne("queryUserById", id);
// 釋放資源
sqlSession.close();
return user;
}
@Override
public List<User> queryUserByUsername(String username) {
// 創建SqlSession
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 執行查詢邏輯
List<User> list = sqlSession.selectList("queryUserByUsername", username);
// 釋放資源
sqlSession.close();
return list;
}
@Override
public void saveUser(User user) {
// 創建SqlSession
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 執行保存邏輯
sqlSession.insert("saveUser", user);
// 提交事務
sqlSession.commit();
// 釋放資源
sqlSession.close();
}
}
4.編寫Dao測試
創建一個JUnit的測試類，對UserDao進行測試（充當main方法），測試代碼如下：
public class UserDaoTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void init() throws Exception {
// 創建SqlSessionFactoryBuilder
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 加載SqlMapConfig.xml配置文件
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
// 創建SqlsessionFactory
this.sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
}
@Test
public void testQueryUserById() {
// 創建DAO
UserDao userDao = new UserDaoImpl(this.sqlSessionFactory);
// 執行查詢
User user = userDao.queryUserById(1);
System.out.println(user);
}
@Test
public void testQueryUserByUsername() {
// 創建DAO
UserDao userDao = new UserDaoImpl(this.sqlSessionFactory);
// 執行查詢
List<User> list = userDao.queryUserByUsername("五");
for (User user : list) {
System.out.println(user);
}
}
@Test
public void testSaveUser() {
// 創建DAO
UserDao userDao = new UserDaoImpl(this.sqlSessionFactory);
// 創建保存對象
User user = new User();
user.setUsername("孫尚香腸");
user.setBirthday(new Date());
user.setSex("1");
user.setAddress("蜀國");
// 執行保存
userDao.saveUser(user);
System.out.println(user);
}
}
Mapper動態代理方式
1.定義Mapper.xml(映射文件)
定義mapper映射文件UserMapper.xml
將UserMapper.xml放在config下mapper目錄下，效果如下：
2、編寫UserMapper.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">
<!-- namespace：命名空間，用於隔離sql -->
<!-- 還有一個很重要的作用，使用動態代理開發DAO，1. namespace必須和Mapper接口類路徑一致 -->
<mapper namespace="com.gx.mybatis.mapper.UserMapper">
<!-- 根據用戶id查詢用戶 -->
<!-- 2. id必須和Mapper接口方法名一致 -->
<!-- 3. parameterType必須和接口方法參數類型一致 -->
<!-- 4. resultType必須和接口方法返回值類型一致 -->
<select id="queryUserById" parameterType="int"
resultType="com.gx.mybatis.pojo.User">
select * from user where id = #{id}
</select>
<!-- 根據用戶名查詢用戶 -->
<select id="queryUserByUsername" parameterType="string"
resultType="com.gx.mybatis.pojo.User">
select * from user where username like '%${value}%'
</select>
<!-- 保存用戶 -->
<insert id="saveUser" parameterType="com.gx.mybatis.pojo.User">
<selectKey keyProperty="id" keyColumn="id" order="AFTER"
resultType="int">
select last_insert_id()
</selectKey>
insert into user(username,birthday,sex,address) values
(#{username},#{birthday},#{sex},#{address});
</insert>
</mapper>
3.編寫UserMapper(接口文件)
創建UserMapper接口代碼如下：
public interface UserMapper {
/**
* 根據id查詢
*
* @param id
* @return
*/
User queryUserById(int id);
/**
* 根據用戶名查詢用戶
*
* @param username
* @return
*/
List<User> queryUserByUsername(String username);
/**
* 保存用戶
*
* @param user
*/
void saveUser(User user);
}
4.加載UserMapper.xml文件
修改SqlMapConfig.xml文件，添加以下所示的內容：
<!-- 加載映射文件 -->
<mappers>
<mapper resource="sqlmap/User.xml" />
<mapper resource="mapper/UserMapper.xml" />
</mappers>
5.編寫測試
編寫的測試方法如下：
public class UserMapperTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void init() throws Exception {
// 創建SqlSessionFactoryBuilder
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
// 加載SqlMapConfig.xml配置文件
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
// 創建SqlsessionFactory
this.sqlSessionFactory = sqlSessionFactoryBuilder.build(inputStream);
}
@Test
public void testQueryUserById() {
// 獲取sqlSession，和spring整合后由spring管理
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 從sqlSession中獲取Mapper接口的代理對象
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
// 執行查詢方法
User user = userMapper.queryUserById(1);
System.out.println(user);
// 和spring整合后由spring管理
sqlSession.close();
}
@Test
public void testQueryUserByUsername() {
// 獲取sqlSession，和spring整合后由spring管理
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 從sqlSession中獲取Mapper接口的代理對象
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
// 執行查詢方法
List<User> list = userMapper.queryUserByUsername("五");
for (User user : list) {
System.out.println(user);
}
// 和spring整合后由spring管理
sqlSession.close();
}
@Test
public void testSaveUser() {
// 獲取sqlSession，和spring整合后由spring管理
SqlSession sqlSession = this.sqlSessionFactory.openSession();
// 從sqlSession中獲取Mapper接口的代理對象
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
// 創建保存對象
User user = new User();
user.setUsername("劉備胎");
user.setBirthday(new Date());
user.setSex("2");
user.setAddress("鼠國");
// 執行查詢方法
userMapper.saveUser(user);
System.out.println(user);
// 和spring整合后由spring管理
sqlSession.commit();
sqlSession.close();
}
}
如果本文對你有一點點幫助，那么請點個贊唄，謝謝~
最后，若有不足或者不正之處，歡迎指正批評，感激不盡！如果有疑問歡迎留言，絕對第一時間回復！
歡迎各位關注我的公眾號，一起探討技術，向往技術，追求技術，說好了來了就是盆友喔...
