源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

Spring Data JPA调用存储过程实例代码

  • 时间:2020-12-15 01:52 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:Spring Data JPA调用存储过程实例代码
JPA连接到数据库,调用存储过程,这样的需求很常见。本文就针对这一点,讲述如何使用spring Data JPA调用存储过程的方法。 [b]1、存储过程[/b] 假设存储过程如下:
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 [b]2、@NamedStoredProcedureQueries[/b] 我们可以使用@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 {
}
关键要点: [list=1] [*]存储过程使用了注释@NamedStoredProcedureQuery,并绑定到一个JPA表。[/*] [*]procedureName是存储过程的名字[/*] [*]name是JPA中的存储过程的名字[/*] [*]使用注释@StoredProcedureParameter来定义存储过程使用的IN/OUT参数[/*] [/list] [b]3、创建Spring Data JPA数据库[/b] 下面我们来创建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);
}

关键要点: [list=1] [*]@Procedure的name参数必须匹配@NamedStoredProcedureQuery的name[/*] [*]@Param必须匹配@StoredProcedureParameter注释的name参数[/*] [*]返回类型必须匹配:in_only_test存储过程返回是void,in_and_out_test存储过程必须返回String[/*] [/list] [b]4、调用[/b] 我们可以这样调用存储过程:
  // 向存储过程传递参数并返回值
  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);
[b]5、其它技巧[/b] 如果上面的代码不工作,可以这么解决。定义自定义的Repository来调用存储过程昨晚本地查询。 定义自定义的Repository:
public interface MyTableRepositoryCustom {
  void inOnlyTest(String inParam1);
}
然后要确保主Repository类继承了这个接口。
[u]复制代码[/u] 代码如下:
public interface MyTableRepository extends CrudRepository<MyTable, Long>, MyTableRepositoryCustom {}
[b]6、创建Repository实现类[/b] 接着该创建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);
是不是很简单。以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程素材网。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部