Coco\SourceWatcher\Core\Loaders\DatabaseLoader::insert()

Complexity

Conditions	4
Paths	4

Size

Total Lines	17
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function insert ( Row $row ) : void
    {
        if ( $this->output == null ) {
            throw new SourceWatcherException( "An output must be provided." );
        }

        $outputIsDatabaseOutput = $this->output instanceof DatabaseOutput;

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

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

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