diff --git a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
index b7b22ab8f7..57417b4a69 100644
--- a/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
+++ b/src/main/java/com/alibaba/druid/pool/DruidDataSource.java
@@ -259,7 +259,7 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
             PoolableConnection poolalbeConnection = getConnectionInternal();
 
             if (isTestOnBorrow()) {
-                boolean validate = testConnection(poolalbeConnection.getRawConnection());
+                boolean validate = testConnection(poolalbeConnection.getConnection());
                 if (!validate) {
                     LOG.debug("skip not validate connection.");
                     Connection realConnection = poolalbeConnection.getConnection();
diff --git a/src/main/java/com/alibaba/druid/pool/PoolableCallableStatement.java b/src/main/java/com/alibaba/druid/pool/PoolableCallableStatement.java
index 2a6272c243..108958dd10 100644
--- a/src/main/java/com/alibaba/druid/pool/PoolableCallableStatement.java
+++ b/src/main/java/com/alibaba/druid/pool/PoolableCallableStatement.java
@@ -41,6 +41,10 @@ public class PoolableCallableStatement extends PoolablePreparedStatement impleme
         this.stmt = stmt;
     }
 
+    public CallableStatement getCallableStatementRaw() {
+        return stmt;
+    }
+
     @Override
     public void registerOutParameter(int parameterIndex, int sqlType) throws SQLException {
         try {
diff --git a/src/main/java/com/alibaba/druid/pool/PoolableConnection.java b/src/main/java/com/alibaba/druid/pool/PoolableConnection.java
index 5c75d055a2..b27f9c4f59 100644
--- a/src/main/java/com/alibaba/druid/pool/PoolableConnection.java
+++ b/src/main/java/com/alibaba/druid/pool/PoolableConnection.java
@@ -104,10 +104,6 @@ public class PoolableConnection implements PooledConnection, Connection {
         this.holder.getStatementPool().put(stmt);
     }
 
-    public Connection getRawConnection() {
-        return conn;
-    }
-
     public ConnectionHolder getConnectionHolder() {
         return holder;
     }
diff --git a/src/main/java/com/alibaba/druid/support/spring/DruidNativeJdbcExtractor.java b/src/main/java/com/alibaba/druid/support/spring/DruidNativeJdbcExtractor.java
new file mode 100644
index 0000000000..6c6edf3266
--- /dev/null
+++ b/src/main/java/com/alibaba/druid/support/spring/DruidNativeJdbcExtractor.java
@@ -0,0 +1,111 @@
+package com.alibaba.druid.support.spring;
+
+import java.sql.CallableStatement;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+import org.springframework.jdbc.support.nativejdbc.NativeJdbcExtractor;
+
+import com.alibaba.druid.pool.PoolableCallableStatement;
+import com.alibaba.druid.pool.PoolableConnection;
+import com.alibaba.druid.pool.PoolablePreparedStatement;
+import com.alibaba.druid.pool.PoolableResultSet;
+import com.alibaba.druid.pool.PoolableStatement;
+import com.alibaba.druid.proxy.jdbc.CallableStatementProxy;
+import com.alibaba.druid.proxy.jdbc.ConnectionProxy;
+import com.alibaba.druid.proxy.jdbc.PreparedStatementProxy;
+import com.alibaba.druid.proxy.jdbc.ResultSetProxy;
+import com.alibaba.druid.proxy.jdbc.StatementProxy;
+
+public class DruidNativeJdbcExtractor implements NativeJdbcExtractor {
+
+    @Override
+    public boolean isNativeConnectionNecessaryForNativeStatements() {
+        return true;
+    }
+
+    @Override
+    public boolean isNativeConnectionNecessaryForNativePreparedStatements() {
+        return true;
+    }
+
+    @Override
+    public boolean isNativeConnectionNecessaryForNativeCallableStatements() {
+        return true;
+    }
+
+    @Override
+    public Connection getNativeConnection(Connection conn) throws SQLException {
+        if (conn instanceof PoolableConnection) {
+            conn = ((PoolableConnection) conn).getConnection();
+        }
+
+        if (conn instanceof ConnectionProxy) {
+            conn = ((ConnectionProxy) conn).getConnectionRaw();
+        }
+
+        return conn;
+    }
+
+    @Override
+    public Connection getNativeConnectionFromStatement(Statement stmt) throws SQLException {
+        Connection conn = stmt.getConnection();
+        return getNativeConnection(conn);
+    }
+
+    @Override
+    public Statement getNativeStatement(Statement stmt) throws SQLException {
+        if (stmt instanceof PoolableStatement) {
+            stmt = ((PoolableStatement) stmt).getStatement();
+        }
+
+        if (stmt instanceof StatementProxy) {
+            stmt = ((StatementProxy) stmt).getStatementRaw();
+        }
+
+        return stmt;
+    }
+
+    @Override
+    public PreparedStatement getNativePreparedStatement(PreparedStatement stmt) throws SQLException {
+        if (stmt instanceof PoolablePreparedStatement) {
+            stmt = ((PoolablePreparedStatement) stmt).getRawPreparedStatement();
+        }
+
+        if (stmt instanceof PreparedStatementProxy) {
+            stmt = ((PreparedStatementProxy) stmt).getRawPreparedStatement();
+        }
+
+        return stmt;
+    }
+
+    @Override
+    public CallableStatement getNativeCallableStatement(CallableStatement stmt) throws SQLException {
+        if (stmt instanceof PoolableCallableStatement) {
+            stmt = ((PoolableCallableStatement) stmt).getCallableStatementRaw();
+        }
+
+        if (stmt instanceof CallableStatementProxy) {
+            stmt = ((CallableStatementProxy) stmt).getRawCallableStatement();
+        }
+
+        return stmt;
+    }
+
+    @Override
+    public ResultSet getNativeResultSet(ResultSet rs) throws SQLException {
+        if (rs instanceof PoolableResultSet) {
+            rs = ((PoolableResultSet) rs).getRawResultSet();
+        }
+
+        if (rs instanceof ResultSetProxy) {
+            rs = ((ResultSetProxy) rs).getResultSetRaw();
+        }
+
+        return rs;
+    }
+
+}