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; @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);
是不是很简单。以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持移动技术网。
如对本文有疑问, 点击进行留言回复!!
SpringBoot引用阿里easyexcel,Excel导出返回浏览器下载
HashMap、Hashtable、ConcurrentHashMap三者间的异同
解决RecycleView 中Item包含Edittext时,滑动view复用导致数据错乱的问题
多线程、同步工作原理、死锁案例、Lock接口、线程的生命周期的讲解及实现
网友评论