From bbd960899ae2ade780b7df567cf622feeb90278e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 25 Feb 2022 18:37:49 +0800 Subject: [PATCH] modify plugin name --- kiri-engine/Pool/Connection.php | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/kiri-engine/Pool/Connection.php b/kiri-engine/Pool/Connection.php index bf8115d6..eeffcb75 100644 --- a/kiri-engine/Pool/Connection.php +++ b/kiri-engine/Pool/Connection.php @@ -4,6 +4,7 @@ declare(strict_types=1); namespace Kiri\Pool; use Closure; +use Database\Db; use Database\Mysql\PDO; use Exception; use Kiri; @@ -103,11 +104,13 @@ class Connection extends Component $minx = Config::get('databases.pool.min', 1); - /** @var PDO $connections */ + /** @var PDO $pdo */ $pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) { return Kiri::getDi()->create(PDO::class, [$config]); }, $minx); - + if (Db::inTransactionsActive() && !$pdo->inTransaction()) { + $pdo->beginTransaction(); + } return Context::setContext($config['cds'], $pdo); }