Velikonja\LabbyBundle\Database\Mysql\MySqlDumper

Complexity

Total Complexity

5

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

95.24%

Importance

Changes	4
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	29	3
A	dump()	0	12	2

<?php

namespace Velikonja\LabbyBundle\Database\Mysql;

use Symfony\Component\Process\ProcessBuilder;
use Velikonja\LabbyBundle\Database\DatabaseException;
use Velikonja\LabbyBundle\Database\DumperInterface;

class MySqlDumper implements DumperInterface
{
    /**
     * @var \Symfony\Component\Process\ProcessBuilder
     */
    private $processBuilder;

    /**
     * @var string
     */
    private $executable;

    /**
     * @param array               $options
     * @param int                 $timeout
     * @param null|string         $executable
     * @param null|ProcessBuilder $processBuilder
     */
    public function __construct(
        array $options,
        $timeout = 60,
        $executable = null,
        ProcessBuilder $processBuilder = null
    ) {
        if (! $executable) {
            $executable = '/usr/bin/mysqldump';
        }

        $this->executable = $executable;

        if (! $processBuilder) {
            $processBuilder = new ProcessBuilder();
        }

        $processBuilder
            ->setTimeout($timeout)
            ->setPrefix($this->executable)
            ->setArguments(array(
                '--user=' . $options['user'],
                '--password=' . $options['password'],
                '--host=' . $options['host'],
                $options['dbname'],
            ));

        $this->processBuilder = $processBuilder;

    }

    /**
     * @throws DatabaseException
     *
     * @return string
     */
    public function dump()
    {
        $process = $this->processBuilder->getProcess();

        $process->run();

        if (! $process->isSuccessful()) {
            throw new DatabaseException($process->getErrorOutput());
        }

        return $process->getOutput();
    }
}