[Java] mybatis查询语句揭秘之封装数据

@override
 public <e> list<e> doquery(mappedstatement ms, object parameter, rowbounds rowbounds, resulthandler resulthandler, boundsql boundsql) throws sqlexception {
 statement stmt = null;
 try {
 configuration configuration = ms.getconfiguration();
 // 这里也就是采用了策略模式(个人感觉有点像)，实际的statementhandler为routingstatementhandler
 statementhandler handler = configuration.newstatementhandler(wrapper, ms, parameter, rowbounds, resulthandler, boundsql);
 stmt = preparestatement(handler, ms.getstatementlog());
 // 虽然是执行的routingstatementhandler.query，但返回结果的还是preparedstatementhandler处理
 return handler.query(stmt, resulthandler);
 } finally {
 closestatement(stmt);
 }
 }
 
private statement preparestatement(statementhandler handler, log statementlog) throws sqlexception {
 statement stmt;
 // 使用了代理模式，也可以理解为对connection进行了一层包装，这里的作用就是加了log处理
 connection connection = getconnection(statementlog);
 //进行预编译,即类似jdbc的 sql,如 select * from user where id=?
 stmt = handler.prepare(connection, transaction.gettimeout());
 // 对执行查询的sql进行参数设置
 handler.parameterize(stmt);
 return stmt;
 }

@override
 public void setparameters(preparedstatement ps) {
 errorcontext.instance().activity("setting parameters").object(mappedstatement.getparametermap().getid());
 // 获取配置文件里面的sql参数信息，如sql为select * from user where id=#{userid,jdbctype=integer}
 // parametermapping 记录了参数名也就是userid,还有记录了对应的jdbc类型，还有对应的javatype等等，具体可以debug看下
 list<parametermapping> parametermappings = boundsql.getparametermappings();
 if (parametermappings != null) {
 for (int i = 0; i < parametermappings.size(); i++) {
 parametermapping parametermapping = parametermappings.get(i);
 if (parametermapping.getmode() != parametermode.out) {
  object value;
  string propertyname = parametermapping.getproperty();
  // 如果为true，那么sql参数中有类似 user.name 格式
  if (boundsql.hasadditionalparameter(propertyname)) { // issue #448 ask first for additional params
  value = boundsql.getadditionalparameter(propertyname);
  } else if (parameterobject == null) {
  value = null;
  } else if (typehandlerregistry.hastypehandler(parameterobject.getclass())) {
  value = parameterobject;
  } else {
  // metaobject 类似一个工具类，它里面有一个反射工厂，可以专门解析一个类的信息，如字段的setter/getter/属性信息，这里不做多余介绍
  // 1、下面详细介绍 
  metaobject metaobject = configuration.newmetaobject(parameterobject);
  value = metaobject.getvalue(propertyname);// 取值
  }
  // 获取对应的typehandler，一般情况不设置的话，基本都是objecttypehandler
  typehandler typehandler = parametermapping.gettypehandler();
  jdbctype jdbctype = parametermapping.getjdbctype();
  if (value == null && jdbctype == null) {
  jdbctype = configuration.getjdbctypefornull();
  }
  try {
  // 进行设值
  typehandler.setparameter(ps, i + 1, value, jdbctype);
  } catch (typeexception e) {
  throw new typeexception("could not set parameters for mapping: " + parametermapping + ". cause: " + e, e);
  } catch (sqlexception e) {
  throw new typeexception("could not set parameters for mapping: " + parametermapping + ". cause: " + e, e);
  }
 }
 }
 }
 }

/**
 * mybatis数据处理有单结果集和多结果集处理，一般多结果集出现存储过程中，如果存储过程中写了两条select语句，如
 * select * from user , select * from classes 这种情况这里不做介绍，因为本人用的不多，理解的也不是很透彻。
 * 这里不多做介绍，这里只针对简单映射做一个大概介绍
 *
 */
