Compare commits

..

4 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
as2252258 5d77face53 1 2022-01-09 14:46:34 +08:00
7 changed files with 14 additions and 12 deletions
+1 -1
View File
@@ -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
View File
@@ -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
+6 -4
View File
@@ -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)) {
@@ -56,7 +58,7 @@ class DatabasesProviders extends Providers
foreach ($databases as $key => $database) {
$database = $this->_settings($database);
$connection = Kiri::getDi()->create(Connection::class, $database);
$connection = Kiri::getDi()->create(Connection::class, [$database]);
$connection->fill();
$app->set($key, $connection);
+1 -1
View File
@@ -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
View File
@@ -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
View File
@@ -12,7 +12,7 @@ use Database\Query;
use Exception;
use JetBrains\PhpStorm\Pure;
use Kiri\Exception\NotFindClassException;
use Kiri\Kiri;
use Kiri;
use ReflectionException;
+1 -1
View File
@@ -18,7 +18,7 @@ use Database\Query;
use Database\SqlBuilder;
use Exception;
use Kiri\Exception\NotFindClassException;
use Kiri\Kiri;
use Kiri;
use ReflectionException;
/**