diff --git a/jOOQ/src/main/java/org/jooq/impl/DataSourceConnectionProvider.java b/jOOQ/src/main/java/org/jooq/impl/DataSourceConnectionProvider.java index 063af90d1f..661303665a 100644 --- a/jOOQ/src/main/java/org/jooq/impl/DataSourceConnectionProvider.java +++ b/jOOQ/src/main/java/org/jooq/impl/DataSourceConnectionProvider.java @@ -71,7 +71,6 @@ import org.jooq.exception.DataAccessException; public class DataSourceConnectionProvider implements ConnectionProvider { private final DataSource dataSource; - private Connection connection; public DataSourceConnectionProvider(DataSource dataSource) { this.dataSource = dataSource; @@ -83,27 +82,18 @@ public class DataSourceConnectionProvider implements ConnectionProvider { @Override public Connection acquire() { - if (null == connection) { - try { - connection = dataSource.getConnection(); - } - catch (SQLException e) { - throw new DataAccessException("Error getting connection from data source " + dataSource, e); - } + try { + return dataSource.getConnection(); + } + catch (SQLException e) { + throw new DataAccessException("Error getting connection from data source " + dataSource, e); } - - return connection; } @Override - public void release(Connection released) { - if (this.connection != released) { - throw new IllegalArgumentException("Expected " + this.connection + " but got " + released); - } - + public void release(Connection connection) { try { connection.close(); - this.connection = null; } catch (SQLException e) { throw new DataAccessException("Error closing connection " + connection, e);