mirror of
https://github.com/appwrite/appwrite.git
synced 2026-05-26 13:51:13 +00:00
fogelito
117 lines
4.5 KiB
PHP
117 lines
4.5 KiB
PHP
<?php
|
|
|
|
global $cli, $register;
|
|
|
|
use Utopia\CLI\Console;
|
|
use Utopia\App;
|
|
use Utopia\Cache\Cache;
|
|
use Utopia\Cache\Adapter\None;
|
|
use Utopia\Config\Config;
|
|
use Utopia\Database\Adapter\MariaDB;
|
|
use Utopia\Database\Database;
|
|
use Utopia\Database\Validator\Authorization;
|
|
use Utopia\Database\Validator\UID;
|
|
|
|
# example:
|
|
# docker compose exec appwrite backup --projectId=648704ab178219be05c0
|
|
|
|
$cli
|
|
->task('backup')
|
|
->param('projectId', '', new UID(), 'Project id for backup', false)
|
|
->action(function ($projectId) use ($register) {
|
|
Authorization::disable();
|
|
$app = new App('UTC');
|
|
Console::success('Starting Data Backup for project ' . $projectId);
|
|
|
|
/**
|
|
* @var $db \PDO
|
|
*/
|
|
$db = $register->get('db', true);
|
|
|
|
$cache = new Cache(new None());
|
|
|
|
// todo: we want the adapter dynamic....
|
|
|
|
$consoleDB = new Database(new MariaDB($db), $cache);
|
|
$consoleDB->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
|
|
$consoleDB->setNamespace('_console');
|
|
|
|
// $console = $app->getResource('console');
|
|
//$project = $consoleDB->find('projects', [Query::equal('$uid', [$projectId])]);
|
|
$project = $consoleDB->getDocument('projects', $projectId);
|
|
if ($project->isEmpty()) {
|
|
throw new Exception('Project ' . $projectId . ' not found');
|
|
}
|
|
|
|
if ($project->getId() === 'console' && $project->getInternalId() !== 'console') {
|
|
// How to detect "console"
|
|
// todo: make sure not to backup console!!!!
|
|
}
|
|
|
|
$projectDB = new Database(new MariaDB($db), $cache);
|
|
$projectDB->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
|
|
$projectDB->setNamespace('_' . $project->getInternalId());
|
|
|
|
$collections = Config::getParam('collections', []);
|
|
$tables = [];
|
|
|
|
foreach ($collections as $collection) {
|
|
if (in_array($collection['$id'], ['files', 'collections'])) {
|
|
continue;
|
|
}
|
|
|
|
$tables[] = $projectDB->getNamespace() . "_" . $collection['$id'];
|
|
|
|
switch ($collection['$id']) {
|
|
case 'databases':
|
|
$databases = $projectDB->find('databases', []);
|
|
|
|
foreach ($databases as $database) {
|
|
$tables[] = $projectDB->getNamespace() . '_database_' . $database->getInternalId();
|
|
$databaseCollections = $projectDB->find('database_' . $database->getInternalId(), []);
|
|
foreach ($databaseCollections as $databaseCollection) {
|
|
$tables[] = $projectDB->getNamespace() . '_database_' . $database->getInternalId() . '_collection_' . $databaseCollection->getInternalId();
|
|
}
|
|
}
|
|
|
|
break;
|
|
case 'buckets':
|
|
$buckets = $projectDB->find('buckets', []);
|
|
foreach ($buckets as $bucket) {
|
|
$tables[] = $projectDB->getNamespace() . '_bucket_' . $bucket->getInternalId();
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
|
|
$schema = 'appwrite';
|
|
$destination = 'backup.sql.gz'; // todo: do we want to output as gz?
|
|
$return = null;
|
|
$output = null;
|
|
$singleTransaction = '--single-transaction --quick --skip-lock-tables'; //
|
|
//$singleTransaction = '';
|
|
|
|
$tables = implode(' ', $tables);
|
|
//$command = "mysqldump -u user -h bla " . $schema . " " . implode(' ', $tables) . "> " . $destination;
|
|
//https://phpsolved.com/backup-huge-mysql-database/
|
|
$command = "docker exec appwrite-mariadb /usr/bin/mysqldump -u root --password=rootsecretpassword " . $schema . " " . $tables . " " . $singleTransaction . " | gzip > " . $destination;
|
|
|
|
Console::error($command);
|
|
//exec($command, $output, $return);
|
|
|
|
var_dump($output);
|
|
var_dump($return);
|
|
|
|
$restore = "docker exec -i appwrite-mariadb mysql -u root --password=rootsecretpassword shmuel < " . $destination;
|
|
$restore = "gzip -dc " . $destination . " | docker exec -i appwrite-mariadb mysql -u root --password=rootsecretpassword shmuel";
|
|
Console::error($restore);
|
|
|
|
// $migration
|
|
// ->setProject($project, $projectDB, $consoleDB)
|
|
// ->setPDO($register->get('db'))
|
|
// ->execute();
|
|
|
|
Swoole\Event::wait(); // Wait for Coroutines to finish
|
|
Console::success('Complete');
|
|
});
|