Compare commits

...

3 Commits

Author SHA1 Message Date
as2252258 dad6a63ee2 Revert "改名"
This reverts commit fdf58326
2022-01-12 14:10:32 +08:00
as2252258 47ed967e46 Revert "改名"
This reverts commit fdf58326
2022-01-11 10:51:50 +08:00
as2252258 227aad2910 Revert "改名"
This reverts commit fdf58326
2022-01-10 11:39:56 +08:00
7 changed files with 13 additions and 11 deletions
+1 -1
View File
@@ -27,7 +27,7 @@ use Database\Traits\HasBase;
use Exception; use Exception;
use Kiri\Abstracts\Component; use Kiri\Abstracts\Component;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Kiri\Kiri; use Kiri;
use Kiri\ToArray; use Kiri\ToArray;
use ReflectionException; use ReflectionException;
use ReturnTypeWillChange; use ReturnTypeWillChange;
+3 -3
View File
@@ -21,11 +21,11 @@ use Kiri\Abstracts\Component;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
use Kiri\Events\EventProvider; use Kiri\Events\EventProvider;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Kiri\Kiri; use Kiri;
use Kiri\Annotation\Inject; use Kiri\Annotation\Inject;
use ReflectionException; use ReflectionException;
use Server\Events\OnWorkerExit; use Kiri\Server\Events\OnWorkerExit;
use Server\Events\OnWorkerStop; use Kiri\Server\Events\OnWorkerStop;
/** /**
* Class Connection * Class Connection
+5 -3
View File
@@ -9,8 +9,9 @@ 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\Kiri; use Kiri;
use Server\Events\OnWorkerStart; use Kiri\Server\Events\OnTaskerStart;
use Kiri\Server\Events\OnWorkerStart;
/** /**
* Class DatabasesProviders * Class DatabasesProviders
@@ -27,6 +28,7 @@ class DatabasesProviders extends Providers
public function onImport(Application $application) public function onImport(Application $application)
{ {
$this->eventProvider->on(OnWorkerStart::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(OnWorkerStart $onWorkerStart) public function createPool(OnWorkerStart|OnTaskerStart $onWorkerStart)
{ {
$databases = Config::get('databases.connections', []); $databases = Config::get('databases.connections', []);
if (empty($databases)) { if (empty($databases)) {
+1 -1
View File
@@ -14,7 +14,7 @@ use Database\Base\Getter;
use Database\Traits\HasBase; use Database\Traits\HasBase;
use Exception; use Exception;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Kiri\Kiri; use Kiri;
use Kiri\ToArray; use Kiri\ToArray;
use ReflectionException; use ReflectionException;
use Swoole\Coroutine; use Swoole\Coroutine;
+1 -1
View File
@@ -5,7 +5,7 @@ namespace Database\Mysql;
use Exception; use Exception;
use Kiri\Abstracts\Config; use Kiri\Abstracts\Config;
use Kiri\Abstracts\Logger; use Kiri\Abstracts\Logger;
use Kiri\Kiri; use Kiri;
use Kiri\Pool\StopHeartbeatCheck; use Kiri\Pool\StopHeartbeatCheck;
use PDOStatement; use PDOStatement;
use Swoole\Timer; use Swoole\Timer;
+1 -1
View File
@@ -12,7 +12,7 @@ use Database\Query;
use Exception; use Exception;
use JetBrains\PhpStorm\Pure; use JetBrains\PhpStorm\Pure;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Kiri\Kiri; use Kiri;
use ReflectionException; use ReflectionException;
+1 -1
View File
@@ -18,7 +18,7 @@ use Database\Query;
use Database\SqlBuilder; use Database\SqlBuilder;
use Exception; use Exception;
use Kiri\Exception\NotFindClassException; use Kiri\Exception\NotFindClassException;
use Kiri\Kiri; use Kiri;
use ReflectionException; use ReflectionException;
/** /**