java.sql.SQLException Closed语句

问题描述 投票:1回答:1

我有一个问题,如果我在没有autoCommit属性的情况下运行它,下面的代码运行正常,但我宁愿将它作为一个事务运行,代码基本上插入一篇文章的标题信息,然后列出每个与之关联的文章(所以它是就像一对多的关系一样),所以我想一次性提交所有内容,而不是首先提交文章信息,然后是项目。问题是当我到达cn.commit()行时,我得到一个异常,说“已关闭的声明”

数据库插入方法

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

我也有项目插入,其中For运行时使用addBatch()然后执行executeBatch,但是在到达cn.commit()时也会出现相同的Closed Statement错误...我不明白为什么它关闭,所有连接和所有内容都在finally中发布条款,所以我觉得我做了一些根本性的错误,我不知道......有什么想法吗?提前致谢!

编辑:下面是堆栈跟踪:

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

编辑2:

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

min-connections="20" 
max-connections="200" 
inactivity-timeout="20" 
stmt-cache-size="40"/>
java oracle jdbc transactions sqlexception
1个回答
1
投票

通常最好创建一个语句,使用它并尽快关闭它,并且在提交事务之前这样做没有坏处。通过阅读关于批处理模型的Oracle tuturial,听起来好像一次打开多个语句可能是一个问题。我会尝试在使用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版本,并查看是否有可用的更新版本。

© www.soinside.com 2019 - 2024. All rights reserved.