Mybatis调用数据库的存储过程和方法

 

 转载。 https://blog.csdn.net/ml0228123/article/details/81002258

 

上次的项目，要求我用java代码调用存储过程，折腾了好久。最后总算成功了。发片帖子纪念下，也给不懂存储过程的但是要调用的人一些提示

首先介绍下存储过程（本人是不会写的，但是目前能看懂）

1.  
   create or replace procedure P_DAP_UNI_CUBE_INFO(V_CUBE_NAME IN VARCHAR2, --每个参数都有三部分 形参 in/out 类型， in是入参 ，out是返回的参数
2.  
   V_TABLE_NAME IN VARCHAR2,
3.  
   V_RETCODE OUT VARCHAR2,
4.  
   V_RETINFO OUT VARCHAR2) is /看括号里面的参数
5.  
   /*
6.  
   ************************************************************************* 后面不用看了我就粘了一半，反正不是我写的
7.  
   *名 称 --%@NAME: P_DAP_UNI_CUBE_INFO
8.  
   *功能描述 --%@COMMENT:
9.  
   *执行周期 --%@PERIOD:
10.  
    *参 数 --%@PARAM:ACCT_MONTH 帐期 YYMMDD
11.  
    *参 数 --%@PARAM:V_RETCODE 过程执行结果代码(成功：SUCCESS/失败：FAIL/等待：WAIT),输出参数
12.  
    *参 数 --%@PARAM:V_RETINFO 过程执行结果描述,输出参数
13.  
    *创 建 人 --%@CREATOR:
14.  
    *创建时间 --%@CREATED_TIME: 2018-3-12
15.  
    *备 注 --%@REMARK:
16.  
    *修改记录 --%@MODIFY: 修改人 YYYYMMDD 修改内容
17.  
    *来 源 表 --%@FROM:
18.  
    *目 标 表 --%@TO:
19.  
    **************************************************************************
20.  
    */
21.  
    V_PROV_ID VARCHAR2(3);
22.  
    V_PKG VARCHAR2(40);
23.  
    V_PROCNAME VARCHAR2(50);
24.  
    V_ROWLINE NUMBER := 0; -- 记录目标表数据变化记录数
25.  
    V_CUBE_ID VARCHAR2(100);
26.  
    V_FILEDATE VARCHAR2(100);

上面就是数据库里已经存在的 存储过程了。有4个参数，前两个是输入，后两个是输出。假如直接从plsql调用，可以这么写

然后点旁边的输出就能看到结果；

你需要在plsql能调用成功的情况下才能使用代码调用

用mybatis调用时候的xml文件

1.  
   <select id="addCubeSqlMap" parameterType="java.util.Map" statementType="CALLABLE" >
2.  
   {CALL jzyx_label.P_DAP_UNI_CUBE_INFO
3.  
   (#{V_CUBE_NAME,mode=IN,jdbcType=VARCHAR},
4.  
   #{V_TABLE_NAME,mode=IN,jdbcType=VARCHAR},
5.  
   #{V_RETCODE,mode=OUT,jdbcType=VARCHAR},
6.  
   #{V_RETINFO,mode=OUT,jdbcType=VARCHAR}
7.  
   )}
8.  
   </select>

大概就是select标签里面 call 存储过程名（参数1，参数2，参数3……）

虽然写了四个参数，但是其实你传过来的map只需要封装入参（就是mode=in）的就好了

mapper层

1.  
   // 执行 存储过程
2.  
   public int addCubeSqlMap(Map<String,String> sql);

 String cubeName = "第一个入参";
 String factTableName = "第二个入参";

 Map<String,String > parm = new HashMap<String,String>();
 parm.put("V_CUBE_NAME",cubeName);
 parm.put("V_TABLE_NAME",factTableName);
evapMapper.addCubeSqlMap(parm);

反正在map里面放入两个入参，传过去就能执行储存过程。

我当时不需要存储过程的返回值就没有取，如果要取存储过程的返回值直接用这个map去get就拿到了假设我要取这个过程的参数应该这么写

1.  
               evapMapper.addCubeSqlMap(parm); //接着上面的代码
