|
/**
* Database class
*
* @version: 2.2
* @revised: 27 may 2007
*
**/
class Database {
var $host;
var $name;
var $user;
var $pass;
var $prefix;
var $linkId;
function Database($mysql) {
foreach($mysql as $k => $v){
$this->$k = $v;
}
if(strlen($this->prefix)>0 && substr($this->prefix, -1) !== "_")
$prefix .= "_";
$this->prefix = $prefix;
}
function getLastID() {
$id = mysql_fetch_row(mysql_query("SELECT LAST_INSERT_ID()", $this->linkId));
return $id[0];
}
function getPossibleValues($tableA, $whereA) {
if(gettype($tableA) == "array") {
$table = "";
foreach($tableA as $t) {
$table .= $this->prefix.$t.", ";
}
$table = substr($table, 0, -2);
} else $table = $this->prefix.$tableA;
if(gettype($whereA) != "array") {
$whereA = array($whereA);
}
$return = array();
foreach($whereA as $where) {
$sql = mysql_query("SHOW COLUMNS FROM ".$table." LIKE '%".$where."%'");
while($arr = mysql_fetch_array($sql)) {
if(strpos($arr['Type'], 'enum')===0) {
$vals = substr($arr['Type'], 5, -1);
} else {
$vals = substr($arr['Type'], 4, -1);
}
$vals = str_replace("'","",$vals);
$vals = explode(",",$vals);
$i = 1;
foreach($vals as $val) {
$return[$arr['Field']][$i++] = $val;
}
$return[$arr['Field']]['default'] = $arr['Default'];
if($arr['Null'] != "NO") $return[$arr['Field']][0] = NULL;
}
}
return $return;
}
function connect() {
$this->linkId = mysql_connect($this->host, $this->user, $this->pass);
if(!$this->linkId) {
return false;
}
if(mysql_select_db($this->name, $this->linkId)) return true;
mysql_close($this->linkId);
return false;
}
function runSelect($tables, $where = "1", $fieldsA = "*", $order = false, $limit = false, $offset = false, $group = false) {
if(gettype($tables) == "array") {
$table = "";
foreach($tables as $t) {
$table .= $this->prefix.$t.", ";
}
$table = substr($table, 0, -2);
} else $table = $this->prefix.$tables;
if(gettype($fieldsA) == "array") {
$fields = "";
$keys = array_keys($fieldsA);
if($keys[0] != '0') {
foreach($keys as $key) {
$fields .= $key.' AS '.$fieldsA[$key].', ';
}
} else {
foreach($fieldsA as $field) {
$fields .= $field.', ';
}
}
$fields = substr($fields, 0, -2);
} else $fields = $fieldsA;
$query = "SELECT ".$fields." FROM ".$table." WHERE ".$where.
($order!== false?" ORDER BY ".$order:($group!==false ? " GROUP BY ".$group : "")).
($limit !== false?" LIMIT ".$limit:"").
($offset !== false?" OFFSET ".$offset:"");
return mysql_query($query, $this->linkId);
}
function runUpdate($table, $valuesA, $where = "1") {
if(gettype($valuesA) == "array") {
$fields = "";
$values = "";
$keys = array_keys($valuesA);
foreach($keys as $key) {
if($valuesA[$key] !== NULL)
$values .= "`".$key."`='".str_replace("'",'\'', $valuesA[$key])."',";
else
$values .= $key."=NULL,";
}
$fields = substr($fields, 0, -1);
$values = substr($values, 0, -1);
} else $values = $valuesA;
$query = "UPDATE ".$this->prefix.$table." SET ".$values." WHERE ".$where;
if(mysql_query($query,
$this->linkId))
return mysql_affected_rows($this->linkId);
return false;
}
function runDelete($table, $where = "1") {
if(mysql_query("DELETE FROM ".$this->prefix.$table." WHERE ".$where, $this->linkId))
return mysql_affected_rows($this->linkId);
return false;
}
function runInsert($table, $valuesA, $onDuplicate = NULL) {
if(gettype($valuesA) == "array") {
$fields = "";
$values = "";
$keys = array_keys($valuesA);
foreach($keys as $key) {
$fields .= "`".$key."`, ";
$values .= ($valuesA[$key]===NULL?"NULL, ":"'".str_replace("'", '\'', $valuesA[$key])."', ");
}
$fields = substr($fields, 0, -2);
$values = substr($values, 0, -2);
}
$onDup = "";
if($onDuplicate != NULL) {
$onDup = " ON DUPLICATE KEY UPDATE ";
if(gettype($onDuplicate) == "array") {
$keys = array_keys($onDuplicate);
foreach($keys as $key) {
$onDup .= '`'.$key.'`='.($onDuplicate[$key]===NULL?"NULL,":"'".str_replace("'", '\'', $onDuplicate[$key])."', ");
}
$onDup = substr($onDup, 0, -2);
} else $onDup .= $onDuplicate;
}
$query = "INSERT INTO ".$this->prefix.$table.($fields!==NULL?"(".$fields.")":"").
" VALUES (".$values.")".$onDup;
if(mysql_query($query, $this->linkId))
return mysql_affected_rows($this->linkId);
return false;
}
function getCells($table){
$query = "SHOW COLUMNS FROM `".$table."`";
$fields = mysql_query($query, $this->linkId) or die('hej');
return $fields;
}
function translateCellName($cellName){
$sql = $this->runSelect("mysql_cell_translation","mysql_name = '".$cellName."'");
$row = mysql_fetch_assoc($sql);
return $row['human_name']?$row['human_name']:'['.$cellName.']';
}
function getError() {
return mysql_error($this->linkId);
}
function close()
{
mysql_close($this->linkId);
}
}
?>
|
