如何使用 Hibernate (EntityManager) 或 JPA 调用 Oracle 函数或过程

Question

我有一个返回 sys-refcursor 的 Oracle 函数，当我使用 Hibernate 调用此函数时，出现以下异常。

 Hibernate: { ? = call my_function(?) }
 org.hibernate.exception.GenericJDBCException: could not execute query
javax.persistence.PersistenceException: org.hibernate.exception.GenericJDBCException: could not execute query
    at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1360)
    at org.hibernate.ejb.AbstractEntityManagerImpl.convert(AbstractEntityManagerImpl.java:1288)
    at org.hibernate.ejb.QueryImpl.getSingleResult(QueryImpl.java:313)

我该如何解决这个问题？

神谕功能

create or replace
FUNCTION my_function(p_val IN varchar2)
    RETURN SYS_REFCURSOR
  AS
    my_cursor SYS_REFCURSOR;
  BEGIN
    OPEN my_cursor FOR SELECT emp_name FROM employees
    WHERE lower(emp_name) like lower(p_val||'%');
    RETURN my_cursor;
  END;

我的实体类

@Entity
@javax.persistence.NamedNativeQuery(name = "getFunc", query =
"{ ? = call my_function(:empName) }",
 resultClass = Employee.class, hints =
 { @javax.persistence.QueryHint(name = "org.hibernate.callable", value = "true") })
 @Table(name = "EMPLOYEES")

在 DAO 中

    @Override
        public void findEmployees(QueryData data,
                String empName) {

        List query = (List) entityManager.createNamedQuery("getFunc")
                         .setParameter("empName", empName)
                         .getSingleResult();
                data.setResult(query);
}

原文由 Jacob 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

可以按以下方式使用 EntityManager 调用 Oracle 函数或存储过程。

对于 Oracle 函数

创建一个以 sys_refcursor 作为返回类型的函数

CREATE OR REPLACE FUNCTION my_function
(p_val IN varchar2)
    RETURN SYS_REFCURSOR
  AS
    my_cursor SYS_REFCURSOR;
  BEGIN
    OPEN my_cursor FOR SELECT emp_name FROM employees
    WHERE lower(emp_name) like lower(p_val||'%');
    RETURN my_cursor;
  END;

在实体类中，将函数定义为

@javax.persistence.NamedNativeQuery(name = "getFunc", query = "{? =  call
my_function(:empName) }", resultClass = Employee.class, hints = {
@javax.persistence.QueryHint(name = "org.hibernate.callable", value = "true") })

对于 Oracle 存储过程

使用 sys_refcursor 作为第一个 OUT 参数创建过程

CREATE OR REPLACE PROCEDURE myProcedure(p_cursor out sys_refcursor,
     p_val  in varchar2
)
 AS
BEGIN
     OPEN o_cursor FOR
          SELECT     emp_name
             FROM     employees
            WHERE     LOWER (emp_name) LIKE lower(p_val||'%');

在实体类中将过程定义为

@javax.persistence.NamedNativeQuery(name = "getProc", query = "{ call
my_procedure(?,:empName) }", resultClass = Employee.class, hints = {
@javax.persistence.QueryHint(name = "org.hibernate.callable", value = "true") })

最后在 DAO 类中，调用函数或过程作为

Query query = entityManager.createNamedQuery("getFunc"); // if procedure then getProc
query.setParameter("empName","smith");
query.getResultList();

谢谢

原文由 Jacob 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

对于你的功能，

 create or replace
FUNCTION my_function(p_val IN varchar2)
    RETURN SYS_REFCURSOR
  AS
    my_cursor SYS_REFCURSOR;
  BEGIN
    OPEN my_cursor FOR SELECT emp_name FROM employees
    WHERE lower(emp_name) like lower(p_val||'%');
    RETURN my_cursor;
  END;

您可以定义以下内容 NamedNativeQuery ：

 @NamedNativeQuery(
    name = "my_function",
    query = "{ ? = call my_function( ? ) }",
    callable = true,
    resultClass = String.class
)

而且，您可以这样调用查询：

 List<String> employeeNames = entityManager
    .createNamedQuery("my_function")
    .setParameter(1, 1L)
    .getResultList();

对于存储过程：

 CREATE OR REPLACE
PROCEDURE my_procedure(p_val IN VARCHAR2,
    my_cursor OUT SYS_REFCURSOR,
)
AS
BEGIN
    OPEN my_cursor FOR
    SELECT emp_name FROM employees
    WHERE lower(emp_name) like lower(p_val||'%');
END;

，您可以使用以下 JPA 2.1 查询：

 StoredProcedureQuery query = entityManager
    .createStoredProcedureQuery("my_procedure")
    .registerStoredProcedureParameter(1, String.class,
         ParameterMode.IN)
    .registerStoredProcedureParameter(2, Class.class,
         ParameterMode.REF_CURSOR)
    .setParameter(1, 1L);

query.execute();

List<Object[]> result = query.getResultList();

原文由 Vlad Mihalcea 发布，翻译遵循 CC BY-SA 4.0 许可协议