as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify plugin name

Browse Source
This commit is contained in:
向林
2022-06-08 16:13:16 +08:00
parent 8b7dc42185
commit 1955e73881
1 changed files with 7 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-engine/Pool/Connection.php
+7 -11
View File
@@ -95,21 +95,17 @@ class Connection extends Component
*/ */
public function get(mixed $config): ?PDO public function get(mixed $config): ?PDO
{ {
$coroutineName = $config['cds'];
if (isset($this->master[$coroutineName])) {
return $this->master[$coroutineName];
}
$minx = Config::get('databases.pool.min', 1); $minx = Config::get('databases.pool.min', 1);
$connect = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) { return $this->pool->get($config['cds'], static function () use ($config) {
return Kiri::getDi()->create(PDO::class, [$config]); $connect = Kiri::getDi()->create(PDO::class, [$config]);
}, $minx); if (!Db::inTransactionsActive()) {
if (Db::inTransactionsActive()) { return $connect;
}
if (!$connect->inTransaction()) { if (!$connect->inTransaction()) {
$connect->beginTransaction(); $connect->beginTransaction();
} }
return $this->master[$coroutineName] = $connect; return $connect;
} }, $minx);
return $connect;
} }