MyBatis的几个重要类和生命周期(四)-阿里云开发者社区

一. MyBatis 在创建的过程中，所使用到的重要类

在创建Mapper 的过程中，所使用到的工具类 SqlSessionFactoryUtils 。

package com.yjl.util;
import java.io.IOException;
import java.io.InputStream;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
/**
 @author:两个蝴蝶飞
 @date: 2019年6月15日 上午11:13:26
 @Description 类的相关描述
*/
public class SqlSessionFactoryUtils {
  /*创建SqlSession的工厂 SqlSessionFactory对象*/
  private static SqlSessionFactory sqlSessionFactory=null;
  private SqlSessionFactoryUtils(){
  }
  /**
   * 单例模式 获取实例
   * @author 两个蝴蝶飞
   * @return
   */
  public static SqlSessionFactory getInstance(){
    synchronized(SqlSessionFactoryUtils.class){
      if(sqlSessionFactory==null){
        InputStream input=null;
        // Mybatis 核心配置文件名
        String resource_name="SqlMapConfig.xml";
        try {
          input=Resources.getResourceAsStream(resource_name);
          sqlSessionFactory=new SqlSessionFactoryBuilder().build(input);
        } catch (IOException e) {
          e.printStackTrace();
        }
      }
    }
    return sqlSessionFactory;
  }
  /**
   * 
   * @author 两个蝴蝶飞
   * @return 获取当前的Session
   */
  public static SqlSession getSession(){
    if(sqlSessionFactory==null){
      getInstance();
    }
    return sqlSessionFactory.openSession();
  }
}

在创建的过程中，使用到了 SqlSessionFactoryBuilder 类，SqlSessionFactory 接口，SqlSession 接口，SqlMapper 接口。

用一张图表示就是:

下面，简单讲解一下，这几个类的使用。

二. SqlSessionFactoryBuilder

通过调用. builder(资源文件inputstream) 来达到创建SqlSessionFactory 工厂.

package org.apache.ibatis.session;
import java.io.IOException;
import java.io.InputStream;
import java.io.Reader;
import java.util.Properties;
import javax.security.auth.login.Configuration;
public class SqlSessionFactoryBuilder {
//调用字符流创建 SqlSessionFactory 工厂。
  public SqlSessionFactory build(Reader reader) {
    return build(reader, null, null);
  }
  public SqlSessionFactory build(Reader reader, String environment) {
    return build(reader, environment, null);
  }
  public SqlSessionFactory build(Reader reader, Properties properties) {
    return build(reader, null, properties);
  }
  public SqlSessionFactory build(Reader reader, String environment, Properties properties) {
    try {
      XMLConfigBuilder parser = new XMLConfigBuilder(reader, environment, properties);
      return build(parser.parse());
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error building SqlSession.", e);
    } finally {
      ErrorContext.instance().reset();
      try {
        reader.close();
      } catch (IOException localIOException1) {
      }
    }
  }
  // 调用字节流 创建SqlSessionFactory 工厂
  public SqlSessionFactory build(InputStream inputStream) {
    return build(inputStream, null, null);
  }
  public SqlSessionFactory build(InputStream inputStream, String environment) {
    return build(inputStream, environment, null);
  }
  public SqlSessionFactory build(InputStream inputStream, Properties properties) {
    return build(inputStream, null, properties);
  }
  public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
    try {
      XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
      return build(parser.parse());
    } catch (Exception e) {
      throw ExceptionFactory.wrapException("Error building SqlSession.", e);
    } finally {
      ErrorContext.instance().reset();
      try {
        inputStream.close();
      } catch (IOException localIOException1) {
      }
    }
  }
  // 采用代码形式，构建Configuration 对象，来创建工厂。
  public SqlSessionFactory build(Configuration config) {
    return new DefaultSqlSessionFactory(config);
  }
}

SqlSessionFactoryBuilder 会根据配置信息或者代码来生成SqlSessionFactory 。

提供了三种方式，字符流，字节流，和代码Configuration 类三种形式来创建SqlSessionFactory 类。

三. SqlSessionFactory 类

