Mybatis源码分析之存储过程调用和运行流程

这一篇我们学习一下mybatis调用存储过程的使用和运行流程。首先我们先创建一个简单的存储过程

delimiter $ 
create procedure mybatis.ges_user_count(in age int, out user_count int) 
begin 
select count(*) from users where users.age=age into user_count; 
end 
$ 

这个存储过程的含义其实比较简单的，就是输入age，然后执行select count(*) from users where users.age = age into user_count；获得年龄等于age的人数赋值给user_count，还是比较简单的。

接下来是存储过程的调用，执行如下命令就可以完成存储过程的调用。

接下来我们看看利用mybatis是如何调用存储过程的。

usermapper.xml添加存储过程调用配置：

<select id="count" statementtype="callable" parametermap="getusercountmap"> 
  call mybatis.ges_user_count(?,?) 
</select> 

main函数：

public class learn1main { 
 public static void main(string [] args){ 
  //mybatis的配置文件 
  string resource = "learn/mybatis-config.xml"; 
  //使用类加载器加载mybatis的配置文件（它也加载关联的映射文件） 
  inputstream is = learn1main.class.getclassloader().getresourceasstream(resource); 
  //构建sqlsession的工厂 
  sqlsessionfactory sessionfactory = new sqlsessionfactorybuilder().build(is); 
  sqlsession session = sessionfactory.opensession(); 
  map<string, integer> parametermap = new hashmap<string, integer>(); 
  parametermap.put("age", 12); 
  parametermap.put("user_count", -1); 
  session.selectone("com.tianjunwei.learn.learn1.entity.user.count", parametermap); 
  integer result = parametermap.get("user_count"); 
  system.out.println(result); 
 } 
} 

运行结果：

其最终的执行过程在defaultresultsethandler中，调用普通的sql和存储过程之间还是有所区别的，sql语句的执行是使用callablestatement。

// 
// handle output parameter 
// 
//调用存储过程返回结果，将结果值放在参数中 
@override 
public void handleoutputparameters(callablestatement cs) throws sqlexception { 
 final object parameterobject = parameterhandler.getparameterobject(); 
 final metaobject metaparam = configuration.newmetaobject(parameterobject); 
 final list<parametermapping> parametermappings = boundsql.getparametermappings(); 
/循环处理每个参数 
 for (int i = 0; i < parametermappings.size(); i++) { 
 final parametermapping parametermapping = parametermappings.get(i); 
 //判断参数的模式 
 if (parametermapping.getmode() == parametermode.out || parametermapping.getmode() == parametermode.inout) { 
  if (resultset.class.equals(parametermapping.getjavatype())) { 
  handlerefcursoroutputparameter((resultset) cs.getobject(i + 1), parametermapping, metaparam); 
  } else { 
  final typehandler<?> typehandler = parametermapping.gettypehandler(); 
  metaparam.setvalue(parametermapping.getproperty(), typehandler.getresult(cs, i + 1)); 
  } 
 } 
 } 
} 
private void handlerefcursoroutputparameter(resultset rs, parametermapping parametermapping, metaobject metaparam) throws sqlexception { 
 try { 
 final string resultmapid = parametermapping.getresultmapid(); 
 final resultmap resultmap = configuration.getresultmap(resultmapid); 
 final defaultresulthandler resulthandler = new defaultresulthandler(objectfactory); 
 final resultsetwrapper rsw = new resultsetwrapper(rs, configuration); 
 handlerowvalues(rsw, resultmap, resulthandler, new rowbounds(), null); 
 metaparam.setvalue(parametermapping.getproperty(), resulthandler.getresultlist()); 
 } finally { 
 // issue #228 (close resultsets) 
 closeresultset(rs); 
 } 
} 

以上所述是小编给大家介绍的mybatis源码分析之存储过程调用和运行流程，希望对大家有所帮助