一:不使用動(dòng)態(tài)代理的情況
? ? 首先看下如果不基于動(dòng)態(tài)代理的mapper(dao)層接口是怎樣的,
dao接口定義：
public interface SysUserDao {
????public SysUser selectById(Long id);
}
impl實(shí)現(xiàn)類：
public class SysUserDaoImpl? implements SysUserDao{
? ? ????public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
? ? ? ? this.sqlSessionFactory = sqlSessionFactory;
? ? }
? ? private SqlSessionFactorysqlSessionFactory;
? ? @Override
? ? public SysUserselectById(Long id) {
? ? ? SqlSession sqlSession =sqlSessionFactory.openSession();
SysUser user =?
(SysUser)sqlSession.selectOne("com.wonders.project.system.mapper.SysUserMapper.selectUserById");
sqlSession.close();
return user;
? ? }
}
其實(shí)就是拿到sqlsession 去調(diào)用api。
demo:
String resource = "mybatis-configuration.xml";
Reader reader;
try {
reader = Resources.getResourceAsReader(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader); SysUserDaoImpl sysUserDaoImpl = new SysUserDaoImpl(); sysUserDaoImpl.setSqlSessionFactory(sqlSessionFactory);
SysUser sysUser = sysUserDaoImpl.selectById(1L);
System.out.println(sysUser.toString());
} catch (IOException e) {
e.printStackTrace();
}
二：動(dòng)態(tài)代理的方式
首先demo的寫法：
String resource = "mybatis-configuration.xml";
Reader reader;
try {
reader = Resources.getResourceAsReader(resource);
SqlSessionFactory sqlMapper = new SqlSessionFactoryBuilder().build(reader);
SqlSession session = sqlMapper.openSession();
try {
SysUserMapper sysUserMapper = session.getMapper(SysUserMapper.class);
SysUser user = sysUserMapper.selectUserById(1L);
System.out.println(user.getUserName() + "," + user.getEmail());
} finally {
session.close();
}} catch (IOException e) {
e.printStackTrace();
}
動(dòng)態(tài)代理的實(shí)現(xiàn)過(guò)程分析
獲取代理對(duì)象
SysUserMapper sysUserMapper = session.getMapper(SysUserMapper.class);
首先來(lái)到：DefaultSqlSession的
@Override
public <T> T getMapper(Class<T> type) {
? return configuration.<T>getMapper(type, this);
}
交由configuration處理:
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) {
final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>)knownMappers.get(type);
if (mapperProxyFactory == null) {
throw new BindingException("Type " + type + " is not known to the MapperRegistry."); }
try {
return mapperProxyFactory.newInstance(sqlSession);
} catch (Exception e) {
throw new BindingException("Error getting mapper instance. Cause: " + e, e); }
接下來(lái)就是熟悉的動(dòng)態(tài)代理創(chuàng)建過(guò)程
protected T newInstance(MapperProxy<T> mapperProxy) {
return (T)?Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
}
public T newInstance(SqlSession sqlSession) {
final MapperProxy<T> mapperProxy = new MapperProxy<T>(sqlSession, mapperInterface, methodCache);
return newInstance(mapperProxy);}
重點(diǎn)關(guān)注MapperProxy的invoke方法
@Override
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
try {
if (Object.class.equals(method.getDeclaringClass())) {
????return method.invoke(this, args);
} else if (isDefaultMethod(method)) {
return invokeDefaultMethod(proxy, method, args);
} } catch (Throwable t) {
throw ExceptionUtil.unwrapThrowable(t);
}
final MapperMethod mapperMethod = cachedMapperMethod(method);
return mapperMethod.execute(sqlSession, args);
}
MapperMethod 的excute方法邏輯主要就是先判斷當(dāng)前方法是執(zhí)行語(yǔ)句的類型，包括select,update,insert。。。
然后組裝參數(shù)，如果是多個(gè)參數(shù)就放到map中,
最后執(zhí)行sqlSession的api方法,組裝返回值
case SELECT:
if (method.returnsVoid() && method.hasResultHandler()) {
executeWithResultHandler(sqlSession, args);
result = null;
} else if (method.returnsMany()) {
result = executeForMany(sqlSession, args);
} else if (method.returnsMap()) {
result = executeForMap(sqlSession, args);
} else if (method.returnsCursor()) {
result = executeForCursor(sqlSession, args);
} else {
Object param = method.convertArgsToSqlCommandParam(args); result = sqlSession.selectOne(command.getName(), param);
} break;
可以看到此處和不使用動(dòng)態(tài)代理的執(zhí)行邏輯其實(shí)是一樣的
以上只是mapper層面動(dòng)態(tài)代理實(shí)現(xiàn)過(guò)程，具體由這個(gè)"com.example.myabtislearn.SysUserMapper.selectUserById" 如何定位到執(zhí)行sql，我們下次分解
