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 {
}

关键要点：

1. 存储过程使用了注释@namedstoredprocedurequery，并绑定到一个jpa表。
2. procedurename是存储过程的名字
3. name是jpa中的存储过程的名字
4. 使用注释@storedprocedureparameter来定义存储过程使用的in/out参数

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);
}

关键要点：

1. @procedure的name参数必须匹配@namedstoredprocedurequery的name
2. @param必须匹配@storedprocedureparameter注释的name参数
3. 返回类型必须匹配：in_only_test存储过程返回是void，in_and_out_test存储过程必须返回string

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);

是不是很简单。以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。