Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Attempt to reuse db connections

Browse Source
This commit is contained in:
Matej Baco
2022-11-15 14:30:19 +01:00
parent 451c6334bb
commit bfe8b98008
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/cli.php
+12 -2
View File
@@ -56,19 +56,29 @@ CLI::setResource('dbForConsole', function ($pools, $cache) {
}, ['pools', 'cache']);
CLI::setResource('getProjectDB', function (Group $pools, Database $dbForConsole, $cache) {
$getProjectDB = function (Document $project) use ($pools, $dbForConsole, $cache) {
$databases = [];
$getProjectDB = function (Document $project) use ($pools, $dbForConsole, $cache, &$databases) {
if ($project->isEmpty() || $project->getId() === 'console') {
return $dbForConsole;
}
$databaseName = $project->getAttribute('database');
if(isset($databases[$databaseName])) {
return $databases[$databaseName];
}
$dbAdapter = $pools
->get($project->getAttribute('database'))
->get($databaseName)
->pop()
->getResource();
$database = new Database($dbAdapter, $cache);
$database->setNamespace('_' . $project->getInternalId());
$databases[$databaseName] = $database;
return $database;
};