个人中心
gpt4 book ai didi

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

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Mybatis源码分析之存储过程调用和运行流程由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

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

?
1
2
3
4
5
6
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添加存储过程调用配置:

?
1
2
3
<select id= "count" statementType= "CALLABLE" parameterMap= "getUserCountMap" >
   CALL mybatis.ges_user_count(?,?)
</select>

Main函数:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
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.

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
//
// 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源码分析之存储过程调用和运行流程，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对我网站的支持！ 。

原文链接：http://blog.csdn.net/qq924862077/article/details/53198444 。

最后此篇关于Mybatis源码分析之存储过程调用和运行流程的文章就讲到这里了,如果你想了解更多关于Mybatis源码分析之存储过程调用和运行流程的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： PHP的PDO常用类库实例分析
文章推荐： PHP Ajax实现无刷新附件上传
文章推荐： java 中函数的参数传递详细介绍
文章推荐： PHP安全下载文件的方法
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com