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类继承了这个接口。
6、创建Repository实现类
接着该创建Repository实现类了：
public class MyTableRepositoryImpl implements MyTableRepositoryCustom { @PersistenceContext private EntityManager em;@Overridepublic void inOnlyTest(String inParam1) { this.em.createNativeQuery("BEGIN in_only_test(:inParam1); END;").setParameter("inParam1", inParam1) .executeUpdate();}}可以以常规的方式进行调用：
@AutowiredMyTableRepository myTableRepository;// 调用存储过程myTableRepository.inOnlyTest(inParam1);
是不是很简单。以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持VeVb武林网。
新闻热点
疑难解答
图片精选
