我正在使用 postgresql 9.2 和 C3p0 0.9.2.1,我创建了一个连接定制器来禁用 autoCommit
并设置 transactionMode
但是当我在 InitialContext
以检索 dataSource
,autoCommit
未在连接上禁用(记录在底部)。如何禁用自动提交?
连接定制器:
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
、holdability
、transactionIsolation
、readOnly
和 typeMap
。
附注不要将forceIgnoreUnresolvedTransactions
设置为true
。呸。
关于postgresql - setAutoCommit(false) 不适用于 c3p0,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17465133/