123 lines
4.6 KiB
PHP
Executable File
123 lines
4.6 KiB
PHP
Executable File
<?php
|
|
// a simple wrapper for pdo
|
|
class db extends PDO {
|
|
|
|
|
|
private $error;
|
|
private $sql;
|
|
private $bind;
|
|
private $debugger=0;
|
|
public $working="yes";
|
|
|
|
public function __construct($dsn, $user="", $passwd="",$debug_level=0) {
|
|
$options = array(
|
|
PDO::ATTR_PERSISTENT => true,
|
|
PDO::ATTR_EMULATE_PREPARES => false,
|
|
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
|
|
);
|
|
$this->debugger=$debug_level;
|
|
try {
|
|
parent::__construct($dsn, $user, $passwd, $options);
|
|
} catch (PDOException $e) {
|
|
$this->error = $e->getMessage();
|
|
die("Could not connect to the DB - ".$this->error);
|
|
}
|
|
}
|
|
|
|
private function debug() {
|
|
if(!$this->debugger) return;
|
|
$error = array("Error" => $this->error);
|
|
if(!empty($this->sql))
|
|
$error["SQL Statement"] = $this->sql;
|
|
if(!empty($this->bind))
|
|
$error["Bind Parameters"] = trim(print_r($this->bind, true));
|
|
|
|
$backtrace = debug_backtrace();
|
|
if(!empty($backtrace)) {
|
|
foreach($backtrace as $info) {
|
|
if($info["file"] != __FILE__)
|
|
$error["Backtrace"] = $info["file"] . " at line " . $info["line"];
|
|
}
|
|
}
|
|
$msg = "";
|
|
$msg .= "SQL Error\n" . str_repeat("-", 50);
|
|
foreach($error as $key => $val)
|
|
$msg .= "\n\n$key:\n$val";
|
|
|
|
if($this->debugger){
|
|
|
|
echo nl2br($msg);
|
|
|
|
}
|
|
}
|
|
|
|
private function cleanup($bind,$sql="") {
|
|
if(!is_array($bind)) {
|
|
if(!empty($bind))
|
|
$bind = array($bind);
|
|
else
|
|
$bind = array();
|
|
}
|
|
|
|
foreach($bind as $key=>$val){
|
|
if(str_replace($key,"",$sql)==$sql) unset($bind[$key]);
|
|
}
|
|
return $bind;
|
|
}
|
|
|
|
|
|
|
|
|
|
public function single($sql,$bind="") {
|
|
$this->sql = trim($sql);
|
|
$this->bind = $this->cleanup($bind,$sql);
|
|
$this->error = "";
|
|
try {
|
|
$pdostmt = $this->prepare($this->sql);
|
|
if($pdostmt->execute($this->bind) !== false) {
|
|
return $pdostmt->fetchColumn();
|
|
}
|
|
} catch (PDOException $e) {
|
|
$this->error = $e->getMessage();
|
|
$this->debug();
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
public function run($sql, $bind="") {
|
|
$this->sql = trim($sql);
|
|
$this->bind = $this->cleanup($bind,$sql);
|
|
$this->error = "";
|
|
|
|
try {
|
|
$pdostmt = $this->prepare($this->sql);
|
|
if($pdostmt->execute($this->bind) !== false) {
|
|
if(preg_match("/^(" . implode("|", array("select", "describe", "pragma")) . ") /i", $this->sql))
|
|
return $pdostmt->fetchAll(PDO::FETCH_ASSOC);
|
|
elseif(preg_match("/^(" . implode("|", array("delete", "insert", "update")) . ") /i", $this->sql))
|
|
return $pdostmt->rowCount();
|
|
}
|
|
} catch (PDOException $e) {
|
|
$this->error = $e->getMessage();
|
|
$this->debug();
|
|
return false;
|
|
}
|
|
}
|
|
|
|
public function row($sql,$bind=""){
|
|
$query=$this->run($sql,$bind);
|
|
if(count($query)==0) return false;
|
|
if(count($query)>1) return $query;
|
|
if(count($query)==1){
|
|
foreach($query as $row) $result=$row;
|
|
return $result;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
?>
|