修改连接池开启判断

we7coreteam · Mar 26, 2020 · d8392ab · d8392ab
1 parent 9f6a0c0
commit d8392ab
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Src/Core/Cache/ConnectorManager.php b/Src/Core/Cache/ConnectorManager.php
@@ -35,7 +35,7 @@ public function connect($name = 'default') : CacheInterface {
 			throw new \RuntimeException('Cache is not configured.');
 		}
 
-		if (empty($poolConfig) || empty($poolConfig['enable'])) {
+		if (!isCo() || empty($poolConfig) || empty($poolConfig['enable'])) {
 			/**
 			 * @var HandlerAbstract $handlerClass
 			 */

diff --git a/Src/Core/Database/ConnectorManager.php b/Src/Core/Database/ConnectorManager.php
@@ -34,7 +34,7 @@ public function __construct() {
 	 */
 	public function connect(array $config) {
 		//未设置连接池时，直接返回数据连接对象
-		if (empty($this->poolConfig[$config['name']]) || empty($this->poolConfig[$config['name']]['enable'])) {
+		if (!isCo() || empty($this->poolConfig[$config['name']]) || empty($this->poolConfig[$config['name']]['enable'])) {
 			return $this->getDefaultConnection($config);
 		}
 		$pool = $this->getPool($config['name'], $config);