diff --git a/src/main/java/com/alibaba/druid/mock/MockConnection.java b/src/main/java/com/alibaba/druid/mock/MockConnection.java
index d47d985d9b..1b8e748377 100644
--- a/src/main/java/com/alibaba/druid/mock/MockConnection.java
+++ b/src/main/java/com/alibaba/druid/mock/MockConnection.java
@@ -55,6 +55,8 @@ public class MockConnection extends ConnectionBase implements Connection {
 
     private SQLException    error;
 
+    private String          lastSql;
+
     public MockConnection(){
         this(null, null, null);
     }
@@ -69,6 +71,14 @@ public class MockConnection extends ConnectionBase implements Connection {
         }
     }
 
+    public String getLastSql() {
+        return lastSql;
+    }
+
+    public void setLastSql(String lastSql) {
+        this.lastSql = lastSql;
+    }
+
     public SQLException getError() {
         return error;
     }
@@ -268,7 +278,7 @@ public class MockConnection extends ConnectionBase implements Connection {
         if (error != null) {
             throw error;
         }
-        
+
         if (closed) {
             throw new MockConnectionClosedException();
         }
@@ -469,7 +479,7 @@ public class MockConnection extends ConnectionBase implements Connection {
     public int getNetworkTimeout() throws SQLException {
         throw new SQLFeatureNotSupportedException();
     }
-    
+
     @Override
     public void setReadOnly(boolean readOnly) throws SQLException {
         checkState();
diff --git a/src/main/java/com/alibaba/druid/mock/MockStatement.java b/src/main/java/com/alibaba/druid/mock/MockStatement.java
index 650614a2d0..5d44e966a8 100644
--- a/src/main/java/com/alibaba/druid/mock/MockStatement.java
+++ b/src/main/java/com/alibaba/druid/mock/MockStatement.java
@@ -86,6 +86,7 @@ public class MockStatement extends StatementBase implements MockStatementBase, S
         }
 
         if (mockConnection != null) {
+            mockConnection.setLastSql(sql);
             mockConnection.handleSleep();
         }
 
diff --git a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java
index 6155f1aebe..1d9f4ebb9d 100644
--- a/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java
+++ b/src/main/java/com/alibaba/druid/pool/DruidAbstractDataSource.java
@@ -31,7 +31,6 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.IdentityHashMap;
-import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Properties;
@@ -598,20 +597,24 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements
         return result;
     }
 
-    public void setConnectionInitSqls(Collection<Object> connectionInitSqls) {
+    public void setConnectionInitSqls(Collection<? extends Object> connectionInitSqls) {
         if ((connectionInitSqls != null) && (connectionInitSqls.size() > 0)) {
             ArrayList<String> newVal = null;
-            for (Iterator<Object> iterator = connectionInitSqls.iterator(); iterator.hasNext();) {
-                Object o = iterator.next();
-                if (o != null) {
-                    String s = o.toString();
-                    if (s.trim().length() > 0) {
-                        if (newVal == null) {
-                            newVal = new ArrayList<String>();
-                        }
-                        newVal.add(s);
-                    }
+            for (Object o : connectionInitSqls) {
+                if (o == null) {
+                    continue;
                 }
+
+                String s = o.toString();
+                s = s.trim();
+                if (s.length() == 0) {
+                    continue;
+                }
+
+                if (newVal == null) {
+                    newVal = new ArrayList<String>();
+                }
+                newVal.add(s);
             }
             this.connectionInitSqls = newVal;
         } else {
@@ -1456,6 +1459,25 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements
         if (getDefaultCatalog() != null && getDefaultCatalog().length() != 0) {
             conn.setCatalog(getDefaultCatalog());
         }
+
+        Collection<String> initSqls = getConnectionInitSqls();
+        if (initSqls.size() == 0) {
+            return;
+        }
+
+        Statement stmt = null;
+        try {
+            stmt = conn.createStatement();
+            for (String sql : initSqls) {
+                if (sql == null) {
+                    continue;
+                }
+                
+                stmt.execute(sql);
+            }
+        } finally {
+            JdbcUtils.close(stmt);
+        }
     }
 
     public abstract int getActivePeak();
diff --git a/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql.java b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql.java
new file mode 100644
index 0000000000..7f3a4f0837
--- /dev/null
+++ b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql.java
@@ -0,0 +1,43 @@
+package com.alibaba.druid.bvt.pool;
+
+import java.sql.Connection;
+import java.util.ArrayList;
+import java.util.List;
+
+import junit.framework.TestCase;
+
+import org.junit.Assert;
+
+import com.alibaba.druid.mock.MockConnection;
+import com.alibaba.druid.pool.DruidDataSource;
+
+public class DruidDataSourceTest_initSql extends TestCase {
+
+    private DruidDataSource dataSource;
+
+    protected void setUp() throws Exception {
+        dataSource = new DruidDataSource();
+        dataSource.setUrl("jdbc:mock:xxx");
+        List<Object> sqlList = new ArrayList<Object>();
+        sqlList.add("select 123");
+        sqlList.add(null);
+        sqlList.add("");
+
+        dataSource.setConnectionInitSqls(sqlList);
+    }
+
+    protected void tearDown() throws Exception {
+        dataSource.close();
+    }
+
+    public void testDefault() throws Exception {
+        Connection conn = dataSource.getConnection();
+
+        MockConnection mockConn = conn.unwrap(MockConnection.class);
+
+        Assert.assertEquals("select 123", mockConn.getLastSql());
+
+        conn.close();
+    }
+
+}
diff --git a/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql_factory.java b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql_factory.java
new file mode 100644
index 0000000000..ca2146896a
--- /dev/null
+++ b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSql_factory.java
@@ -0,0 +1,39 @@
+package com.alibaba.druid.bvt.pool;
+
+import java.sql.Connection;
+import java.util.Properties;
+
+import junit.framework.TestCase;
+
+import org.junit.Assert;
+
+import com.alibaba.druid.mock.MockConnection;
+import com.alibaba.druid.pool.DruidDataSource;
+import com.alibaba.druid.pool.DruidDataSourceFactory;
+
+public class DruidDataSourceTest_initSql_factory extends TestCase {
+
+    private DruidDataSource dataSource;
+
+    protected void setUp() throws Exception {
+        Properties properties = new Properties();
+        properties.put(DruidDataSourceFactory.PROP_URL, "jdbc:mock:xxx");
+        properties.put(DruidDataSourceFactory.PROP_INITCONNECTIONSQLS, ";;select 123");
+        dataSource = (DruidDataSource) DruidDataSourceFactory.createDataSource(properties);
+    }
+
+    protected void tearDown() throws Exception {
+        dataSource.close();
+    }
+
+    public void testDefault() throws Exception {
+        Connection conn = dataSource.getConnection();
+
+        MockConnection mockConn = conn.unwrap(MockConnection.class);
+
+        Assert.assertEquals("select 123", mockConn.getLastSql());
+
+        conn.close();
+    }
+
+}
diff --git a/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest9.java b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSqls.java
similarity index 94%
rename from src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest9.java
rename to src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSqls.java
index b7e76f9137..f735d2730a 100644
--- a/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest9.java
+++ b/src/test/java/com/alibaba/druid/bvt/pool/DruidDataSourceTest_initSqls.java
@@ -8,7 +8,7 @@ import org.junit.Assert;
 
 import com.alibaba.druid.pool.DruidDataSource;
 
-public class DruidDataSourceTest9 extends TestCase {
+public class DruidDataSourceTest_initSqls extends TestCase {
 
     private DruidDataSource dataSource;