seafood/app/libs/alipay/lotusphp_run.../DB/DbConfigBuil...

<?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;
	}
}