Coco\SourceWatcher\Core\Loaders\DatabaseLoader

Complexity

Total Complexity

5

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setConnector()	0	3	1
A	insert()	0	7	2
A	getConnector()	0	3	1
A	load()	0	3	1

<?php

namespace Coco\SourceWatcher\Core\Loaders;

use Coco\SourceWatcher\Core\Database\Connections\Connector;
use Coco\SourceWatcher\Core\Loader;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;

class DatabaseLoader extends Loader
{
    /**
     * @var Connector
     */
    private Connector $connector;

    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    public function load ( Row $row )
    {
        $this->insert( $row );
    }

    /**
     * @return Connector
     */
    public function getConnector () : Connector
    {
        return $this->connector;
    }

    /**
     * @param Connector $connector
     */
    public function setConnector ( Connector $connector ) : void
    {
        $this->connector = $connector;
    }

    /**
     * @param Row $row
     * @throws SourceWatcherException
     */
    protected function insert ( Row $row ) : void
    {
        if ( $this->connector == null ) {
            throw new SourceWatcherException( "No connector found. Set a connector before trying to insert a row." );
        }

        $this->connector->insert( $row );
    }
}