<?php
|
class LtDbConfigBuilder
|
{
|
protected $servers = array();
|
|
protected $tables = array();
|
|
protected $adapters = array(
|
//"php_ext" => array("connection_adapter" => "", "sql_adapter" => "")
|
"pgsql" => array("connection_adapter" => "pgsql", "sql_adapter" => "pgsql"),
|
"pdo_pgsql" => array("connection_adapter" => "pdo", "sql_adapter" => "pgsql"),
|
"oci" => array("connection_adapter" => "oci", "sql_adapter" => "oracle"),
|
"pdo_oci" => array("connection_adapter" => "pdo", "sql_adapter" => "oracle"),
|
"mssql" => array("connection_adapter" => "mssql", "sql_adapter" => "mssql"),
|
"pdo_dblib" => array("connection_adapter" => "pdo", "sql_adapter" => "mssql"),
|
"mysql" => array("connection_adapter" => "mysql", "sql_adapter" => "mysql"),
|
"mysqli" => array("connection_adapter" => "mysqli", "sql_adapter" => "mysql"),
|
"pdo_mysql" => array("connection_adapter" => "pdo", "sql_adapter" => "mysql"),
|
"sqlite" => array("connection_adapter" => "sqlite", "sql_adapter" => "sqlite"),
|
"sqlite3" => array("connection_adapter" => "sqlite3", "sql_adapter" => "sqlite"),
|
"pdo_sqlite" => array("connection_adapter" => "pdo", "sql_adapter" => "sqlite"),
|
);
|
|
protected $defaultConfig = array(
|
"host" => "localhost", //some ip, hostname
|
//"port" => 3306,
|
"username" => "root",
|
"password" => null,
|
//"adapter" => "mysql", //mysql,mysqli,pdo_mysql,sqlite,pdo_sqlite
|
"charset" => "UTF-8",
|
"pconnect" => true, //true,false
|
"connection_ttl" => 3600, //any seconds
|
"dbname" => null, //default dbname
|
"schema" => null, //default schema
|
"connection_adapter" => null,
|
"sql_adapter" => null,
|
);
|
|
protected $defaultAdapterConfigs = array(
|
"pgsql" => array(
|
"port" => 5432,
|
),
|
"oracle" => array(
|
"port" => 1521,
|
),
|
"mssql" => array(
|
"port" => 1433,
|
),
|
"mysql" => array(
|
"port" => 3306,
|
"pconnect" => false,
|
"connection_ttl" => 30,
|
),
|
);
|
|
public function addSingleHost($hostConfig)
|
{
|
$this->addHost("group_0", "node_0", "master", $hostConfig);
|
}
|
|
public function addHost($groupId, $nodeId = "node_0", $role = "master", $hostConfig)
|
{
|
if (isset($this->servers[$groupId][$nodeId][$role]))
|
{//以相同role的第一个host为默认配置
|
$ref = $this->servers[$groupId][$nodeId][$role][0];
|
}
|
else if ("slave" == $role && isset($this->servers[$groupId][$nodeId]["master"]))
|
{//slave host以master的第一个host为默认配置
|
$ref = $this->servers[$groupId][$nodeId]["master"][0];
|
}
|
else if (isset($this->servers[$groupId]) && count($this->servers[$groupId]))
|
{//以本group第一个node的master第一个host为默认配置
|
$refNode = key($this->servers[$groupId]);
|
$ref = $this->servers[$groupId][$refNode]["master"][0];
|
}
|
else
|
{
|
if (!isset($hostConfig["adapter"]))
|
{
|
trigger_error("No db adapter specified");
|
}
|
$ref = $this->defaultConfig;
|
if (isset($this->defaultAdapterConfigs[$this->adapters[$hostConfig["adapter"]]["sql_adapter"]]))
|
{
|
$ref = array_merge($ref, $this->defaultAdapterConfigs[$this->adapters[$hostConfig["adapter"]]["sql_adapter"]]);
|
}
|
}
|
$conf = array_merge($ref, $hostConfig);
|
$conf = array_merge($conf, $this->adapters[$conf["adapter"]]);
|
$conf = $this->convertDbnameToSchema($conf);
|
$this->servers[$groupId][$nodeId][$role][] = $conf;
|
}
|
|
public function getServers()
|
{
|
return $this->servers;
|
}
|
|
public function getTables()
|
{
|
return $this->tables;
|
}
|
|
public function buildTablesConfig()
|
{
|
|
}
|
|
/**
|
* Convert dbname to schema for: FrontBase, MySQL, mSQL, MS SQL Server, MaxDB, Sybase
|
* See: http://www.php.net/manual-lookup.php?pattern=_select_db
|
*/
|
protected function convertDbnameToSchema($conf)
|
{
|
if (preg_match("/fbsql|mysql|msql|mssql|maxdb|sybase/i", $conf["sql_adapter"]) && isset($conf["dbname"]))
|
{
|
$conf["schema"] = $conf["dbname"];
|
$conf["dbname"] = null;
|
}
|
return $conf;
|
}
|
}
|
