一直在用Mybatis,身处互联网公司,对于存储过程这块一直没怎么使用,数据库设计基本上都是单表+冗余+服务划分来设计,关键部分使用缓存,因此对存储过程一直不怎么感冒。今天偶然看到一篇Mybatis操作存储过程的文章,发现了一奇妙的事情(可能是见识少了些),传入的参数在查询成功后就有了结果的值。二话不说下载源码就开干!
-------------------------------------------一个文档中的内容,未标明作者,这里就不注明版权了------------------------
首先是,数据库创建的脚本:
CREATE TABLE p_user(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(10),sex CHAR(2));INSERT INTO p_user(NAME,sex) VALUES('A',"男");INSERT INTO p_user(NAME,sex) VALUES('B',"女");INSERT INTO p_user(NAME,sex) VALUES('C',"男");#创建存储过程( 查询得到男性或女性的数量, 如果传入的是 0 就女性否则是男性)DELIMITER $CREATE PROCEDURE tssss.ges_user_count(IN sex_id INT, OUT user_count INT)BEGINIF sex_id=0 THENSELECT COUNT(*) FROM tssss.p_user WHERE p_user.sex='女' INTO user_count;ELSESELECT COUNT(*) FROM tssss.p_user WHERE p_user.sex='男' INTO user_count;END IF;END$#调用存储过程DELIMITER ;SET @user_count = 0;CALL tssss.ges_user_count(1, @user_count);SELECT @user_count;
然后新建一个Java项目,需要的jar包为Mybatis的jar和mysql连接jar,如下:
mybatis-3.2.8.jarmysql-connector-java-5.1.34.jar
新建一个Mybatis的配置文件sqlMapConfig.xml
新建一个mapper映射文件TssssMapper.xml:
新建一个测试类:
package mybatis2;import java.io.IOException;import java.io.Reader;import java.util.HashMap;import java.util.Map;import org.apache.ibatis.io.Resources;import org.apache.ibatis.session.ResultContext;import org.apache.ibatis.session.ResultHandler;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;public class A { public static void main(String[] args) throws IOException { String resource = "sqlMapConfig.xml"; Reader reader = Resources.getResourceAsReader(resource); SqlSessionFactory ssf = new SqlSessionFactoryBuilder().build(reader); SqlSession session = ssf.openSession(); MapparamMap = new HashMap<>(); paramMap.put("sex_id", 1); try { Object returnValue = session.selectOne("getCount", paramMap); System.out.println("result="+paramMap.get("result")); System.out.println("sex_id="+paramMap.get("sex_id")); System.out.println("returnValue="+returnValue); } catch (Exception e) { e.printStackTrace(); } finally { session.close(); } System.out.println("result="+paramMap.get("result")); System.out.println("sex_id="+paramMap.get("sex_id")); } }
--------------------------------------------------------------------------------------------------------------------------------------------------
很神奇的发现,传入的paraMap参数在查询后有了存储过程的结果值 result,我决定去找找源码。通过跟踪找到了两个关键的类org.apache.ibatis.mapping.ParameterMode.java和org.apache.ibatis.executor.resultset.DefaultResultSetHandler.Java:
package org.apache.ibatis.mapping;/** * @author Clinton Begin */public enum ParameterMode { IN, OUT, INOUT}
public void handleOutputParameters(CallableStatement cs) throws SQLException { final Object parameterObject = parameterHandler.getParameterObject(); final MetaObject metaParam = configuration.newMetaObject(parameterObject); final ListparameterMappings = 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)); } } } }
其中在DefaultResultSetHandler类中的handleOutputParameters(CallableStatement cs)方法中处理了传入参数和传出的参数。有兴趣的童鞋也可以试着跟一下,这里判断了当parameterMapping.getMode() == ParameterMode.OUT时候,即现在操作的为存储过程的out参数,因此这里在metaParam.setValue(parameterMapping.getProperty(), typeHandler.getResult(cs, i + 1)); 该句的时候将存储过程的result值设置给了输入的参数map。
该句执行前:
该句执行后:
到此为止,知道其内部的设置结果。其实对于使用来说这并没有什么意义,但是多看源码对自己的思路以及底层还是有好处,反正我是信了。
纯手打,欢迎拍砖~
转载请指明出处: