From 2a52172af6957a95fdd0c6e8ddaa9d7b30ed8987 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Tue, 4 Jan 2022 16:04:22 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"=E6=94=B9=E5=90=8D"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit fdf58326 --- src/Connection.php | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/Connection.php b/src/Connection.php index d1bbd72..80e152e 100644 --- a/src/Connection.php +++ b/src/Connection.php @@ -81,12 +81,11 @@ class Connection extends Component */ public function init() { - $eventProvider = Kiri::getDi()->get(EventProvider::class); - $eventProvider->on(OnWorkerStop::class, [$this, 'clear_connection'], 0); - $eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0); - $eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0); - $eventProvider->on(Rollback::class, [$this, 'rollback'], 0); - $eventProvider->on(Commit::class, [$this, 'commit'], 0); + $this->eventProvider->on(OnWorkerStop::class, [$this, 'clear_connection'], 0); + $this->eventProvider->on(OnWorkerExit::class, [$this, 'clear_connection'], 0); + $this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0); + $this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0); + $this->eventProvider->on(Commit::class, [$this, 'commit'], 0); if (Db::transactionsActive()) { $this->beginTransaction();