Mybatis|Mybatis 执行顺序 Mybatis执行顺序

ListappMuserident = appMuseridentService.getAppMuserident(startDate, endDate, IOS_LIVE_VIDEO_CONTROLLER, null);
//MapperFactoryBean
public T getObject() throws Exception {
return this.sqlSession.getMapper(this.mapperInterface);
}
//SqlSessionFactoryBean 建造者模式
public void afterPropertiesSet() throws Exception {
Assert.notNull(this.dataSource, "Property 'dataSource' is required");
Assert.notNull(this.sqlSessionFactoryBuilder, "Property 'sqlSessionFactoryBuilder' is required");
Assert.notNull(this.transactionFactoryClass, "Property 'transactionFactoryClass' is required");
this.sqlSessionFactory = this.buildSqlSessionFactory();
}
public SqlSessionFactory getObject() throws Exception {
if (this.sqlSessionFactory == null) {
this.afterPropertiesSet();
}
return this.sqlSessionFactory;
}
//SqlSessionFactoryBuilder
public SqlSessionFactory build(Configuration config) {
return new DefaultSqlSessionFactory(config);
}
发现，其实调用DefaultSqlSesion的getMapper
//DefaultSqlSession
public T getMapper(Class type) {
return configuration.getMapper(type, this);
}
//Configuration
public T getMapper(Class type, SqlSession sqlSession) {
return mapperRegistry.getMapper(type, sqlSession);
}
//MapperRegistry
public T getMapper(Class 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);
}
}
//MapperProxy 动态代理
public static T newMapperProxy(Class mapperInterface, SqlSession sqlSession) {
ClassLoader classLoader = mapperInterface.getClassLoader();
Class[] interfaces = new Class[]{mapperInterface};
MapperProxy proxy = new MapperProxy(sqlSession);
return (T) Proxy.newProxyInstance(classLoader, interfaces, proxy);
}
}
public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
if (!OBJECT_METHODS.contains(method.getName())) {
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()) {
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;
}
查看invoke
//MapperMethod
public Object execute(Object[] args) {
Object result;
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 (returnsList) {
result = executeForList(args);
} else if (returnsMap) {
result = executeForMap(args);
} else {
Object param = getParam(args);
result = sqlSession.selectOne(commandName, param);
}
} else {
throw new BindingException("Unkown execution method for: " + commandName);
}
return result;
}
private List executeForList(Object[] args) {
List result;
Object param = getParam(args);
if (rowBoundsIndex != null) {
RowBounds rowBounds = (RowBounds) args[rowBoundsIndex];
result = sqlSession.selectList(commandName, param, rowBounds);
} else {
result = sqlSession.selectList(commandName, param);
}
return result;
}
private Map executeForMap(Object[] args) {
Map result;
Object param = getParam(args);
if (rowBoundsIndex != null) {
RowBounds rowBounds = (RowBounds) args[rowBoundsIndex];
result = sqlSession.selectMap(commandName, param, mapKey, rowBounds);
} else {
result = sqlSession.selectMap(commandName, param, mapKey);
}
return result;
}
private Object getParam(Object[] args) {
final int paramCount = paramPositions.size();
if (args == null || paramCount == 0) {
return null;
} else if (!hasNamedParameters && paramCount == 1) {
return args[paramPositions.get(0)];
} else {
Map param = new HashMap();
for (int i = 0; i < paramCount; i++) {
param.put(paramNames.get(i), args[paramPositions.get(i)]);
}
return param;
}
}
最后发现执行还是SqlSession 里的方法
//DefaultSqlSession
public void select(String statement, Object parameter, RowBounds rowBounds, ResultHandler handler) {
try {
MappedStatement ms = configuration.getMappedStatement(statement);
executor.query(ms, wrapCollection(parameter), rowBounds, handler);
} catch (Exception e) {
throw ExceptionFactory.wrapException("Error querying database.Cause: " + e, e);
} finally {
ErrorContext.instance().reset();
}
}
发现执行的是Executor中的方法
//SimpleExecutor
public List doQuery(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
Statement stmt = null;
try {
Configuration configuration = ms.getConfiguration();
StatementHandler handler = configuration.newStatementHandler(this, ms, parameter, rowBounds, resultHandler);
stmt = prepareStatement(handler);
return handler.query(stmt, resultHandler);
} finally {
closeStatement(stmt);
}
}
【Mybatis|Mybatis 执行顺序】//SimpleStatementHandlerpublic List query(Statement statement, ResultHandler resultHandler)throws SQLException {String sql = boundSql.getSql(); statement.execute(sql); return resultSetHandler.handleResultSets(statement); }

Mybatis|Mybatis 执行顺序

推荐阅读

油漆的漆怎么组词汉字漆怎么组词

mysqldatatime设置默认值，mysql数据库怎么设置默认当前时间

佳能相机滤镜怎么调好看佳能滤镜模式

局域网行为分析系统,行为分析系统的主要功能

爱普生wf7710固件FA27HC

妹妹的女儿怎么称呼弟弟的女儿怎么称呼

iphone自动清除短信苹果自动清除短信验证码怎么设置

鼻炎|宝宝一直流鼻涕，是感冒还是鼻炎？

2020年立秋准确时间几点几分

40多岁了,在北京还能干什么工作？

要做直播需要什么，做直播需要什么配置的电脑

尼康3200，尼康3200与5100差别有多大

秋天有哪些成熟的水果

吉利博瑞和博瑞ge有什么区别吉利博瑞和博瑞GE的区别是什么

Win7彻底隐藏文件及解除彻底隐藏的方法

卫星到处偷拍,被监视的国家能不能用导弹将其打下来？为什么？

黑莓手机怎么下载软件? 黑莓手机怎么下载软件

笔记本无法关机是什么情况？Win10怎么限制用户使用关机？

荆芥的功效与作用荆芥的功效与作用及禁忌

狭义的人力资源规划实质上是什么