尝试资源：检测异常？

Question

这是一个示例代码：

     try ( PgConnection conn = application.adminDb.getConnection() ) {
         // execute SQL statements here (and other possible statements)
     }

我希望 AutoCloseable PgConnection 类在创建时开始新事务，并在关闭时提交或回滚。如果在 try 块中没有抛出异常，它应该 COMMIT，否则它应该 ROLLBACK。

我真正需要的是一个上下文管理器 a'la Python。有可能以某种方式做到这一点吗？理论上，在调用 PgConnection.close() 时，JVM 已经知道是否存在异常。就是不知道怎么说。

当然我可以这样说：

try ( PgConnection conn = application.adminDb.getConnection()) {

    conn.begin();
    try {
      // execute SQL statements here
      conn.commit();
    } catch (Exception e) {
      conn.rollback();
      throw e;
    }

}

但我需要这样做一百次，所以我正在寻找一个“噪音较小”的选项。

更新

我当然可以这样做：

public interface PgTransactionWrapper {
    public void run(PgConnection connection) throws SQLException;
}

然后把这个放到PgConnection中：

   public void runInTransaction(PgTransactionWrapper wrapper) throws SQLException {
       int trId = begin();
       try {
           wrapper.run(this);
           commit(trId);
       } catch (SQLException e) {
           rollback(trId);
           throw e;
       }
   }

这就是它的使用方法：

     try ( PgConnection conn = application.adminDb.getConnection() ) {
         conn.runInTransaction(new PgTransactionWrapper() {

            @Override
            public void run(PgConnection connection) throws SQLException {
                // SQL statements here

            }
        });
     }

但我认为情况更糟。确实实现了自动提交/回滚，但付出的代价是更多的语法噪音，并且引入了一个额外的问题：事务包装器除了 SQLException 不能抛出任何东西。

我想念的是 AutoCloseable.close(Exception excOrNull) 的一个简单参数，但我想这是语言的限制，无法做到。 :-(

更新 2：只是为了澄清问题：我不想抑制或转换异常。我只想在没有异常的时候提交，在有异常的时候回滚。但除此之外，我不想从内部处理它们——它们应该原封不动地传播给调用者。

Answer 1

这是我对扩展您的代码的想法。你怎么看？至少您不必捕获异常并在所有地方处理它们以提交/回滚您的事务

公共接口 SQLStatementExecutor
{
    无效运行（PgConnection 连接）抛出 SQLException；
}

公共类 PgConnectionWrapper 实现 Closeable
{

    私有 PgConnection 连接；
    私人布尔状态=假；

    公共 PgConnectionWrapper()
    {
        连接 = 获得连接（）；
    }

    私人 PgConnection 获得连接（）
    {
        返回 application.adminDb.getConnection();
    }

    公共无效runInTransaction（SQLStatementExecutor执行器）抛出SQLException
    {
        尝试 {
            executor.run（连接）；
            状态=真；
        }
        捕捉（SQLException e）{
            状态=假；
            扔 e;
        }
    }

    公共 PgConnection getConnection()
    {
        返回连接；
    }

    @Override public void close() 抛出 IOException
    {
        如果（状态）{
            连接.commit();
        }
        别的 {
            连接.回滚（）；
        }

        连接.close();
    }
}

公共类TestMain
{

    公共静态 void main(String[] args) 抛出 IOException
    {
        尝试（PgConnectionWrapper connectionWrapper = new PgConnectionWrapper（））{
            connectionWrapper.runInTransaction（新 SQLStatementExecutor（）
            {
                @Override public void run(PgConnection connection) 抛出 SQLException
                {
                    // SQL 语句，但没有提交或回滚
                }
            });
        }
    }
}