public interface Executor {
?
? ResultHandler NO_RESULT_HANDLER = null;
?
? // 數(shù)據(jù)更新操作，其中數(shù)據(jù)的增加、刪除、更新均可由該方法實現(xiàn)
? int update(MappedStatement ms, Object parameter) throws SQLException;
? // 數(shù)據(jù)查詢操作，返回結(jié)果為列表形式
? <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey cacheKey, BoundSql boundSql) throws SQLException;
? // 數(shù)據(jù)查詢操作，返回結(jié)果為列表形式
? /**
? ?* 執(zhí)行查詢操作
? ?* @param ms 映射語句對象
? ?* @param parameter 參數(shù)對象
? ?* @param rowBounds 翻頁限制
? ?* @param resultHandler 結(jié)果處理器
? ?* @param <E> 輸出結(jié)果類型
? ?* @return 查詢結(jié)果
? ?* @throws SQLException
? ?*/
? <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException;
? // 數(shù)據(jù)查詢操作，返回結(jié)果為游標形式
? <E> Cursor<E> queryCursor(MappedStatement ms, Object parameter, RowBounds rowBounds) throws SQLException;
? // 清理緩存
? List<BatchResult> flushStatements() throws SQLException;
? // 提交事務
? void commit(boolean required) throws SQLException;
? // 回滾事務
? void rollback(boolean required) throws SQLException;
? // 創(chuàng)建當前查詢的緩存鍵值
? CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql);
? // 本地緩存是否有指定值
? boolean isCached(MappedStatement ms, CacheKey key);
? // 清理本地緩存
? void clearLocalCache();
? // 懶加載
? void deferLoad(MappedStatement ms, MetaObject resultObject, String property, CacheKey key, Class<?> targetType);
? // 獲取事務
? Transaction getTransaction();
? // 關(guān)閉執(zhí)行器
? void close(boolean forceRollback);
? // 判斷執(zhí)行器是否關(guān)閉
? boolean isClosed();
? // 設(shè)置執(zhí)行器包裝
? void setExecutorWrapper(Executor executor);
?
}

