JPA - 如何从数据库函数中进行选择？

Question

我在 T-SQL 中有以下 SQL 查询：

SELECT a.ReportDate,
    a.Value,
    a.Quantity,
    a.ID,
    a.Code
FROM AQF.fCalc(@data) a

@data 是 varbinary。我正在尝试使用 JPA 复制此查询。 （我实际上使用的是 Spring Data JPA 1.10.2。）我在MyRepository 中定义了以下内容：

@Query("SELECT a "
        + "FROM function('AQF.fCalc', :data) a "
       )
List<MyClass> getCalcData(@Param("data") byte[] data);

MyClass如下：

@Entity
@Data // using lombok to create setters, getters, etc.
public class MyClass {

    @Id
    private Long id;

    private Date reportDate;
    private BigDecimal value;
    private BigDecimal quantity;
    private String code;

}

当我调用 getCalcData 时，我收到以下错误：

antlr.NoViableAltException: unexpected token: function
at org.hibernate.hql.internal.antlr.HqlBaseParser.fromRange(HqlBaseParser.java:1501) [hibernate-core-5.0.9.Final.jar:5.0.9.Final]...

如何使用 JPA 调用函数 AQF.fCalc（并传入字节数组）？

更新 1

我现在也尝试过使用本机查询，但现在我收到一条错误消息：

java.sql.SQLException: An error occurred while getting new row from user defined Table Valued Function : 
System.Xml.XmlException: Unexpected end of file has occurred. The following elements are not closed: Data, Report. Line 24, position 804.

这是 MyRepository 中原生查询的测试代码：

@Query(value = "SELECT a.code "
        + "FROM AQF.fCalc(?1) a",
       nativeQuery = true)
List<String> getCalcData(byte[] data);

更新 2

我能够解决上面“更新 1”中提到的错误。 getCalcData 中的数据字节数组已损坏。一旦我解决了这个问题，错误就不再出现了。所以，现在我可以作为本机查询运行。不过，我还是想知道如何使用 JPQL 来进行这个函数调用。

Answer 1

您可以使用 StoredProcedureQuery。来自javadoc

用于控制存储过程查询执行的接口。

请参阅此示例代码。

假设在本例中您的 SQL 函数名称是 sales_tax。

        EntityManager em = factory.createEntityManager();

        // Create call stored procedure
        em.getTransaction().begin();
        StoredProcedureQuery storedProcedure = em.createStoredProcedureQuery("sales_tax");
        // set parameters
        storedProcedure.registerStoredProcedureParameter("subtotal", Double.class, ParameterMode.IN);
        storedProcedure.registerStoredProcedureParameter("tax", Double.class, ParameterMode.OUT);
        storedProcedure.setParameter("subtotal", 1f);
        // execute SP
        storedProcedure.execute();
        // get result
        Double tax = (Double)storedProcedure.getOutputParameterValue("tax");
        System.out.println("Tax is: " + tax);
        em.getTransaction().commit();
        em.close();