Spring Data JPA调用存储过程实例代码
JPA连接到数据库,调用存储过程,这样的需求很常见。本文就针对这一点,讲述如何使用springDataJPA调用存储过程的方法。
1、存储过程
假设存储过程如下:
CREATEORREPLACEPACKAGEtest_pkgAS PROCEDUREin_only_test(inParam1INVARCHAR2); PROCEDUREin_and_out_test(inParam1INVARCHAR2,outParam1OUTVARCHAR2); ENDtest_pkg; / CREATEORREPLACEPACKAGEBODYtest_pkgAS PROCEDUREin_only_test(inParam1INVARCHAR2)AS BEGIN DBMS_OUTPUT.PUT_LINE('in_only_test'); ENDin_only_test; PROCEDUREin_and_out_test(inParam1INVARCHAR2,outParam1OUTVARCHAR2)AS BEGIN outParam1:='WoohooImanoutparam,andthisismyinparam'||inParam1; ENDin_and_out_test; ENDtest_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)})}) publicclassMyTableimplementsSerializable{ }
关键要点:
- 存储过程使用了注释@NamedStoredProcedureQuery,并绑定到一个JPA表。
- procedureName是存储过程的名字
- name是JPA中的存储过程的名字
- 使用注释@StoredProcedureParameter来定义存储过程使用的IN/OUT参数
3、创建SpringDataJPA数据库
下面我们来创建SpringDataJPA数据库:
publicinterfaceMyTableRepositoryextendsCrudRepository{ @Procedure(name="in_only_test") voidinOnlyTest(@Param("inParam1")StringinParam1); @Procedure(name="in_and_out_test") StringinAndOutTest(@Param("inParam1")StringinParam1); }
关键要点:
- @Procedure的name参数必须匹配@NamedStoredProcedureQuery的name
- @Param必须匹配@StoredProcedureParameter注释的name参数
- 返回类型必须匹配:in_only_test存储过程返回是void,in_and_out_test存储过程必须返回String
4、调用
我们可以这样调用存储过程:
//向存储过程传递参数并返回值 StringinParam="HiImaninputParam"; StringoutParam=myTableRepository.inAndOutTest(inParam); Assert.assertEquals(outParam,"WoohooImanoutparam,andthisismyinparamHiImaninputParam"); //向存储过程传递参数不返回值 myTableRepository.inOnlyTest(inParam);
5、其它技巧
如果上面的代码不工作,可以这么解决。定义自定义的Repository来调用存储过程昨晚本地查询。
定义自定义的Repository:
publicinterfaceMyTableRepositoryCustom{ voidinOnlyTest(StringinParam1); }
然后要确保主Repository类继承了这个接口。
publicinterfaceMyTableRepositoryextendsCrudRepository,MyTableRepositoryCustom{}
6、创建Repository实现类
接着该创建Repository实现类了:
publicclassMyTableRepositoryImplimplementsMyTableRepositoryCustom{ @PersistenceContext privateEntityManagerem; @Override publicvoidinOnlyTest(StringinParam1){ this.em.createNativeQuery("BEGINin_only_test(:inParam1);END;").setParameter("inParam1",inParam1) .executeUpdate(); } }
可以以常规的方式进行调用:
@Autowired MyTableRepositorymyTableRepository; //调用存储过程 myTableRepository.inOnlyTest(inParam1);
是不是很简单。以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。