Initial import

htdocs/lib/DBH.php

@@ -0,0 +1,185 @@
+<?php
+/* $Id$ */
+
+class DBH
+{
+
+	public
+	$db_name,
+	$db_pass,
+	$db_user,
+	$db_host,
+	$dbh,
+	$last_error = "";
+
+	function log($line)
+	{
+		static $f = false;
+		static $failed = false;
+
+		if ($failed) {
+			return false;
+		}
+
+		if (!$f) {
+			$f = @fopen(SITE_ROOT.'/lib/logs/sql.log', 'a');
+		}
+
+		if (!$f) {
+			$failed = true;
+			return false;
+		}
+
+		@fwrite($f, "[".date('Y-m-d H:i')."] ".$line."\n");
+	}
+
+
+	function connect($db_name, $db_host, $db_user, $db_pass)
+	{
+		$this->db_name = $db_name;
+		$this->db_pass = $db_pass;
+		$this->db_user = $db_user;
+		$this->db_host = $db_host;
+
+		$this->dbh = @mysql_connect($db_host, $db_user, $db_pass);
+
+		if (!$this->dbh) {
+			DBH::log("[error] connection to database failed");
+			DBH::log("[error] connection string used '$conn_str'");
+			return false;
+		} 
+
+		if (!mysql_select_db($db_name)) {
+			DBH::log("[error] database {$db_name} dose not exist");
+			return false;
+		}
+
+
+		$this->query("SET SQL_MODE='TRADITIONAL'");
+        $this->query("SET NAMES 'utf8'");
+		return true;
+
+	}
+
+	function query($q)
+	{
+		$res = @mysql_query($q, $this->dbh);
+
+		if (!$res) {
+			DBH::log("[error] ".$q);
+			DBH::log("[error_msg] " . mysql_error($this->dbh));
+			$this->last_error = mysql_error($this->dbh);
+
+			$e = debug_backtrace();
+			$c = count($e);
+			$btr = "";
+
+			for ($i=0; $i<$c; $i++) {
+				$btr .= "{$e[$i]['class']}::{$e[$i]['function']} {$e[$i]['file']}({$e[$i]['line']})\n";
+			}
+
+			DBH::log("[backtrace]\n".$btr);
+
+			return false;
+		} else {
+			if ($res !== TRUE) {
+				$result_id = (int)$res;
+				if (!isset($this->field_desc[$result_id])) {
+					$nf = mysql_num_fields($res);
+					for ($i=0; $i<$nf; $i++) {
+						$this->field_desc[$result_id][mysql_field_name($res, $i)] = mysql_field_type($res, $i);
+					}
+				}
+			}
+			DBH::log("[success] ".$q);
+			return $res;
+		}
+	}
+
+	function loadFromDbRow(&$obj, $res, $row)
+	{
+		foreach ($row as $symbolicName => $nativeName){
+			if ($nativeName && ($this->field_desc[(int)$res][$symbolicName] == "timestamp" ||
+			    $this->field_desc[(int)$res][$symbolicName] == "date" ||
+                $this->field_desc[(int)$res][$symbolicName] == "datetime")) {
+				$obj->{$symbolicName} = strtotime($nativeName);
+			} else {
+				$obj->{$symbolicName} = $nativeName;
+			}
+		}
+		return true;
+	}
+
+    function insertID()
+    {
+        return @mysql_insert_id($this->dbh);
+    }
+    
+	function numRows($res)
+	{
+		return @mysql_num_rows($res);
+	}
+
+	function affectedRows()
+	{
+        return @mysql_affected_rows($this->dbh);
+	}
+
+	function fieldName($res, $num)
+	{
+		return @mysql_field_name($res, $num);
+	}
+
+	function numFields($res)
+	{
+		return @mysql_num_fields($res);
+	}
+
+	function fetchRow($res)
+	{
+		return @mysql_fetch_assoc($res);
+	}
+
+	function begin()
+	{
+		return $this->query('begin');
+	}
+
+	function rollback()
+	{
+		return $this->query('rollback');
+	}
+
+	function commit()
+	{
+		return $this->query('commit');
+	}
+
+	/* FIXME: port from postgres */
+	function nextId($seq)
+	{
+		$res = $this->query("select nextval('$seq') as n");
+
+		if (!$res || !$row = $this->fetchRow($res)) {
+			return false;
+		} else {
+			return (int)$row['n'];
+		}
+	}
+
+	/* Date time conversion */
+	function db2unix($s)
+	{
+		return strtotime($s);
+	}
+
+}
+/*
+* Local variables:
+* tab-width: 4
+* c-basic-offset: 4
+* End:
+* vim600: sw=4 ts=4 fdm=marker
+* vim<600: sw=4 ts=4
+*/
+?>