我有一个问题,如果我在没有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);
}
}
我也有插入项目,其中For使用addBatch()然后运行executeBatch,但是在到达cn.commit()时也出现了同样的Closed Statement错误...我不明白为什么它关闭,所有连接和所有东西最终都被释放了。子句,所以我感觉到我犯了一些根本不知道的错误...有什么想法吗?提前致谢!
编辑:下面是堆栈跟踪:
java.sql.SQLException:的封闭语句
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(未知来源)
编辑2:
这些是驱动程序的数据源配置中的参数,我认为调试过程可能会使它超时,但是即使在不到一秒钟的时间内完成也会引发封闭语句异常
min-connections="20"
max-connections="200"
inactivity-timeout="20"
stmt-cache-size="40"/>
最佳答案
通常最好创建一条语句,使用它并尽快将其关闭,并且在事务提交之前这样做没有任何害处。通过阅读有关批处理模型的Oracle教程,听起来好像一次打开多个语句可能是个问题。我将尝试在使用itemStatement之前关闭ps对象,然后移动初始化
itemStatement = cn.prepareStatement(itemsSQL.toString());
移至for循环的正上方,并且还将您将itemStatement关闭的位置移至for循环后立即:
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);
}
似乎正在发生的事情是您在连接上设置了一些批处理参数,这导致该连接尝试在语句中查找未完成的业务以完成该操作;它发现该语句已经关闭并且连接正在抱怨它。这很奇怪,因为在此时提交被炸断了,代码还没有到达语句关闭的最终位置。
阅读Oracle批处理模型可能会有所帮助。还要检查JDBC驱动程序版本,并确保它与您所使用的Oracle版本正确,并查看是否有可用的更新。