java.sql.SQLException 关闭语句

Question

我有一个问题，如果我在没有 autoCommit 属性的情况下运行下面的代码，它运行良好，但是我更愿意将它作为事务运行，代码基本上插入文章的标题信息，然后列出与之关联的每篇文章（所以这就像一对多的关系），所以我想一次性提交所有内容，而不是先提交文章信息，然后提交项目。问题是当我到达 cn.commit() 行时，我得到一个异常，上面写着“Closed Statement”

数据库插入方法

public static void addArticle(Article article) throws SQLException {
             Connection cn = null;
             PreparedStatement ps = null;
             StringBuffer insert = new StringBuffer();
             StringBuffer itemsSQL = new StringBuffer();

             try {
                    article.setArticleSortNum(getNextArticleNum(article.getShopId()));
                    article.setArticleId(DAOHelper.getNextId("article_id_sequence"));

                    cn = DBHelper.makeConnection();
                    cn.setAutoCommit(false);

                    insert.append("insert query for article goes here");
                    ps = cn.prepareStatement(insert.toString());
                    int i = 1;
                    ps.setLong(i, article.getArticleId()); i++;
                    ps.setLong(i, article.getShopId()); i++;
                    ps.setInt(i, article.getArticleNum()); i++;
                    // etcetera...
                    ps.executeUpdate(); 

                    itemsSQL.append("insert query for each line goes here");
                    itemStatement = cn.prepareStatement(itemsSQL.toString());
                    for(Article item : article.getArticlesList()) {

                        item.setArticleId(article.getArticleId());
                        i= 1;
                        itemStatement.setLong(i, item.getArticleId()); i++;
                        itemStatement.setInt(i,  item.getItemsOnStock()); i++;
                        itemStatement.setInt(i,  item.getQuantity()); i++;
                        // etcetera...
                        itemStatement.executeUpdate();

                    }
                    cn.commit();

             } catch (SQLException e) {
                    cn.rollback();
                    log.error(e.getMessage());
                    throw e;
             }
             finally {
                    DBHelper.releasePreparedStatement(ps);
                    DBHelper.releasePreparedStatement(itemStatement);
                    DBHelper.releaseConnection(cn);
             }
       }

我还使用 addBatch() 运行 For 的项目插入然后 executeBatch 但到达 cn.commit() 时也出现相同的 Closed Statement 错误...我不明白为什么它关闭，所有连接和一切都被释放在 finally 子句中，所以我觉得我犯了一些我不知道的基本错误......有什么想法吗？提前致谢！

编辑：下面是堆栈跟踪：

java.sql.SQLException: Closed Statement at oracle.jdbc.dbaccess.DBError.throwSqlException(DBError.java:189) 在 oracle.jdbc.dbaccess.DBError.throwSqlException(DBError.java:231) 在 oracle.jdbc.dbaccess.DBError.throwSqlException(DBError.java:294) 在 oracle.jdbc.driver.OracleStatement.ensureOpen(OracleStatement.java:6226) 在 oracle.jdbc.driver.OraclePreparedStatement.sendBatch(OraclePreparedStatement.java:592) 在 oracle.jdbc.driver.OracleConnection.commit(OracleConnection.java:1376) 在 com.evermind.sql.FilterConnection.commit(FilterConnection.java:201) 在 com.evermind.sql.OrionCMTConnection.commit(OrionCMTConnection.java:461) 在 com.evermind.sql.FilterConnection.commit(FilterConnection.java:201) 在 com.dao.ArticlesDAO.addArticle(ArticlesDAO.java:571) 在 com.action.registry.CustomBaseAction.execute(CustomBaseAction.java:57) 在 org.apache.struts.action.RequestProcessor.processActionPerform(RequestProcessor.java:431) 在 org.apache.struts.action.RequestProcessor.process(RequestProcessor.java:236) 在 org.apache.struts.action.ActionServlet.process(ActionServlet.java:1196) 在 org.apache.struts.action.ActionServlet.doPost(ActionServlet.java:432) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:760) 在 javax.servlet.http.HttpServlet.service(HttpServlet.java:853) 在 com.evermind.server.http.ServletRequestDispatcher.invoke(ServletRequestDispatcher.java:765) 在 com.evermind.server.http.ServletRequestDispatcher.forwardInternal(ServletRequestDispatcher.java:317) 在 com.evermind.server.http.HttpRequestHandler.processRequest(HttpRequestHandler.java:790) 在 com.evermind.server.http.HttpRequestHandler.run(HttpRequestHandler.java:270) 在 com.evermind.server.http.HttpRequestHandler.run(HttpRequestHandler.java:112) 在 com.evermind.util.ReleasableResourcePooledExecutor$MyWorker.run(ReleasableResourcePooledExecutor.java:192) 在 java.lang.Thread.run(Unknown Source)

编辑2：

这些是驱动数据源配置中的参数，我以为调试过程可能会超时，但即使在不到一秒的时间内完成也会抛出关闭语句异常

min-connections="20" 
max-connections="200" 
inactivity-timeout="20" 
stmt-cache-size="40"/>

Answer 1

通常最好创建一个语句，使用它并尽快关闭它，在事务提交之前这样做并没有什么坏处。通过阅读有关批处理模型的 Oracle 教程，听起来一次打开多个语句可能是个问题。我会尝试在使用 itemStatement 之前关闭 ps 对象，然后移动初始化

itemStatement = cn.prepareStatement(itemsSQL.toString());

到 for 循环的正上方，并在 for 循环之后立即移动关闭 itemStatement 的位置：

PreparedStatement itemStatement = cn.prepareStatement(itemsSQL.toString());
try {
    for(Article item : article.getArticlesList()) {
       item.setArticleId(article.getArticleId());
        i= 1;
        itemStatement.setLong(i, item.getArticleId()); i++;
        itemStatement.setInt(i,  item.getItemsOnStock()); i++;
        itemStatement.setInt(i,  item.getQuantity()); i++;
                    // etcetera...
        itemStatement.executeUpdate();
    }
} finally {
    DBHelper.releasePreparedStatement(itemStatement);
}

看起来发生了什么是您在连接上设置了一些批处理参数，导致连接尝试在语句中查找未完成的业务以完成；它发现该语句已经关闭并且连接正在抱怨它。这很奇怪，因为在提交给你带来爆炸的那一刻，代码还没有到达语句关闭的finally。

阅读 Oracle 批处理模型可能会有所帮助。还要检查 JDBC 驱动程序版本，确保它适合您使用的 Oracle 版本，并查看是否有可用的更新。