1、MyBatis對資料庫表進行增/刪/改/查

前一篇使用基於XML的方式實現對資料庫的增/刪/改/查

下面我們來看怎麼使用註解的方式實現對資料庫表的增/刪/改/查

1.1  首先需要定義對映sql的介面，程式碼如下：

package org.guus.inter;

import java.util.List;

import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import org.guus.bean.User;

/**
 * 
 * @描述：定義sql對映的介面，使用註解指明方法要執行的SQL
 * @author Guus
 * @date 2015年8月7日
 */
public interface UserMapperInterface {

    //使用@Insert註解指明add方法要執行的SQL
    @Insert("insert into users(name, age) values(#{name}, #{age})")
    public int add(User user);
    
    //使用@Delete註解指明deleteById方法要執行的SQL
    @Delete("delete from users where id=#{id}")
    public int deleteById(int id);
    
    //使用@Update註解指明update方法要執行的SQL
    @Update("update users set name=#{name},age=#{age} where id=#{id}")
    public int update(User user);
    
    //使用@Select註解指明getById方法要執行的SQL
    @Select("select * from users where id=#{id}")
    public User getById(int id);
    
    //使用@Select註解指明getAll方法要執行的SQL
    @Select("select * from users")
    public List<User> getAll();
}
 

<?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>
	<environments default="development">
		<environment id="development">
			<transactionManager type="JDBC" />
			<!-- 配置資料庫連線資訊 -->
			<dataSource type="POOLED">
				<property name="driver" value="com.mysql.jdbc.Driver" />
				<property name="url" value="jdbc:mysql://localhost:3306/mybatis" />
				<property name="username" value="root" />
				<property name="password" value="2015" />
			</dataSource>
		</environment>
	</environments>

	<mappers>
		<!-- 註冊userMapper.xml檔案， userMapper.xml位於org.guus.mapping這個包下，
		所以resource寫成org/guus/mapping/userMapper.xml -->
		<mapper resource="org/guus/mapping/userMapper.xml" />
		<!-- 註冊UserMapper對映介面-->
        <mapper class="org.guus.inter.UserMapperInterface"/>
	</mappers>

</configuration>
 

1.3  下面我們編寫測試類進行測試 ，測試類中用的SessionUtil是一個獲取Session的工具類，具體見：MyBatis -- 對錶進行增刪改查(基於XML的實現)

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.inter.UserMapperInterface;
import org.guus.utils.SessionUtil;
import org.junit.Test;

/**
 * 
 * @描述：測試MyBatis的CURD操作  -- 基於註解
 * @author Guus
 * @date 2015年8月7日
 */
public class TestCURD2 {

    @Test
    public void Add() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);  //true代表自動提交事務
        //得到UserMapperI介面的實現類物件，UserMapperI介面的實現類物件由sqlSession.getMapper(UserMapperI.class)動態構建出來
        UserMapperInterface mapper = sqlSession.getMapper(UserMapperInterface.class);
        User user = new User();
        user.setName("Guus3");
        user.setAge(3);
        //執行插入操作
        int retResult = mapper.add(user);
        //使用SqlSession執行完SQL之後需要關閉SqlSession
        sqlSession.close();
        System.out.println("Add操作返回值----> "+retResult);
    }
    
    @Test
    public void Update() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);
        UserMapperInterface mapper = sqlSession.getMapper(UserMapperInterface.class);
        User user = new User();
        user.setId(3);
        user.setName("Guus333");
        user.setAge(4);
        //執行修改操作
        int retResult = mapper.update(user);
        sqlSession.close();
        System.out.println("Update操作返回值----> "+retResult);
    }
    
    @Test
    public void Delete() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession(true);
        UserMapperInterface mapper = sqlSession.getMapper(UserMapperInterface.class);
        //執行刪除操作
        int retResult = mapper.deleteById(2);
        sqlSession.close();
        System.out.println("Delete操作返回值----> "+retResult);
    }
    
    @Test
    public void GetAll() throws IOException{
        SqlSession sqlSession = SessionUtil.getSqlSession();
        UserMapperInterface mapper = sqlSession.getMapper(UserMapperInterface.class);
        //執行查詢操作，將查詢結果自動封裝成List<User>返回
        List<User> lstUsers = mapper.getAll();
        sqlSession.close();
        System.out.println("GetAll操作返回值----> "+lstUsers);
    }
}