第3篇:SqlSession的创建与生命周期
1. 学习目标确认
1.0 第2篇思考题解答
在深入学习SqlSession之前,让我们先回顾并解答第2篇中提出的思考题,这将帮助我们更好地理解SqlSession在整个架构中的作用。
思考题1:为什么MyBatis要设计如此复杂的配置系统?
答案要点:
- 统一管理:所有配置项集中管理,避免配置分散和重复
- 灵活性:支持XML、注解、代码三种配置方式,满足不同场景需求
- 可扩展性:通过插件系统和自定义配置支持功能扩展
- 性能优化:配置缓存、懒加载等机制提升性能
- 类型安全:强类型配置减少运行时错误
SqlSession的作用:SqlSession作为配置系统的使用者,通过Configuration获取所有必要的配置信息。
思考题2:配置系统的扩展性体现在哪些方面?
答案要点:
- 插件扩展:Interceptor接口支持功能扩展
- 类型处理器扩展:TypeHandler接口支持自定义类型转换
- 对象工厂扩展:ObjectFactory接口支持自定义对象创建
- 数据源扩展:DataSource接口支持自定义数据源
- 事务管理扩展:TransactionFactory接口支持自定义事务管理
SqlSession的扩展性:SqlSession通过Executor、StatementHandler等组件实现功能扩展。
思考题3:如何优化配置解析的性能?
答案要点:
- 缓存机制:解析后的配置对象缓存,避免重复解析
- 懒加载:非必需配置延迟加载,减少启动时间
- 批量处理:相关配置项批量解析,提高效率
- 内存优化:优化配置对象的内存使用,减少GC压力
SqlSession的性能:SqlSession通过Executor缓存、连接池等技术优化性能。
思考题4:基于配置系统的理解,应该从哪个组件开始深入源码分析?
推荐顺序:SqlSession → Executor → StatementHandler → ParameterHandler + ResultSetHandler
从SqlSession开始的原因:
- SqlSession是配置系统的直接使用者
- 理解SqlSession有助于理解整个执行流程
- 为后续学习Executor等组件奠定基础
1.1 SqlSession概述(基于MyBatis 3.5.x)
SqlSession是MyBatis的核心接口,代表与数据库的一次会话。它是MyBatis架构中接口层的重要组成部分,为用户提供了简洁的API来执行数据库操作。
SqlSession的核心职责:
- 数据库操作:提供CRUD操作的统一接口
- 事务管理:管理数据库事务的提交和回滚
- Mapper管理:获取Mapper接口的动态代理对象
- 会话管理:管理会话的生命周期和资源释放
重要提示:理解SqlSession的设计和实现是深入MyBatis源码的关键,后续的Executor、StatementHandler等组件都围绕SqlSession展开。
2. SqlSession接口设计分析
2.1 SqlSession接口结构
让我们深入分析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;
- import org.apache.ibatis.executor.result.ResultHandler;
- public interface SqlSession extends Closeable {
- // 查询操作
- <T> T selectOne(String statement);
- <T> T selectOne(String statement, Object parameter);
- <E> List<E> selectList(String statement);
- <E> List<E> selectList(String statement, Object parameter);
- <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds);
-
- // Map查询操作
- <K, V> Map<K, V> selectMap(String statement, String mapKey);
- <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey);
- <K, V> Map<K, V> selectMap(String statement, Object parameter, String mapKey, RowBounds rowBounds);
-
- // 游标查询
- <T> Cursor<T> selectCursor(String statement);
- <T> Cursor<T> selectCursor(String statement, Object parameter);
- <T> Cursor<T> selectCursor(String statement, Object parameter, RowBounds rowBounds);
-
- // 自定义结果处理(流式结果)
- void select(String statement, Object parameter, ResultHandler handler);
- void select(String statement, ResultHandler handler);
- void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);
-
- // 更新操作
- int insert(String statement);
- int insert(String statement, Object parameter);
- int update(String statement);
- int update(String statement, Object parameter);
- int delete(String statement);
- int delete(String statement, Object parameter);
-
- // 事务管理
- void commit();
- void commit(boolean force);
- void rollback();
- void rollback(boolean force);
-
- // 批量操作
- List<BatchResult> flushStatements();
-
- // Mapper获取
- <T> T getMapper(Class<T> type);
-
- // 连接管理
- Connection getConnection();
-
- // 配置获取
- Configuration getConfiguration();
-
- // 缓存管理
- void clearCache();
- }
复制代码 2.2 接口设计特点分析
2.2.1 泛型设计
- // 泛型设计提供了类型安全
- <T> T selectOne(String statement, Object parameter);
- <E> List<E> selectList(String statement, Object parameter);
复制代码 优势:
- 类型安全:编译时类型检查,避免运行时类型转换错误
- 代码简洁:无需手动类型转换
- IDE支持:更好的代码提示和重构支持
2.2.2 ResultHandler自定义结果处理
- // 支持自定义结果处理,适用于流式结果处理
- void select(String statement, Object parameter, ResultHandler handler);
- void select(String statement, ResultHandler handler);
- void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler);
复制代码 使用场景:
- 流式处理:处理大量数据时避免内存溢出
- 自定义转换:对结果进行自定义处理
- 实时处理:边查询边处理结果
示例用法:
[code]// 流式处理大量数据session.select("selectAllUsers", null, new ResultHandler() { @Override public void handleResult(ResultContext |