mirror/Part-DB.Part-DB-server
1
0
Fork 1
mirror of https://github.com/Part-DB/Part-DB-server.git synced 2025-06-21 09:35:49 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Support postgres in the backup command

Browse source
This commit is contained in:
Jan Böhmer 2024-06-18 23:02:33 +02:00
parent 3f471d0c73
commit e3dfbf0e95
1 changed files with 25 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

36
src/Command/BackupCommand.php
View file

@ -4,6 +4,8 @@ declare(strict_types=1);
namespace App\Command; namespace App\Command;
use Doctrine\DBAL\Platforms\PostgreSQLPlatform;
use Spatie\DbDumper\Databases\PostgreSql;
use Symfony\Component\Console\Attribute\AsCommand; use Symfony\Component\Console\Attribute\AsCommand;
use Doctrine\DBAL\Platforms\SQLitePlatform; use Doctrine\DBAL\Platforms\SQLitePlatform;
use Doctrine\DBAL\Platforms\AbstractMySQLPlatform; use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
@ -136,30 +138,42 @@ class BackupCommand extends Command
} }
} }
private function runSQLDumper(DbDumper $dumper, ZipFile $zip, array $connectionParams): void
{
$this->configureDumper($connectionParams, $dumper);
$tmp_file = tempnam(sys_get_temp_dir(), 'partdb_sql_dump');
$dumper->dumpToFile($tmp_file);
$zip->addFile($tmp_file, 'database.sql');
}
protected function backupDatabase(ZipFile $zip, SymfonyStyle $io): void protected function backupDatabase(ZipFile $zip, SymfonyStyle $io): void
{ {
$io->note('Backup database...'); $io->note('Backup database...');
//Determine if we use MySQL or SQLite //Determine if we use MySQL or SQLite
$connection = $this->entityManager->getConnection(); $connection = $this->entityManager->getConnection();
if ($connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) { $params = $connection->getParams();
$platform = $connection->getDatabasePlatform();
if ($platform instanceof AbstractMySQLPlatform) {
try { try {
$io->note('MySQL database detected. Dump DB to SQL using mysqldump...'); $io->note('MySQL database detected. Dump DB to SQL using mysqldump...');
$params = $connection->getParams(); $this->runSQLDumper(MySql::create(), $zip, $params);
$dumper = MySql::create();
$this->configureDumper($params, $dumper);
$tmp_file = tempnam(sys_get_temp_dir(), 'partdb_sql_dump');
$dumper->dumpToFile($tmp_file);
$zip->addFile($tmp_file, 'mysql_dump.sql');
} catch (\Exception $e) { } catch (\Exception $e) {
$io->error('Could not dump database: '.$e->getMessage()); $io->error('Could not dump database: '.$e->getMessage());
$io->error('This can maybe be fixed by installing the mysqldump binary and adding it to the PATH variable!'); $io->error('This can maybe be fixed by installing the mysqldump binary and adding it to the PATH variable!');
} }
} elseif ($connection->getDatabasePlatform() instanceof SQLitePlatform) { } elseif ($platform instanceof PostgreSQLPlatform) {
try {
$io->note('PostgreSQL database detected. Dump DB to SQL using pg_dump...');
$this->runSQLDumper(PostgreSql::create(), $zip, $params);
} catch (\Exception $e) {
$io->error('Could not dump database: '.$e->getMessage());
$io->error('This can maybe be fixed by installing the pg_dump binary and adding it to the PATH variable!');
}
} elseif ($platform instanceof SQLitePlatform) {
$io->note('SQLite database detected. Copy DB file to ZIP...'); $io->note('SQLite database detected. Copy DB file to ZIP...');
$params = $connection->getParams();
$zip->addFile($params['path'], 'var/app.db'); $zip->addFile($params['path'], 'var/app.db');
} else { } else {
$io->error('Unknown database platform. Could not backup database!'); $io->error('Unknown database platform. Could not backup database!');