public abstract class BaseExecutor implements Executor {
?
? private static final Log log = LogFactory.getLog(BaseExecutor.class);
?
? protected Transaction transaction;
? protected Executor wrapper;
?
? protected ConcurrentLinkedQueue<DeferredLoad> deferredLoads;
? // 查詢操作的結(jié)果緩存
? protected PerpetualCache localCache;
? // Callable查詢的輸出參數(shù)緩存
? protected PerpetualCache localOutputParameterCache;
? protected Configuration configuration;
?
? protected int queryStack;
? private boolean closed;
?
?
?
?
? /**
? ?* 更新數(shù)據(jù)庫數(shù)據(jù)，INSERT/UPDATE/DELETE三種操作都會調(diào)用該方法
? ?* @param ms 映射語句
? ?* @param parameter 參數(shù)對象
? ?* @return 數(shù)據(jù)庫操作結(jié)果
? ?* @throws SQLException
? ?*/
? @Override
? public int update(MappedStatement ms, Object parameter) throws SQLException {
? ? ErrorContext.instance().resource(ms.getResource())
? ? ? ? ? ? .activity("executing an update").object(ms.getId());
? ? if (closed) {
? ? ? // 執(zhí)行器已經(jīng)關(guān)閉
? ? ? throw new ExecutorException("Executor was closed.");
? ? }
? ? // 清理本地緩存
? ? clearLocalCache();
? ? // 返回調(diào)用子類進行操作
? ? return doUpdate(ms, parameter);
? }
?
??
?
? /**
? ?* 執(zhí)行查詢操作
? ?* @param ms 映射語句對象
? ?* @param parameter 參數(shù)對象
? ?* @param rowBounds 翻頁限制
? ?* @param resultHandler 結(jié)果處理器
? ?* @param <E> 輸出結(jié)果類型
? ?* @return 查詢結(jié)果
? ?* @throws SQLException
? ?*/
? @Override
? public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
? ? BoundSql boundSql = ms.getBoundSql(parameter);
? ? // 生成緩存的鍵
? ? CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);
? ? return query(ms, parameter, rowBounds, resultHandler, key, boundSql);
? }
?
? /**
? ?* 查詢數(shù)據(jù)庫中的數(shù)據(jù)
? ?* @param ms 映射語句
? ?* @param parameter 參數(shù)對象
? ?* @param rowBounds 翻頁限制條件
? ?* @param resultHandler 結(jié)果處理器
? ?* @param key 緩存的鍵
? ?* @param boundSql 查詢語句
? ?* @param <E> 結(jié)果類型
? ?* @return 結(jié)果列表
? ?* @throws SQLException
? ?*/
? @SuppressWarnings("unchecked")
? @Override
? public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
? ? ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
? ? if (closed) {
? ? ? // 執(zhí)行器已經(jīng)關(guān)閉
? ? ? throw new ExecutorException("Executor was closed.");
? ? }
? ? if (queryStack == 0 && ms.isFlushCacheRequired()) { // 新的查詢棧且要求清除緩存
? ? ? // 清除一級緩存
? ? ? clearLocalCache();
? ? }
? ? List<E> list;
? ? try {
? ? ? queryStack++;
? ? ? // 嘗試從本地緩存獲取結(jié)果
? ? ? list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
? ? ? if (list != null) {
? ? ? ? // 本地緩存中有結(jié)果，則對于CALLABLE語句還需要綁定到IN/INOUT參數(shù)上
? ? ? ? handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
? ? ? } else {
? ? ? ? // 本地緩存沒有結(jié)果，故需要查詢數(shù)據(jù)庫
? ? ? ? list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
? ? ? }
? ? } finally {
? ? ? queryStack--;
? ? }
? ? if (queryStack == 0) {
? ? ? // 懶加載操作的處理
? ? ? for (DeferredLoad deferredLoad : deferredLoads) {
? ? ? ? deferredLoad.load();
? ? ? }
? ? ? deferredLoads.clear();
? ? ? // 如果本地緩存的作用域為STATEMENT，則立刻清除本地緩存
? ? ? if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
? ? ? ? clearLocalCache();
? ? ? }
? ? }
? ? return list;
? }
?
??
?
? /**
? ?* 生成查詢的緩存的鍵
? ?* @param ms 映射語句對象
? ?* @param parameterObject 參數(shù)對象
? ?* @param rowBounds 翻頁限制
? ?* @param boundSql 解析結(jié)束后的SQL語句
? ?* @return 生成的鍵值
? ?*/
? @Override
? public CacheKey createCacheKey(MappedStatement ms, Object parameterObject, RowBounds rowBounds, BoundSql boundSql) {
? ? if (closed) {
? ? ? throw new ExecutorException("Executor was closed.");
? ? }
? ? // 創(chuàng)建CacheKey，并將所有查詢參數(shù)依次更新寫入
? ? CacheKey cacheKey = new CacheKey();
? ? cacheKey.update(ms.getId());
? ? cacheKey.update(rowBounds.getOffset());
? ? cacheKey.update(rowBounds.getLimit());
? ? cacheKey.update(boundSql.getSql());
? ? List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
? ? TypeHandlerRegistry typeHandlerRegistry = ms.getConfiguration().getTypeHandlerRegistry();
? ? for (ParameterMapping parameterMapping : parameterMappings) {
? ? ? if (parameterMapping.getMode() != ParameterMode.OUT) {
? ? ? ? Object value;
? ? ? ? String propertyName = parameterMapping.getProperty();
? ? ? ? if (boundSql.hasAdditionalParameter(propertyName)) {
? ? ? ? ? value = boundSql.getAdditionalParameter(propertyName);
? ? ? ? } else if (parameterObject == null) {
? ? ? ? ? value = null;
? ? ? ? } else if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
? ? ? ? ? value = parameterObject;
? ? ? ? } else {
? ? ? ? ? MetaObject metaObject = configuration.newMetaObject(parameterObject);
? ? ? ? ? value = metaObject.getValue(propertyName);
? ? ? ? }
? ? ? ? cacheKey.update(value);
? ? ? }
? ? }
? ? if (configuration.getEnvironment() != null) {
? ? ? cacheKey.update(configuration.getEnvironment().getId());
? ? }
? ? return cacheKey;
? }
}