More unit tests

src/test/java/com/zaxxer/hikari/ConnectionStateTest.java

@@ -0,0 +1,94 @@
+package com.zaxxer.hikari;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class ConnectionStateTest
+{
+    @Test
+    public void testAutoCommit() throws SQLException
+    {
+        HikariDataSource ds = new HikariDataSource();
+        ds.setAutoCommit(true);
+        ds.setMinimumPoolSize(1);
+        ds.setMaximumPoolSize(1);
+        ds.setAcquireIncrement(1);
+        ds.setConnectionTestQuery("VALUES 1");
+        ds.setDataSourceClassName("com.zaxxer.hikari.mocks.StubDataSource");
+
+        try
+        {
+            Connection connection = ds.getConnection();
+            connection.setAutoCommit(false);
+            connection.close();
+
+            Connection connection2 = ds.getConnection();
+            Assert.assertSame(connection, connection2);
+            Assert.assertTrue(connection2.getAutoCommit());
+            connection2.close();
+        }
+        finally
+        {
+            ds.shutdown();
+        }
+    }
+
+    @Test
+    public void testTransactionIsolation() throws SQLException
+    {
+        HikariDataSource ds = new HikariDataSource();
+        ds.setTransactionIsolation("TRANSACTION_READ_COMMITTED");
+        ds.setMinimumPoolSize(1);
+        ds.setMaximumPoolSize(1);
+        ds.setAcquireIncrement(1);
+        ds.setConnectionTestQuery("VALUES 1");
+        ds.setDataSourceClassName("com.zaxxer.hikari.mocks.StubDataSource");
+
+        try
+        {
+            Connection connection = ds.getConnection();
+            connection.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
+            connection.close();
+
+            Connection connection2 = ds.getConnection();
+            Assert.assertSame(connection, connection2);
+            Assert.assertEquals(Connection.TRANSACTION_READ_COMMITTED, connection2.getTransactionIsolation());
+            connection2.close();
+        }
+        finally
+        {
+            ds.shutdown();
+        }
+    }
+
+    @Test
+    public void testCatalog() throws SQLException
+    {
+        HikariDataSource ds = new HikariDataSource();
+        ds.setCatalog("test");
+        ds.setMinimumPoolSize(1);
+        ds.setMaximumPoolSize(1);
+        ds.setAcquireIncrement(1);
+        ds.setConnectionTestQuery("VALUES 1");
+        ds.setDataSourceClassName("com.zaxxer.hikari.mocks.StubDataSource");
+
+        try
+        {
+            Connection connection = ds.getConnection();
+            connection.setCatalog("other");
+            connection.close();
+
+            Connection connection2 = ds.getConnection();
+            Assert.assertSame(connection, connection2);
+            Assert.assertEquals("test", connection2.getCatalog());
+            connection2.close();
+        }
+        finally
+        {
+            ds.shutdown();
+        }
+    }
+}

src/test/java/com/zaxxer/hikari/mocks/StubConnection.java

@@ -42,6 +42,9 @@ import java.util.concurrent.Executor;
 public class StubConnection extends StubBaseConnection implements Connection
 {
     private static long foo;
+    private boolean autoCommit;
+    private int isolation;
+    private String catalog;
 
     static
     {
@@ -75,13 +78,13 @@ public class StubConnection extends StubBaseConnection implements Connection
     /** {@inheritDoc} */
     public void setAutoCommit(boolean autoCommit) throws SQLException
     {
-
+        this.autoCommit = autoCommit;
     }
 
     /** {@inheritDoc} */
     public boolean getAutoCommit() throws SQLException
     {
-        return false;
+        return autoCommit;
     }
 
     /** {@inheritDoc} */
@@ -128,23 +131,25 @@ public class StubConnection extends StubBaseConnection implements Connection
     /** {@inheritDoc} */
     public void setCatalog(String catalog) throws SQLException
     {
+        this.catalog = catalog;
     }
 
     /** {@inheritDoc} */
     public String getCatalog() throws SQLException
     {
-        return null;
+        return catalog;
     }
 
     /** {@inheritDoc} */
     public void setTransactionIsolation(int level) throws SQLException
     {
+        this.isolation = level;
     }
 
     /** {@inheritDoc} */
     public int getTransactionIsolation() throws SQLException
     {
-        return 0;
+        return isolation;
     }
 
     /** {@inheritDoc} */