suda\application\database\Database

Complexity

Total Complexity

16

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	application()	0	3	1
A	getDefaultDataSource()	0	3	1
A	loadApplication()	0	3	1
A	getDataSource()	0	3	1
A	applyDataSource()	0	23	6
A	getDataSourceFrom()	0	26	6

<?php


namespace suda\application\database;

use suda\framework\Config;
use suda\database\DataSource;
use suda\application\ApplicationModule;
use suda\database\exception\SQLException;
use suda\database\connection\observer\Observer;
use suda\application\Resource as ApplicationResource;
use suda\application\database\creator\MySQLTableCreator;

/**
 * Class Database
 * @package suda\application\database
 */
class Database
{
    /**
     * 应用引用
     *
     * @var ApplicationModule
     */
    protected static $application;

    /**
     * @var DataSource[]
     */
    protected static $dataSource = [];

    /**
     * 从应用创建表
     *
     * @param ApplicationModule $application
     * @return void
     */
    public static function loadApplication(ApplicationModule $application)
    {
        static::$application = $application;
    }

    /**
     * Get 应用引用
     *
     * @return  ApplicationModule
     */
    public static function application()
    {
        return static::$application;
    }

    /**
     * 获取默认的数据源
     * @return DataSource
     * @throws SQLException
     */
    public static function getDefaultDataSource():DataSource
    {
        return static::getDataSource('default');
    }

    /**
     * @param string $name
     * @return DataSource
     * @throws SQLException
     */
    public static function getDataSource(string $name)
    {
        return static::getDataSourceFrom(static::$application->getResource(), $name);
    }

    /**
     * @param ApplicationResource $resource
     * @param string $groupName
     * @return DataSource
     * @throws SQLException
     */
    public static function getDataSourceFrom(ApplicationResource $resource, string $groupName)
    {
        if (array_key_exists($groupName, static::$dataSource)) {
            return static::$dataSource[$groupName];
        }
        $group = $groupName === 'default' ? '': '-'. $groupName;
        $dataSourceConfigPath = $resource->getConfigResourcePath('config/data-source'.$group);
        $dataSource = new DataSource;
        if ($dataSourceConfigPath !== null) {
            $observer = new DebugObserver(static::$application->debug());
            $dataSourceConfig = Config::loadConfig($dataSourceConfigPath);
            foreach ($dataSourceConfig as $name => $config) {
                $enable = $config['enable'];
                if ($enable) {
                    static::applyDataSource(
                        $dataSource,
                        $observer,
                        $name,
                        $config['type'] ?? 'mysql',
                        $config['mode'] ?? '',
                        $config
                    );
                }
            }
        }
        return static::$dataSource[$groupName] = $dataSource;
    }


    /**
     * @param DataSource $source
     * @param Observer $observer
     * @param string $name
     * @param string $type
     * @param string $mode
     * @param array $config
     * @throws SQLException
     */
    protected static function applyDataSource(
        DataSource $source,
        Observer $observer,
        string $name,
        string $type,
        string $mode,
        array $config
    ) {
        $mode = strtolower($mode);
        $data = DataSource::new($type, $config, $name);
        $data->setObserver($observer);
        if (strlen($mode) > 0) {
            if (strpos($mode, 'read') !== false || strpos($mode, 'slave') !== false) {
                $source->addRead($data);
            }
            if (strpos($mode, 'write') !== false) {
                $source->addWrite($data);
            }
            if (strpos($mode, 'master') !== false) {
                $source->add($data);
            }
        } else {
            $source->add($data);
        }
    }
}