fixes #5 by closing connection

jcabi · Nov 1, 2013 · 030ca5e · 030ca5e
1 parent 7868e87
commit 030ca5e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/main/java/com/jcabi/jdbc/JdbcSession.java b/src/main/java/com/jcabi/jdbc/JdbcSession.java
@@ -416,6 +416,9 @@ private <T> T run(final JdbcSession.Handler<T> handler,
             }
             throw new SQLException(ex);
         } finally {
+            if (this.auto) {
+                this.disconnect();
+            }
             this.args.clear();
         }
         return result;

diff --git a/src/test/java/com/jcabi/jdbc/JdbcSessionTest.java b/src/test/java/com/jcabi/jdbc/JdbcSessionTest.java
@@ -127,6 +127,7 @@ public String handle(final ResultSet rset)
      * @since 0.10.2
      */
     @Test
+    @SuppressWarnings("PMD.AvoidInstantiatingObjectsInLoops")
     public void releasesConnectionsFromThePool() throws Exception {
         final DataSource src = JdbcSessionTest.source();
         new JdbcSession(src)
@@ -162,7 +163,7 @@ public void executesSqlInParallelThreads() throws Exception {
      */
     @Parallel(threads = Tv.FIFTY)
     private void insert(final DataSource src, final String table)
-        throws Exception{
+        throws Exception {
         new JdbcSession(src)
             .sql(String.format("INSERT INTO %s VALUES ('hey')", table))
             .execute();