2. 程式人生 > 程式設計 >Spring boot呼叫Oracle儲存過程的兩種方式及完整程式碼

Spring boot呼叫Oracle儲存過程的兩種方式及完整程式碼

阿新 • • 發佈：2020-08-17

前言

因工作需要將公司SSH專案改為Spingboot專案，將專案中部分需要呼叫儲存過程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()來獲取Session實現後發現專案訪問資料庫超過十次就會掛掉，原因是Springboot連線池數量預設為10，猜測是每次訪問資料庫後連線未釋放導致的，手動關閉session後問題解決。

解決問題的過程中又發現了另外兩種呼叫方式：

  • 直接用EntityManager的createStoredProcedureQuery（）方法呼叫 （推薦）
  • 通過如下方式獲取Session來呼叫，這種方式不需要手動關閉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呼叫儲存過程
	 * 
	 * @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,ParameterMode.OUT);
		call.registerStoredProcedureParameter(3,ParameterMode.OUT);
		call.registerStoredProcedureParameter(4,ParameterMode.OUT);
		call.registerStoredProcedureParameter(5,ParameterMode.OUT);
		call.registerStoredProcedureParameter(6,ParameterMode.OUT);
		call.registerStoredProcedureParameter(7,ParameterMode.OUT);
		call.registerStoredProcedureParameter(8,ParameterMode.OUT);
		call.registerStoredProcedureParameter(9,ParameterMode.OUT);
		call.registerStoredProcedureParameter(10,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呼叫儲存過程
	 * 
	 * @param pay_ID
	 * @return
	 */
	public QueryResponse queryBill2(String pay_ID) throws Exception {
		QueryResponse queryResponse = new QueryResponse();
		// 呼叫完成後需關閉Session否則會出現連線失效
		try (Session session = getSession();) {
			ProcedureCall call = session.createStoredProcedureCall(PSBC_QUERYBILL);
			call.registerParameter(1,ParameterMode.IN).bindValue(pay_ID);
			call.registerParameter(2,ParameterMode.OUT);
			call.registerParameter(3,ParameterMode.OUT);
			call.registerParameter(4,ParameterMode.OUT);
			call.registerParameter(5,ParameterMode.OUT);
			call.registerParameter(6,ParameterMode.OUT);
			call.registerParameter(7,ParameterMode.OUT);
			call.registerParameter(8,ParameterMode.OUT);
			call.registerParameter(9,ParameterMode.OUT);
			call.registerParameter(10,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呼叫儲存過程
	 * 
	 * @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,ParameterMode.IN).bindValue(pay_ID);
		call.registerParameter(2,ParameterMode.OUT);
		call.registerParameter(3,ParameterMode.OUT);
		call.registerParameter(4,ParameterMode.OUT);
		call.registerParameter(5,ParameterMode.OUT);
		call.registerParameter(6,ParameterMode.OUT);
		call.registerParameter(7,ParameterMode.OUT);
		call.registerParameter(8,ParameterMode.OUT);
		call.registerParameter(9,ParameterMode.OUT);
		call.registerParameter(10,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);
		}
	}
}

總結

到此這篇關於Spring boot呼叫Oracle儲存過程的兩種方式及完整程式碼的文章就介紹到這了,更多相關Springboot呼叫Oracle儲存過程內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！

相關推薦

Spring boot呼叫Oracle儲存過程的兩種方式及完整程式碼

前言 因工作需要將公司SSH專案改為Spingboot專案，將專案中部分需要呼叫儲存過程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()來獲取Session實現後發現專案訪問資料庫超過十次就會掛掉，

Springboot呼叫Oracle儲存過程的幾種方式

因工作需要將公司SSH專案改為Spingboot專案，將專案中部分需要呼叫儲存過程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()來獲取Session實現後發現專案訪問資料庫超過十次就會掛掉，原因

Python使用cx_Oracle呼叫Oracle儲存過程的方法示例

本文例項講述了Python使用cx_Oracle呼叫Oracle儲存過程的方法。分享給大家供大家參考，具體如下：

Spring Boot 中密碼加密的兩種方法

先說一句：密碼是無法解密的。大家也不要再問鬆哥微人事專案中的密碼怎麼解密了！

Spring Boot 配置檔案密碼加密兩種方案

