MyCat1.6带返回参数存储过程调用示例

本例环境:SpringMVC3.x + Mybatis3.x + Mycat1.6 + Mysql5.6

1、创建带出参存储过程

[sql] view plain copy

  1. DELIMITER &&
  2. CREATE  PROCEDURE `test_proc`( in a_id int , out a_goods_id int)
  3. BEGIN
  4.               SELECT  a.goods_id  INTO  a_goods_id
  5.               FROM  es_goods_community a
  6.               WHERE  a.id=a_id ;
  7. END &&
  8. DELIMITER ;

备注:这里的存储过程比较简单,就是根据一个表的ID,返回一个表的另外一个字段,本例中a_goods_id为出参。
2、mybatis映射文件

[html] view plain copy

  1. <select id=“testCallProc” resultType=“java.lang.Integer”>  <!– statementType=”CALLABLE” –>
  2.          <![CDATA[
  3.        /*!mycat:sql=select 1 from es_goods_community where seller_id=26*/{call test_proc(
  4.               #{id,mode=IN,jdbcType=INTEGER},
  5.               @goodsId
  6.            )};select @goodsId;
  7.        ]]>
  8.     </select>
这里的关键:statementType=”CALLABLE”不需要加上,而是把存储过程当成一条普通的SQL语句,发送给mycat执行,mycat根据注解路由到具体的后端节点,然后执行之,并返回结果,还需要在后面使用selelect语句返回OUT参数。在call语句中,出参用@加变量名定义,名字与select语句中的名字保持一样即可。
为什么要这样写呢?原因如下:
1、mycat已经声明,存储过程的调用通过注解来支持(主要原因,调用存储过程的语句无法定位路由信息),如果statementType=”CALLABLE”,mysql客户端(本例指mysql驱动包)会把语句当存储过程来看到,势必需要知道存储过程的元数据(出参列表)。故在mybatis文件中,call语句之前需要待上注解,但这和mycat驱动包处理存储过程的代码产生了矛盾,如下代码:
[java] view plain copy

  1. public CallableStatement(MySQLConnection conn, String sql, String catalog,
  2.             boolean isFunctionCall) throws SQLException {
  3.         super(conn, sql, catalog);
  4.         this.callingStoredFunction = isFunctionCall;
  5.         if (!this.callingStoredFunction) {
  6.             if (!StringUtils.startsWithIgnoreCaseAndWs(sql, “CALL”)) {      // @1
  7.                 // not really a stored procedure call
  8.                 fakeParameterTypes(false);      //@2
  9.             } else {
  10.                 determineParameterTypes();  //@3
  11.             }
  12.             generateParameterMap();
  13.         } else {
  14.             determineParameterTypes();
  15.             generateParameterMap();
  16.             this.parameterCount += 1;
  17.         }
  18.         this.retrieveGeneratedKeys = true// not provided for in the JDBC spec
  19.     }
代码来源与mysql-connector-java-5.1.30.jar中CallableStatement,现在做个简单的解读:
代码@1,判断SQL语句是否以CALL语句开头,如果不是,则调用代码@2fakeParameterTypes方法, 我可以很负责任人的告诉你,该方法只是固定返回一个参数列表,完全与调用的存储过程的出参列表不匹配
代码@3,调用后端连接,得到存储过程的源信息:发送的语句为:SELECT name, type, comment FROM mysql.proc WHERE name like ‘存储过程名’ and db <=> ‘数据库名’ ORDER BY name, type;
但mycat的处理如下:io.mycat.server.ServerConnection 的public void execute(String sql, int type) 方法:

跟进MysqlProcHandler.handle方法得知,mycat只是返回空数据给前端连接,并没有去后端执行该语句。所以,mybatis配置文件的statementType不能陪在为CALLABLE的原因。
3、DAO与控制层的代码就在这里省略。完整的代码如下:http://git.oschina.net/zhcsoft/StudyDemo  包路径为:persistent.prestige.web下。
备注:不能在mysql客户端连接工具(连接mycat)中直接运行:
call test_proc(140,@goodsId)};select @goodsId;得不到正确的数据原因分析:
因为在客户端查询分析器中执行该命令,,是分两条语句 call test_proc(140,@goodsId);  select @goodsId;两条命令发送给mycat执行的,这样发送到后端的连接,两次不一定使用相同的Connection连接,所以无法得到值,
 call test_proc(140,@goodsId);  select @goodsId; 必须当成一个multi-statement语句一起发送给mycat,才能正确得到结果。
再次声明:完整的示例代码地址:http://git.oschina.net/zhcsoft/StudyDemo

Leave a Reply

This site uses Akismet to reduce spam. Learn how your comment data is processed.