Factory.php

Go to the documentation of this file.

<?php
namespace Xoops\Core\Database;

use Xoops\Core\Database\Logging\XoopsDebugStack;

class Factory
{

    public static function getConnection($options = null)
    {
        static $instance;
        if (!isset($instance)) {
                        $xoops = \Xoops::getInstance();
            $config = new \Doctrine\DBAL\Configuration();
            $config->setSQLLogger(new XoopsDebugStack());
            $parameters = \XoopsBaseConfig::get('db-parameters');
            if (!empty($parameters) && is_array($parameters)) {
                $connectionParams = $parameters;
                $connectionParams['wrapperClass'] = '\\Xoops\\Core\\Database\\Connection';
            } else {
                $driver = 'pdo_' . \XoopsBaseConfig::get('db-type');
                $connectionParams = array(
                    'dbname' => \XoopsBaseConfig::get('db-name'),
                    'user' => \XoopsBaseConfig::get('db-user'),
                    'password' => \XoopsBaseConfig::get('db-pass'),
                    'host' => \XoopsBaseConfig::get('db-host'),
                    'charset' => \XoopsBaseConfig::get('db-charset'),
                    'driver' => $driver,
                    'wrapperClass' => '\\Xoops\\Core\\Database\\Connection',
                );
                // Support for other doctrine databases
                                $xoops_db_port = \XoopsBaseConfig::get('db-port');
                if (!empty($xoops_db_port)) {
                    $connectionParams['port'] = $xoops_db_port;
                }
                                $xoops_db_socket = \XoopsBaseConfig::get('db-socket');
                if (!empty($xoops_db_socket)) {
                    $connectionParams['unix_socket'] = $xoops_db_socket;
                }
                if (!is_null($options) && is_array($options)) {
                    $connectionParams['driverOptions'] = $options;
                }
            }

            $instance = \Doctrine\DBAL\DriverManager::getConnection(
                $connectionParams,
                $config
            );
        }
        return $instance;
    }
}