as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

eee

Browse Source
This commit is contained in:
xl
2024-11-18 16:35:37 +08:00
parent 6304684683
commit 8d006568ef
1 changed files with 15 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+15 -8
View File
@@ -67,6 +67,14 @@ class Connection extends Component
#[Container(LoggerInterface::class)]
public StdoutLogger $logger;
/**
* @var EventProvider
*/
#[Container(EventProvider::class)]
public EventProvider $eventProvider;
/**
* @param Pool $connections
*/
@@ -99,14 +107,13 @@ class Connection extends Component
*/
public function init(): void
{
$eventProvider = Kiri::getDi()->get(EventProvider::class);
$eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
$eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
$eventProvider->on(Commit::class, [$this, 'commit'], 0);
$eventProvider->on(OnAfterRequest::class, [$this, 'clear']);
$eventProvider->on(OnWorkerExit::class, [$this, 'disconnect']);
$eventProvider->on(OnWorkerStart::class, [$this, 'tick']);
$eventProvider->on(OnTaskerStart::class, [$this, 'tick']);
$this->eventProvider->on(BeginTransaction::class, [$this, 'beginTransaction'], 0);
$this->eventProvider->on(Rollback::class, [$this, 'rollback'], 0);
$this->eventProvider->on(Commit::class, [$this, 'commit'], 0);
$this->eventProvider->on(OnAfterRequest::class, [$this, 'clear']);
$this->eventProvider->on(OnWorkerExit::class, [$this, 'disconnect']);
$this->eventProvider->on(OnWorkerStart::class, [$this, 'tick']);
$this->eventProvider->on(OnTaskerStart::class, [$this, 'tick']);
}