package org.apache.ibatis.session;
import java.sql.Connection;
public abstract interface SqlSessionFactory
{
//打开openSession()
  public abstract SqlSession openSession();
  public abstract SqlSession openSession(boolean paramBoolean);
  //根据连接创建
  public abstract SqlSession openSession(Connection paramConnection);
  //根据事务
  public abstract SqlSession openSession(TransactionIsolationLevel paramTransactionIsolationLevel);
  public abstract SqlSession openSession(ExecutorType paramExecutorType);
  public abstract SqlSession openSession(ExecutorType paramExecutorType, boolean paramBoolean);
  public abstract SqlSession openSession(ExecutorType paramExecutorType, TransactionIsolationLevel paramTransactionIsolationLevel);
  public abstract SqlSession openSession(ExecutorType paramExecutorType, Connection paramConnection);
  //获取代码配置的Configuration 对象信息
  public abstract Configuration getConfiguration();
}

主要用于创建SqlSession 接口。用 openSession() 方法即可。

有两个实现类: DefaultSqlSessionFactory 和SqlSessionManager。目前用前者， SqlSessionManager 还没有使用。

有两个方式创建SqlSessionFactory ,一种是配置文件的方式，另外一种是代码的方式，即Configuration 类，

org.apache.ibatis.session.Configuration

后面还有很多，定义了大量的 setter 和getter 方法，来设置和获取配置的信息。与xml 配置的属性是一样的。 Configuration 对象存储在整个Mybatis 运行的生命周期内，以便重复的读取和运用。

三.一 xml 配置文件的方式创建SqlSessionFactory

就是前三章所用的形式。

<?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>
  <!-- 配置别名 -->
  <typeAliases>
    <typeAlias type="com.yjl.pojo.User" alias="user"/>
  </typeAliases>
  <!-- 开发环境  development -->
  <environments default="development">
    <environment id="development">
      <!-- 事务管理 -->
      <transactionManager type="JDBC"></transactionManager>
      <!-- 数据源 ，为pooled 连接池 -->
      <dataSource type="pooled">
        <property name="driver" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf8"/>
        <property name="username" value="root"/>
        <property name="password" value="abc123"/>
      </dataSource> 
    </environment>
  </environments>
  <mappers>
    <!-- 引入文件资源 -->
    <mapper resource="com/yjl/mapper/UserMapper.xml"/>
  </mappers>
</configuration>

三.二代码样式创建SqlSessionFactory

package com.yjl.util;
import javax.sql.DataSource;
import org.apache.ibatis.datasource.pooled.PooledDataSource;
import org.apache.ibatis.mapping.Environment;
import org.apache.ibatis.session.Configuration;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.apache.ibatis.transaction.TransactionFactory;
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
import com.yjl.mapper.UserMapper;
import com.yjl.pojo.User;
/**
 @author:两个蝴蝶飞
 @date: 2019年6月15日 上午11:13:26
 @Description 类的相关描述
*/
public class SqlSessionFactoryUtils {
  /*创建SqlSession的工厂 SqlSessionFactory对象*/
  private static SqlSessionFactory sqlSessionFactory=null;
  private SqlSessionFactoryUtils(){
  }
  /**
   * 单例模式 获取实例
   * @author 两个蝴蝶飞
   * @return
   */
  public static SqlSessionFactory getInstance(){
    synchronized(SqlSessionFactoryUtils.class){
      if(sqlSessionFactory==null){
        try {
          String driver = "com.mysql.jdbc.Driver";
          String url = "jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf8";
          String username="root";
          String password="abc123";
          //设置数据库的数据源
          DataSource dataSource =new PooledDataSource(driver,url,username,password);
          //事务为jdbc处理
          TransactionFactory transactionFactory =  new JdbcTransactionFactory();
          //环境为development 环境
          Environment environment = new Environment("development", transactionFactory, dataSource);
          //创建Configuration
          Configuration configuration = new Configuration(environment);
          //设置别名
          configuration.getTypeAliasRegistry().registerAlias("user",User.class);
          //配置文件 UserMapper
          configuration.addMapper(UserMapper.class);
          //创建SqlSessionFactory
          sqlSessionFactory=new SqlSessionFactoryBuilder().build(configuration);
        } catch (Exception e) {
          e.printStackTrace();
        }
      }
    }
    return sqlSessionFactory;
  }
  /**
   * 
   * @author 两个蝴蝶飞
   * @return 获取当前的Session
   */
  public static SqlSession getSession(){
    if(sqlSessionFactory==null){
      getInstance();
    }
    return sqlSessionFactory.openSession();
  }
}

测试方法

@Test
  public void findAllTest(){
    SqlSession sqlSession=SqlSessionFactoryUtils.getSession();
    UserMapper userMapper=sqlSession.getMapper(UserMapper.class);
    List<User> allList=userMapper.findAll();
    allList.forEach(n ->System.out.println(n));
  }

正常的查询了出来，代码创建是没有错的。

