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:00:54 +08:00
parent 8681a23919
commit 751168b2de
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
kiri-engine/Pool/Connection.php
+6
View File
@@ -22,6 +22,9 @@ class Connection extends Component
{ {
private array $master = [];
/** /**
* @param Pool $pool * @param Pool $pool
* @param array $config * @param array $config
@@ -93,6 +96,9 @@ class Connection extends Component
public function get(mixed $config): ?PDO public function get(mixed $config): ?PDO
{ {
$coroutineName = $config['cds']; $coroutineName = $config['cds'];
if (Db::inTransactionsActive() && isset($this->master[$coroutineName])) {
return $this->master[$coroutineName];
}
$minx = Config::get('databases.pool.min', 1); $minx = Config::get('databases.pool.min', 1);
return $this->pool->get($coroutineName, static function () use ($coroutineName, $config) { return $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
$connect = Kiri::getDi()->create(PDO::class, [$config]); $connect = Kiri::getDi()->create(PDO::class, [$config]);