JPA createStoredProcedureQuery 在使用 Hibernate 时抛出“ORA-01000: maximum open cursors exceeded”

Question

我尝试通过这种方式使用EntityManager的“createStoredProcedureQuery”调用Oracle存储过程：

@Transactional(readOnly = false, propagation = Propagation.REQUIRED, isolation = Isolation.READ_COMMITTED)
public void saveMeterVol(Meter meter, Double vol1, Chng chng, User user, Date dt1, Date dt2) {
    StoredProcedureQuery qr = em.createStoredProcedureQuery("mt.P_METER.meter_vol_ins_upd_java");
    qr.registerStoredProcedureParameter(1, Integer.class, ParameterMode.OUT);
    qr.registerStoredProcedureParameter(2, Integer.class, ParameterMode.IN);
    qr.registerStoredProcedureParameter(3, Integer.class, ParameterMode.IN);
    qr.registerStoredProcedureParameter(4, Double.class, ParameterMode.IN);
    qr.registerStoredProcedureParameter(5, Date.class, ParameterMode.IN);
    qr.registerStoredProcedureParameter(6, Date.class, ParameterMode.IN);
    qr.registerStoredProcedureParameter(7, String.class, ParameterMode.IN);

    qr.setParameter(2, meter.getId());
    qr.setParameter(3, chng.getId());
    qr.setParameter(4, vol1);
    qr.setParameter(5, dt1);
    qr.setParameter(6, dt2);
    qr.setParameter(7, user.getCd());
    qr.execute();
}

当我调用此方法超过 300 次时，Oracle 陷入异常： ORA-01000: 超出最大打开游标数

据我了解，Java 在调用我的过程后不会关闭 Oracle 游标，但我不明白为什么？

我试过了

em.close();

但它没有帮助。

我用：

<spring-framework.version>5.0.5.RELEASE</spring-framework.version>
<hibernate.version>5.1.0.Final</hibernate.version>
<java.version>1.8</java.version>

Answer 1

默认CallableStatement处理机制

当在 JPA StoredProcedureQuery 上调用 execute 方法或在 Hibernate ProcedureCall 上调用 outputs().getCurrent() 时，Hibernate 执行以下操作：

请注意，JDBC CallableStatement 已准备好并存储在关联的 ProcedureOutputsImpl 对象中。在调用getOutputParameterValue方法时，Hibernate会使用底层的CallableStatement来获取OUT参数。

因此，即使在执行存储过程并获取 OUT 或 REF_CURSOR 参数之后，底层 JDBC CallableStatement 仍保持打开状态。

现在，默认情况下，CallableStatement 在结束当前正在运行的数据库事务时关闭，方法是调用 commit 或 rollback。

尽快关闭JDBC语句

因此，要尽快关闭 JDBC CallableStatement，您应该在从存储过程中获取所需的所有数据后调用 release：

StoredProcedureQuery query = entityManager
.createStoredProcedureQuery("count_comments")
.registerStoredProcedureParameter(
    "postId",
    Long.class,
    ParameterMode.IN
)
.registerStoredProcedureParameter(
    "commentCount",
    Long.class,
    ParameterMode.OUT
)
.setParameter("postId", 1L);
 
try {
    query.execute();
     
    Long commentCount = (Long) query
    .getOutputParameterValue("commentCount");
 
    assertEquals(Long.valueOf(2), commentCount);
} finally {
    query.unwrap(ProcedureOutputs.class).release();
}

在finally 块中对关联的ProcedureOutputs 对象调用release 方法可确保无论存储过程调用的结果如何，JDBC CallableStatement 都会关闭。

休眠 6 起

现在，手动调用 release 有点乏味，所以我决定创建 HHH-13215 Jira 问题，从 Hibernate ORM 6 开始，您可以像这样重写前面的示例：

Long commentCount = doInJPA(entityManager -> {
    try(ProcedureCall query = entityManager
            .createStoredProcedureQuery("count_comments")
            .unwrap(ProcedureCall.class)) {
             
        return (Long) query
        .registerStoredProcedureParameter(
            "postId",
            Long.class,
            ParameterMode.IN
        )
        .registerStoredProcedureParameter(
            "commentCount",
            Long.class,
            ParameterMode.OUT
        )
        .setParameter("postId", 1L)
        .getOutputParameterValue("commentCount");
    }
});

Answer 2

这是我的解决方案：

int           retValue = -1;
ProcedureCall query    = null;

try {
  query = (ProcedureCall)entityManager.createNamedStoredProcedureQuery("MyStoredProcedure");

  query
    .setParameter("param1", value1)
    .setParameter("param2", value2)
    .execute();

  retValue = (int)query.getOutputParameterValue("outParam");
} finally {
  query.getOutputs().release();
}

Answer 3

最终我找到了解决办法，我换了行

qr.execute();

与

qr.executeUpdate();

根据文档：“当对 StoredProcedureQuery 对象调用 executeUpdate 时，提供程序将对未执行的存储过程查询调用 execute，然后是 getUpdateCount。executeUpdate 的结果将是 getUpdateCount 的结果”

但他们没有说任何关于关闭游标的内容，但我的方法现在效果很好。