SSM-6-Mybatis

什么是Mybatis
Mybatis工作原理
Mybatis入门

Mybatis是orm框架

Mybatis工作原理

从图 6-4 可以看出， MyBati 框架在操作数据库时，大体经过了个步骤下面就对图 6-4 中的每一步流程进行详细讲解，具体如下

( 1 )读取 MyBatis 配置文件 mybatis-config .xml mybatis-config.xml 作为 MyBatis 的全局配置文件，配置了 MyBatis 的运行环境等信息，其中主要内容是获取数据库连接。

(2 )加载映射文件 Mapper.xml Mapper.xml 文件即 SQL 映射文件，该文件中配置了操作数据库的 SOL 语句，需要在 mybatis-config .xml 中加载才能执行mybatis-config.xml 可以加载多个配置文件，每个配置文件对应数据库中的一张表

(3 )构建会话通过 MyBatis 的环境等配置信息构建会话工厂 SqlSessionFactory

(4 )创 SqlSession 对象由会话工厂创建 SqlSession 对象，该对象中包含了执行 SOL 的所有方法

(5) MyBatis 底层定义了一个 Executor 接口来操作数据库，它会根据 SqlSession 传递的参数动态地生成需要执行的 SOL 语句，同时负责查询缓存的维护。

(6 )在 Executor 接口的执行方法中，包含一个 MappedStatement 类型的参数，该参数是对映射信息的封装用于存储要映射的 SQL 语句的 id 、参数等 Mapper.xml 文件中一个 SOL 对应一个 MappedStatement 对象 SQL id 即是 MappedStatement id

