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

Revert "改名"

Browse Source 
This reverts commit fdf58326
This commit is contained in:
向林
2022-01-14 16:07:57 +08:00
parent 4ca0a61344
commit f3d878e21c
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DatabasesProviders.php
+6 -4
View File
@@ -5,12 +5,13 @@ namespace Database;
use Exception; use Exception;
use Kiri;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
use Kiri\Abstracts\Providers; use Kiri\Abstracts\Providers;
use Kiri\Application; use Kiri\Application;
use Kiri\Exception\ConfigException; use Kiri\Exception\ConfigException;
use Kiri; use Kiri\Server\Events\OnTaskerStart;
use Kiri\Events\OnBeforeCommandExecute; use Kiri\Server\Events\OnWorkerStart;
/** /**
* Class DatabasesProviders * Class DatabasesProviders
@@ -26,7 +27,8 @@ class DatabasesProviders extends Providers
*/ */
public function onImport(Application $application) public function onImport(Application $application)
{ {
$this->eventProvider->on(OnBeforeCommandExecute::class, [$this, 'createPool']); $this->eventProvider->on(OnWorkerStart::class, [$this, 'createPool']);
$this->eventProvider->on(OnTaskerStart::class, [$this, 'createPool']);
} }
@@ -45,7 +47,7 @@ class DatabasesProviders extends Providers
* @throws ConfigException * @throws ConfigException
* @throws Exception * @throws Exception
*/ */
public function createPool(OnBeforeCommandExecute $onWorkerStart) public function createPool(OnTaskerStart|OnWorkerStart $onWorkerStart)
{ {
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);
if (empty($databases)) { if (empty($databases)) {