Mybatis實現簡單的CRUD（增刪改查）原理及實例分析筆記【全】

Mybatis實現簡單的CRUD（增刪改查）

用到的數據庫：

CREATE DATABASE `mybatis`;
USE `mybatis`;
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
  `id` int(20) NOT NULL,
  `name` varchar(30) DEFAULT NULL,
  `pwd` varchar(30) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
insert  into `user`(`id`,`name`,`pwd`) values (1,'靠譜楊','123456'),(2,'張三','abcdef'),(3,'李四','987654');

使用之前要在Maven中導入Mybatis依賴包

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis</artifactId>
    <version>3.5.2</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.47</version>
</dependency>

官方的MyBatis核心配置文件mybatis-config.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>
    <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?	
                	useSSL=false&amp;useUnicode=true&amp;characterEncoding=utf8"/>
                <property name="username" value="root"/>
                <property name="password" value="000429"/>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="com/kuang/dao/userMapper.xml"/>
    </mappers>
</configuration>

---

注意

** **

這里很有可能會報錯，需要解決Maven靜態資源過濾問題，Maven有習慣大於配置原則

在pom.xml文件中加入以下代碼：

    <build>
        <resources>
            <resource>
                <directory>src/main/resources</directory>
                <includes>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
        </resources>
    </build>

注意配置完之后刷新maven！

---

簡單數據類型User.java：

package com.kuang.pojo;
public class User {
	private int id;  //id
	private String name;   //姓名
	private String pwd;   //密碼
	//構造,有參,無參
	//set/get
	//toString()

	@Override
	public String toString() {
		return "User{" +
				"id=" + id +
				", name='" + name + '\'' +
				", pwd='" + pwd + '\'' +
				'}';
	}

	public User(){}
	public int getId() {
		return id;
	}

	public void setId(int id) {
		this.id = id;
	}

	public User(int id, String name, String pwd) {

		this.id = id;
		this.name = name;
		this.pwd = pwd;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getPwd() {
		return pwd;
	}

	public void setPwd(String pwd) {
		this.pwd = pwd;
	}
}

數據接口層UserMapper.java：

public interface UserMapper {
	//查詢全部用戶
	List<User> getUserList();
	//根據ID查詢用戶
	User getUserByID(int id);
	//insert一個用戶
	int addUser(User user);
	//update一個用戶
	int updateUser(User user);
	//delete一個用戶
	int deleteUser(User user);
}

用戶定義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">
<mapper namespace="com.kuang.dao.UserMapper">
    
    <select id="getUserList" resultType="com.kuang.pojo.User">
    select * from user
    </select>
    
    <select id="getUserByID" resultType="com.kuang.pojo.User" parameterType="int">
    select * from user WHERE id = #{id}
    </select>
    
