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 14:08:32 +08:00
parent def499c2f6
commit 80fd889ae4
1 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-engine/Pool/Connection.php
+9 -12
View File
@@ -93,20 +93,17 @@ class Connection extends Component
public function get(mixed $config): ?PDO public function get(mixed $config): ?PDO
{ {
$coroutineName = $config['cds']; $coroutineName = $config['cds'];
if (($pdo = Context::getContext($config['cds'])) instanceof PDO) {
return $pdo;
}
$minx = Config::get('databases.pool.min', 1); $minx = Config::get('databases.pool.min', 1);
return $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
/** @var PDO $pdo */ $connect = Kiri::getDi()->create(PDO::class, [$config]);
$pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) { if (!Db::inTransactionsActive()) {
return Kiri::getDi()->create(PDO::class, [$config]); return $connect;
}, $minx);
if (Db::inTransactionsActive() && !$pdo->inTransaction()) {
$pdo->beginTransaction();
} }
return Context::setContext($config['cds'], $pdo); if (!$connect->inTransaction()) {
$connect->beginTransaction();
}
return $connect;
}, $minx);
} }