如何使用实体管理器调用具有多个输入和输出参数的存储过程答案

【问题标题】：how to call stored procedure with multiple in and out parameters using entity manager如何使用实体管理器调用具有多个输入和输出参数的存储过程
【发布时间】：2012-11-06 07:50:43
【问题描述】：

我们在从应用程序调用存储过程时遇到问题。数据库是oracle 10g 这个proc有2个输入参数和2个输出参数。

输入 1：- 数据库列表输入 2：- 字符串

输出 1：-再次是一个 DB-List 输出 2：- 数字

当我们尝试使用时

 Query q = session.createSQLQuery("{call proc_name(?,?,?,?)}");

我们无法区分in 参数和out 参数。那么我们应该如何使用它来处理呢。

另外，我们尝试使用如下可调用语句：

Session session = (Session) getEntityManager().getDelegate();
SessionImpl sessionImpl = ((SessionImpl) getEntityManager().getDelegate());
Connection cc = sessionImpl.connection();
CallableStatement callableStatement = null;

callableStatement = cc.prepareCall("{call proc_name(?,?,?,?)}");
ArrayDescriptor descriptor = ArrayDescriptor.createDescriptor("DB_LIST",callableStatement.getConnection());
ARRAY paramArray = new ARRAY(descriptor, callableStatement.getConnection(), array);
callableStatement.setArray(1, paramArray);
callableStatement.setString(2, "N");
callableStatement.registerOutParameter(3, OracleTypes.ARRAY, "DB_RETURN_LIST");
callableStatement.registerOutParameter(4, Types.INTEGER);
// executing the query
callableStatement.execute();

我们得到以下错误：

javax.ejb.EJBException: java.lang.ClassCastException: 
$Proxy50 cannot be cast to oracle.jdbc.OracleConnection

能否请您提供一些建议。

这是我们正在使用的实体管理器

public abstract class GenericDAO<T, ID extends Serializable> implements IGenericDAO<T, ID> {
private final Class<T> persistentClass;
@PersistenceContext(unitName = "firstPersistenceUnit")
@Produces
private EntityManager entityManager;

public void setEntityManager(final EntityManager entityManager) throws DataAccessException {
this.entityManager = entityManager;
}

public EntityManager getEntityManager() throws DataAccessException {
return entityManager;
}
}

这是 Persistance.xml 中的条目

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0" xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
<persistence-unit name="firstPersistenceUnit">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>java:jboss/firstDataSource</jta-data-source>
<class>com.domain.Branch</class>
<exclude-unlisted-classes>true</exclude-unlisted-classes>
<shared-cache-mode>ENABLE_SELECTIVE</shared-cache-mode>
<validation-mode>AUTO</validation-mode>
    <properties>
        <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle10gDialect" />
        <property name="hibernate.connection.driver_class" value="oracle.jdbc.driver.OracleDriver" />
        <property name="hibernate.show_sql" value="true"/>
        <property name="hibernate.format_sql" value="true"/>
    </properties>
</persistence-unit>

<persistence-unit name="secondPersistenceUnit">
<provider>org.hibernate.ejb.HibernatePersistence</provider>
<jta-data-source>java:jboss/secondDataSource</jta-data-source>
<class>com.domain.PocJeeCounty</class>
<exclude-unlisted-classes>true</exclude-unlisted-classes>
<shared-cache-mode>ENABLE_SELECTIVE</shared-cache-mode>
<validation-mode>AUTO</validation-mode>
    <properties>
        <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle10gDialect" />
        <property name="hibernate.connection.driver_class" value="oracle.jdbc.driver.OracleDriver" />
        <property name="hibernate.show_sql" value="true"/>
        <property name="hibernate.format_sql" value="true"/>
    </properties>
</persistence-unit>
</persistence>

【问题讨论】：

我认为问题不在于存储过程，而在于您的实体管理器。您可以粘贴您的完整代码吗？
嗨@SajanChandran 我已经添加了实体管理器的代码以及我们正在使用的persistance.xml
我们使用 unwrap 和 session.doWork 进行了尝试。但它仍然给我们错误：- java.lang.Exception: javax.ejb.EJBException: java.lang.ClassCastException: $Proxy66 cannot be cast to oracle.jdbc.OracleConnection.[/code]当我们尝试获取数组描述符的连接。 ArrayDescriptor 描述符 = ArrayDescriptor.createDescriptor(DB_LIST",callableStatement.getConnection());

标签： java stored-procedures jpa ejb java-ee-6

【解决方案1】：

不要使用第二种方式，而是使用@NamedStoredProcedureQuery 和@StoredProcedureParameter 创建和定义查询和查询参数。以下是您要求的代码

@NamedStoredProcedureQuery(  
    name="PROC_NAME",  
    procedureName="proc_name",  
    returnsResultSet=true/false,  
    parameters={  
        @StoredProcedureParameter(queryParameter="param1",name="p1",direction=Direction.IN,type=Integer.class),  
        @StoredProcedureParameter(queryParameter="param2",name="p2",direction=Direction.IN,type=Timestamp.class),  
        @StoredProcedureParameter(queryParameter="param3",name="p3",direction=Direction.OUT,type=String.class),  
        @StoredProcedureParameter(queryParameter="param4",name="p4",direction=Direction.OUT,type=Integer.class)  
    }  
    )

并使用 em.createNativeQuery() 方法

【讨论】：