/ 支持不同参数组合 T T selectOne(String statement); T T selectOne(String statement, Object parameter); E ListE selectList(String statement, Object parameter); E ListE selectList(String statement, Object parameter, RowBounds rowBounds);优势使用灵活支持不同使用场景向后兼容保持API的向后兼容性渐进式学习从简单到复杂的使用方式2.2.4 资源管理设计public interface SqlSession extends Closeable { // 继承Closeable接口支持try-with-resources语法 }优势自动资源管理支持try-with-resources语法防止资源泄漏确保资源正确释放代码简洁减少样板代码3. SqlSessionFactory工厂模式分析3.1 SqlSessionFactory接口设计SqlSessionFactory是创建SqlSession的工厂接口采用工厂模式设计package org.apache.ibatis.session; import java.sql.Connection; public interface SqlSessionFactory { // 基本创建方法 SqlSession openSession(); SqlSession openSession(boolean autoCommit); SqlSession openSession(Connection connection); // 执行器类型指定 SqlSession openSession(ExecutorType execType); SqlSession openSession(ExecutorType execType, boolean autoCommit); SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level); SqlSession openSession(ExecutorType execType, Connection connection); // 事务隔离级别指定 SqlSession openSession(TransactionIsolationLevel level); // 配置获取 Configuration getConfiguration(); }3.2 DefaultSqlSessionFactory实现分析DefaultSqlSessionFactory是SqlSessionFactory的默认实现让我们深入分析其源码package org.apache.ibatis.session.defaults; import org.apache.ibatis.executor.Executor; import org.apache.ibatis.session.Configuration; import org.apache.ibatis.session.ExecutorType; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.TransactionIsolationLevel; import org.apache.ibatis.transaction.Transaction; import org.apache.ibatis.transaction.TransactionFactory; import org.apache.ibatis.transaction.managed.ManagedTransactionFactory; import org.apache.ibatis.mapping.Environment; import org.apache.ibatis.exceptions.ExceptionFactory; import org.apache.ibatis.executor.ErrorContext; public class DefaultSqlSessionFactory implements SqlSessionFactory { private final Configuration configuration; public DefaultSqlSessionFactory(Configuration configuration) { this.configuration configuration; } Override public SqlSession openSession() { return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false); } Override public SqlSession openSession(boolean autoCommit) { return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, autoCommit); } Override public SqlSession openSession(ExecutorType execType) { return openSessionFromDataSource(execType, null, false); } // 核心创建方法 private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) { Transaction tx null; try { // 1. 获取环境配置 final Environment environment configuration.getEnvironment(); // 2. 获取事务工厂 final TransactionFactory transactionFactory getTransactionFactoryFromEnvironment(environment); // 3. 创建事务 tx transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit); // 4. 创建执行器 final Executor executor configuration.newExecutor(tx, execType); // 5. 创建SqlSession return createSqlSession(configuration, executor, autoCommit); } catch (Exception e) { closeTransaction(tx); throw ExceptionFactory.wrapException(Error opening session. Cause: e, e); } finally { ErrorContext.instance().reset(); } } protected SqlSession createSqlSession(Configuration configuration, Executor executor, boolean autoCommit) { return new DefaultSqlSession(configuration, executor, autoCommit); } }3.3 工厂模式的优势3.3.1 封装复杂性// 用户只需要调用简单的方法 SqlSession session sqlSessionFactory.openSession(); // 内部复杂的创建过程被封装 // 1. 环境配置获取 // 2. 事务工厂创建 // 3. 事务对象创建 // 4. 执行器创建 // 5. SqlSession创建3.3.2 参数灵活性// 支持多种参数组合 SqlSession session1 sqlSessionFactory.openSession(); // 默认配置 SqlSession session2 sqlSessionFactory.openSession(true); // 自动提交 SqlSession session3 sqlSessionFactory.openSession(ExecutorType.BATCH); // 批处理执行器3.3.3 配置驱动// 基于Configuration配置创建SqlSession final Executor executor configuration.newExecutor(tx, execType);4. SqlSession生命周期管理4.1 生命周期阶段SqlSession的生命周期可以分为以下几个阶段openSessioncommit/rollbackcloseEnvironmentTransactionExecutorselect/updategetMapper操作完成结束事务executor.closetx.closeclearCache 创建阶段⚡ 使用阶段 事务管理阶段 资源释放阶段 获取配置️ 创建事务⚙️ 创建执行器 创建SqlSession 执行SQL 结果处理 Mapper调用 事务开始✅ 提交/回滚 事务结束 关闭执行器 关闭事务 关闭连接️ 清理缓存4.2 创建阶段详细分析4.2.1 配置获取// 从Configuration获取环境配置 final Environment environment configuration.getEnvironment();Environment包含DataSource数据源配置TransactionFactory事务工厂配置Id环境标识4.2.2 事务创建// 创建事务对象 final TransactionFactory transactionFactory getTransactionFactoryFromEnvironment(environment); tx transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);事务创建过程获取事务工厂从环境配置获取TransactionFactory创建事务对象使用DataSource和参数创建Transaction设置事务属性隔离级别、自动提交等4.2.3 执行器创建// 创建执行器 final Executor executor configuration.newExecutor(tx, execType);执行器创建过程执行器类型选择根据ExecutorType选择具体实现缓存包装如果启用缓存用CachingExecutor包装插件应用应用所有配置的插件4.2.4 SqlSession创建// 创建SqlSession对象 return new DefaultSqlSession(configuration, executor, autoCommit);4.3 使用阶段分析4.3.1 SQL执行流程// 用户调用 User user session.selectOne(selectUser, 1); // 内部执行流程 public T T selectOne(String statement, Object parameter) { ListT list this.selectList(statement, parameter); if (list.size() 1) { return list.get(0); } if (list.size() 1) { throw new TooManyResultsException(Expected one result...); } else { return null; } }4.3.2 Mapper获取流程// 用户调用 UserMapper mapper session.getMapper(UserMapper.class); // 内部实现 Override public T T getMapper(ClassT type) { return configuration.getMapper(type, this); }4.4 资源释放阶段4.4.1 手动关闭// 手动关闭SqlSession session.close(); // 内部关闭流程 Override public void close() { try { executor.close(isCommitOrRollbackRequired(false)); } catch (SQLException e) { throw ExceptionFactory.wrapException(Error closing SqlSession. Cause: e, e); } finally { // 清理资源 dirty false; executor null; configuration null; } }