55 lines
1.6 KiB
PHP
55 lines
1.6 KiB
PHP
<?php
|
|
|
|
namespace S3DB\Sync;
|
|
|
|
use Spatie\Emoji\Emoji;
|
|
|
|
class PostgresSyncer extends AbstractSyncer
|
|
{
|
|
public function push(): void
|
|
{
|
|
// Dump file from Postgres
|
|
$dumpFile = 'dump.sql';
|
|
$command = sprintf('PG_PASSWORD=$POSTGRESS_PASSWORD pg_dump -U $POSTGRES_USER --clean --inserts > /dumps/%s', $dumpFile);
|
|
passthru($command);
|
|
|
|
// Verify the dump worked
|
|
$this->verifyDumpSucceeded($dumpFile);
|
|
|
|
// Checksum dump and don't upload if the checksum is the same as last time.
|
|
$this->checksumCheck($dumpFile);
|
|
|
|
// XZ compress dump
|
|
$compressedDumpFile = $this->compress($dumpFile);
|
|
|
|
// Upload
|
|
$storageFile = sprintf('s3db-%s.sql.xz', date('Ymd-His'));
|
|
$this->upload($storageFile, $compressedDumpFile);
|
|
|
|
// Cleanup
|
|
$this->cleanup([$compressedDumpFile]);
|
|
}
|
|
|
|
public function pull(): void
|
|
{
|
|
// Download latest dumpfile
|
|
$localDownloadedFile = $this->download();
|
|
|
|
// Decompress
|
|
$localDecompressedFile = $this->decompress($localDownloadedFile);
|
|
|
|
// Push into postgres
|
|
$startImport = microtime(true);
|
|
$command = sprintf('PG_PASSWORD=$POSTGRESS_PASSWORD psql -U $POSTGRES_USER --quiet < /dumps/%s', $localDecompressedFile);
|
|
exec($command);
|
|
$this->logger->info(sprintf(
|
|
'%s Imported %s to postgres in %s seconds',
|
|
Emoji::accordion(),
|
|
$localDecompressedFile,
|
|
number_format(microtime(true) - $startImport, 3)
|
|
));
|
|
|
|
// Cleanup
|
|
$this->cleanup([$localDecompressedFile]);
|
|
}
|
|
}
|