( 7 )输入参数映射在执行方法时， MappedStatement 对象会对用户执行 SQL 语句的输入参数进行定义(可以定义为 Map 、Li st 类型、基本类型和 POJO 类型 Executor 执行器会通过 MappedStatement 对象在执行 SOL 前，将输入的 Java 对象映射到 SOL 语句中这里对输入参数的映射过程就类似于 JDBC 编程中对 preparedStatement 对象设置参数的过程

( 8 )输出结果映射在数据库中执行完 SOL 语句后， MappedStatement 对象会对 SOL 行输出的结果进行定义(可以定义为 Map 和List 类型、基本类型、 POJO 类型 Executor 执行器会通过 MappedStatement 对象在执行 SOL 语句后，将输出结果映射至 Java 对象中这种将输出结果映射到 Java 对象的过程就类似于 JDBC 编程中对结果的解析处理过程

Mybatis基本操作

Mybatis配置文件

<?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>
    <!--1.配置环境 ，默认的环境id为mysql-->
    <environments default="mysql">
        <!--1.2.配置id为mysql的数据库环境 -->
        <environment id="mysql">
            <!-- 使用JDBC的事务管理 -->
            <transactionManager type="JDBC" />
            <!--数据库连接池 -->
            <dataSource type="POOLED">
			  <property name="driver" value="com.mysql.jdbc.Driver" />
			  <property name="url" 
                            value="jdbc:mysql://192.168.134.128:3306/mybatis" />
			  <property name="username" value="root" />
			  <property name="password" value="root" />
            </dataSource>
        </environment>
    </environments>
    <!--2.配置Mapper的位置 -->
    <mappers>
		<mapper resource="com/itheima/mapper/MyCustomerMapper.xml" />
    </mappers>
</configuration>

加载映射文件CustomerMapper

<?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表示命名空间 -->
<mapper namespace="com.itheima.mapper.CustomerMapper">
    <!--根据客户编号获取客户信息 -->
	<select id="findCustomerById" parameterType="Integer"
		resultType="com.itheima.po.Customer">
		select * from t_customer where id = #{id}
	</select>
	
	<!--根据客户名模糊查询客户信息列表-->
	<select id="findCustomerByName" parameterType="String"
	    resultType="com.itheima.po.Customer">
	    <!-- select * from t_customer where username like '%${value}%' -->
	    select * from t_customer where username like concat('%',#{value},'%')
	</select>
	
	<!-- 添加客户信息 -->
	<insert id="addCustomer" parameterType="com.itheima.po.Customer">
	    insert into t_customer(username,jobs,phone)
	    values(#{username},#{jobs},#{phone})
	</insert>
	
	<!-- 更新客户信息 -->
	<update id="updateCustomer" parameterType="com.itheima.po.Customer">
	    update t_customer set
	    username=#{username},jobs=#{jobs},phone=#{phone}
	    where id=#{id}
	</update>
	
	<!-- 删除客户信息 -->
	<delete id="deleteCustomer" parameterType="Integer">
	    delete from t_customer where id=#{id}
	</delete>
</mapper>

Customer

package com.itheima.po;

/**
 * @author NoOne dotaerday@gmail.com:
 * @version 创建时间：2020年3月7日 上午9:01:31 类说明
 */
public class Customer {
	private Integer id; // 主键id
	private String username; // 客户名称
	private String jobs; // 职业
	private String phone; // 电话

	public Integer getId() {
		return id;
	}

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

	public String getUsername() {
		return username;
	}

	public void setUsername(String username) {
		this.username = username;
	}

	public String getJobs() {
		return jobs;
	}

	public void setJobs(String jobs) {
		this.jobs = jobs;
	}

	public String getPhone() {
		return phone;
	}

	public void setPhone(String phone) {
		this.phone = phone;
	}

	@Override
	public String toString() {
		return "Customer [id=" + id + ", username=" + username + ", jobs=" + jobs + ", phone=" + phone + "]";
	}
}

配置Debug

# Global logging configuration
log4j.rootLogger=ERROR, stdout
# MyBatis logging configuration...
log4j.logger.com.itheima=DEBUG
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

测试代码

package com.itheima.test;

/**
* @author NoOne dotaerday@gmail.com:
* @version 创建时间：2020年3月7日 上午9:02:27
* 类说明
*/
import java.io.InputStream;
import java.util.List;

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 org.junit.Test;
import com.itheima.po.Customer;

/**
 * 入门程序测试类
 */
public class MybatisTest {
	/**
	 * 根据客户编号查询客户信息
	 */
	@Test
	public void findCustomerByIdTest() throws Exception {
		// 1、读取配置文件
		String resource = "mybatis-config.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 2、根据配置文件构建SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		// 3、通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		// 4、SqlSession执行映射文件中定义的SQL，并返回映射结果
		Customer customer = sqlSession.selectOne("com.itheima.mapper" + ".CustomerMapper.findCustomerById", 1);
		// 打印输出结果
		System.out.println(customer.toString());
		// 5、关闭SqlSession
		sqlSession.close();
	}

	/**
	 * 根据用户名称来模糊查询用户信息列表
	 */
	@Test
	public void findCustomerByNameTest() throws Exception {
		// 1、读取配置文件
		String resource = "mybatis-config.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 2、根据配置文件构建SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		// 3、通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		// 4、SqlSession执行映射文件中定义的SQL，并返回映射结果
		List<Customer> customers = sqlSession.selectList("com.itheima.mapper" + ".CustomerMapper.findCustomerByName",
				"j");
		for (Customer customer : customers) {
			// 打印输出结果集
			System.out.println(customer);
		}
		// 5、关闭SqlSession
		sqlSession.close();
	}

	/**
	 * 添加客户
	 */
	@Test
	public void addCustomerTest() throws Exception {
		// 1、读取配置文件
		String resource = "mybatis-config.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 2、根据配置文件构建SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		// 3、通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		// 4、SqlSession执行添加操作
		// 4.1创建Customer对象，并向对象中添加数据
		Customer customer = new Customer();
		customer.setUsername("rose");
		customer.setJobs("student");
		customer.setPhone("13333533092");
		// 4.2执行SqlSession的插入方法，返回的是SQL语句影响的行数
		int rows = sqlSession.insert("com.itheima.mapper" + ".CustomerMapper.addCustomer", customer);
		// 4.3通过返回结果判断插入操作是否执行成功
		if (rows > 0) {
			System.out.println("您成功插入了" + rows + "条数据！");
		} else {
			System.out.println("执行插入操作失败！！！");
		}
		// 4.4提交事务
		sqlSession.commit();
		// 5、关闭SqlSession
		sqlSession.close();
	}

	/**
	 * 更新客户
	 */
	@Test
	public void updateCustomerTest() throws Exception {
		// 1、读取配置文件
		String resource = "mybatis-config.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 2、根据配置文件构建SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		// 3、通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		// 4、SqlSession执行更新操作
		// 4.1创建Customer对象，对对象中的数据进行模拟更新
		Customer customer = new Customer();
		customer.setId(1);
		customer.setUsername("john");
		customer.setJobs("programmer");
		customer.setPhone("6666666666");
		// 4.2执行SqlSession的更新方法，返回的是SQL语句影响的行数
		int rows = sqlSession.update("com.itheima.mapper" + ".CustomerMapper.updateCustomer", customer);
		// 4.3通过返回结果判断更新操作是否执行成功
		if (rows > 0) {
			System.out.println("您成功修改了" + rows + "条数据！");
		} else {
			System.out.println("执行修改操作失败！！！");
		}
		// 4.4提交事务
		sqlSession.commit();
		// 5、关闭SqlSession
		sqlSession.close();
	}

	/**
	 * 删除客户
	 */
	@Test
	public void deleteCustomerTest() throws Exception {
		// 1、读取配置文件
		String resource = "mybatis-config.xml";
		InputStream inputStream = Resources.getResourceAsStream(resource);
		// 2、根据配置文件构建SqlSessionFactory
		SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
		// 3、通过SqlSessionFactory创建SqlSession
		SqlSession sqlSession = sqlSessionFactory.openSession();
		// 4、SqlSession执行删除操作
		// 4.1执行SqlSession的删除方法，返回的是SQL语句影响的行数
		int rows = sqlSession.delete("com.itheima.mapper" + ".CustomerMapper.deleteCustomer", 4);
		// 4.2通过返回结果判断删除操作是否执行成功
		if (rows > 0) {
			System.out.println("您成功删除了" + rows + "条数据！");
		} else {
			System.out.println("执行删除操作失败！！！");
		}
		// 4.3提交事务
		sqlSession.commit();
		// 5、关闭SqlSession
		sqlSession.close();
	}

}

这里注意从工厂获取Session是重复操作，我们可以将其封装

MyBatis核心对象

SqlSessionFactory
SqlSession

使用工具类创建SqlSessionFactory

package com.itheima.utils;

/**
* @author NoOne dotaerday@gmail.com:
* @version 创建时间：2020年3月7日 上午9:15:03
* 类说明
*/
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;

/**
 * 工具类
 */
public class MybatisUtils {
	private static SqlSessionFactory sqlSessionFactory = null;
	// 初始化SqlSessionFactory对象
	static {
		try {
			// 使用MyBatis提供的Resources类加载mybatis的配置文件
			Reader reader = Resources.getResourceAsReader("mybatis-config.xml");
			// 构建sqlSession的工厂
			sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	// 获取SqlSession对象的静态方法
	public static SqlSession getSession() {
		return sqlSessionFactory.openSession();
	}
}

MyBatis配置

本文作者：NoOne
本文地址： https://noonegroup.xyz/posts/94b94ba/
版权声明：转载请注明出处！