public list<object> handleresultsets(statement stmt) throws sqlexception {
 errorcontext.instance().activity("handling results").object(mappedstatement.getid());
 // 保存查询结果
 final list<object> multipleresults = new arraylist<>();
 
 int resultsetcount = 0;
 // 获取第一条数据
 resultsetwrapper rsw = getfirstresultset(stmt);
 // 如果不是多结果集映射，一般resultmaps的大小为1
 // resultmap中存储的有类的字段属性，数据库字段名称等信息
 list<resultmap> resultmaps = mappedstatement.getresultmaps();
 int resultmapcount = resultmaps.size();
 // 校验数据的正确性
 validateresultmapscount(rsw, resultmapcount);
 while (rsw != null && resultmapcount > resultsetcount) {
 resultmap resultmap = resultmaps.get(resultsetcount);
 // 处理结果集映射
 handleresultset(rsw, resultmap, multipleresults, null);
 rsw = getnextresultset(stmt);
 cleanupafterhandlingresultset();
 resultsetcount++;
 }
 // 处理slect 标签的resultsets属性，多个用逗号隔开，个人几乎没用过，略过
 string[] resultsets = mappedstatement.getresultsets();
 if (resultsets != null) {
 while (rsw != null && resultsetcount < resultsets.length) {
 resultmapping parentmapping = nextresultmaps.get(resultsets[resultsetcount]);
 if (parentmapping != null) {
  string nestedresultmapid = parentmapping.getnestedresultmapid();
  resultmap resultmap = configuration.getresultmap(nestedresultmapid);
  handleresultset(rsw, resultmap, null, parentmapping);
 }
 rsw = getnextresultset(stmt);
 cleanupafterhandlingresultset();
 resultsetcount++;
 }
 }
 
 return collapsesingleresultlist(multipleresults);
 }

private void handleresultset(resultsetwrapper rsw, resultmap resultmap, list<object> multipleresults, resultmapping parentmapping) throws sqlexception {
 try {// 针对简单映射，parentmapping是为null的
 if (parentmapping != null) {
 handlerowvalues(rsw, resultmap, null, rowbounds.default, parentmapping);
 } else {
 // 默认使用defaultresulthandler，如需使用自定义的，则可在传参加入resulthandler接口实现类
 if (resulthandler == null) {
  defaultresulthandler defaultresulthandler = new defaultresulthandler(objectfactory);
  // 处理结果，结果存在resulthandler里
  handlerowvalues(rsw, resultmap, defaultresulthandler, rowbounds, null);
  multipleresults.add(defaultresulthandler.getresultlist());
 } else {
  handlerowvalues(rsw, resultmap, resulthandler, rowbounds, null);
 }
 }
 } finally {
 // issue #228 (close resultsets)
 closeresultset(rsw.getresultset());
 }
 }

public void handlerowvalues(resultsetwrapper rsw, resultmap resultmap, resulthandler<?> resulthandler, rowbounds rowbounds, resultmapping parentmapping) throws sqlexception {
 // 处理有嵌套映射的情况
 if (resultmap.hasnestedresultmaps()) {
 ensurenorowbounds();
 checkresulthandler();
 handlerowvaluesfornestedresultmap(rsw, resultmap, resulthandler, rowbounds, parentmapping);
 } else {//没有嵌套映射
 handlerowvaluesforsimpleresultmap(rsw, resultmap, resulthandler, rowbounds, parentmapping);
 }
 }

private void handlerowvaluesforsimpleresultmap(resultsetwrapper rsw, resultmap resultmap, resulthandler<?> resulthandler, rowbounds rowbounds, resultmapping parentmapping)
 throws sqlexception {
 defaultresultcontext<object> resultcontext = new defaultresultcontext<>();
 resultset resultset = rsw.getresultset();
 // 跳过多少行，到达指定记录位置，如在传参的时候传入了rowbounds，则会根据该类的offset值跳到指定记录位置
 skiprows(resultset, rowbounds);
 // shouldprocessmorerows 用来检测是否能继续对后续的结果进行映射
 while (shouldprocessmorerows(resultcontext, rowbounds) && !resultset.isclosed() && resultset.next()) {
 //用来处理resultmap节点中配置了discriminator节点，这里忽略掉
 resultmap discriminatedresultmap = resolvediscriminatedresultmap(resultset, resultmap, null);
 // 得到的结果就是sql执行后的一行记录，如返回user对象信息，则rowvalue就代表一个user实例，里面已经有值了
 object rowvalue = getrowvalue(rsw, discriminatedresultmap, null);
 //保存数据
 storeobject(resulthandler, resultcontext, rowvalue, parentmapping, resultset);
 }
 }

