Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dad6a63ee2 | |||
| 47ed967e46 | |||
| 227aad2910 |
+1
-1
@@ -27,7 +27,7 @@ use Database\Traits\HasBase;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Component;
|
||||
use Kiri\Exception\NotFindClassException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use Kiri\ToArray;
|
||||
use ReflectionException;
|
||||
use ReturnTypeWillChange;
|
||||
|
||||
+3
-3
@@ -21,11 +21,11 @@ use Kiri\Abstracts\Component;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Events\EventProvider;
|
||||
use Kiri\Exception\NotFindClassException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use Kiri\Annotation\Inject;
|
||||
use ReflectionException;
|
||||
use Server\Events\OnWorkerExit;
|
||||
use Server\Events\OnWorkerStop;
|
||||
use Kiri\Server\Events\OnWorkerExit;
|
||||
use Kiri\Server\Events\OnWorkerStop;
|
||||
|
||||
/**
|
||||
* Class Connection
|
||||
|
||||
@@ -9,8 +9,9 @@ use Kiri\Abstracts\Config;
|
||||
use Kiri\Abstracts\Providers;
|
||||
use Kiri\Application;
|
||||
use Kiri\Exception\ConfigException;
|
||||
use Kiri\Kiri;
|
||||
use Server\Events\OnWorkerStart;
|
||||
use Kiri;
|
||||
use Kiri\Server\Events\OnTaskerStart;
|
||||
use Kiri\Server\Events\OnWorkerStart;
|
||||
|
||||
/**
|
||||
* Class DatabasesProviders
|
||||
@@ -27,6 +28,7 @@ class DatabasesProviders extends Providers
|
||||
public function onImport(Application $application)
|
||||
{
|
||||
$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 Exception
|
||||
*/
|
||||
public function createPool(OnWorkerStart $onWorkerStart)
|
||||
public function createPool(OnWorkerStart|OnTaskerStart $onWorkerStart)
|
||||
{
|
||||
$databases = Config::get('databases.connections', []);
|
||||
if (empty($databases)) {
|
||||
|
||||
@@ -14,7 +14,7 @@ use Database\Base\Getter;
|
||||
use Database\Traits\HasBase;
|
||||
use Exception;
|
||||
use Kiri\Exception\NotFindClassException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use Kiri\ToArray;
|
||||
use ReflectionException;
|
||||
use Swoole\Coroutine;
|
||||
|
||||
+1
-1
@@ -5,7 +5,7 @@ namespace Database\Mysql;
|
||||
use Exception;
|
||||
use Kiri\Abstracts\Config;
|
||||
use Kiri\Abstracts\Logger;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use Kiri\Pool\StopHeartbeatCheck;
|
||||
use PDOStatement;
|
||||
use Swoole\Timer;
|
||||
|
||||
+1
-1
@@ -12,7 +12,7 @@ use Database\Query;
|
||||
use Exception;
|
||||
use JetBrains\PhpStorm\Pure;
|
||||
use Kiri\Exception\NotFindClassException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use ReflectionException;
|
||||
|
||||
|
||||
|
||||
@@ -18,7 +18,7 @@ use Database\Query;
|
||||
use Database\SqlBuilder;
|
||||
use Exception;
|
||||
use Kiri\Exception\NotFindClassException;
|
||||
use Kiri\Kiri;
|
||||
use Kiri;
|
||||
use ReflectionException;
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user