jeena/seinheit.ch
1
0
Fork 0
Code Issues Pull requests Projects Packages Wiki Activity Actions

cleaned project, repaired router

Browse source
This commit is contained in:
Logsol 2013-07-08 22:52:36 +02:00
parent 2156d3f5c6
commit bffe0f1660
16 changed files with 1172 additions and 1440 deletions
Download patch file Download diff file Expand all files Collapse all files

222
library/Katharsis/DatabaseConnector.php
View file

@ -1,130 +1,92 @@
<?php
/**
* Database Connector
* controls database connections
*
* @author Karl Pannek <info@katharsis.in>
* @version 0.5.2
* @package Katharsis
*/
class Katharsis_DatabaseConnector
{
/**
* @var array
*/
public static $_conns = array();
/**
* Reading ini file information and connecting
*
* @param string $requestedName
* @return Katharsis_Db5
*/
protected static function connect($requestedName = null)
{
$ini = parse_ini_file('config/database.config.ini', true);
if($ini !== array())
{
$conInformation = self::_selectConnection($ini, $requestedName);
return self::_realConnect($conInformation);
} else
{
return null;
}
}
/**
* Connects to all connections in config file
*
* @param string $requestedName
* @return void
*/
public static function connectAll()
{
$groups = parse_ini_file('config/database.config.ini', true);
foreach($groups as $iniName => $conInformation)
{
if(preg_match("~^connection:([^:]+)~", $iniName, $matches))
{
self::getConnection($matches[1]);
}
}
}
/**
* Calling Katharsis Db connecting method
*
* @param string $requestedName
* @return Katharsis_Db5
*/
protected static function _realConnect($conInformation)
{
$con = new Katharsis_Db5($conInformation['host'], $conInformation['user'], $conInformation['password'], $conInformation['database']);
self::$_conns[$conInformation['name']]['connection'] = $con;
self::$_conns[$conInformation['name']]['info'] = $conInformation;
return $con;
}
/**
* Returns specified or default connection
*
* @param string $requestedName
* @return Katharsis_Db5
*/
public static function getConnection($requestedName = null)
{
if($requestedName === null)
{
foreach(self::$_conns as $con)
{
if($con['info']['default'] === true)
{
return $con['connection'];
}
}
return self::connect(null);
} else
{
if(in_array($requestedName, array_keys(self::$_conns)))
{
return self::$_conns[$requestedName]['connection'];
}
return self::connect($requestedName);
}
}
/**
* Returns an array of connection information
*
* @param array $ini
* @param string $requestedName
* @return array
*/
protected static function _selectConnection($ini, $requestedName = null)
{
foreach($ini as $name => $connectionInfo)
{
if($requestedName === null)
{
if(preg_match("~^connection:([^:]+):default~", $name, $matches))
{
$connectionInfo['name'] = $matches[1];
$connectionInfo['default'] = true;
return $connectionInfo;
}
} else
{
if(preg_match("~^connection:" . $requestedName . ".*~", $name))
{
$connectionInfo['default'] = false;
$connectionInfo['name'] = $requestedName;
return $connectionInfo;
}
}
}
throw new Katharsis_Exception('Could not find database connection information for "' . $requestedName . '"');
}
}
<?php
class Katharsis_DatabaseConnector
{
public static $_conns = array();
protected static function connect($requestedName = null)
{
$ini = parse_ini_file('config/database.config.ini', true);
if($ini !== array())
{
$conInformation = self::_selectConnection($ini, $requestedName);
return self::_realConnect($conInformation);
} else
{
return null;
}
}
public static function connectAll($requestedName = null)
{
$groups = parse_ini_file('config/database.config.ini', true);
foreach($groups as $iniName => $conInformation)
{
if(preg_match("~^connection:([^:]+)~", $iniName, $matches))
{
self::getConnection($matches[1]);
}
}
}
protected static function _realConnect($conInformation)
{
//$con = new PDO('mysql:host=' . $conInformation['host'] . ';dbname=' . $conInformation['database'], $conInformation['user'], $conInformation['password']);
$con = new Katharsis_Db5($conInformation['host'], $conInformation['user'], $conInformation['password'], $conInformation['database']);
self::$_conns[$conInformation['name']]['connection'] = $con;
self::$_conns[$conInformation['name']]['info'] = $conInformation;
return $con;
}
public static function getConnection($requestedName = null)
{
if($requestedName === null)
{
foreach(self::$_conns as $con)
{
if($con['info']['default'] === true)
{
return $con['connection'];
}
}
return self::connect(null);
} else
{
if(in_array($requestedName, array_keys(self::$_conns)))
{
return self::$_conns[$requestedName]['connection'];
}
return self::connect($requestedName);
}
}
protected static function _selectConnection($ini, $requestedName = null)
{
foreach($ini as $name => $connectionInfo)
{
if($requestedName === null)
{
if(preg_match("~^connection:([^:]+):default~", $name, $matches))
{
$connectionInfo['name'] = $matches[1];
$connectionInfo['default'] = true;
return $connectionInfo;
}
} else
{
if(preg_match("~^connection:" . $requestedName . ".*~", $name))
{
$connectionInfo['default'] = false;
$connectionInfo['name'] = $requestedName;
return $connectionInfo;
}
}
}
throw new Katharsis_Exception('Could not find database connection information for "' . $requestedName . '"');
}
}
?>