diff --git a/app/DbCoroutineContext.php b/app/DbCoroutineContext.php index fed0c6b..baab437 100644 --- a/app/DbCoroutineContext.php +++ b/app/DbCoroutineContext.php @@ -25,16 +25,16 @@ class DbCoroutineContext // put 存数据到 list public static function put(mixed $value): void { -// $val = self::get('startTrans'); -// if (!empty($val) && $val === true) { -// $value->startTrans(); -// } -// $cid = self::getCid(); -// if ($cid !== null) { -// self::$list[$cid][] = $value; -// } else { -// self::$globalList[] = $value; -// } + $val = self::get('startTrans'); + if (!empty($val) && $val === true) { + $value->startTrans(); + } + $cid = self::getCid(); + if ($cid !== null) { + self::$list[$cid][] = $value; + } else { + self::$globalList[] = $value; + } } // set 设置 key-value @@ -83,14 +83,6 @@ class DbCoroutineContext public static function clearList() { - foreach (self::getList() as $conn) { - try { - $conn->query('SELECT 1'); - $conn->close(); - // 连接正常 - } catch (\Exception $e) { - } - } $cid = self::getCid(); if ($cid !== null) { unset(self::$list[$cid]); @@ -112,7 +104,6 @@ class DbCoroutineContext foreach (self::getList() as $conn) { try { $conn->query('SELECT 1'); - $conn->close(); // 连接正常 } catch (\Exception $e) { }