2.  
   parm.get("V_RETCODE");        //直接get你要传入xml的map get mode=out 的那个参数名就拿到了存储过程给你返回的值……是不是很奇妙
3.  
   parm.get(" V_RETINFO");

---------------------------------分隔线

当时遇到的一个错误，贴出来警告自己，为什么那么蠢

PLS-00904 就是告诉你你这个账户没有权限调用那个库的存储过程，不用怀疑！！赶紧登上plsql试试，肯定是这样的

---------------------分割线

 

Mybatis调用数据库的存储过程和方法

 

 

定义一个存储过程：

create or replace procedure prg_add(p1 in number,p2 in number,p3 out number)
as
begin
  p3:=p1+p2;
end;

定义一个方法：

create or replace function fun_add(p1 number, p2 number)
return number
as
begin
  return p1+p2;
end;

java中的sql调用语句：

String sql="{call 存储过程名(?,?,?)}"

Register(3,Number);

String sql="{?=call 函数名(?,?)}"

jdbc.properties:

url=jdbc:oracle:thin:@localhost:1521:orcl
driverClass=oracle.jdbc.OracleDriver
account=scott
password=tiger

mybatis.xml:

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>

    <properties resource="cn/et/mybatis/lesson01/jdbc.properties">

    </properties>

  <!--
    配置连接数据库的环境   development开发环境
  -->
  <environments default="development">
    <environment id="development">
      <!-- 事务交给JDBC来管理   也就是通过 Connection的 commit和rollback管事事务 -->
      <transactionManager type="JDBC"/>
      <dataSource type="POOLED">
        <property name="driver" value="${driverClass}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${account}"/>
        <property name="password" value="${password}"/>
      </dataSource>
    </environment>
  </environments>

  <mappers>
    <mapper resource="cn/et/mybaits/lesson02/func/call_mapper.xml" />
  </mappers>
</configuration>

call_mapper.xml:

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<!--
    接口映射
    namespace必需跟接口的全名一致
 -->
<mapper namespace="cn.et.mybaits.lesson02.func.CallMapper">
    <!--  statementType: STATEMENT就是搞sql语句     CALLABLE就是搞存储过程和函数-->
    <select id="callProcedure" parameterType="map"  statementType="CALLABLE">
        {
            call prg_add(
                #{p1,mode=IN,jdbcType=NUMERIC},
                #{p2,mode=IN,jdbcType=NUMERIC},
                #{p3,mode=OUT,jdbcType=NUMERIC}
            )
        }
    </select>
    <select id="callFunction" parameterType="map"  statementType="CALLABLE">
        {
            #{p3,mode=OUT,jdbcType=NUMERIC}=call fun_add(
                #{p1,mode=IN,jdbcType=NUMERIC},
                #{p2,mode=IN,jdbcType=NUMERIC}
            )
        }
    </select>


</mapper>

CallMapper接口：

package cn.et.mybaits.lesson02.func;

import java.util.Map;

public interface CallMapper {

    public void callProcedure(Map map);

    public void callFunction(Map map);
}

TestMabatis.Java:

package cn.et.mybaits.lesson02.func;

import java.io.InputStream;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.Test;

public class TestMybatis {

    public static SqlSession getSession(){
        String resource = "/cn/et/mybaits/lesson02/mybatis.xml";
        InputStream inputStream = TestMybatis.class.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        //打开会话
        SqlSession session = sqlSessionFactory.openSession();
        return session;
    }

/*  public static void main(String[] args) {
        SqlSession session = getSession();
        CallMapper cm = session.getMapper(CallMapper.class);
        Map map = new HashMap();
        map.put("p1", 145);
        map.put("p2", 100);
        cm.callProcedure(map);
        System.out.println(map.get("p3"));
    }
    */
    public static void main(String[] args) {
        SqlSession session = getSession();
        CallMapper cm = session.getMapper(CallMapper.class);
        Map map = new HashMap();
        map.put("p1", 1243);
        map.put("p2", 1000);
        cm.callFunction(map);
        System.out.println(map.get("p3"));
    }
}