diff --git a/src/LayerInterface.php b/src/LayerInterface.php
index 1bc532a..7d4b8d0 100644
--- a/src/LayerInterface.php
+++ b/src/LayerInterface.php
@@ -1,6 +1,17 @@
 <?php
 namespace Bee\Db;
 
+/**
+ * 数据连接对象接口
+ *
+ * @package Bee\Db
+ */
 interface LayerInterface
 {
+    /**
+     * 释放数据连接
+     *
+     * @return mixed
+     */
+    public function clean();
 }
diff --git a/src/MySQL.php b/src/MySQL.php
index 1ec2c80..8ea0905 100644
--- a/src/MySQL.php
+++ b/src/MySQL.php
@@ -181,4 +181,13 @@ public function delete(string $sql, array $params = [], float $timeout = 0)
     {
         return $this->master($sql, $params, $timeout);
     }
+
+    /**
+     * 释放数据连接
+     */
+    public function clean()
+    {
+        $this->masterPool->clean();
+        $this->slavePool->clean();
+    }
 }
\ No newline at end of file
diff --git a/src/MySQL/Pool.php b/src/MySQL/Pool.php
index ff8048a..5c784e5 100644
--- a/src/MySQL/Pool.php
+++ b/src/MySQL/Pool.php
@@ -51,7 +51,7 @@ public function get() : Item
         $item = $this->pool->pop($this->timeout);
 
         if ($item === false) {
-            throw new Exception('Get Item instance timeout, all connection is used!');
+            throw new Exception('Get mysql connection instance timeout, pool: ' . $this->getLength());
         }
 
         return $item;
@@ -64,4 +64,14 @@ public function getLength() : int
     {
         return $this->pool->length();
     }
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     */
+    public function clean()
+    {
+        while ($item = $this->pool->pop($this->timeout)) {
+            $item->close();
+        }
+    }
 }
diff --git a/src/PoolInterface.php b/src/PoolInterface.php
index ef75edf..66cb47f 100644
--- a/src/PoolInterface.php
+++ b/src/PoolInterface.php
@@ -1,7 +1,6 @@
 <?php
 namespace Bee\Db;
 
-
 /**
  * Interface PoolInterface
  *
@@ -10,13 +9,24 @@
 interface PoolInterface
 {
     /**
+     * 放回数据连接实例
+     *
      * @param \Bee\Db\MySQL\Item|\Bee\Db\Redis\Item $item
      * @return bool
      */
     public function put($item);
 
     /**
+     * 获取数据连接实例
+     *
      * @return \Bee\Db\MySQL\Item|\Swoole\Coroutine\Redis
      */
     public function get();
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     *
+     * @return mixed
+     */
+    public function clean();
 }
diff --git a/src/Redis.php b/src/Redis.php
index 3fd0dde..555edfa 100644
--- a/src/Redis.php
+++ b/src/Redis.php
@@ -182,4 +182,13 @@ public function putSlaveConnect($item)
     {
         $this->slavePool->put($item);
     }
+
+    /**
+     * 释放数据连接
+     */
+    public function clean()
+    {
+        $this->masterPool->clean();
+        $this->slavePool->clean();
+    }
 }
diff --git a/src/Redis/Pool.php b/src/Redis/Pool.php
index 23ee49b..f7d6591 100644
--- a/src/Redis/Pool.php
+++ b/src/Redis/Pool.php
@@ -51,7 +51,7 @@ public function get()
         $item = $this->pool->pop($this->timeout);
 
         if ($item === false) {
-            throw new Exception('Get Item instance timeout, all connection is used!');
+            throw new Exception('Get redis connection instance timeout, pool: ' . $this->getLength());
         }
 
         return $item;
@@ -64,4 +64,14 @@ public function getLength() : int
     {
         return $this->pool->length();
     }
+
+    /**
+     * 清空数据库连接池（释放数据连接）
+     */
+    public function clean()
+    {
+        while ($item = $this->pool->pop($this->timeout)) {
+            $item->close();
+        }
+    }
 }