kalanis\kw_mapper\Storage\Database\PDO\MySQL

Complexity

Total Complexity

4

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Test Coverage

Coverage

9.52%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	languageDialect()	0	3	1
A	connectToServer()	0	28	3

<?php

namespace kalanis\kw_mapper\Storage\Database\PDO;


use kalanis\kw_mapper\Storage\Database\Dialects;
use PDO;


/**
 * Class MySQL
 * @package kalanis\kw_mapper\Storage\Database\PDO
 * Can be also used for Sphinx search engine
 */
class MySQL extends APDO
{
    protected $extension = 'pdo_mysql';

    public function languageDialect(): string
    {
        return Dialects\MySQL::class;
    }

    protected function connectToServer(): PDO
    {
        ini_set('mysql.connect_timeout', strval($this->config->getTimeout()));
        ini_set('default_socket_timeout', strval($this->config->getTimeout()));

        $connection = new PDO(
            sprintf('mysql:host=%s;port=%d;dbname=%s',
                $this->config->getLocation(),
                $this->config->getPort(),
                $this->config->getDatabase()
            ),
            $this->config->getUser(),
            $this->config->getPassword()
        );

        $connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

        if ($this->config->isPersistent()) {
            $connection->setAttribute(PDO::ATTR_PERSISTENT, true);
        }

        foreach ($this->attributes as $key => $value){
            $connection->setAttribute($key, $value);
        }

        $connection->query('SET NAMES utf8;');

        return $connection;
    }
}