我们知道,在数据库中有着存储过程这么一个结构,一般在程序数据量特为庞大时就特别需要使用它,而我们一般都会使用mybatis框架来与数据库交互,问题来了,那小伙伴们知道如何在mybatis中调用存储过程吗?下面小编就为你一步步的解答。
一、首先我们要先在数据库中定义一个存储过程
//定义存储过程create or replace procedure pag_add(p1 varchar2,p2 varchar2,p3 out varchar2) as begin p3: = p1 + p2; end; //定义函数 create or replace function fun_add(p1 number, p2 number) return number asbegin return p1 + p2; end;
二、在java定义好接口后,再通过mapper接口映射Sql
package cn.et.mybatis.lesson02.func;
import java.util.List;
import java.util.Map;
public interface CallMapper
{
// public void queryEmp(Map map);
//查询存储过程的方法
public void callProcedure(Map map);
//查询函数的方法
public void callFunction(Map map);
}三、定义mybatis的映射文件
<?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">
<!-- 此文件主要用于编写sql语句
namespace是为了解决相同名字的sql操作问题
-->
<mapper namespace="cn.et.mybatis.lesson02.func.CallMapper">
<!-- statementType 声明指向的是什么类型,其中CALLABLE是执行存储过程和函数的-->
<select id="queryEmp" parameterType="map" statementType="CALLABLE">
{
call pag_add(
#{p1,mode=IN,jdbcType=NUMERIC},
#{p2,mode=IN,jdbcType=NUMERIC},
#{p3,mode=OUT,jdbcType=NUMERIC}
)
}
</select>
<!-- 定义存储过程 -->
<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>四、定义mybaits.xml配置文件
<?xml version="1.0" encoding="UTF-8" ?>
<!-- 说明mybatis的根节点 -->
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<!--mybatis的根标签configuration -->
<configuration>
<!-- 资源文件的路径配置 注:cn前面不能用/否则会抛出异常-->
<properties resource="cn/et/mybatis/lesson02/jdbc.properties">
</properties>
<!-- 配置连接数据库的环境,(开发环境) -->
<environments default="development">
<environment id="development">
<!-- 事务交给jdbc管理,Conection(事务) commit(提交) rollback(回滚) -->
<transactionManager type="JDBC"/>
<!-- 数据源 用来连接数据库(包含四要素,driver,url,username,password) -->
<dataSource type="POOLED">
<property name="driver" value="${driverClass}"/>
<property name="url" value="${url}"/>
<property name="username" value="${userAccount}"/>
<property name="password" value="${password}"/>
</dataSource>
</environment>
</environments>
<!-- 包含隐射文件主要用于编写sql语句 -->
<mappers>
<!-- 隐射的资源文件 隐射文件主要编写sql语句 -->
<mapper resource="cn/et/mybatis/lesson02/func/call_mapper.xml"/>
</mappers>
</configuration>五、这里我们就已经完成了整个存储过程的调用了,最后我们再测试一下
package cn.et.mybatis.lesson02.func;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
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
{
//封装session的返回
public static SqlSession getSession()
{
String resource = "/cn/et/mybatis/lesson02/mybatis.xml";
InputStream inputStream = TestMyBatis.class.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
.build(inputStream);
//操作数据库的类 SqlSession
SqlSession session = sqlSessionFactory.openSession();
return session;
}
//调用存储过程
public static void main(String[] args) throws IOException
{
SqlSession session = getSession();
CallMapper cm = session.getMapper(CallMapper.class);
Map map = new HashMap();
map.put("p1", 100);
map.put("p2", 200);
cm.callProcedure(map);
System.out.println(map.get("p3"));
}
@Test
//调用函数
public void funTest()
{
SqlSession session = getSession();
CallMapper cm = session.getMapper(CallMapper.class);
Map map = new HashMap();
map.put("p1", 100);
map.put("p2", 400);
cm.callFunction(map);
System.out.println(map.get("p3"));
}
}以上就是关于存储过程调用的全部步骤了,更多相关java常见问题,请记得关注我们的网站来了解详情。
推荐阅读:
mybatis二级缓存面试大全,mybatis企业必问面试题java