From 043b847f05caa4f415ec528e3ee125cbf7bc52e3 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Wed, 29 Nov 2017 12:01:42 +0800
Subject: [PATCH] =?UTF-8?q?DataSource=E5=A2=9E=E5=8A=A0getType()=E6=96=B9?=
 =?UTF-8?q?=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/org/redkale/source/DataJdbcSource.java | 13 +++++++++++++
 src/org/redkale/source/DataSource.java     |  7 +++++++
 2 files changed, 20 insertions(+)

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>