From dab56caa98320b6e407e6d9b7237a84873f4a7b1 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Tue, 10 Apr 2018 14:15:50 +0800
Subject: [PATCH]

---
 ...ataAsyncSource.java => DataSqlSource.java} |  6 ++--
 src/org/redkale/source/PoolSource.java        | 36 +++++++++++++++++++
 2 files changed, 39 insertions(+), 3 deletions(-)
 rename src/org/redkale/source/{DataAsyncSource.java => DataSqlSource.java} (67%)
 create mode 100644 src/org/redkale/source/PoolSource.java

diff --git a/src/org/redkale/source/DataAsyncSource.java b/src/org/redkale/source/DataSqlSource.java
similarity index 67%
rename from src/org/redkale/source/DataAsyncSource.java
rename to src/org/redkale/source/DataSqlSource.java
index d56be40c0..7b605dec2 100644
--- a/src/org/redkale/source/DataAsyncSource.java
+++ b/src/org/redkale/source/DataSqlSource.java
@@ -10,7 +10,7 @@ import org.redkale.service.*;
 import org.redkale.util.*;
 
 /**
- * DataSource的异步抽象实现类
+ * DataSource的SQL抽象实现类
  *
  * <p>
  * 详情见: https://redkale.org
@@ -21,6 +21,6 @@ import org.redkale.util.*;
 @AutoLoad(false)
 @SuppressWarnings("unchecked")
 @ResourceType(DataSource.class)
-public abstract class DataAsyncSource extends AbstractService implements DataSource, DataCacheListener, Function<Class, EntityInfo>, AutoCloseable, Resourcable {
-
+public abstract class DataSqlSource extends AbstractService implements DataSource, DataCacheListener, Function<Class, EntityInfo>, AutoCloseable, Resourcable {
+ 
 }
diff --git a/src/org/redkale/source/PoolSource.java b/src/org/redkale/source/PoolSource.java
new file mode 100644
index 000000000..7034b9ea1
--- /dev/null
+++ b/src/org/redkale/source/PoolSource.java
@@ -0,0 +1,36 @@
+/*
+ * To change this license header, choose License Headers in Project Properties.
+ * To change this template file, choose Tools | Templates
+ * and open the template in the editor.
+ */
+package org.redkale.source;
+
+import java.util.Properties;
+import java.util.concurrent.CompletableFuture;
+
+/**
+ * 连接池类
+ *
+ * <p>
+ * 详情见: https://redkale.org
+ *
+ * @author zhangjx
+ * @param <T> 连接泛型
+ */
+public abstract class PoolSource<T> {
+
+    /**
+     * 是否异步， 为true则只能调用pollAsync方法，为false则只能调用poll方法
+     *
+     * @return 是否异步
+     */
+    public abstract boolean isAysnc();
+
+    public abstract void change(Properties property);
+
+    public abstract T poll();
+
+    public abstract CompletableFuture<T> pollAsync();
+
+    public abstract void close();
+}