Spring Data JPA調用存儲過程實例代碼。本站提示廣大學習愛好者:(Spring Data JPA調用存儲過程實例代碼)文章只能為提供參考,不一定能成為您想要的結果。以下是Spring Data JPA調用存儲過程實例代碼正文
JPA連接到數據庫,調用存儲過程,這樣的需求很常見。本文就針對這一點,講述如何使用spring Data JPA調用存儲過程的方法。
1、存儲過程
假設存儲過程如下:
CREATE OR REPLACE PACKAGE test_pkg AS PROCEDURE in_only_test (inParam1 IN VARCHAR2); PROCEDURE in_and_out_test (inParam1 IN VARCHAR2, outParam1 OUT VARCHAR2); END test_pkg; / CREATE OR REPLACE PACKAGE BODY test_pkg AS PROCEDURE in_only_test(inParam1 IN VARCHAR2) AS BEGIN DBMS_OUTPUT.PUT_LINE('in_only_test'); END in_only_test; PROCEDURE in_and_out_test(inParam1 IN VARCHAR2, outParam1 OUT VARCHAR2) AS BEGIN outParam1 := 'Woohoo Im an outparam, and this is my inparam ' || inParam1; END in_and_out_test; END test_pkg;
這裡有兩個存儲過程:
1)in_only_test
它需要一個輸入參數inParam1,但不返回值
2)in_and_out_test
它需要一個輸入參數inParam1,且返回值outParam1
2、@NamedStoredProcedureQueries
我們可以使用@NamedStoredProcedureQueries注釋來調用存儲過程。
@Entity @Table(name = "MYTABLE") @NamedStoredProcedureQueries({ @NamedStoredProcedureQuery(name = "in_only_test", procedureName = "test_pkg.in_only_test", parameters = { @StoredProcedureParameter(mode = ParameterMode.IN, name = "inParam1", type = String.class) }), @NamedStoredProcedureQuery(name = "in_and_out_test", procedureName = "test_pkg.in_and_out_test", parameters = { @StoredProcedureParameter(mode = ParameterMode.IN, name = "inParam1", type = String.class), @StoredProcedureParameter(mode = ParameterMode.OUT, name = "outParam1", type = String.class) }) }) public class MyTable implements Serializable { }
關鍵要點:
3、創建Spring Data JPA數據庫
下面我們來創建Spring Data JPA數據庫:
public interface MyTableRepository extends CrudRepository<MyTable, Long> { @Procedure(name = "in_only_test") void inOnlyTest(@Param("inParam1") String inParam1); @Procedure(name = "in_and_out_test") String inAndOutTest(@Param("inParam1") String inParam1); }
關鍵要點:
4、調用
我們可以這樣調用存儲過程:
// 向存儲過程傳遞參數並返回值 String inParam = "Hi Im an inputParam"; String outParam = myTableRepository.inAndOutTest(inParam); Assert.assertEquals(outParam, "Woohoo Im an outparam, and this is my inparam Hi Im an inputParam"); // 向存儲過程傳遞參數不返回值 myTableRepository.inOnlyTest(inParam);
5、其它技巧
如果上面的代碼不工作,可以這麼解決。定義自定義的Repository來調用存儲過程昨晚本地查詢。
定義自定義的Repository:
public interface MyTableRepositoryCustom { void inOnlyTest(String inParam1); }
然後要確保主Repository類繼承了這個接口。
復制代碼 代碼如下:
public interface MyTableRepository extends CrudRepository<MyTable, Long>, MyTableRepositoryCustom {}
6、創建Repository實現類
接著該創建Repository實現類了:
public class MyTableRepositoryImpl implements MyTableRepositoryCustom { @PersistenceContext private EntityManager em; @Override public void inOnlyTest(String inParam1) { this.em.createNativeQuery("BEGIN in_only_test(:inParam1); END;").setParameter("inParam1", inParam1) .executeUpdate(); } }
可以以常規的方式進行調用:
@Autowired MyTableRepository myTableRepository; // 調用存儲過程 myTableRepository.inOnlyTest(inParam1);
是不是很簡單。以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持。