如何使用Hibernate（EntityManager）或JPA 2调用Oracle函数或过程

我有一个返回sys-refcursor的Oracle函数，当我使用Hibernate 4调用此函数时，我收到以下exception。

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) 

我该如何解决这个问题？

Oraclefunction

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

Answer 1

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

对于Oraclefunction

使用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; 

在Entity类中，将函数定义为

 @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||'%'); 

在Entity类中定义过程为

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

谢谢

Answer 2

本文详细介绍了调用Oracle存储过程和函数的所有组合。

为了你的function，

 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 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 result = query.getResultList(); 

Answer 3

对于程序：

 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; 

替代解决方案：使用sys_refcursor作为OUT参数调用过程，而不定义@NamedNativeQuery

 StoredProcedureQuery query = entityManager.createStoredProcedureQuery("myProcedure"); query.registerStoredProcedureParameter(1, void.class, ParameterMode.REF_CURSOR); query.registerStoredProcedureParameter(2, String.class, ParameterMode.IN); query.setParameter(2, "Umesh"); List result = query.getResultList(); 

Answer 4

据 Oracle的Arun Gupta称，JPA 2.1早期草案表明将支持存储过程。

对存储过程的支持：添加了对Java Persistence查询语言调用预定义数据库函数和用户定义数据库函数的支持。

EntityManager.createXXXStoredProcedureQuery方法有不同的变体，它们返回StoredProcedureQuery以执行存储过程。 只是喜欢@NamedQuery ，有@NamedStoredProcedureQuery ，它指定并命名存储过程，其参数和结果类型。 可以在实体或映射的超类上指定此注释。 然后，在EntityManager.createNamedStoredProcedureQuery使用注释中指定的名称。 可以设置IN，OUT和INOUT参数并用于检索从过程传回的值。 例如：

 @Entity @NamedStoredProcedureQuery(name="topGiftsStoredProcedure", procedureName="Top10Gifts") public class Product { . . . } // In your client StoredProcedreQuery query = EntityManager.createNamedStoredProcedureQuery("topGiftsStoredProcedure"); query.registerStoredProcedureParameter(1, String.class, ParameterMode.INOUT); query.setParameter(1, "top10"); query.registerStoredProcedureParameter(2, Integer.class, ParameterMode.IN); query.setParameter(2, 100); // there are other setParameter methods for defining the temporal type of a parameter . . . query.execute(); String response = query.getOutputParameterValue(1); 

至于规范什么时候最终确定，或者Hibernate将支持JPA 2.1，我不能说。 但它值得关注。

Answer 5

以前的解决方案似乎不适用于eclipselink。 我在JPA下使用本机查询运行

  List result = em.createNativeQuery("select YOURFUNCTION(?) from dual ") .setParameter(1, ONEPARAMETER) .getResultList(); 

Answer 6

您似乎将Oracle函数与Oracle存储过程混淆。

可以从select语句调用函数 – 像您这样的用户定义函数的行为方式与内置函数相同，如min（）和max（）。 它们不能像存储过程那样由外部“调用”调用。

有关函数的定义，请参见http://docs.oracle.com/cd/B19306_01/server.102/b14200/functions231.htm#i1012049 。

您可能需要将函数重写为存储过程。