Merge remote-tracking branch 'origin/master'

This commit is contained in:
2025-08-16 09:02:55 +08:00
3 changed files with 72 additions and 89 deletions

View File

@@ -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) {
}

View File

@@ -161,7 +161,6 @@ class DatabaseRoute
->page($currPage, $pageSize)
->select()
->toArray();
$query->getConnection()->close();
return [
'totalCount' => $totalCount,
@@ -204,7 +203,6 @@ class DatabaseRoute
// 不要order避免报错
$query->removeOption('order');
$count = $query->count();
$query->getConnection()->close();
$counts[$connName] = $count;
$total += $count;
}
@@ -258,7 +256,6 @@ class DatabaseRoute
->limit($localOffset, $localLimit)
->select()
->toArray();
$query->getConnection()->close();
$allRows = array_merge($allRows, $rows);
@@ -375,7 +372,6 @@ class DatabaseRoute
$query = Db::connect($connName)->name($table);
$query = call_user_func($builder, $query);
$deleted = $query->delete();
$query->getConnection()->close();
$totalDeleted += $deleted;
}
@@ -415,13 +411,11 @@ class DatabaseRoute
if (method_exists($query, $method)) {
$result = call_user_func_array([$query, $method], $args);
$finalResult = $result;
$query->getConnection()->close();
// find 返回 nullselect 返回空数组count 返回数字
if ($result || $result === 0) {
return $result;
}
}else {
$query->getConnection()->close();
}
}
}
@@ -436,7 +430,6 @@ class DatabaseRoute
$result = call_user_func_array([$query, $method], $args);
// find 返回 nullselect 返回空数组count 返回数字
$finalResult = $result;
$query->getConnection()->close();
if ($result instanceof Collection) {
if (!$result->isEmpty()) {
return $result;
@@ -447,7 +440,6 @@ class DatabaseRoute
return $result;
}
}else {
$query->getConnection()->close();
}
}
}