sql - 从Java / JPA调用存储过程

我正在编写一个简单的Web应用程序来调用存储过程并检索一些数据。它是一个非常简单的应用程序,它与客户端的数据库进行交互。 我们传递员工ID和公司ID,存储过程将返回员工详细信息。

Web应用程序无法更新/删除数据并且正在使用SQL Server。

我正在Jboss AS中部署我的Web应用程序。 我应该使用JPA来访问存储过程还是resultSetMapping.在这种情况下使用JPA的任何优点。

另外,调用此存储过程的sql语句是什么。 我之前从未使用过存储过程,而且我正在努力解决这个问题。 谷歌没有多大帮助。

这是存储过程:

CREATE procedure getEmployeeDetails (@employeeId int, @companyId int)
as
begin
    select firstName, 
           lastName, 
           gender, 
           address
      from employee et
     where et.employeeId = @employeeId
       and et.companyId = @companyId
end

更新:

对于其他任何使用JPA调用存储过程的问题。

Query query = em.createNativeQuery("{call getEmployeeDetails(?,?)}",
                                   EmployeeDetails.class)           
                                   .setParameter(1, employeeId)
                                   .setParameter(2, companyId);

List<EmployeeDetails> result = query.getResultList();

我注意到的事情:

  1. 参数名称对我不起作用,因此请尝试使用参数索引。
  2. 更正sql语句resultSetMapping而不是call sp_name(?,?)
  3. 如果存储过程返回结果集,即使您只知道一行,resultSetMapping也不会工作
  4. 传递resultSetMapping名称或结果类详细信息
user431514 asked 2019-09-10T05:34:22Z
18个解决方案
49 votes

JPA 2.1现在支持存储过程,请在此处阅读Java文档。

例:

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

请参阅此处的详细示例

Pau Kiat Wee answered 2019-09-10T05:34:44Z
21 votes

我正在Jboss AS中部署我的Web应用程序。 我应该使用JPA来访问存储过程或CallableStatement。 在这种情况下使用JPA的任何优点。

JPA并不真正支持它,但它是可行的。 我仍然不会这样:

  • 使用JPA只是为了在一些bean中映射存储过程调用的结果实在是太过分了,
  • 特别是考虑到JPA不适合调用存储过程(语法非常冗长)。

因此,我宁愿考虑使用Spring支持JDBC数据访问,或者像MyBatis那样使用数据映射器,或者考虑到应用程序的简单性,使用原始JDBC和CallableStatement.实际上,JDBC可能是我的选择。 这是一个基本的启动示例:

CallableStatement cstmt = con.prepareCall("{call getEmployeeDetails(?, ?)}");
cstmt.setInt("employeeId", 123);
cstmt.setInt("companyId", 456);
ResultSet rs = cstmt.executeQuery();

参考

  • JDBC文档:Java SE 6
Pascal Thivent answered 2019-09-10T05:35:45Z
9 votes

您需要将参数传递给存储过程。

它应该像这样工作:

    List result = em
      .createNativeQuery("call getEmployeeDetails(:employeeId,:companyId)")
      .setParameter("emplyoyeeId", 123L)
      .setParameter("companyId", 456L)
      .getResultList();

更新:

或许它不应该。

在Book EJB3 in Action中,它在第383页上说,JPA不支持存储过程(页面只是一个预览,你没有得到全文,整本书可以在几个地方下载,包括这个 ,我不知道这是否合法)。

无论如何,文本是这样的:

JPA和数据库存储过程

如果你是SQL的忠实粉丝,你可能会   愿意利用的力量   数据库存储过程。   不幸的是,JPA不支持   存储过程,你必须   取决于的专有特征   你的持久性提供者。 然而,   你可以使用简单的存储功能   (没有输出参数)与原生   SQL查询。

Sean Patrick Floyd answered 2019-09-10T05:36:55Z
9 votes

如何使用JPA检索存储过程输出参数(2.0需要EclipseLink导入,2.1不需要)

