Spring boot調(diào)用Oracle存儲過程的兩種方式及完整代碼
更新時間：2020年08月16日 16:54:17 作者：Tiro8183
這篇文章主要給大家介紹了關(guān)于Spring boot調(diào)用Oracle存儲過程的兩種方式及完整代碼，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
前言
因工作需要將公司SSH項目改為Spingboot項目，將項目中部分需要調(diào)用存儲過程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()來獲取Session實現(xiàn)后發(fā)現(xiàn)項目訪問數(shù)據(jù)庫超過十次就會掛掉，原因是Springboot連接池數(shù)量默認(rèn)為10，猜測是每次訪問數(shù)據(jù)庫后連接未釋放導(dǎo)致的，手動關(guān)閉session后問題解決。
解決問題的過程中又發(fā)現(xiàn)了另外兩種調(diào)用方式：
- 直接用EntityManager的createStoredProcedureQuery（）方法調(diào)用 （推薦）
- 通過如下方式獲取Session來調(diào)用，這種方式不需要手動關(guān)閉Session來釋放連接，具體原因我也沒搞明白，有知道的朋友歡迎指點
Session session = entityManager.unwrap(Session.class);
完整代碼
package com.hzjd.produre.repository;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.ParameterMode;
import javax.persistence.PersistenceContext;
import javax.persistence.StoredProcedureQuery;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.procedure.ProcedureCall;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import com.hzjd.produre.bean.QueryResponse;
import com.hzjd.produre.utils.Assistant;
@Repository
public class ProdureDAO {
public final static String PUBLIC_PAG_SYS_GETNEXTID = "PUBLIC_PAG.SYS_GETNEXTID";
public final static String PSBC_QUERYBILL = "PSBCPAY.QUERYBILL";
@PersistenceContext
EntityManager entityManager;
@Autowired
EntityManagerFactory entityManagerFactory;
public Session getSession() {
return entityManagerFactory.unwrap(SessionFactory.class).openSession();
}
/**
* 使用entityManager調(diào)用存儲過程
*
* @param pay_ID
* @return
*/
public QueryResponse queryBill1(String pay_ID) throws Exception {
QueryResponse queryResponse = new QueryResponse();
StoredProcedureQuery call = 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)));
int errorcode = Assistant.nullToInt(call.getOutputParameterValue(9));
String errormsg = Assistant.nullToEmpty(call.getOutputParameterValue(10));
if (errorcode == 0) {
return queryResponse;
} else {
throw new Exception(errormsg);
}
}
/**
* 使用sessionFactory開啟Session調(diào)用存儲過程
*
* @param pay_ID
* @return
*/
public QueryResponse queryBill2(String pay_ID) throws Exception {
QueryResponse queryResponse = new QueryResponse();
// 調(diào)用完成后需關(guān)閉Session否則會出現(xiàn)連接失效
try (Session session = getSession();) {
ProcedureCall call = 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)));
int errorcode = Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
String errormsg = Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
if (errorcode == 0) {
return queryResponse;
} else {
throw new Exception(errormsg);
}
}
}
/**
* 使用sessionFactory開啟Session調(diào)用存儲過程
*
* @param pay_ID
* @return
*/
public QueryResponse queryBill3(String pay_ID) throws Exception {
QueryResponse queryResponse = new QueryResponse();
Session session = entityManager.unwrap(Session.class);
ProcedureCall call = 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)));
int errorcode = Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
String errormsg = Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
if (errorcode == 0) {
return queryResponse;
} else {
throw new Exception(errormsg);
}
}
}
總結(jié)
到此這篇關(guān)于Spring boot調(diào)用Oracle存儲過程的兩種方式及完整代碼的文章就介紹到這了,更多相關(guān)Springboot調(diào)用Oracle存儲過程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Java3D API是Sun定義的用于實現(xiàn)3D顯示的接口。3D技術(shù)是底層的顯示技術(shù)，Java3D提供了基于Java的上層接口。Java3D把OpenGL和DirectX這些底層技術(shù)包裝在Java接口中。這種全新的設(shè)計使3D技術(shù)變得不再繁瑣且可以加入到J2SE、J2EE的整套架構(gòu)，故保證了Java3D技術(shù)強(qiáng)大的擴(kuò)展性2021-10-10
這篇文章主要為大家詳細(xì)介紹了Java如何根據(jù)起始和結(jié)束的IP地址獲取IP段內(nèi)所有IP地址,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-11-11
詳解如何用spring Restdocs創(chuàng)建API文檔
這篇文章將帶你了解如何用spring官方推薦的restdoc去生成api文檔。具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
這篇文章主要介紹了Java經(jīng)典面試題最全匯總208道(五)，本文章內(nèi)容詳細(xì)，該模塊分為了六個部分，本次為第五部分，需要的朋友可以參考下2023-01-01
這篇文章主要介紹了Java中的內(nèi)存屏障的相關(guān)資料，幫助大家更好的理解和學(xué)習(xí)使用Java，感興趣的朋友可以了解下2021-05-05
解決mybatis 數(shù)據(jù)庫date 與 java中Date類型映射問題
這篇文章主要介紹了解決mybatis 數(shù)據(jù)庫date 與 java中Date類型映射問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來吧2020-11-11
這篇文章主要介紹了MyBatis在DAO層定義接口返回類型泛型無效的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
SpringBoot最簡單的定時任務(wù)@Scheduler的使用及解讀
這篇文章主要介紹了SpringBoot最簡單的定時任務(wù)@Scheduler的使用及解讀,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-03-03
nacos客戶端一致性hash負(fù)載需求實現(xiàn)
這篇文章主要介紹了nacos客戶端一致性hash負(fù)載的需求實現(xiàn)過程及步驟詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步2022-02-02
詳解Spring Security中獲取當(dāng)前登錄用戶的詳細(xì)信息的幾種方法
本文主要介紹了詳解Spring Security中獲取當(dāng)前登錄用戶的詳細(xì)信息的幾種方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05