Spring boot调用Oracle存储过程的两种方式及完整代码
前言
因工作需要将公司SSH项目改为Spingboot项目，将项目中部分需要调用存储过程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()来获取Session实现后发现项目访问数据库超过十次就会挂掉，原因是Springboot连接池数量默认为10，猜测是每次访问数据库后连接未释放导致的，手动关闭session后问题解决。
解决问题的过程中又发现了另外两种调用方式：
- 直接用EntityManager的createStoredProcedureQuery（）方法调用（推荐）
- 通过如下方式获取Session来调用，这种方式不需要手动关闭Session来释放连接，具体原因我也没搞明白，有知道的朋友欢迎指点
Sessionsession=entityManager.unwrap(Session.class);
完整代码
packagecom.hzjd.produre.repository;
importjavax.persistence.EntityManager;
importjavax.persistence.EntityManagerFactory;
importjavax.persistence.ParameterMode;
importjavax.persistence.PersistenceContext;
importjavax.persistence.StoredProcedureQuery;
importorg.hibernate.Session;
importorg.hibernate.SessionFactory;
importorg.hibernate.procedure.ProcedureCall;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Repository;
importcom.hzjd.produre.bean.QueryResponse;
importcom.hzjd.produre.utils.Assistant;
@Repository
publicclassProdureDAO{
publicfinalstaticStringPUBLIC_PAG_SYS_GETNEXTID="PUBLIC_PAG.SYS_GETNEXTID";
publicfinalstaticStringPSBC_QUERYBILL="PSBCPAY.QUERYBILL";
@PersistenceContext
EntityManagerentityManager;
@Autowired
EntityManagerFactoryentityManagerFactory;
publicSessiongetSession(){
returnentityManagerFactory.unwrap(SessionFactory.class).openSession();
}
/**
*使用entityManager调用存储过程
*
*@parampay_ID
*@return
*/
publicQueryResponsequeryBill1(Stringpay_ID)throwsException{
QueryResponsequeryResponse=newQueryResponse();
StoredProcedureQuerycall=entityManager.createStoredProcedureQuery(PSBC_QUERYBILL);
call.registerStoredProcedureParameter(1,String.class,ParameterMode.IN).setParameter(1,pay_ID);
call.registerStoredProcedureParameter(2,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(3,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(4,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(5,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(6,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(7,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(8,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(9,String.class,ParameterMode.OUT);
call.registerStoredProcedureParameter(10,String.class,ParameterMode.OUT);
call.execute();
queryResponse.getBody().setPAY_ID(pay_ID);
queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputParameterValue(2)));
queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputParameterValue(3)));
queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputParameterValue(5)));
queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputParameterValue(6)));
queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputParameterValue(8)));
interrorcode=Assistant.nullToInt(call.getOutputParameterValue(9));
Stringerrormsg=Assistant.nullToEmpty(call.getOutputParameterValue(10));
if(errorcode==0){
returnqueryResponse;
}else{
thrownewException(errormsg);
}
}
/**
*使用sessionFactory开启Session调用存储过程
*
*@parampay_ID
*@return
*/
publicQueryResponsequeryBill2(Stringpay_ID)throwsException{
QueryResponsequeryResponse=newQueryResponse();
//调用完成后需关闭Session否则会出现连接失效
try(Sessionsession=getSession();){
ProcedureCallcall=session.createStoredProcedureCall(PSBC_QUERYBILL);
call.registerParameter(1,String.class,ParameterMode.IN).bindValue(pay_ID);
call.registerParameter(2,String.class,ParameterMode.OUT);
call.registerParameter(3,String.class,ParameterMode.OUT);
call.registerParameter(4,String.class,ParameterMode.OUT);
call.registerParameter(5,String.class,ParameterMode.OUT);
call.registerParameter(6,String.class,ParameterMode.OUT);
call.registerParameter(7,String.class,ParameterMode.OUT);
call.registerParameter(8,String.class,ParameterMode.OUT);
call.registerParameter(9,String.class,ParameterMode.OUT);
call.registerParameter(10,String.class,ParameterMode.OUT);
queryResponse.getBody().setPAY_ID(pay_ID);
queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(2)));
queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(3)));
queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(5)));
queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(6)));
queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(8)));
interrorcode=Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
Stringerrormsg=Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
if(errorcode==0){
returnqueryResponse;
}else{
thrownewException(errormsg);
}
}
}
/**
*使用sessionFactory开启Session调用存储过程
*
*@parampay_ID
*@return
*/
publicQueryResponsequeryBill3(Stringpay_ID)throwsException{
QueryResponsequeryResponse=newQueryResponse();
Sessionsession=entityManager.unwrap(Session.class);
ProcedureCallcall=session.createStoredProcedureCall(PSBC_QUERYBILL);
call.registerParameter(1,String.class,ParameterMode.IN).bindValue(pay_ID);
call.registerParameter(2,String.class,ParameterMode.OUT);
call.registerParameter(3,String.class,ParameterMode.OUT);
call.registerParameter(4,String.class,ParameterMode.OUT);
call.registerParameter(5,String.class,ParameterMode.OUT);
call.registerParameter(6,String.class,ParameterMode.OUT);
call.registerParameter(7,String.class,ParameterMode.OUT);
call.registerParameter(8,String.class,ParameterMode.OUT);
call.registerParameter(9,String.class,ParameterMode.OUT);
call.registerParameter(10,String.class,ParameterMode.OUT);
queryResponse.getBody().setPAY_ID(pay_ID);
queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(2)));
queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(3)));
queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(5)));
queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(6)));
queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(8)));
interrorcode=Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
Stringerrormsg=Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
if(errorcode==0){
returnqueryResponse;
}else{
thrownewException(errormsg);
}
}
}
总结
到此这篇关于Springboot调用Oracle存储过程的两种方式及完整代码的文章就介绍到这了,更多相关Springboot调用Oracle存储过程内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。