尽管这个答案确实详细说明了从存储过程返回记录集,我在这里发帖,因为我花了很长时间才弄清楚这个线程对我有帮助。

我的应用程序使用Eclipselink-2.3.1,但我将强制升级到Eclipselink-2.5.0,因为JPA 2.1对存储过程有更好的支持。

使用EclipseLink-2.3.1 / JPA-2.0:依赖于实现

此方法需要从“org.eclipse.persistence”导入EclipseLink类,因此它特定于Eclipselink实现。

我在“[http://www.yenlo.nl/en/calling-oracle-stored-procedures-from-eclipselink-with-multiple-out-parameters”中找到了它。]

StoredProcedureCall storedProcedureCall = new StoredProcedureCall();
storedProcedureCall.setProcedureName("mypackage.myprocedure");
storedProcedureCall.addNamedArgument("i_input_1"); // Add input argument name.
storedProcedureCall.addNamedOutputArgument("o_output_1"); // Add output parameter name.
DataReadQuery query = new DataReadQuery();
query.setCall(storedProcedureCall);
query.addArgument("i_input_1"); // Add input argument names (again);
List<Object> argumentValues = new ArrayList<Object>();
argumentValues.add("valueOf_i_input_1"); // Add input argument values.
JpaEntityManager jpaEntityManager = (JpaEntityManager) getEntityManager();
Session session = jpaEntityManager.getActiveSession();
List<?> results = (List<?>) session.executeQuery(query, argumentValues);
DatabaseRecord record = (DatabaseRecord) results.get(0);
String result = String.valueOf(record.get("o_output_1")); // Get output parameter

使用EclipseLink-2.5.0 / JPA-2.1:独立于实现(已在此线程中记录)

此方法独立于实现(不需要Eclipslink导入)。

StoredProcedureQuery query = getEntityManager().createStoredProcedureQuery("mypackage.myprocedure");
query.registerStoredProcedureParameter("i_input_1", String.class, ParameterMode.IN);
query.registerStoredProcedureParameter("o_output_1", String.class, ParameterMode.OUT);
query.setParameter("i_input_1", "valueOf_i_input_1");
boolean queryResult = query.execute();
String result = String.valueOf(query.getOutputParameterValue("o_output_1"));
Malcolm Boekhoff answered 2019-09-10T05:38:06Z
6 votes

对我来说,只有以下内容适用于Oracle 11g和Glassfish 2.1(Toplink):

Query query = entityManager.createNativeQuery("BEGIN PROCEDURE_NAME(); END;");
query.executeUpdate();

带花括号的变体导致ORA-00900。

Dmitry Chornyi answered 2019-09-10T05:38:39Z
6 votes

如果使用EclipseLink,您可以使用@NamedStoredProcedureQuery或StoreProcedureCall来执行任何存储过程,包括具有输出参数或存储游标的存储过程。 还支持存储函数和PLSQL数据类型。

看到,[http://en.wikibooks.org/wiki/Java_Persistence/Advanced_Topics#Stored_Procedures]

James answered 2019-09-10T05:39:11Z
3 votes

以下适用于我:

Query query = em.createNativeQuery("BEGIN VALIDACIONES_QPAI.RECALC_COMP_ASSEMBLY('X','X','X',0); END;");
query.executeUpdate();
roberto quevedo answered 2019-09-10T05:39:35Z
3 votes
  1. 对于使用这样的IN / OUT参数的简单存储过程

    StoredProcedureQuery

    您可以从JPA中调用它,如下所示:

    StoredProcedureQuery
  2. 对于使用StoredProcedureQuery OUT参数的存储过程:

    StoredProcedureQuery

    您可以按如下方式调用它:

    StoredProcedureQuery
  3. 对于看起来如下的SQL函数:

    StoredProcedureQuery

    你可以这样称呼它:

    StoredProcedureQuery

    至少在使用Hibernate 4.x和5.x时,因为JPA StoredProcedureQuery不适用于SQL FUNCTIONS。

有关在使用JPA和Hibernate时如何调用存储过程和函数的更多详细信息,请查看以下文章

  • 如何使用JPA和Hibernate调用Oracle存储过程和函数
  • 如何使用JPA和Hibernate调用SQL Server存储过程和函数
  • 如何使用JPA和Hibernate调用PostgreSQL函数(存储过程)
  • 如何使用JPA和Hibernate调用MySQL存储过程和函数
Vlad Mihalcea answered 2019-09-10T05:41:24Z
2 votes

可能是Sql Server不一样,但对于使用oracle和eclipselink的人来说,它对我有用

例如:具有一个IN参数(类型CHAR)和两个OUT参数(NUMBER&VARCHAR)的过程

在persistence.xml中声明持久性单元:

<persistence-unit name="presistanceNameOfProc" transaction-type="RESOURCE_LOCAL">
    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
    <jta-data-source>jdbc/DataSourceName</jta-data-source>
    <mapping-file>META-INF/eclipselink-orm.xml</mapping-file>
    <properties>
        <property name="eclipselink.logging.level" value="FINEST"/>
        <property name="eclipselink.logging.logger" value="DefaultLogger"/>
        <property name="eclipselink.weaving" value="static"/>
        <property name="eclipselink.ddl.table-creation-suffix" value="JPA_STORED_PROC" />
    </properties>
</persistence-unit>

并在eclipselink-orm.xml中声明proc的结构

<?xml version="1.0" encoding="UTF-8"?><entity-mappings version="2.0"
xmlns="http://java.sun.com/xml/ns/persistence/orm" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence/orm orm_2_0.xsd">
<named-stored-procedure-query name="PERSIST_PROC_NAME" procedure-name="name_of_proc" returns-result-set="false">
    <parameter direction="IN" name="in_param_char" query-parameter="in_param_char" type="Character"/>
    <parameter direction="OUT" name="out_param_int" query-parameter="out_param_int" type="Integer"/>
    <parameter direction="OUT" name="out_param_varchar" query-parameter="out_param_varchar" type="String"/>
</named-stored-procedure-query>

在代码中你只需要像这样调用你的proc:

try {
        final Query query = this.entityManager
                .createNamedQuery("PERSIST_PROC_NAME");
        query.setParameter("in_param_char", 'V'); 
        resultQuery = (Object[]) query.getSingleResult();

    } catch (final Exception ex) {
        LOGGER.log(ex);
        throw new TechnicalException(ex);
    }

得到两个输出参数:

Integer myInt = (Integer) resultQuery[0];
String myStr =  (String) resultQuery[1];
Réda answered 2019-09-10T05:42:24Z
2 votes

这对我有用。

@Entity
@Table(name="acct")
@NamedNativeQueries({
 @NamedNativeQuery(callable=true, name="Account.findOne", query="call sp_get_acct(?), resultClass=Account.class)})
public class Account{
 // Code 
}

注意:将来如果你决定使用findOne的默认版本,那么只需注释NamedNativeQueries注释,JPA将切换到默认值

Amit answered 2019-09-10T05:42:51Z
1 votes

如果您有实体经理,这个答案可能会有所帮助

我有一个存储过程来创建下一个数字,在服务器端我有接缝框架。

客户端

 Object on = entityManager.createNativeQuery("EXEC getNextNmber").executeUpdate();
        log.info("New order id: " + on.toString());

数据库端(SQL服务器)我有一个名为getNextNmber的存储过程

tosha Shah answered 2019-09-10T05:43:35Z
1 votes

JPA 2.0不支持RETURN值,只支持调用。

我的解决方案是。 创建一个调用PROCEDURE的FUNCTION。

因此,在JAVA代码中,您执行一个调用oracle FUNCTION的NATIVE QUERY。

Musashi Miyamoto answered 2019-09-10T05:44:13Z
0 votes

要调用存储过程,我们可以在java.sql包中使用Callable Statement。

vinoth answered 2019-09-10T05:44:38Z
0 votes

试试这段代码:

return em.createNativeQuery("{call getEmployeeDetails(?,?)}",
                               EmployeeDetails.class)           
                               .setParameter(1, employeeId)
                               .setParameter(2, companyId).getResultList();
Patricio Dominguez answered 2019-09-10T05:45:02Z
0 votes

您可以在存储库中使用@Query(value = "{call PROC_TEST()}", nativeQuery = true)。 这对我有用。

注意:使用“{”和“}”,否则它将无效。

Everton Oliveira answered 2019-09-10T05:45:35Z
0 votes

persistence.xml中

 <persistence-unit name="PU2" transaction-type="RESOURCE_LOCAL">
<non-jta-data-source>jndi_ws2</non-jta-data-source>
<exclude-unlisted-classes>false</exclude-unlisted-classes>
<properties/>

codigo java

  String PERSISTENCE_UNIT_NAME = "PU2";
    EntityManagerFactory factory2;
    factory2 = Persistence.createEntityManagerFactory(PERSISTENCE_UNIT_NAME);

    EntityManager em2 = factory2.createEntityManager();
    boolean committed = false;
    try {

        try {
            StoredProcedureQuery storedProcedure = em2.createStoredProcedureQuery("PKCREATURNO.INSERTATURNO");
            // set parameters
            storedProcedure.registerStoredProcedureParameter("inuPKEMPRESA", BigDecimal.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("inuPKSERVICIO", BigDecimal.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("inuPKAREA", BigDecimal.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("isbCHSIGLA", String.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("INUSINCALIFICACION", BigInteger.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("INUTIMBRAR", BigInteger.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("INUTRANSFERIDO", BigInteger.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("INTESTADO", BigInteger.class, ParameterMode.IN);
            storedProcedure.registerStoredProcedureParameter("inuContador", BigInteger.class, ParameterMode.OUT);

            BigDecimal inuPKEMPRESA = BigDecimal.valueOf(1);
            BigDecimal inuPKSERVICIO = BigDecimal.valueOf(5);
            BigDecimal inuPKAREA = BigDecimal.valueOf(23);
            String isbCHSIGLA = "";
            BigInteger INUSINCALIFICACION = BigInteger.ZERO;
            BigInteger INUTIMBRAR = BigInteger.ZERO;
            BigInteger INUTRANSFERIDO = BigInteger.ZERO;
            BigInteger INTESTADO = BigInteger.ZERO;
            BigInteger inuContador = BigInteger.ZERO;

            storedProcedure.setParameter("inuPKEMPRESA", inuPKEMPRESA);
            storedProcedure.setParameter("inuPKSERVICIO", inuPKSERVICIO);
            storedProcedure.setParameter("inuPKAREA", inuPKAREA);
            storedProcedure.setParameter("isbCHSIGLA", isbCHSIGLA);
            storedProcedure.setParameter("INUSINCALIFICACION", INUSINCALIFICACION);
            storedProcedure.setParameter("INUTIMBRAR", INUTIMBRAR);
            storedProcedure.setParameter("INUTRANSFERIDO", INUTRANSFERIDO);
            storedProcedure.setParameter("INTESTADO", INTESTADO);
            storedProcedure.setParameter("inuContador", inuContador);

            // execute SP
            storedProcedure.execute();
            // get result

            try {
                long _inuContador = (long) storedProcedure.getOutputParameterValue("inuContador");
                varCon = _inuContador + "";
            } catch (Exception e) {
            } 
        } finally {

        }
    } finally {
        em2.close();
    }
Elohim Julio Cesar C answered 2019-09-10T05:46:07Z
0 votes

从JPA 2.1开始,JPA支持使用动态StoredProcedureQuery和声明性@NamedStoredProcedureQuery来调用存储过程。

H.Ostwal answered 2019-09-10T05:46:34Z
-2 votes

我的解决方案是。创建一个调用PROCEDURE的FUNCTION。

因此,在JAVA代码中,您执行一个调用oracle FUNCTION的NATIVE QUERY。

Musashi Miyamoto answered 2019-09-10T05:47:01Z
translate from https://stackoverflow.com:/questions/3572626/calling-stored-procedure-from-java-jpa