    <!--對象中的屬性可以直接取出來 -->
    <insert id="addUser" parameterType="com.kuang.pojo.User">
        insert into mybatis.user (id,name,pwd) values (#{id},#{name},#{pwd});
    </insert>

    <update id="updateUser" parameterType="com.kuang.pojo.User">
        update mybatis.user set name = #{name} , pwd=#{pwd} where id = #{id} ;
    </update>
    
    <delete id="deleteUser" parameterType="com.kuang.pojo.User" >
        delete from mybatis.user where id = #{id}
    </delete>
</mapper>

這里我們可以發現：數據接口是和xml對應的，xml文件實例了這個接口和里面的方法，namespace就是這個接口的名字，里面的select標簽對應這個接口里的一個方法，id就是方法名，resultType對應這個方法的返回值類型。

xml文件namespace的包名要和Dao/Mapper接口類名保持一致！

• id（getUserList）：就是對應的namespace中的方法名（ List getUserList(); ）
• resultType：是SQL語句執行后的返回值！（Class、基本數據類型）
• parameterType：參數類型！
• delete from mybatis.user where id = #{id} 分析這個sql語句，賦值方式和JDBC有所不同，使用這樣的格式#{ } 里面的參數是這個方法參數User對象里的成員屬性 id 可以直接放到這里用！

配置工具類（MybatisUtils.java）獲取連接對象:

package com.kuang.utils;

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

import java.io.IOException;
import java.io.InputStream;

public class MybatisUtils {
	//從SqlSessionFactory中獲得SqlSession的實例，SqlSession完全包含了SQL命令的執行方法
	private static SqlSessionFactory sqlSessionFactory;
	static {
		try {
			String resource = "mybatis-config.xml";
			InputStream inputStream = Resources.getResourceAsStream(resource);
            //讀取配置文件獲取連接
			sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	//返回獲取的SqlSession連接
	public static SqlSession getSession(){
		return sqlSessionFactory.openSession();
	}
}

分析一下這個工具類：

首先這個SqlSessionFactory類是一個工廠類，這個工廠可以產生傳統JDBC方法中獲得的PreparedStatement對象。也就是這個工具類要完成和JDBCutils同樣的任務，首先獲取和數據庫的連接，那么第一步也就是讀取用戶配置的mybatis-config.xml文件，可以得到一個數據庫連接對象，之后用這個對象去獲得一個類似於PreparedStatement對象的SqlSession類的對象。

---

下面給出具體的調用方法（UserDaoTest.java）：

import com.kuang.dao.UserMapper;
import com.kuang.pojo.User;
import com.kuang.utils.MybatisUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;
import java.util.List;
public class UserDaoTest {
	@Test
	public void test(){
		//sqlSession對象相當於是一個JDBC的PreparedStatement對象,這個對象可以執行sql語句
		//我們現在做的事情就是：獲取數據庫連接，得到sqlSession對象，通過這個對象去實現我們定義的數據操作接口
		//UserMapper，這個接口再通過解析我們定義的userMapper.xml文件去執行帶有SQL語句的特定方法。
		SqlSession sqlSession = MybatisUtils.getSession();
		UserMapper mapper = sqlSession.getMapper(UserMapper.class);
//		List<User> userList = mapper.getUserList();
//		for (User user : userList)
//		{
//			System.out.println(user);
//		}
		//根據ID取
		/*User user=mapper.getUserByID(1);
		System.out.println(user);
		sqlSession.close();*/
		//更新一條數據 id為1
//		updateUser();
		//刪除一個用戶
		deleteUser();
	}
	public void addUser(){
		SqlSession sqlSession = MybatisUtils.getSession();
		UserMapper mapper = sqlSession.getMapper(UserMapper.class);
		//插入一條數據
		User user = new User(4, "名字", "密碼");
		int res = mapper.addUser(user);
		if (res>0){
			System.out.println("插入成功！");
		}
		//提交事務
		sqlSession.commit();
		sqlSession.close();
	}
	public void updateUser(){
		//獲得連接coon和執行sql語句的對象 類似JDBC的PreparedStatement
		SqlSession sqlSession = MybatisUtils.getSession();
		//實現UserMapper接口 通過反射機制
		UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
		User user = new User(1, "修改后的名字", "resetpass01");
		userMapper.updateUser(user);
		sqlSession.commit();
		sqlSession.close();
	}

	public void deleteUser(){
		//獲取連接
		SqlSession sqlSession = MybatisUtils.getSession();
		//實現接口
		UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
		//實現接口后的mapper調用自己的方法執行sql語句
		userMapper.deleteUser(new User(1,"sss","123"));
		sqlSession.commit();
		sqlSession.close();
	}
}

分析一下這兩行代碼：

	SqlSession sqlSession = MybatisUtils.getSession();
	UserMapper mapper = sqlSession.getMapper(UserMapper.class);

• 第一行代碼，通過MybatisUtils類的getSession方法獲得一個sqlSession對象，這個對象是一個已經連接了數據庫的可以執行sql語句的對象（類似JDBC的PreparedStatement對象）
• 這樣還不夠，這只是停留在工具類層面，下面要做的一件事情就是讓這個工具類去實現用戶自定義的數據層接口，從而可以根據用戶定義的數據操作方法去執行相應的sql語句，進而得到相應的結果集。