private object getrowvalue(resultsetwrapper rsw, resultmap resultmap, string columnprefix) throws sqlexception {
 final resultloadermap lazyloader = new resultloadermap();
 // 创建对象，可以理解为对resultmap节点的type属性值，进行了反射处理，得到了一个对象，但属性值都是默认值。
 object rowvalue = createresultobject(rsw, resultmap, lazyloader, columnprefix);
 if (rowvalue != null && !hastypehandlerforresultobject(rsw, resultmap.gettype())) {
 final metaobject metaobject = configuration.newmetaobject(rowvalue);
 boolean foundvalues = this.useconstructormappings;
 //是否需要自动映射，有三种映射，分别为none,partial,full，默认第二种，处理非嵌套映射，可通过automappingbehavior 配置
 if (shouldapplyautomaticmappings(resultmap, false)) {
 // 映射resultmap中未明确指定的列，如类中含有username属性，但是resultmap中没配置，则通过这个进行数据映射，还是可以查询到结果
 foundvalues = applyautomaticmappings(rsw, resultmap, metaobject, columnprefix) || foundvalues;
 }
 // 处理resultmap中指定的列
 foundvalues = applypropertymappings(rsw, resultmap, metaobject, lazyloader, columnprefix) || foundvalues;
 foundvalues = lazyloader.size() > 0 || foundvalues;
 // 如果没查询到结果，但配置可返回空对象(指的是没有设置属性值得对象)，则返回空对象，否则返回null
 rowvalue = foundvalues || configuration.isreturninstanceforemptyrow() ? rowvalue : null;
 }
 return rowvalue;
 }

private boolean applypropertymappings(resultsetwrapper rsw, resultmap resultmap, metaobject metaobject, resultloadermap lazyloader, string columnprefix)
 throws sqlexception {
 // 获取数据字段名
 final list<string> mappedcolumnnames = rsw.getmappedcolumnnames(resultmap, columnprefix);
 boolean foundvalues = false;
 // 获取的数据就是resultmap节点中配置的result节点，有多个result节点，这个集合大小就是多少
 // 里面存储的是属性名/字段名等信息
 final list<resultmapping> propertymappings = resultmap.getpropertyresultmappings();
 for (resultmapping propertymapping : propertymappings) {
 string column = prependprefix(propertymapping.getcolumn(), columnprefix);
 // 是否有嵌套映射
 if (propertymapping.getnestedresultmapid() != null) {
 // the user added a column attribute to a nested result map, ignore it
 column = null;
 }
 // 针对1来说一般常与嵌套查询配合使用
 // 2 判断属性基本映射
 // 3 多结果集的一个处理
 if (propertymapping.iscompositeresult()// 1
  || (column != null && mappedcolumnnames.contains(column.touppercase(locale.english)))// 2
  || propertymapping.getresultset() != null) {// 3
 // 获取当前column字段对于的值，有用到typehandler来进行参数的一个转换
 object value = getpropertymappingvalue(rsw.getresultset(), metaobject, propertymapping, lazyloader, columnprefix);
 
 //获取类的属性字段名
 final string property = propertymapping.getproperty();
 if (property == null) {
  continue;
 } else if (value == deferred) {// 类似占位符。处理懒加载数据
  foundvalues = true;
  continue;
 }
 if (value != null) {
  foundvalues = true;
 }
 if (value != null || (configuration.iscallsettersonnulls() && !metaobject.getsettertype(property).isprimitive())) {
  // 进行设置属性值
  metaobject.setvalue(property, value);
 }
 }
 }
 return foundvalues;
 }