modify plugin name
This commit is contained in:
@@ -108,6 +108,9 @@ class Connection extends Component
|
|||||||
$pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
|
$pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) {
|
||||||
return Kiri::getDi()->create(PDO::class, [$config]);
|
return Kiri::getDi()->create(PDO::class, [$config]);
|
||||||
}, $minx);
|
}, $minx);
|
||||||
|
if (Db::inTransactionsActive() && !$pdo->inTransaction()) {
|
||||||
|
$pdo->beginTransaction();
|
||||||
|
}
|
||||||
return Context::setContext($config['cds'], $pdo);
|
return Context::setContext($config['cds'], $pdo);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user