欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-03-12 09:38:50
这一篇我们学习一下mybatis调用存储过程的使用和运行流程。首先我们先创建一个简单的存储过程 delimiter $ create procedure my...

这一篇我们学习一下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源码分析之存储过程调用和运行流程

接下来我们看看利用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源码分析之存储过程调用和运行流程

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