用 Spring 调用数据库函数答案

【问题标题】：Call database function with Spring用 Spring 调用数据库函数
【发布时间】：2017-01-26 00:47:24
【问题描述】：

我需要通过SQL查询数据库的一个函数，像

这样简单

@Query("SELECT random()")

如何实现一个 domain/repository 或 service 方法呢？

【问题讨论】：

一个与此相关的未决问题，stackoverflow.com/q/41880120/287948
.. 并获得赏金here！

标签： java spring spring-boot spring-data spring-data-jpa

【解决方案1】：

有various ways how to bind stored procedures with Spring Data JPA（使用 JPA 2.1）。

最简单的例子：

@Procedure("random")
Integer randomStoredProcedure();

【讨论】：

感谢 docs.spring 链接并解释“函数”是 JPA 行话中的“存储过程”！现在实现它的一个问题：可以在控制器上调用吗？在我的代码@Procedure 上是“无法解析符号'程序'”
更正，它不是整数，是双精度...所以像@Procedure("random") double x = randomStoredProcedure();
...但是需要声明更多的东西...我最声明的地方？（在controller？，在domain/repository？）其他要声明的东西的例子：@NamedStoredProcedureQuery(name = "Double.random", procedureName = "random") ...但是在哪里声明呢？
如果 db 函数是“返回表”函数，那么 randomStoredProcedure () 的类型应该是什么？
@9900kf 试试this.

【解决方案2】：

如果您没有任何 Entity/DTO（非 @Entity）对象，并且想知道如何将返回的表从函数映射到您的自定义对象。

@Repository
public class YourRepository {

    private final EntityManager entityManager;

    public(EntityManager entityManager) {
        this.entityManager = entityManager;
    }

    public List<YourObject> findObjects() {
        List<Object[]> columns = entityManager
                .createStoredProcedureQuery("your_sql_func")
                .getResultList();
        return columns.stream().map(this::toYourObject).collect(Collectors.toList());
    }

    private YourObject toYourObject(Object[] columns) {
        return new YourObject((int)columns[0], (String)columns[1]);
    }

}

class YourObject {

    private int number;
    private String name;
    
    public YourObject(int number, String name) {
       this.number = number;
       this.name = name;
    }
    // getters/setters or use Lombok
}

如果您的函数中有任何参数，那么您的查询应该如下所示，

List<Object[]> columns = entityManager
     .createStoredProcedureQuery("your_sql_func")
     .registerStoredProcedureParameter("param1Name", String.class, ParameterMode.IN)
     .setParameter("param1Name", param1Value)
     .getResultList();

您也可以使用本机查询，

List<Object[]> columns = entityManager
      .createNativeQuery("SELECT * FROM your_sql_func(:param1Name)")
      .setParameter("param1Name", param1Value)
      .getResultList();

【讨论】：