tomcat jdbc连接池-回滚废弃事务

提问者：小点点

tomcat jdbc连接池-回滚废弃事务

我们将tomcat-jdbc连接池配置为RemoveAbandated=true。如果连接被放弃，该选项确实有效，但连接只是关闭。对于Oracle，这意味着当前事务已提交（请参阅此问题）。这不好，因为未完成的事务不应提交。

如何配置池，以便如果连接被放弃，则首先回滚当前事务，然后关闭连接？

我尝试了rollbackOnBack=true，但池似乎没有将其用于废弃的连接。

编辑：我们使用defaultAutoCommit=false

编辑：发生这种情况的一个例子是联调的调试；由于这样的提交，我们的事件表被截断了

共3个答案

匿名用户

根据http://docs.oracle.com/javase/7/docs/api/java/sql/Connection.html#close（）：

"强烈建议应用程序在调用关闭方法之前显式提交或回滚活动事务。如果调用了关闭方法并且存在活动事务，则结果由实现定义。"

这个使用Mysql而不是Oracle的测试证实了这一事实：

import static org.junit.Assert.assertEquals;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.junit.Test;


public class DBTest {

    public Connection openConnection() throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.jdbc.Driver");
        Connection c = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
        c.setAutoCommit(false);
        return c;
    }

    @Test
    public void testSO25886466() throws SQLException, ClassNotFoundException {

        {
            Connection c = openConnection();
            PreparedStatement delete = c.prepareStatement("delete from temp");
            delete.executeUpdate();
            c.commit();
            c.close();
        }

        {
            Connection c = openConnection();
            PreparedStatement insert = c.prepareStatement("insert into temp values ('a', 'b')");
            insert.execute();
            //c.commit(); as the op says, DONT commit!!
            c.close(); //WITHOUT having closed the statement or committing the transaction!!
        }

        {
            Connection c = openConnection();
            PreparedStatement select = c.prepareStatement("select count(*) from temp");
            select.execute();
            ResultSet rs = select.getResultSet();
            while(rs.next()){
                assertEquals(0/*i'd expect zero here!*/, rs.getInt(1));
            }
            rs.close();
            select.close();
            c.close();
        }
    }
}

根据http://tomcat.apache.org/tomcat-7.0-doc/jdbc-pool.html：

（boolean）标记删除已放弃的连接，如果它们超过了RemoveAbandonedTimeout。如果设置为true，则连接被视为已放弃，并且如果它的使用时间超过了RemoveAbandonedTimeout，则有资格删除将其设置为true可以从未能关闭连接的应用程序中恢复db连接。另请参阅logAbandonedTimeout默认值为false。

我建议不要设置移除被遗弃，以便Oracle在服务器端超时后关闭连接，而不是Tomcat关闭它。在这种情况下，Oracle可能不会提交事务，但您需要测试这一点。

或者，您是否可以增加RemoveAbandonedTimeout设置，以便您的程序可以完成，并且没有连接被放弃？

你的另一个问题是，你的应用程序已经绑定到Oracle，因为你依赖于规范有漏洞的驱动程序实现。如果可以，根据规范进行编程，这样你就可以自由地将应用程序迁移到不同的数据库，尽管我知道这在实践中很难。

一个完全不同的解决方案是采用一个开源连接池，并使用一个AOP拦截器对其进行扩展，该拦截器可以拦截对close的调用，并确定事务是否已提交，如果没有，则调用连接上的rollback。这是一个相当复杂的解决方案…：-）

匿名用户

好的……我认为如果你不能排除放弃的连接，你只有3个选择：

将关闭废弃连接的Tomcat ConnectionPool中的方法更改为回滚关闭
更改连接的关闭方法以执行回滚关闭
让DB回滚在超时后关闭连接（禁用Tomcat处理程序）

对于选项1，您可以在Tomcat源代码中编辑方法，通过HotSwap或Jav帮助替换它，或者一起禁用它并编写您自己的方法，该方法循环所有连接并检测哪些被放弃并关闭它们

对于选项2，您可以为Conntion-Interface编写自己的Wrapper，它将用rollback close替换close（）调用，并配置TomCat以将Connection包装到您的Wraper-Class中，或者您可以在运行时使用HotSwap或Jav帮助替换连接类中的Close-Method。

对于选项3，您可以禁用对废弃连接的整体处理，并将您的DB配置为在某个超时后杀死空闲连接。但是这也有一个缺点，即当连接池中的连接长时间不使用时，也会定期杀死它们…

匿名用户

您可以注册一个JDBCInterceptor来执行此修改，这样您就可以在其关闭之前回滚-看这里：http://tomcat.apache.org/tomcat-7.0-doc/jdbc-pool.html#JDBC_interceptors。放弃将调用release，它将调用disconnect，因此拦截器将收到有关此的通知。例如，您可以这样做：

package test;
import java.sql.SQLException;
import oracle.jdbc.OracleConnection;

import org.apache.tomcat.jdbc.pool.ConnectionPool;
import org.apache.tomcat.jdbc.pool.JdbcInterceptor;
import org.apache.tomcat.jdbc.pool.PooledConnection;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class RollbackInterceptor extends JdbcInterceptor {

  /**
   * Logger.
   */
private static final Logger LOG = LoggerFactory.getLogger(RollbackInterceptor.class);

/**
* {@inheritDoc}
*/
@Override
public void reset(ConnectionPool parent, PooledConnection con) {
  return;
}

/**
 * {@inheritDoc}
 */
@Override
public void disconnected(ConnectionPool parent, PooledConnection con, boolean finalizing) {
  // if its oracle make sure we rollback here before disconnect just in case a running TX is open
  try {
    if (con.getConnection().isWrapperFor(OracleConnection.class)) {
      if (!con.getConnection().getAutoCommit()) {
        LOG.error("Connection {} with Auto-Commit false is going to be closed. Doing an explicit Rollback here!", con);
        try {
          con.getConnection().rollback();
        } catch (SQLException e) {
          LOG.error("Failed to rollback connection {} before closing it.", con, e);
        }
      }
    }
  } catch (SQLException e) {
    LOG.error("Failed to check auto commit of connection {}", con, e);
  }
  super.disconnected(parent, con, finalizing);
}

}