From d67bbd69ca9d22418307a061feb2496d5b9d98b0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Fri, 25 Feb 2022 18:30:59 +0800 Subject: [PATCH] modify plugin name --- kiri-engine/Pool/Connection.php | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/kiri-engine/Pool/Connection.php b/kiri-engine/Pool/Connection.php index 5359f257..bf8115d6 100644 --- a/kiri-engine/Pool/Connection.php +++ b/kiri-engine/Pool/Connection.php @@ -104,11 +104,11 @@ class Connection extends Component $minx = Config::get('databases.pool.min', 1); /** @var PDO $connections */ - $connections = $this->pool->get($coroutineName, $this->create($coroutineName, $config), $minx); - if (Context::hasContext('begin_' . $coroutineName)) { - $connections->beginTransaction(); - } - return $connections; + $pdo = $this->pool->get($coroutineName, static function () use ($coroutineName, $config) { + return Kiri::getDi()->create(PDO::class, [$config]); + }, $minx); + + return Context::setContext($config['cds'], $pdo); }