Config.php

Go to the documentation of this file.

<?php

class Elgg_Database_Config {

    const READ = 'read';
    const WRITE = 'write';
    const READ_WRITE = 'readwrite';

    protected $config;

    public function __construct(stdClass $config) {
        $this->config = $config;
    }

    public function getTablePrefix() {
        return $this->config->dbprefix;
    }

    public function isQueryCacheEnabled() {
        if (isset($this->config->db_disable_query_cache)) {
            return !$this->config->db_disable_query_cache;
        }

        return true;
    }

    public function isDatabaseSplit() {
        if (isset($this->config->db) && isset($this->config->db['split'])) {
            return $this->config->db['split'];
        }

        // this was the recommend structure from Elgg 1.0 to 1.8
        if (isset($this->config->db) && isset($this->config->db->split)) {
            return $this->config->db->split;
        }

        return false;
    }

    public function getConnectionConfig($type = self::READ_WRITE) {
        $config = array();
        switch ($type) {
            case self::READ:
            case self::WRITE:
                $config = $this->getParticularConnectionConfig($type);
                break;
            default:
                $config = $this->getGeneralConnectionConfig();
                break;
        }

        return $config;
    }

    protected function getGeneralConnectionConfig() {
        return array(
            'host' => $this->config->dbhost,
            'user' => $this->config->dbuser,
            'password' => $this->config->dbpass,
            'database' => $this->config->dbname,
        );
    }

    protected function getParticularConnectionConfig($type) {
        if (is_object($this->config->db[$type])) {
            // old style single connection (Elgg < 1.9)
            $config = array(
                'host' => $this->config->db[$type]->dbhost,
                'user' => $this->config->db[$type]->dbuser,
                'password' => $this->config->db[$type]->dbpass,
                'database' => $this->config->db[$type]->dbname,
            );
        } else if (array_key_exists('dbhost', $this->config->db[$type])) {
            // new style single connection
            $config = array(
                'host' => $this->config->db[$type]['dbhost'],
                'user' => $this->config->db[$type]['dbuser'],
                'password' => $this->config->db[$type]['dbpass'],
                'database' => $this->config->db[$type]['dbname'],
            );
        } else if (is_object(current($this->config->db[$type]))) {
            // old style multiple connections
            $index = array_rand($this->config->db[$type]);
            $config = array(
                'host' => $this->config->db[$type][$index]->dbhost,
                'user' => $this->config->db[$type][$index]->dbuser,
                'password' => $this->config->db[$type][$index]->dbpass,
                'database' => $this->config->db[$type][$index]->dbname,
            );
        } else {
            // new style multiple connections
            $index = array_rand($this->config->db[$type]);
            $config = array(
                'host' => $this->config->db[$type][$index]['dbhost'],
                'user' => $this->config->db[$type][$index]['dbuser'],
                'password' => $this->config->db[$type][$index]['dbpass'],
                'database' => $this->config->db[$type][$index]['dbname'],
            );
        }

        return $config;
    }
}