TheCodingMachine\TDBM\ConnectionFactory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	resetDatabase()	0	57	3
A	createConnection()	0	51	3

<?php


namespace TheCodingMachine\TDBM;

use Doctrine\Common\EventManager;
use Doctrine\DBAL\Connection;
use Doctrine\DBAL\DriverManager;
use Doctrine\DBAL\Event\Listeners\OracleSessionInit;
use function strtoupper;

class ConnectionFactory
{
    /**
     * Resets the database and returns a (root) connection
     */
    public static function resetDatabase(
        string $dbDriver,
        ?string $dbHost = null,
        ?string $dbPort = null,
        ?string $dbUserName = null,
        ?string $dbAdminUserName = null,
        ?string $dbPassword = null,
        ?string $dbName = null
    ): Connection {
        $config = new \Doctrine\DBAL\Configuration();

        $dbDriver = $dbDriver;

        if ($dbDriver === 'pdo_sqlite') {
            $dbConnection = self::getConnection();

The method getConnection() does not exist on TheCodingMachine\TDBM\ConnectionFactory.

            $dbConnection->exec('PRAGMA foreign_keys = ON;');
        } elseif ($dbDriver === 'oci8') {
            $connectionParams = array(
                'servicename' => 'XE',
                'user' => $dbAdminUserName,
                // Because of issues in DBAL, admin and normal user password have to be the same.
                'password' => $dbPassword,
                'host' => $dbHost,
                'port' => $dbPort,
                'driver' => $dbDriver,
                'dbname' => $dbAdminUserName,
                'charset' => 'AL32UTF8',
            );

            $adminConn = DriverManager::getConnection($connectionParams, $config);

            // When dropAndCreateDatabase is run several times, Oracle can have some issues releasing the TDBM user.
            // Let's forcefully delete the connection!
            $adminConn->exec("select 'alter system kill session ''' || sid || ',' || serial# || ''';' from v\$session where username = '".strtoupper($dbName)."'");

            $adminConn->getSchemaManager()->dropAndCreateDatabase($dbName);

            $dbConnection = self::getConnection();
        } else {
            $connectionParams = array(
                'user' => $dbUserName,
                'password' => $dbPassword,
                'host' => $dbHost,
                'port' => $dbPort,
                'driver' => $dbDriver,
            );

            $adminConn = DriverManager::getConnection($connectionParams, $config);

            $adminConn->getSchemaManager()->dropAndCreateDatabase($dbName);

            $connectionParams['dbname'] = $dbName;

            $dbConnection = DriverManager::getConnection($connectionParams, $config);
        }

        return $dbConnection;
    }

    public static function createConnection(
        string $dbDriver,
        ?string $dbHost = null,
        ?string $dbPort = null,
        ?string $dbUserName = null,
        ?string $dbPassword = null,
        ?string $dbName = null
    ): Connection {
        $config = new \Doctrine\DBAL\Configuration();

        $dbDriver = $dbDriver;

        if ($dbDriver === 'pdo_sqlite') {
            $connectionParams = array(
                'memory' => true,
                'driver' => 'pdo_sqlite',
            );
            $dbConnection = DriverManager::getConnection($connectionParams, $config);
        } elseif ($dbDriver === 'oci8') {
            $evm = new EventManager();
            $evm->addEventSubscriber(new OracleSessionInit(array(
                'NLS_TIME_FORMAT' => 'HH24:MI:SS',
                'NLS_DATE_FORMAT' => 'YYYY-MM-DD HH24:MI:SS',
                'NLS_TIMESTAMP_FORMAT' => 'YYYY-MM-DD HH24:MI:SS',
            )));

            $connectionParams = array(
                'servicename' => 'XE',
                'user' => $dbUserName,
                'password' => $dbPassword,
                'host' => $dbHost,
                'port' => $dbPort,
                'driver' => $dbDriver,
                'dbname' => $dbName,
                'charset' => 'AL32UTF8',
            );
            $dbConnection = DriverManager::getConnection($connectionParams, $config, $evm);
            $dbConnection->setAutoCommit(true);
        } else {
            $connectionParams = array(
                'user' => $dbUserName,
                'password' => $dbPassword,
                'host' => $dbHost,
                'port' => $dbPort,
                'driver' => $dbDriver,
                'dbname' => $dbName,
            );
            $dbConnection = DriverManager::getConnection($connectionParams, $config);
        }
        
        return $dbConnection;
    }
}