diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java
index 53495c45a..5c64fc62a 100644
--- a/src/org/redkale/source/DataJdbcSource.java
+++ b/src/org/redkale/source/DataJdbcSource.java
@@ -64,6 +64,11 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
     protected void preConstruct(String unitName, Properties readprop, Properties writeprop) {
     }
 
+    @Override
+    public String getType() {
+        return "jdbc";
+    }
+
     @Override
     public final String resourceName() {
         return name;
@@ -75,6 +80,14 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC
         writePool.close();
     }
 
+    public PoolJdbcSource getReadPoolJdbcSource() {
+        return readPool;
+    }
+
+    public PoolJdbcSource getWritePoolJdbcSource() {
+        return writePool;
+    }
+
     public Connection createReadSQLConnection() {
         return readPool.poll();
     }
diff --git a/src/org/redkale/source/DataSource.java b/src/org/redkale/source/DataSource.java
index 8994606ae..9a3fa9b85 100644
--- a/src/org/redkale/source/DataSource.java
+++ b/src/org/redkale/source/DataSource.java
@@ -24,6 +24,13 @@ import org.redkale.util.*;
 @SuppressWarnings("unchecked")
 public interface DataSource {
 
+    /**
+     * 获取数据源类型
+     *
+     * @return String
+     */
+    public String getType();
+
     //----------------------insertAsync-----------------------------
     /**
      * 新增记录， 多对象必须是同一个Entity类  <br>