Page MenuHomePhorge
Files F117883787

SQL.php
No OneTemporary
Actions

Authored By
Unknown
Size
4 KB
Referenced Files
None
Subscribers
None

SQL.php
View Options

<?php
/*
+--------------------------------------------------------------------------+
| This file is part of the Kolab Web Admin Panel |
| |
| Copyright (C) 2011-2012, Kolab Systems AG |
| |
| This program is free software: you can redistribute it and/or modify |
| it under the terms of the GNU Affero General Public License as published |
| by the Free Software Foundation, either version 3 of the License, or |
| (at your option) any later version. |
| |
| This program is distributed in the hope that it will be useful, |
| but WITHOUT ANY WARRANTY; without even the implied warranty of |
| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| GNU Affero General Public License for more details. |
| |
| You should have received a copy of the GNU Affero General Public License |
| along with this program. If not, see <http://www.gnu.org/licenses/> |
+--------------------------------------------------------------------------+
| Author: Aleksander Machniak <machniak@kolabsys.com> |
| Author: Jeroen van Meeuwen <vanmeeuwen@kolabsys.com> |
+--------------------------------------------------------------------------+
*/
class SQL
{
static private $instance = array();
private $sql_uri = "mysql://username:password@hostname/database";
/* Placeholder for the existing MySQL connection */
private $conn = false;
private $conn_tried = false;
private $sql_stats = array(
'queries' => 0,
'query_time' => 0,
'connections' => 0
);
/**
* This implements the 'singleton' design pattern
*
* @return SQL The one and only instance associated with $_conn
*/
static function get_instance($_conn = 'kolab_wap')
{
if (!isset(self::$instance[$_conn])) {
self::$instance[$_conn] = new SQL($_conn);
}
return self::$instance[$_conn];
}
public function __construct($_conn = 'kolab_wap')
{
$conf = Conf::get_instance();
$this->name = $_conn;
$this->sql_uri = $conf->get($_conn, 'sql_uri');
}
public function query()
{
if (!$this->conn) {
$this->_connect();
}
$i = 0;
$start = 0;
$query = func_get_arg(0);
while (strlen($query) > $start && ($pos = strpos($query, '?', $start)) !== false) {
$i++;
$param = $this->escape(func_get_arg($i));
$query = substr_replace($query, $param, $pos, 1);
$start = $pos + strlen($param) + 1;
}
Log::trace("SQL: $query");
$result = mysql_query($query);
if (!$result) {
Log::error('SQL Error: ' . mysql_error($this->conn));
}
return $result;
}
public function fetch_assoc($result)
{
if (!$result) {
return array();
}
return mysql_fetch_assoc($result);
}
public function affected_rows()
{
return mysql_affected_rows($this->conn);
}
public function last_insert_id()
{
return mysql_insert_id($this->conn);
}
public function escape($str)
{
if ($str === null || is_array($str)) {
return 'NULL';
}
if (!$this->conn) {
$this->_connect();
}
return "'" . mysql_real_escape_string($str, $this->conn) . "'";
}
public function escape_identifier($str)
{
$name = array();
foreach (explode('.', $str) as $elem) {
$elem = str_replace('`', '', $elem);
$name[] = '`' . $elem . '`';
}
return implode($name, '.');
}
private function _connect()
{
if (!$this->conn && !$this->conn_tried) {
Log::debug("SQL: Connecting to " . $this->sql_uri);
$_uri = parse_url($this->sql_uri);
$this->_username = $_uri['user'];
$this->_password = $_uri['pass'];
$this->_hostname = $_uri['host'];
$this->_database = str_replace('/','',$_uri['path']);
$this->conn_tried = true;
$this->conn = mysql_connect($this->_hostname, $this->_username, $this->_password);
mysql_select_db($this->_database, $this->conn);
}
}
}

File Metadata

Mime Type
text/x-php
Expires
Mon, Apr 6, 1:10 AM (2 d, 12 h ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
84/5b/d175d4960c3eb52051a4dce0f495
Default Alt Text
SQL.php (4 KB)

Event Timeline