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

qqq

Browse Source
This commit is contained in:
向林
2023-08-16 14:30:39 +08:00
parent 9f51ff4659
commit b3759bfa53
1 changed files with 48 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DatabasesProviders.php
+48 -48
View File
@@ -17,60 +17,60 @@ class DatabasesProviders extends Providers
{ {
/** /**
* @param LocalService $application * @param LocalService $application
* @return void * @return void
* @throws Exception * @throws Exception
*/ */
public function onImport(LocalService $application): void public function onImport(LocalService $application): void
{ {
$main = Kiri::getDi()->get(Kiri\Application::class); $main = Kiri::getDi()->get(Kiri\Application::class);
$main->command(BackupCommand::class); $main->command(BackupCommand::class);
$databases = \config('databases.connections', []); $databases = \config('databases.connections', []);
if (empty($databases)) { if (empty($databases)) {
return; return;
} }
foreach ($databases as $key => $database) { foreach ($databases as $key => $database) {
$application->set($key, Kiri::createObject($this->_settings($database))); $application->set($key, Kiri::createObject($this->_settings($database)));
} }
} }
/** /**
* @param $name * @param $name
* @return Connection * @return Connection
* @throws Exception * @throws Exception
*/ */
public function get($name): Connection public function get($name): Connection
{ {
return Kiri::service()->get($name); return Kiri::service()->get($name);
} }
/** /**
* @param $database * @param $database
* @return array * @return array
*/ */
private function _settings($database): array private function _settings($database): array
{ {
$clientPool = $database['pool'] ?? ['min' => 1, 'max' => 5, 'tick' => 60]; $clientPool = $database['pool'] ?? ['min' => 1, 'max' => 5, 'tick' => 60];
return [ return [
'id' => $database['id'], 'id' => $database['id'],
'cds' => $database['cds'], 'cds' => $database['cds'],
'class' => Connection::class, 'class' => Connection::class,
'username' => $database['username'], 'username' => $database['username'],
'password' => $database['password'], 'password' => $database['password'],
'tablePrefix' => $database['tablePrefix'], 'tablePrefix' => $database['tablePrefix'],
'database' => $database['database'], 'database' => $database['database'],
'connect_timeout' => $database['connect_timeout'] ?? 30, 'connect_timeout' => $database['connect_timeout'] ?? 10,
'read_timeout' => $database['read_timeout'] ?? 10, 'idle_time' => $database['idle_time'] ?? 300,
'pool' => $clientPool, 'pool' => $clientPool,
'attributes' => $database['attributes'] ?? [], 'attributes' => $database['attributes'] ?? [],
'charset' => $database['charset'] ?? 'utf8mb4', 'charset' => $database['charset'] ?? 'utf8mb4',
'slaveConfig' => $database['slaveConfig'] 'slaveConfig' => $database['slaveConfig']
]; ];
} }
} }