【源码解读之 Mybatis】【基础篇】-- 第3篇:SqlSession的创建与生命周期
第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);使用场景:
[*]流式处理:处理大量数据时避免内存溢出
[*]自定义转换:对结果进行自定义处理
[*]实时处理:边查询边处理结果
示例用法:
// 流式处理大量数据session.select("selectAllUsers", null, new ResultHandler() { @Override public void handleResult(ResultContext 分享、互助 让互联网精神温暖你我 谢谢分享,辛苦了 感谢分享,下载保存了,貌似很强大 感谢发布原创作品,程序园因你更精彩
页:
[1]