function NumQueries() {
return $this->num_queries;
}
function QFetchObject($query) {
return $this->FetchObject($this->Query($query));
}
function QFetchRow($query) {
return $this->FetchRow($this->Query($query));
}
function QFetchArray($query) {
return $this->FetchArray($this->Query($query));
}
/**
* returns the number of rows from a table based on a certain [optional]
* where clause
*
* @param string $table table in which to count rows
* @param string $where_clause optional where clause [see sql WHERE clause]
*
* @return int row count
*
* @access public
*/
function RowCount($table,$where_clause = "") {
$result = $this->FetchRow($this->Query("SELECT COUNT(*) FROM `$table` $where_clause;"));
return $result[0];
}
/**
* fetch an array w/ rows from the database
*
* @param resource $result sql query result
* @param int $return_type row return type [can be DB_RT_ARRAY or DB_RT_OBJECT]
* @param string $key key the returned array by a certain row field [defaults to ""]
*
* @return array with rows or NULL if none fetched
*
* @access public
*/
function FetchRowArray($result,$return_type = DB_RT_ARRAY,$key = "") {
$ret_val = array();
$i = 0;
// dont panic. its just ternary operators in action :]
while ($row = (($return_type == DB_RT_ARRAY) ? $this->FetchArray($result) : $this->FetchObject($result)))
$ret_val[(($key == "") ? $i++ : (($return_type == DB_RT_ARRAY) ? $row["$key"] : $row->$key))] = $row;
// see if any rows were fetched and return accordingly
return (count($ret_val) != 0) ? $ret_val : NULL;
}
/**
* FetchRowArray wrapper
*
* @param string $query sql query to send to FetchRowArray
* @param int $return_type
* @param string $key
*
* @return array
*
* @access public
*
* @see CDatabase::FetchRowArray
*/
function QFetchRowArray($query,$return_type = DB_RT_ARRAY,$key = "") {
return $this->FetchRowArray($this->Query($query),$return_type,$key);
}
/**
* returns an array w/ the tables fields
*
* @param $table database table from which to get rows
*
* @return array
*
* @access public
*/
function GetTableFields($table) {
$fields = $this->QFetchRowArray("SHOW FIELDS FROM `$table`");
$ret_val = array();
foreach ($fields as $field)
$ret_val[] = $field["Field"];
return $ret_val;
}
/**
* fetches a row from a table based on a certain id using the SELECT SQL query
*
* @param string $table table in which to perform select
* @param int $id row id to fetch
* @param string $fields comma separated list of row fields to fetch [defaults to `*' all]
* @param int $return_type row return type DB_RT_ARRAY|DB_RT_OBJECT [defaults to DB_RT_ARRAY]
*
* @return array w/ the fetched data or NULL if id not found
*
* @access public
*/
function QuerySelectByID($table,$id,$fields = "*",$return_type = DB_RT_ARRAY) {
// build query
$query = "SELECT $fields FROM `$table` WHERE `id` = '$id'";
// fetch row
return ($return_type == DB_RT_ARRAY) ? $this->QFetchArray($query) : $this->QFetchObject($query);
}
/**
* complex fetch row array w/ WHERE/LIMIT/ORDER SQL clauses and page modifier
*
* @param string $table table to fetch rows from
* @param string $fields comma separated list of row fields to fetch
* @param string $where_clause SQL WHERE clause [use empty to ignore]
* @param int $start limit start
* @param int $count number of rows to fetch
* @param bool $pm page modifier. if set to TRUE [default] $start becomes the page
* @param string $order_by field[s] to order the result by [defaults to void]
* @param string $order_dir order direction. can be ASC or DESC [defaults to ASC]
* @param int $return_type row return type [DB_RT_ARRAY(default)|DB_RT_OBJECT]
*
* @return array w/ fetched rows or NULL
*
* @access public
*/
function QuerySelectLimit($table,$fields,$where_clause,$start,$count,$pm = TRUE,$order_by = "",$order_dir = "ASC",$return_type = DB_RT_ARRAY) {
// check if $count is empty just to be safe
$count = ($count == "") ? 0 : $count;
// recompute $start if page modifier set
$_start = ($pm == TRUE) ? ((($start == 0) ? 1 : $start) * $count - $count) : $start;
// setup order clause
$order_clause = ($order_by != "") ? "ORDER BY $order_by " . (in_array($order_dir,array("ASC","DESC")) ? "$order_dir " : "") : "";
// setup where clause
$where_clause = ($where_clause != "") ? "WHERE $where_clause " : "";
// limit clause
$limit_clause = ($start >= 0) ? "LIMIT $_start,$count" : "";
// build query
$query = "SELECT $fields FROM `$table` {$where_clause}{$order_clause}{$limit_clause}";
// fetch rows
return $this->QFetchRowArray($query,$return_type);
}
/**
* builds and performes a SQL INSERT query based on the user data
*
* @param string $table table in which to perform insert
* @param array $fields associative array w/ the row fields to be inserted
*
* @return void
*
* @access public
*/
function QueryInsert($table,$fields) {
// first get the tables fields
$table_fields = $this->GetTableFields($table);
if (count($fields) == 0) {
$names[] = "id";
$values[] = "''";
} else
// prepare field names and values
foreach ($fields as $field => $value)
// check for valid fields
if (in_array($field,$table_fields)) {
$names[] = "`$field`";
$values[] = is_numeric($value) ? $value : "'" . addslashes($value) . "'";
}
// build field names and values
$names = implode(",",$names);
$values = implode(",",$values);
// perform query
$this->Query("INSERT INTO `$table` ($names) VALUES($values)");
return $this->InsertID();
}
/**
* builds and performs a SQL UPDATE query based on the user data
*
* @param string $table table in which to perform update
* @param array $fields associative array w/ the fields to be updated
* @param string $where_clause update where clause [see SQL WHERE clause]
*
* @return void
*
* @access public
*/
function QueryUpdate($table,$fields,$where_clause) {
if (is_array($fields)) {
// first get the tables fields
$table_fields = $this->GetTableFields($table);
// prepare query
foreach ($fields as $field => $value)
// check for valid fields
if (in_array($field,$table_fields))
$pairs[] = "`$field` = " . (is_numeric($value) ? $value : "'" . addslashes($value) . "'");
// $values[] = ;
// build and perform query
if (is_array($pairs))
$this->Query("UPDATE `$table` SET " . implode(", ",$pairs) . " WHERE($where_clause)");
}
}
/**
* builds and performs a SQL UPDATE query based on the user data
*
* @param string $table table in which to perform update
* @param array $fields associative array w/ the fields to be updated
*
* @return void
*
* @access public
*/
function QueryUpdateByID($table,$fields) {
$id = $fields["id"];
unset($fields["id"]);
$this->QueryUpdate($table,$fields,"`id` = '$id'");
}
}
?>