但是代码创建时，是硬编码写入，并且别名和映射文件都是写入的，每次都要进行修改。

建议，使用XML 配置的方式。

四. SqlSession 接口

package org.apache.ibatis.session;
import java.io.Closeable;
import java.sql.Connection;
import java.util.List;
import java.util.Map;
import org.apache.ibatis.cursor.Cursor;
import org.apache.ibatis.executor.BatchResult;
public abstract interface SqlSession
  extends Closeable
{
// 查询单个对象
  public abstract <T> T selectOne(String paramString);
  public abstract <T> T selectOne(String paramString, Object paramObject);
  //查询多个集合对象
  public abstract <E> List<E> selectList(String paramString);
  public abstract <E> List<E> selectList(String paramString, Object paramObject);
  public abstract <E> List<E> selectList(String paramString, Object paramObject, RowBounds paramRowBounds);
  // 查询Map 形式
  public abstract <K, V> Map<K, V> selectMap(String paramString1, String paramString2);
  public abstract <K, V> Map<K, V> selectMap(String paramString1, Object paramObject, String paramString2);
  public abstract <K, V> Map<K, V> selectMap(String paramString1, Object paramObject, String paramString2, RowBounds paramRowBounds);
  // 查询光标
  public abstract <T> Cursor<T> selectCursor(String paramString);
  public abstract <T> Cursor<T> selectCursor(String paramString, Object paramObject);
  public abstract <T> Cursor<T> selectCursor(String paramString, Object paramObject, RowBounds paramRowBounds);
  // 利用ResultHandler 处理来理查询
  public abstract void select(String paramString, Object paramObject, ResultHandler paramResultHandler);
  public abstract void select(String paramString, ResultHandler paramResultHandler);
  public abstract void select(String paramString, Object paramObject, RowBounds paramRowBounds, ResultHandler paramResultHandler);
  //插入-
  public abstract int insert(String paramString);
  public abstract int insert(String paramString, Object paramObject);
  //更新
  public abstract int update(String paramString);
  public abstract int update(String paramString, Object paramObject);
  //删除 
  public abstract int delete(String paramString);
  public abstract int delete(String paramString, Object paramObject);
 //事务提交
  public abstract void commit();
  public abstract void commit(boolean paramBoolean);
  //事务回滚
  public abstract void rollback();
  public abstract void rollback(boolean paramBoolean);
  public abstract List<BatchResult> flushStatements();
  //关闭 SqlSession
  public abstract void close();
  //清理缓存
  public abstract void clearCache();
  //获取Configuration 对象
  public abstract Configuration getConfiguration();
  //获取SqlMapper
  public abstract <T> T getMapper(Class<T> paramClass);
  //获取Connection 连接对象
  public abstract Connection getConnection();
}

SqlSession 相当于JDBC 时的 Connection 对象，用于查询 (selectOne,selectList,selectMap,select), 插入(insert),删除(delete),修改(update), 也用于获取SqlMapper 接口。

SqlSession 有两个实现类， DefaultSqlSession,SqlSessionManager, 目前用的是前者。

五. 生命周期

五.一 SqlSessionFactoryBuilder 方法局部

它的作用是一个构建器，一旦构建了SqlSessionFactory,它的作用就完结了，失去了存在的意义，必须废除，将其回收。所以它只存在于方法的局部。

五.二 SqlSessionFactory 整个MyBatis 生命周期中

责任是唯一的，就是创建SqlSession. 是单例模式

五.三 Configuration 整个MyBatis 生命周期中

用于注册别名，处理器，映射文件等。

五.三 SqlSession 数据库处理事务的过程中

是一个线程不安全的对象，用finally 来close() 关闭连接。

五.四 SqlMapper SqlSession事务方法之内

是一个接口，没有任何实现类，作用就是发送SQL语句，返回结果，或者是执行sql语句，修改数据。

归纳成一个图就是:

谢谢!!!

MyBatis的几个重要类和生命周期(四)

一. MyBatis 在创建的过程中，所使用到的重要类

二. SqlSessionFactoryBuilder

三.二代码样式创建SqlSessionFactory

四. SqlSession 接口

热门文章

最新文章

相关课程

相关电子书

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

MyBatis的几个重要类和生命周期(四)

一. MyBatis 在创建的过程中，所使用到的重要类

二. SqlSessionFactoryBuilder

三.二 代码样式创建SqlSessionFactory

四. SqlSession 接口

热门文章

最新文章

相关课程

相关电子书

三.二代码样式创建SqlSessionFactory