Spring Boot 配置檔案密碼加密兩種方案 jasypt 加解密 jasypt是一個簡單易用的加解密Java庫，可以快速整合到 Spring 專案中。可以快速整合到 Spring Boot 專案中，並提供了自動配置，使用非常簡單。

Java使用jdbcTemplate呼叫Oracle儲存過程和程式包

/*** 測試程式碼，呼叫有返回值的儲存過程*/ public void procedureTest() throws ServiceBusException {String sql = \"{call testPackage.proceduret(?, ?)}\"; //一個入參，一個出參

詳解使用Spring快速建立web應用的兩種方式

介紹 本篇文章主要介紹，如何使用 Spring 開發一個 Web 應用。 我們將研究用 Spring Boot 開發一個 web 應用，並研究用非 Spring Boot 的方法。

Spring Boot讀取配置檔案的幾種方式

Spring Boot獲取檔案總的來說有三種方式，分別是@Value註解，@ConfigurationProperties註解和Environment介面。這三種註解可以配合著@PropertySource來使用，@PropertySource主要是用來指定具體的配置檔案。

【spring掃盲】bean別名的兩種方式與優異

接上文我們實現了一個最基本的配置：https://www.cnblogs.com/yunren/p/14292819.html 我們現在獲取物件的時候都是getBean(\"person\")，與bean.xml檔案中的id對應。如何通過別名，配置一個簡單的，自定義的名字呢？

C# 呼叫 C++ dll的兩種方式

https://www.cnblogs.com/xuqp/p/11987707.html 目錄： 1.非託管方式 2.託管方式 3.介紹 extern \"C\"

PHP資料結構（九） ——圖的定義、儲存與兩種方式遍歷

PHP資料結構（九）——圖的定義、儲存與兩種方式遍歷 （原創內容，轉載請註明來源，謝謝）

呼叫介面主要有兩種方式（網轉）

以下為夜曲程式設計人工智慧部分內容 呼叫介面主要有兩種方式：直接通過網路請求或者通過封裝好的SDK進行呼叫。

Java執行shell指令碼並返回結果兩種方法的完整程式碼

https://www.cnblogs.com/zdz8207/p/java-linux-shell.html Java執行shell指令碼並返回結果兩種方法的完整程式碼

python: 多執行緒實現的兩種方式及讓多條命令併發執行

一 概念介紹 Thread 是threading模組中最重要的類之一，可以使用它來建立執行緒。有兩種方式來建立執行緒：一種是通過繼承Thread類，重寫它的run方法；另一種是建立一個threading.Thread物件，在它的初始化函式（__

android獲取圖片尺寸的兩種方式及bitmap的縮放操作

我就廢話不多說了，大家還是直接看程式碼吧~ //Uri.parse(\"file://\"+result.getImage().getCompressPath()))

Spring Boot 整合 Shiro ，兩種方式全總結

Spring Boot 整合 Shiro ，兩種方式全總結！ shirospringboot 釋出於 2019-06-11 在 Spring Boot 中做許可權管理，一般來說，主流的方案是 Spring Security ，但是，僅僅從技術角度來說，也可以使用 Shiro。

Spring Boot配置過濾器的兩種方式

首先在介紹springboot實現過濾器之前，我們先來了解下sevlet的三大元件： Spring Boot @ServletComponentScan 掃描 @WebServlet、@WebFilter、@WebListener

ORACLE儲存過程呼叫Web Service

2019獨角獸企業重金招聘Python工程師標準>>> 1概述 最近在ESB專案中，客戶在各個系統之間的服務呼叫大多都是在oracle儲存過程中進行的，本文就oracle儲存過程呼叫web service來進行說明。其他

Spring Boot 中實現定時任務的兩種方式【轉】

在 Spring + SpringMVC 環境中，一般來說，要實現定時任務，我們有兩中方案，一種是使用 Spring 自帶的定時任務處理器 @Scheduled 註解，另一種就是使用第三方框架 Quartz ，Spring Boot 源自 Spring+SpringMVC ，因

兩種方式，花五分鐘就能構建一個 Spring Boot 應用

前言 Spring Boot 的好處自然不必多說，對於想要從事 Java 工作的朋友們來說，可謂是必學的技能。