Coco\SourceWatcher\Core\Database\Connections\PostgreSqlConnector

Complexity

Total Complexity

19

Size/Duplication

Total Lines	125
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

19 Methods

Rating	Name	Duplication	Size	Complexity
A	executeExtraStatements()	0	2	1
A	getSslMode()	0	3	1
A	setSslCrl()	0	3	1
A	setSslCert()	0	3	1
A	setApplicationName()	0	3	1
A	setSslRootCert()	0	3	1
A	getSslRootCert()	0	3	1
A	getConnectionParameters()	0	14	1
A	setDefaultDatabaseName()	0	3	1
A	getSslCert()	0	3	1
A	setCharset()	0	3	1
A	__construct()	0	7	1
A	getApplicationName()	0	3	1
A	getSslCrl()	0	3	1
A	setSslMode()	0	3	1
A	getCharset()	0	3	1
A	getDefaultDatabaseName()	0	3	1
A	getSslKey()	0	3	1
A	setSslKey()	0	3	1

<?php

namespace Coco\SourceWatcher\Core\Database\Connections;

use Doctrine\DBAL\Connection;

/**
 * Class PostgreSqlConnector
 *
 * @package Coco\SourceWatcher\Core\Database\Connections
 *
 * Following the definition from:
 *     https://www.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#pdo-pgsql
 */
class PostgreSqlConnector extends ClientServerDatabaseConnector
{
    protected string $charset = "";

    protected string $defaultDatabaseName = "";

    protected string $sslMode = "";

    protected string $sslRootCert = "";

    protected string $sslCert = "";

    protected string $sslKey = "";

    protected string $sslCrl = "";

    protected string $applicationName = "";

    public function __construct ()
    {
        parent::__construct();

        $this->driver = "pdo_pgsql";

        $this->port = 5432;
    }

    public function getCharset () : string
    {
        return $this->charset;
    }

    public function setCharset ( string $charset ) : void
    {
        $this->charset = $charset;
    }

    public function getDefaultDatabaseName () : string
    {
        return $this->defaultDatabaseName;
    }

    public function setDefaultDatabaseName ( string $defaultDatabaseName ) : void
    {
        $this->defaultDatabaseName = $defaultDatabaseName;
    }

    public function getSslMode () : string
    {
        return $this->sslMode;
    }

    public function setSslMode ( string $sslMode ) : void
    {
        $this->sslMode = $sslMode;
    }

    public function getSslRootCert () : string
    {
        return $this->sslRootCert;
    }

    public function setSslRootCert ( string $sslRootCert ) : void
    {
        $this->sslRootCert = $sslRootCert;
    }

    public function getSslCert () : string
    {
        return $this->sslCert;
    }

    public function setSslCert ( string $sslCert ) : void
    {
        $this->sslCert = $sslCert;
    }

    public function getSslKey () : string
    {
        return $this->sslKey;
    }

    public function setSslKey ( string $sslKey ) : void
    {
        $this->sslKey = $sslKey;
    }

    public function getSslCrl () : string
    {
        return $this->sslCrl;
    }

    public function setSslCrl ( string $sslCrl ) : void
    {
        $this->sslCrl = $sslCrl;
    }

    public function getApplicationName () : string
    {
        return $this->applicationName;
    }

    public function setApplicationName ( string $applicationName ) : void
    {
        $this->applicationName = $applicationName;
    }

    public function getConnectionParameters () : array
    {
        $this->extraParameters = [
            "charset" => $this->charset,
            "default_dbname" => $this->defaultDatabaseName,
            "sslmode" => $this->sslMode,
            "sslrootcert" => $this->sslRootCert,
            "sslcert" => $this->sslCert,
            "sslkey" => $this->sslKey,
            "sslcrl" => $this->sslCrl,
            "application_name" => $this->applicationName
        ];

        return parent::getConnectionParameters();
    }

    protected function executeExtraStatements ( Connection $connection ) : void
    {
        // TODO: Implement executeExtraStatements() method.
    }
}