mybatis的拦截器interceptor源代码解析
mybatis支持拦截器，实现的原理就是利用JDK的动态代理。先前利用拦截器实现了分页功能，如今又利用拦截器实现日志记录的功能，感觉拦截器还是不错的，只是相对于spring3 mvc的拦截器感觉有些逊色。接下来，我着重分析一些拦截的使用。
【基本思路】拦截器在哪里拦截？什么情况下才会拦截代理？怎么代理呢？只要搞清楚这些，基本的拦截器功能也就了如指掌啦。
拦截器在哪里呢？mybatis到底提供几处可以拦截呢？请看下图，通过分析源码可知基本查询流程如下:
【简洁的流程】 首先mybatis初始化加载的时候，利用
MapperProxy代理
自己的Mapper接口类，
生成一个代理处理类，代理处理的逻辑都在
invoke方法里，首先获取到目标类的接口
declaringInterface，然后生成
MapperMethod，（其中
sqlSession是
SqlSessionTemplate，是spring连接mybatis的模板类，是由spring负责生成的），生成了
MapperMethod,直接调用
MapperMethod可执行的方法
execute就能获取执行结果，整个流程非常简洁，非常和spring3 mvc的servlet实现类似，也就是说，
MapperMethod就是一个命令，执行命令获取执行结果，也就是标准的命令模式。整个流程代码如下：
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (method.getDeclaringClass() == Object.class) {
return method.invoke(this, args);
}
final Class<?> declaringInterface = findDeclaringInterface(proxy, method);
final MapperMethod mapperMethod = new MapperMethod(declaringInterface, method, sqlSession);
final Object result = mapperMethod.execute(args);
if (result == null && method.getReturnType().isPrimitive()
&& !method.getReturnType().equals(Void.TYPE)) {
throw new BindingException(
"Mapper method '" + method.getName() + "' (" + method.getDeclaringClass()
+ ") attempted to return null from a method with a primitive return type ("
+ method.getReturnType() + ").");
}
return result;
}
【分步分析】
[*]
MapperMethod
查看excute方法可知，就是根据不同的sql类型，交给sqlSession，也就是SqlSessionTemplate类的对象，主要是完成获取执行参数
param
和
commandName，执行具体的操作，例如，
result =
sqlSession
.
selectList
(
commandName
, param);
。
其中sql类型的获取可参考初始化的时候加载的setupCommandType()，初始化的时候还包括获取map的sqlID等
[*]
SqlSessionTemplate和
SqlSessionInterceptor
利用eclipse的f4一下，可知
SqlSessionTemplate的实际执行是交给它的代理类完成的。查看
SqlSessionTemplate构造函数可知，是由
SqlSessionInterceptor动态代理的，那么所有的处理逻辑都是在
invoke方法里，从中可知，就是获取SqlSession,执行操作。其中
SqlSessionUtils
.
getSqlSession静态方法调用外部类
SqlSessionTemplate
的
SqlSessionFactory，
ExecutorType，这些都是在mybatis加载
SqlSessionTemplate
构造函数初始化的。
[*]
DefaultSqlSession
这个就是从
DefaultSqlSessionFactory工厂生成获取的，具体的加载流程就是在
sqlSession
.
selectList静态方法里。
接着上面的查询流程可知，调用的
selectList方法，通过
MapperMethod方法中获取的
commandName，获取到
MappedStatement对象，主要负责的就是sql里xml信息等，具体执行交给
executor，
executor是由
SqlSessionTemplate的
ExecutorType决定的。
[*]
executor和
Plugin
executor的获取是
DefaultSqlSessionFactory生成
DefaultSqlSession，加载的方法是在
Configuration里
newExecutor从中可知
cacheEnabled默认为ture，追加缓存实现，具体的实现还是
SimpleExecutor，属于静态代理，
cacheEnabled只是
实现了缓存功能。
executor = (Executor)
interceptorChain
.pluginAll(executor);
表明可追加拦截器。查看代码可知，
public Object pluginAll(Object target) {
for (Interceptor interceptor : interceptors) {
target = interceptor.plugin(target);
}
return target;
}
就是调用拦截Interceptor的方法plugin,我们在plugin方法里一般都需要调用Plugin的静态方法wrap生成Plugin动态代理目标类，由于又是动态代理，实现逻辑都是在invoke方法里，查看可知，调用Interceptor的intercept方法，由Invoction封装目标类，调用方法，调用参数。因此，我们实现自己的拦截器的时候，都可从intercept方法里获取到拦截的对象，方法，参数等。这里其中涉及到两个问题就是拦截器什么情况下才会代理的，怎样代理呢。第一个问题，查看wrap方法可知，就是查看Map里查找是否设定代理啦，以代理对象的class做为key，代理方法的set集合作为value，就能判定是否要代理的。Map里的数据是遍历拦截器的注解Intercepts，实现很简单。怎样打理的，就是调用Interceptor的intercept方法，具体的实现都是在自定义的拦截器方法里。
[*]
StatementHandler,
ParameterHandler,
ResultSetHandler和
Plugin
由
SimpleExecutor的
doQuery方法是具体的实现，
获取StatementHandler，然后通过StatementHandler获取Statement，其中
StatementHandler的获取又是在Configuration里newStatementHandler，同executor实现的类似，也是有RoutingStatementHandler代理实际的StatementHandler实现，通过StatementType获取具体的StatementHandler类，从默认配置可知，PreparedStatementHandler是实际代理的对象。这里也有
executor = (Executor)
interceptorChain
.pluginAll(executor)可知
同样可添加拦截器。其中构造StatementHandler的时候，查看BaseStatementHandler构造函数可知，ParameterHandler和ResultSetHandler也是有Configuration生成的，同样也可追加拦截器。
[*]
Statement和日志代理
由
SimpleExecutor的
doQuery方法调用
prepareStatement
可知，
Statement获取是通过StatementHandler的prepare方法生成的，由于PreparedStatementHandler是具体的实现类，查看可知，instantiateStatement方法里是具体的获取Statement方法，由ConnectionLogger代理类调用PreparedStatementLogger.newInstance生成PreparedStatementLogger。其中ConnectionLogger是DefaultSqlSessionFactory里wrapConnection方法获取的。
【总结】
mybatis的拦截器都是在
Configuration类的
InterceptorChain负责调用位置，Plugin类负责生成代理，调用具体的拦截器实现类
页:
[1]