postgresql - setAutoCommit(false) 不适用于 c3p0

标签 postgresql jetty connection-pooling c3p0

我正在使用 postgresql 9.2 和 C3p0 0.9.2.1,我创建了一个连接定制器来禁用 autoCommit 并设置 transactionMode 但是当我在 InitialContext 以检索 dataSourceautoCommit 未在连接上禁用(记录在底部)。如何禁用自动提交?

连接定制器:

public class IsolationLevelConnectionCustomizer extends
        AbstractConnectionCustomizer {

    @Override
    public void onAcquire(Connection c, String parentDataSourceIdentityToken)
            throws Exception {
        super.onAcquire(c, parentDataSourceIdentityToken);
        System.out.println("Connection acquired, set autocommit off and repeatable read transaction mode.");
        c.setAutoCommit(false);
        c.setTransactionIsolation(Connection.TRANSACTION_REPEATABLE_READ);
    }
}

为 DAO 检索数据源的类:

public class DAOAcquire {
    private ComboPooledDataSource m_cpdsDataSource = null;
    private static final String LOOKUP_CONNECT = "jdbc/mydb";

    public DAOAcquire() throws NamingException {
        InitialContext context = new InitialContext();
        m_cpdsDataSource = (ComboPooledDataSource) context.lookup(LOOKUP_CONNECT);

        if (m_cpdsDataSource != null) {
            try {
                System.out.println("Autocommit = "+String.valueOf(m_cpdsDataSource.getConnection().getAutoCommit()));

            } catch (SQLException e) {
                System.out.println("Could not get autocommit value : "+e.getMessage());
                e.printStackTrace();
            }
        }
    }

    public ComboPooledDataSource getComboPooledDataSource() {
        return m_cpdsDataSource;
    }

    /**
     * @return the jdbcTemplate
     * @throws NamingException 
     */
    public JdbcTemplate getJdbcTemplate() throws NamingException {
        return new JdbcTemplate(m_cpdsDataSource);
    }

    /**
     * Commit transactions
     * @throws SQLException
     */
    public void commit() throws SQLException {
        if (m_cpdsDataSource != null) {
            m_cpdsDataSource.getConnection().commit();
        } else {
            throw new SQLException("Could not commit. Reason : Unable to connect to database, dataSource is null.");
        }
    }

    /**
     * rollback all transactions to previous save point
     * @throws SQLException
     */
    public void rollback() throws SQLException {
        if (m_cpdsDataSource != null) {
            m_cpdsDataSource.getConnection().rollback();
        } else {
            throw new SQLException("Could not rollback. Reason : Unable to connect to database, dataSource is null.");
        }
    }
}

日志:

Connection acquired, set autocommit off and repeatable read transaction mode.
Connection acquired, set autocommit off and repeatable read transaction mode.
Connection acquired, set autocommit off and repeatable read transaction mode.
Autocommit = true

默认情况下,postgresql auto commit mode is disabled那么为什么 c3p0 会自动激活它呢?我应该将 forceIgnoreUnresolvedTransactions 设置为 true 吗?

编辑:每当我在检索数据源后提交事务时,我都会收到此错误:

org.postgresql.util.PSQLException:启用自动提交时无法提交。

最佳答案

JDBC spec指出,“默认情况下是在创建 Connection 对象时启用自动提交模式。”这是跨 DBMS 的默认设置,无论数据库在其他上下文中的行为如何。 JDBC 程序员可能依赖于设置 autoCommit,除非他们显式调用 setAutoCommit( false )。 c3p0 尊重这一点。

c3p0 允许 ConnectionCustomizers 在未指定任何单一行为时持续覆盖 onAcquire() 方法中的连接默认值。例如,规范声明“Connection 对象的默认事务级别由驱动程序确定 提供连接。”因此,对于 transactionIsolation,如果您在 onAcquire(...) 中重置它,c3p0 将记住您选择的默认值,并始终在结帐之前将 transactionIsolation 恢复为默认值. 但是,c3p0 明确不允许您在 onAcquire(...) 中禁用一次 autoCommit 并且默认禁用 autoCommit。结帐的那一刻,c3p0 坚持认为您有一个符合规范的连接。

您可以通过覆盖 onCheckOut(...) 方法来获得您想要的行为。当 onCheckOut(...) 被调用时,Connection 已经 checkout ,你可以在那里做任何你想做的事,c3p0 已经用尽了它对规范之神的义务。如果您希望您的客户端始终看到非自动提交连接,请在 onCheckOut(...) 中调用 setAutoCommit( false )。但请注意,这会使您的客户端代码不可移植。如果您离开 c3p0 并切换到不同的数据源,您将需要使用一些其他特定于库的方法来始终禁用 autoCommit,否则您会发现您的应用程序行为不正常。因为即使对于 postgres,JDBC 连接默认也是 autoCommit

注意: Connection 属性的值未由规范固定,因此可以在 onAcquire(...) 方法中永久覆盖 catalog holdabilitytransactionIsolationreadOnlytypeMap

附注不要forceIgnoreUnresolvedTransactions 设置为true。呸。

关于postgresql - setAutoCommit(false) 不适用于 c3p0,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17465133/

相关文章:

postgresql - Postgres 自定义浮点类型,它总是在点后截断为 2 位小数

java - 我应该如何配置 Jetty 7 pre3 以使用 oracle JDBC 源?

java - Jetty - 使用 jetty 默认 servlet 是否安全

java - 带有 Jetty 的 Spring MVC - app-servlet.xml 文件中应该包含什么?

java - Jetty 6 Eclipse 数据源 NameNotFoundException

java - H2 postgresql 模式似乎对我不起作用

java - 创建@OneToOne时抛出错误无法检索ResultSet

java - 在 Oracle ucp 中找不到 oracle.ucp.jdbc.PoolDataSourceFactory

sql - 如何从多个表中查询数据并按时间排序?

java - 在没有 JNDI 的情况下管理数据库连接的最佳方式