Coco\SourceWatcher\Core\Extractors\DatabaseExtractor

Complexity

Total Complexity

10

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setQuery()	0	3	1
A	extract()	0	27	6
A	getQuery()	0	3	1
A	getArrayRepresentation()	0	13	1
A	__construct()	0	3	1

<?php

namespace Coco\SourceWatcher\Core\Extractors;

use Coco\SourceWatcher\Core\Extractor;
use Coco\SourceWatcher\Core\IO\Inputs\DatabaseInput;
use Coco\SourceWatcher\Core\Row;
use Coco\SourceWatcher\Core\SourceWatcherException;

/**
 * Class DatabaseExtractor
 *
 * @package Coco\SourceWatcher\Core\Extractors
 */
class DatabaseExtractor extends Extractor
{
    protected string $query;

    protected array $availableOptions = [ "query" ];

    public function __construct ()
    {
        $this->query = "";
    }

    public function getQuery () : string
    {
        return $this->query;
    }

    public function setQuery ( string $query ) : void
    {
        $this->query = $query;
    }

    /**
     * @return array
     * @throws SourceWatcherException
     */
    public function extract () : array
    {
        if ( $this->input == null ) {
            throw new SourceWatcherException( "An input must be provided" );
        }

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

        if ( $this->input->getInput() == null ) {
            throw new SourceWatcherException( "No database connector found. Set a connector before trying to extract from the database" );
        }

        if ( $this->query == null ) {
            throw new SourceWatcherException( "Query missing" );
        }

        $result = [];

        $arrayResults = $this->input->getInput()->executePlainQuery( $this->query );

        foreach ( $arrayResults as $currentRecord ) {
            array_push( $result, new Row( $currentRecord ) );
        }

        return $result;
    }

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

        $dbInput = $this->getInput();
        $dbConnector = $dbInput->getInput();

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

        return $result;
    }
}