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

时间:2024-01-05 09:55:56
 转载。 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调用,可以这么写

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

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

你需要在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");

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

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

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


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

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

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

定义一个存储过程:

  1. create or replace procedure prg_add(p1 in number,p2 in number,p3 out number)
  2. as
  3. begin
  4. p3:=p1+p2;
  5. end;

定义一个方法:

  1. create or replace function fun_add(p1 number, p2 number)
  2. return number
  3. as
  4. begin
  5. return p1+p2;
  6. end;

java中的sql调用语句:

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

Register(3,Number);

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

jdbc.properties:

  1. url=jdbc\:oracle\:thin\:@localhost\:1521\:orcl
  2. driverClass=oracle.jdbc.OracleDriver
  3. account=scott
  4. password=tiger

mybatis.xml:

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration
  3. PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  4. "http://mybatis.org/dtd/mybatis-3-config.dtd">
  5. <configuration>
  6. <properties resource="cn/et/mybatis/lesson01/jdbc.properties">
  7. </properties>
  8. <!--
  9. 配置连接数据库的环境   development开发环境
  10. -->
  11. <environments default="development">
  12. <environment id="development">
  13. <!-- 事务交给JDBC来管理   也就是通过 Connection的 commit和rollback管事事务 -->
  14. <transactionManager type="JDBC"/>
  15. <dataSource type="POOLED">
  16. <property name="driver" value="${driverClass}"/>
  17. <property name="url" value="${url}"/>
  18. <property name="username" value="${account}"/>
  19. <property name="password" value="${password}"/>
  20. </dataSource>
  21. </environment>
  22. </environments>
  23. <mappers>
  24. <mapper resource="cn/et/mybaits/lesson02/func/call_mapper.xml" />
  25. </mappers>
  26. </configuration>

call_mapper.xml:

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3. PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4. "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <!--
  6. 接口映射
  7. namespace必需跟接口的全名一致
  8. -->
  9. <mapper namespace="cn.et.mybaits.lesson02.func.CallMapper">
  10. <!--  statementType: STATEMENT就是搞sql语句     CALLABLE就是搞存储过程和函数-->
  11. <select id="callProcedure" parameterType="map"  statementType="CALLABLE">
  12. {
  13. call prg_add(
  14. #{p1,mode=IN,jdbcType=NUMERIC},
  15. #{p2,mode=IN,jdbcType=NUMERIC},
  16. #{p3,mode=OUT,jdbcType=NUMERIC}
  17. )
  18. }
  19. </select>
  20. <select id="callFunction" parameterType="map"  statementType="CALLABLE">
  21. {
  22. #{p3,mode=OUT,jdbcType=NUMERIC}=call fun_add(
  23. #{p1,mode=IN,jdbcType=NUMERIC},
  24. #{p2,mode=IN,jdbcType=NUMERIC}
  25. )
  26. }
  27. </select>
  28. </mapper>

CallMapper接口:

  1. package cn.et.mybaits.lesson02.func;
  2. import java.util.Map;
  3. public interface CallMapper {
  4. public void callProcedure(Map map);
  5. public void callFunction(Map map);
  6. }

TestMabatis.Java:

  1. package cn.et.mybaits.lesson02.func;
  2. import java.io.InputStream;
  3. import java.util.HashMap;
  4. import java.util.List;
  5. import java.util.Map;
  6. import org.apache.ibatis.session.SqlSession;
  7. import org.apache.ibatis.session.SqlSessionFactory;
  8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  9. import org.junit.Test;
  10. public class TestMybatis {
  11. public static SqlSession getSession(){
  12. String resource = "/cn/et/mybaits/lesson02/mybatis.xml";
  13. InputStream inputStream = TestMybatis.class.getResourceAsStream(resource);
  14. SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
  15. //打开会话
  16. SqlSession session = sqlSessionFactory.openSession();
  17. return session;
  18. }
  19. /*  public static void main(String[] args) {
  20. SqlSession session = getSession();
  21. CallMapper cm = session.getMapper(CallMapper.class);
  22. Map map = new HashMap();
  23. map.put("p1", 145);
  24. map.put("p2", 100);
  25. cm.callProcedure(map);
  26. System.out.println(map.get("p3"));
  27. }
  28. */
  29. public static void main(String[] args) {
  30. SqlSession session = getSession();
  31. CallMapper cm = session.getMapper(CallMapper.class);
  32. Map map = new HashMap();
  33. map.put("p1", 1243);
  34. map.put("p2", 1000);
  35. cm.callFunction(map);
  36. System.out.println(map.get("p3"));
  37. }
  38. }

相关文章