MyBatis -- 對錶進行增刪改查(基於XML的實現)

一、MyBatis對錶中數據進行增/刪/改/查操做

在前一篇中已經知道怎麼搭建環境而且查詢數據庫  MyBatis -- 一步步教你使用MyBatis

接下來咱們來看看怎麼用MyBatis進行增/.刪/改/查

1.1  定義映射sql的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，namespace的值習慣上設置成包名+sql映射文件名，這樣就可以保證namespace的值是惟一的 -->
<mapper namespace="org.guus.mapping.userMapper">
<!-- 在select標籤中編寫查詢的SQL語句設置select標籤的id屬性爲getUser，id屬性值必須是惟一的，不可以重複，使用parameterType屬性指明查詢時使用的參數類型， 
		resultType屬性指明查詢返回的結果集類型 resultType="org.guus.bean.User"就表示將查詢結果封裝成一個User類的對象返回 
		User類就是users表所對應的實體類 -->
	<!-- 根據id查詢獲得一個user對象 -->
	<select id="getUser" parameterType="int" resultType="org.guus.bean.User">
		select *
		from users where id=#{id}
	</select>

	<!-- 添加用戶 -->
	<insert id="addUser" parameterType="org.guus.bean.User">
		insert into users(name,age) values(#{name},#{age})
	</insert>

	<!-- 刪除用戶 -->
	<delete id="deleteUser" parameterType="int">
		delete from users where id=#{id}
	</delete>

	<!-- 修改用戶 -->
	<update id="updateUser" parameterType="org.guus.bean.User">
		update users set name=#{name},age=#{age} where id=#{id}
	</update>

	<!-- 查詢所有用戶 -->
	<select id="getAllUsers" resultType="org.guus.bean.User">
		select * from users
	</select>
</mapper>

1 .2  獲取session的工具類

第一篇中有獲取session的詳細說明，下面咱們將它寫成工具類，內容以下：

package org.guus.utils;
import java.io.IOException;
import java.io.Reader;

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

/**
 * 
 * @描述：獲取sesson的工具類
 * @author Guus
 * @date 2015年8月6日
 */
public class SessionUtil {

    /**
     * 獲取SqlSessionFactory
     * @return SqlSessionFactory
     * @throws IOException 
     */
    public static SqlSessionFactory getSqlSessionFactory() throws IOException {
    	String resource = "mybatis-config.xml";    
        Reader reader = Resources.getResourceAsReader(resource);    
        SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();    
        SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(reader);
        return sqlSessionFactory;
    }
    
    /**
     * 獲取SqlSession
     * @return SqlSession
     * @throws IOException 
     */
    public static SqlSession getSqlSession() throws IOException {
        return getSqlSessionFactory().openSession();
    }
    
    /**
     * 獲取SqlSession
     * @param isAutoCommit 
     *         true 表示建立的SqlSession對象在執行完SQL以後會自動提交事務
     *         false 表示建立的SqlSession對象在執行完SQL以後不會自動提交事務，
     *         		這時就須要咱們手動調用sqlSession.commit()提交事務
     * @return SqlSession
     * @throws IOException 
     */
    public static SqlSession getSqlSession(boolean isAutoCommit) throws IOException {
        return getSqlSessionFactory().openSession(isAutoCommit);
    }
}

1 .3  測試，編寫測試類

首先咱們須要添加Junit 以下圖：

右擊項目-->選擇properties-->選擇java  Build Path

下一步以後選擇版本，而後確認就行了。下面能夠看到junit已經加進來了，點擊ok便可。

下面編寫測試類

package org.guus.test;

import java.io.IOException;
import java.util.List;

import org.apache.ibatis.session.SqlSession;
import org.guus.bean.User;
import org.guus.utils.SessionUtil;
import org.junit.Test;

/**
 * 
 * @描述：測試MyBatis的CURD操做
 * @author Guus
 * @date 2015年8月6日
 */
public class TestCURD {

    @Test
    public void Add() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);  //true表明自動提交事務
        String statement = "org.guus.mapping.userMapper.addUser";//映射sql的標識字符串
        User user = new User();
        user.setName("Guus3");
        user.setAge(3);
        //執行插入操做
        int retResult = sqlSession.insert(statement,user);
        //使用SqlSession執行完SQL以後須要關閉SqlSession
        sqlSession.close();
        System.out.println("Add操做返回值----> "+retResult);
    }
    
    @Test
    public void Update() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);
        String statement = "org.guus.mapping.userMapper.updateUser";//映射sql的標識字符串
        User user = new User();
        user.setId(3);
        user.setName("Guus3-修改");
        user.setAge(4);
        //執行修改操做
        int retResult = sqlSession.update(statement,user);
        sqlSession.close();
        System.out.println("Update操做返回值----> "+retResult);
    }
    
    @Test
    public void Delete() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);
        String statement = "org.guus.mapping.userMapper.deleteUser";//映射sql的標識字符串
        //執行刪除操做
        int retResult = sqlSession.delete(statement,1);
        sqlSession.close();
        System.out.println("Delete操做返回值----> "+retResult);
    }
    
    @Test
    public void GetAll() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession();
        String statement = "org.guus.mapping.userMapper.getAllUsers";//映射sql的標識字符串
        //執行查詢操做，將查詢結果自動封裝成List<User>返回
        List<User> lstUsers = sqlSession.selectList(statement);
        //使用SqlSession執行完SQL以後須要關閉SqlSession
        sqlSession.close();
        System.out.println("GetAll操做返回值----> "+lstUsers);
    }
}

  右鍵點擊run as  -->  而後選擇junit  test  能夠看到返回結果以下，咱們能夠看到各個操做成功時的返回值！