mybatis中动态加载的应用(4)

jiaxp

　　之前，对于数据映射器的理解不是很懂（即 在mybatis中，通过sqlSession可以直接操作xml中sql语句,也可以新建MAPInterface来操作sql）,这几天仔细看了一下，由于基础方面的原因，并不能把全部的设计写出来，只能说个大概，有时间会在看看。
　　涉及数据映射器（这个名字好像只有在与spring整合才有这个说话，但是感觉这个名字比较形象哈）的几个主要类有SqlSession,DefaultSqlsession,Configuration,MapperProxy,MapperRegistry，需要的知识主要是动态代理。之前我困惑主要是在框架中，全部只有接口和sql配置文件，但是却能够操作数据库，有点不像hibernate,在DAO里面是有session这样涉及事务管理的，mybatis DAO没有，只能操作设定的方法，不能获取事务的。(动态代理可以理解为动态加载+代理模式，如果不懂的话，请参考http://www.cnblogs.com/jqyp/archive/2010/08/20/1805041.html，这篇博客，下附我自己随便写的简单代码)
　　( 回到正题，这个东西只能说个大概，请谅解，大神就留下您的理解，方便大家一起提高）
　　根据源代码，可以知道是以动态加载的形式获取代理对象的（在MapperProxy里面），并且是在此类里面获取代理对象

MapperProxy.java
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (!OBJECT_METHODS.contains(method.getName())) {
final Class<?> declaringInterface = findDeclaringInterface(proxy, method);//获取所有需要处理sql的接
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;
}
return null;
}
private Class<?> findDeclaringInterface(Object proxy, Method method) {
Class<?> declaringInterface = null;
for (Class<?> iface : proxy.getClass().getInterfaces()) {
try {
Method m = iface.getMethod(method.getName(), method.getParameterTypes());
if (declaringInterface != null) {
throw new BindingException("Ambiguous method mapping.  Two mapper interfaces contain the identical method signature for " + method);
} else if (m != null) {
declaringInterface = iface;
}
} catch (Exception e) {
// Intentionally ignore.
// This is using exceptions for flow control,
// but it's definitely faster.
}
}
if (declaringInterface == null) {
throw new BindingException("Could not find interface with the given method " + method);
}
return declaringInterface;
}
@SuppressWarnings("unchecked")
//mapperInterface为接口，sqlsession为包含配置xml的
public static <T> T newMapperProxy(Class<T> mapperInterface, SqlSession sqlSession) {
ClassLoader classLoader = mapperInterface.getClassLoader();
Class<?>[] interfaces = new Class[]{mapperInterface};
MapperProxy proxy = new MapperProxy(sqlSession);
return (T) Proxy.newProxyInstance(classLoader, interfaces, proxy);//获取代理对象
}
　　调用的MapperMethod，具体相当于注入代理对象的方法实现

//c初始化
public MapperMethod(Class<?> declaringInterface, Method method, SqlSession sqlSession) {
paramNames = new ArrayList<String>();
paramPositions = new ArrayList<Integer>();
this.sqlSession = sqlSession;
this.method = method;
this.config = sqlSession.getConfiguration();
this.hasNamedParameters = false;
this.declaringInterface = declaringInterface;
setupFields();
setupMethodSignature();
setupCommandType();
validateStatement();
}
//具体执行，返回获取能够执行sql的代理对象
public Object execute(Object[] args) {
Object result = null;
if (SqlCommandType.INSERT == type) {
Object param = getParam(args);
result = sqlSession.insert(commandName, param);
} else if (SqlCommandType.UPDATE == type) {
Object param = getParam(args);
result = sqlSession.update(commandName, param);
} else if (SqlCommandType.DELETE == type) {
Object param = getParam(args);
result = sqlSession.delete(commandName, param);
} else if (SqlCommandType.SELECT == type) {
if (returnsVoid && resultHandlerIndex != null) {
executeWithResultHandler(args);
} else if (returnsList) {
result = executeForList(args);
} else if (returnsMap) {
result = executeForMap(args);
} else {
Object param = getParam(args);
result = sqlSession.selectOne(commandName, param);
}
} else {
throw new BindingException("Unknown execution method for: " + commandName);
}
return result;
}
　　期间MapperMethod进行匹配（即接口与xml namespace下指定操作），但是为什么可以获取xml文件的配置呢？这时候Configuration这个类就出现了，是可以解析配置文件的内容的，所以可以注入相关的指令和sql语句，在封装好下的底层进行实现，我感觉这就是为什么sqlsession是可以完全控制配置文件里面的所有sql操作的原因，而且这一步是在sqlsssionFactory完成的，但是为什么由sqlsession.getMapper(xxx.class)获取的DAO操作类却只能操作接口定义的类？第一，最简单顾名思义，DAO操作类实现接口而已，而我们自己写的代码确实没有对其进行扩充，其实扩充了，但是没有写在配置文件，还是一回事；第二,在getMapper()里面，我们是以某个接口作为参数的，参考

DefaultSqlSession.class
public <T> T getMapper(Class<T> type) {
return configuration.getMapper(type, this);
}
Configuration
public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
return mapperRegistry.getMapper(type, sqlSession);
}
MapperRegistry
public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
if (!knownMappers.contains(type))
throw new BindingException("Type " + type + " is not known to the MapperRegistry.");
try {
return MapperProxy.newMapperProxy(type, sqlSession);
} catch (Exception e) {
throw new BindingException("Error getting mapper instance. Cause: " + e, e);
}
}
　　从上面的代码，我感觉是你单个接口，对吧，首先已经有sqlsession代理对象了，已经能够进行所有操作了，现在是通过getMapper方法获取一个DAO对象，其实还是动态代理的DAO,只不过这次是单个接口，而接口里并没有定义sql操作其他的方法，对吧，所以代理的对象只能进行这些操作了，走的class流程还是跟sqlsession代理对象产生时差不多，或许说在sqlsession里面已经有了所有xml的代理对象，但是我估计底层实现不可行的，因为，得时刻保存在内存里面，还不如构造一个通用的sqlsession，需要去的时候临时把对应的操作方法集合构造代理对象，这样比较科学。这一块我没怎么看明白哈！
　　以上就是我对mybatis获取SqlSession和DAO操作具体实现的一些简单认识，并且我回继续往下看！
　　此博客主要用于记录个人学习内容和梳理整体知识，若有许多不明和错误的地方，还请指出 ，若是其他方面，概不欢迎 ！
　　动态代理演示代码

1接口
public interface Name {
public void sayHello(String nusername);
}
2实现接口类
public class Proxyclass implements Name{
public void sayHello(String username) {
// TODO Auto-generated method stub
System.out.println(username);
}
}
3.实现动态代理
public class ProxyName implements InvocationHandler{
private Object proxied;
ProxyName(Object proxied){
this.proxied=proxied;
}
public Object invoke(Object proxy, Method method, Object[] params)
throws Throwable {
// TODO Auto-generated method stub
System.out.println(proxy.getClass().getName()+":"+method+":"+params[0]);
System.out.println(method.getName());
return(method.invoke(proxied, params));
}
}
4.测试
public class DynamicProxyDemo {
public static void main(String args[]) {
Proxyclass pro = new Proxyclass();
pro.sayHello("yaoge22");
Name name = (Name) Proxy.newProxyInstance(Name.class.getClassLoader(),
new Class[] { Name.class }, new ProxyName(pro));
name.sayHello("hello");
}
}