Coco\SourceWatcher\Core\Database\Connections\MySqlConnector

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getUnixSocket()	0	3	1
A	__construct()	0	7	1
A	getConnectionParameters()	0	5	1
A	setCharset()	0	3	1
A	setUnixSocket()	0	3	1
A	getCharset()	0	3	1
A	executeExtraStatements()	0	2	1

<?php

namespace Coco\SourceWatcher\Core\Database\Connections;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Exception;

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

    protected string $charset = "";

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

        $this->driver = "pdo_mysql";

        $this->port = 3306;
    }

    public function getUnixSocket () : string
    {
        return $this->unixSocket;
    }

    public function setUnixSocket ( string $unixSocket ) : void
    {
        $this->unixSocket = $unixSocket;
    }

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

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

    public function getConnectionParameters () : array
    {
        $this->extraParameters = [ "unix_socket" => $this->unixSocket, "charset" => $this->charset ];

        return parent::getConnectionParameters();
    }

    /**
     * @throws Exception
     */
    public function executeExtraStatements (Connection $connection) : void {
        $connection->executeStatement( "SET SESSION wait_timeout = 3600;" );
    }
}