Coco\SourceWatcher\Core\Loaders\DatabaseLoader

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	load()	0	3	1
A	insert()	0	15	4
A	getArrayRepresentation()	0	13	1

<?php

namespace Coco\SourceWatcher\Core\Loaders;

use Coco\SourceWatcher\Core\IO\Outputs\DatabaseOutput;
use Coco\SourceWatcher\Core\Loader;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;

/**
 * Class DatabaseLoader
 *
 * @package Coco\SourceWatcher\Core\Loaders
 */
class DatabaseLoader extends Loader
{
    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    public function load ( Row $row )
    {
        $this->insert( $row );
    }

    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    protected function insert ( Row $row ) : void
    {
        if ( $this->output == null ) {
            throw new SourceWatcherException( "An output must be provided" );
        }

        if ( !( $this->output instanceof DatabaseOutput ) ) {
            throw new SourceWatcherException( sprintf( "The output must be an instance of %s", DatabaseOutput::class ) );
        }

        if ( $this->output->getOutput() == null ) {
            throw new SourceWatcherException( "No database connector found. Set a connector before trying to insert a row" );
        }

        $this->output->getOutput()->insert( $row );
    }

    public function getArrayRepresentation () : array
    {
        $result = parent::getArrayRepresentation();

        $dbOutput = $this->getOutput();
        $dbConnector = $dbOutput->getOutput();

        $result["output"] = [
            "class" => get_class( $dbConnector ),
            "parameters" => $dbConnector->getConnectionParameters()
        ];

        return $result;
    }
}