Fix console db namespace
This commit is contained in:
parent
5d6029fe7d
commit
a13b7606a2
5 changed files with 6 additions and 6 deletions
|
@ -58,7 +58,7 @@ CLI::setResource('dbForConsole', function ($pools, $cache) {
|
||||||
->getResource();
|
->getResource();
|
||||||
|
|
||||||
$dbForConsole = new Database($dbAdapter, $cache);
|
$dbForConsole = new Database($dbAdapter, $cache);
|
||||||
$dbForConsole->setNamespace('console');
|
$dbForConsole->setNamespace('_console');
|
||||||
|
|
||||||
// Ensure tables exist
|
// Ensure tables exist
|
||||||
$collections = Config::getParam('collections', [])['console'];
|
$collections = Config::getParam('collections', [])['console'];
|
||||||
|
|
|
@ -1116,7 +1116,7 @@ App::setResource('dbForConsole', function (Group $pools, Cache $cache) {
|
||||||
|
|
||||||
$database = new Database($dbAdapter, $cache);
|
$database = new Database($dbAdapter, $cache);
|
||||||
|
|
||||||
$database->setNamespace('console');
|
$database->setNamespace('_console');
|
||||||
|
|
||||||
return $database;
|
return $database;
|
||||||
}, ['pools', 'cache']);
|
}, ['pools', 'cache']);
|
||||||
|
|
|
@ -47,7 +47,7 @@ function getConsoleDB(): Database
|
||||||
|
|
||||||
$database = new Database($dbAdapter, getCache());
|
$database = new Database($dbAdapter, getCache());
|
||||||
|
|
||||||
$database->setNamespace('console');
|
$database->setNamespace('_console');
|
||||||
|
|
||||||
return $database;
|
return $database;
|
||||||
}
|
}
|
||||||
|
|
|
@ -37,7 +37,7 @@ Server::setResource('dbForConsole', function (Cache $cache, Registry $register)
|
||||||
;
|
;
|
||||||
|
|
||||||
$adapter = new Database($database, $cache);
|
$adapter = new Database($database, $cache);
|
||||||
$adapter->setNamespace('console');
|
$adapter->setNamespace('_console');
|
||||||
|
|
||||||
return $adapter;
|
return $adapter;
|
||||||
}, ['cache', 'register']);
|
}, ['cache', 'register']);
|
||||||
|
|
|
@ -223,7 +223,7 @@ abstract class Worker
|
||||||
|
|
||||||
if (isset(self::$databases[$databaseName])) {
|
if (isset(self::$databases[$databaseName])) {
|
||||||
$database = self::$databases[$databaseName];
|
$database = self::$databases[$databaseName];
|
||||||
$database->setNamespace('console');
|
$database->setNamespace('_console');
|
||||||
return $database;
|
return $database;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -237,7 +237,7 @@ abstract class Worker
|
||||||
|
|
||||||
self::$databases[$databaseName] = $database;
|
self::$databases[$databaseName] = $database;
|
||||||
|
|
||||||
$database->setNamespace('console');
|
$database->setNamespace('_console');
|
||||||
|
|
||||||
return $database;
|
return $database;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue