MysqlDumper::prepareDumpCommand() - Code Metrics - Inspection of "Update tests" - Codexshaper/database-backup-restore - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 536d38...8f4370 )

by CodexShaper

created 2019-12-29 11:14 UTC

MysqlDumper::prepareDumpCommand() F

↳ Parent: MysqlDumper

Complexity

Conditions	13
Paths	4096

Size

Total Lines	51
Code Lines	32

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
cc	13
eloc	32
c	2
b	0
f	0
nc	4096
nop	2
dl	0
loc	51
rs	2.45

How to fix Long Method Complexity

<?php

namespace CodexShaper\Dumper\Drivers;

use CodexShaper\Dumper\Dumper;
use Symfony\Component\Process\Exception\ProcessFailedException;

class MysqlDumper extends Dumper
{
    /*@var bool*/
    protected $singleTransaction = false;
    /*@var bool*/
    protected $skipLockTables = false;
    /*@var bool*/
    protected $quick = false;
    /*@var bool*/
    protected $skipComments = true;
    /*@var string*/
    protected $defaultCharacterSet = '';
    /*@var bool*/
    protected $createTables = true;

    public function useSingleTransaction()
    {
        $this->singleTransaction = true;
        return $this;
    }
    public function useSkipLockTables()
    {
        $this->skipLockTables = true;
        return $this;
    }
    public function useQuick()
    {
        $this->quick = true;
        return $this;
    }
    public function doNotUseSkipComments()
    {
        $this->skipComments = false;
        return $this;
    }
    public function doNotUseCreateTables()
    {
        $this->createTables = false;
        return $this;
    }
    public function setDefaultCharacterSet(string $charecterSet)
    {
        $this->defaultCharacterSet = $charecterSet;
        return $this;
    }

    public function dump(string $destinationPath = "")
    {
        $destinationPath = !empty($destinationPath) ? $destinationPath : $this->destinationPath;
        $this->runCommand($destinationPath, "dump");
        return $this;
    }

    public function restore(string $restorePath = "")
    {
        $restorePath = !empty($restorePath) ? $restorePath : $this->restorePath;
        $this->runCommand($restorePath, 'restore');
        return $this;
    }

    protected function prepareDumpCommand(string $credentialFile, string $destinationPath): string
    {
        // Database
        $databaseArg = $this->dbName;
        // Include tables
        $includeTables    = (count($this->tables) > 0) ? implode(' ', $this->tables) : "";
        $includeTablesArg = !empty($includeTables) ? '--tables ' . $includeTables : '';
        // Ignore Tables
        $ignoreTablesArgs = [];
        foreach ($this->ignoreTables as $tableName) {
            $ignoreTablesArgs[] = "--ignore-table=" . $databaseArg . "." . $tableName;
        }
        $ignoreTablesArg = (count($ignoreTablesArgs) > 0) ? implode(' ', $ignoreTablesArgs) : '';
        // Single Transaction
        $singleTransaction = ($this->singleTransaction) ? "--single-transaction" : "";
        // Skip Lock Table
        $skipLockTable = ($this->skipLockTables) ? "--skip-lock-tables" : "";
        // Quick
        $quick = ($this->quick) ? "--quick" : "";
        // Create Tables
        $createTables = (!$this->createTables) ? '--no-create-info' : '';
        // Skip Comments
        $skipComments = ($this->skipComments) ? '--skip-comments' : '';
        // Socket
        $socket = ($this->socket !== '') ? "--socket={$this->socket}" : '';
        // Default charecter set
        $defaultCharacterSet = ($this->defaultCharacterSet !== '') ? '--default-character-set=' . $this->defaultCharacterSet : '';
        // Authentication File
        $authenticate = "--defaults-extra-file=" . $credentialFile;
        // Dump command
        $dumpCommand = sprintf(
            '%smysqldump %s %s %s %s %s %s %s %s %s %s %s',
            $this->dumpCommandPath,
            $authenticate,
            $databaseArg,
            $socket,
            $skipComments,
            $createTables,
            $singleTransaction,
            $skipLockTable,
            $quick,
            $defaultCharacterSet,
            $includeTablesArg,
            $ignoreTablesArg
        );
        // Add compressor if compress is enable
        if ($this->isCompress) {
            return "{$dumpCommand} | {$this->compressBinaryPath}{$this->compressCommand} > {$destinationPath}{$this->compressExtension}";
        }

        return "{$dumpCommand} > {$destinationPath}";
    }

    protected function prepareRestoreCommand(string $credentialFile, string $filePath): string
    {
        // Database
        $database = $this->dbName;
        // Authentication File
        $authenticate = "--defaults-extra-file=" . $credentialFile;
        // Restore command
        $restoreCommand = sprintf("%smysql %s %s",
            $this->dumpCommandPath,
            $authenticate,
            $database
        );
        // Add compressor if compress is enable
        if ($this->isCompress) {
            return "{$this->compressBinaryPath}{$this->compressCommand} < {$filePath} | {$restoreCommand}";
        }

        return "{$restoreCommand} < {$filePath}";
    }

    protected function runCommand($filePath, $action)
    {
        try {
            // Get Credentials
            $credentials = $this->getCredentials();
            // Create a temporary file
            $this->tempFile = tempnam(sys_get_temp_dir(), 'mysqlpass');
            // Create file handler
            $handler = fopen($this->tempFile, 'r+');
            // Write credentials into temporary file
            fwrite($handler, $credentials);
            fwrite(/** @scrutinizer ignore-type */ $handler, $credentials);

            if ($action == 'dump') {
                $this->command = preg_replace('/\s+/', ' ', $this->prepareDumpCommand($this->tempFile, $filePath));
            } else if ($action == 'restore') {
                $this->command = preg_replace('/\s+/', ' ', $this->prepareRestoreCommand($this->tempFile, $filePath));
            }
            // Get Symfony process with prepared command
            $process = $this->prepareProcessCommand();

            if ($this->debug) {
                $process->mustRun();
            } else {
                $process->run();
            }
            // close handler
            fclose($handler);
            fclose(/** @scrutinizer ignore-type */ $handler);
            // Remove temporary file
            unlink($this->tempFile);

        } catch (ProcessFailedException $e) {
            throw new \Exception($e->getMessage());

        }
    }

    protected function getCredentials()
    {
        $contents = [
            '[client]',
            "user = '{$this->username}'",
            "password = '{$this->password}'",
            "host = '{$this->host}'",
            "port = '{$this->port}'",
        ];
        return implode(PHP_EOL, $contents);
    }
}


Codexshaper / database-backup-restore

Push — master ( 536d38...8f4370 )

MysqlDumper::prepareDumpCommand() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like