"; + print "SQL/DB Error -- "; + print "[$str]"; + print ""; + } + else + { + return false; + } + } + + // ================================================================== + // Turn error handling on or off.. + + function show_errors() + { + $this->show_errors = true; + } + + function hide_errors() + { + $this->show_errors = false; + } + + // ================================================================== + // Kill cached query results + + function flush() + { + + // Get rid of these + $this->last_result = null; + $this->col_info = null; + $this->last_query = null; + + } + + // ================================================================== + // Basic Query - see docs for more detail + + function query($query) + { + + // For reg expressions + $query = trim($query); + + // initialise return + $return_val = 0; + + // Flush cached values.. + $this->flush(); + + // Log how the function was called + $this->func_call = "\$db->query(\"$query\")"; + + // Keep track of the last query for debug.. + $this->last_query = $query; + + $this->num_queries++; + + // Query was an insert, delete, update, replace + if ( preg_match("/^(insert|delete|update|replace|drop|create)\s+/i",$query) ) + { + + // Perform the query and log number of affected rows + $this->rows_affected = $this->dbh->exec($query); + + // Take note of the insert_id + if ( preg_match("/^(insert|replace)\s+/i",$query) ) + { + $this->insert_id = $this->dbh->lastInsertId(); + } + + // Return number fo rows affected + $return_val = $this->rows_affected; + } + // Query was an select + else + { + + // Perform the query and log number of affected rows + $sth = $this->dbh->query($query); + + if (!$sth) + { + $this->print_error(); + return false; + } + + $col_count = $sth->columnCount(); + + for ( $i=0 ; $i < $col_count ; $i++ ) + { + if ( $meta = $sth->getColumnMeta($i) ) + { + $this->col_info[$i]->name = $meta['name']; + $this->col_info[$i]->type = $meta['native_type']; + $this->col_info[$i]->max_length = ''; + } + else + { + $this->col_info[$i]->name = 'undefined'; + $this->col_info[$i]->type = 'undefined'; + $this->col_info[$i]->max_length = ''; + } + } + + // Store Query Results + $this->last_result = $sth->fetchAll(PDO::FETCH_OBJ); + + // Log number of rows the query returned + $this->num_rows = count($this->last_result); + + // Return number of rows selected + $return_val = $this->num_rows; + } + + // If debug ALL queries + $this->trace || $this->debug_all ? $this->debug() : null ; + + return $return_val; + + } + + // ================================================================== + // Get one variable from the DB - see docs for more detail + + function get_var($query=null,$x=0,$y=0) + { + + // Log how the function was called + $this->func_call = "\$db->get_var(\"$query\",$x,$y)"; + + // If there is a query then perform it if not then use cached results.. + if ( $query ) + { + $this->query($query); + } + + // Extract var out of cached results based x,y vals + if ( $this->last_result[$y] ) + { + $values = array_values(get_object_vars($this->last_result[$y])); + } + + // If there is a value return it else return null + return (isset($values[$x]) && $values[$x]!=='')?$values[$x]:null; + } + + // ================================================================== + // Get one row from the DB - see docs for more detail + + function get_row($query=null,$output=OBJECT,$y=0) + { + + // Log how the function was called + $this->func_call = "\$db->get_row(\"$query\",$output,$y)"; + + // If there is a query then perform it if not then use cached results.. + if ( $query ) + { + $this->query($query); + } + + // If the output is an object then return object using the row offset.. + if ( $output == OBJECT ) + { + return $this->last_result[$y]?$this->last_result[$y]:null; + } + // If the output is an associative array then return row as such.. + elseif ( $output == ARRAY_A ) + { + return $this->last_result[$y]?get_object_vars($this->last_result[$y]):null; + } + // If the output is an numerical array then return row as such.. + elseif ( $output == ARRAY_N ) + { + return $this->last_result[$y]?array_values(get_object_vars($this->last_result[$y])):null; + } + // If invalid output type was specified.. + else + { + $this->print_error(" \$db->get_row(string query, output type, int offset) -- Output type must be one of: OBJECT, ARRAY_A, ARRAY_N"); + } + + } + + // ================================================================== + // Function to get 1 column from the cached result set based in X index + // se docs for usage and info + + function get_col($query=null,$x=0) + { + + // If there is a query then perform it if not then use cached results.. + if ( $query ) + { + $this->query($query); + } + + // Extract the column values + for ( $i=0; $i < count($this->last_result); $i++ ) + { + $new_array[$i] = $this->get_var(null,$x,$i); + } + + return $new_array; + } + + // ================================================================== + // Return the the query as a result set - see docs for more details + + function get_results($query=null, $output = OBJECT) + { + + // Log how the function was called + $this->func_call = "\$db->get_results(\"$query\", $output)"; + + // If there is a query then perform it if not then use cached results.. + if ( $query ) + { + $result = $this->query_start($query); + if ($result) { + return $this->query_fetch_all($output); + } + } + return null; + } + + + // ================================================================== + // Function to get column meta data info pertaining to the last query + // see docs for more info and usage + + function get_col_info($info_type="name",$col_offset=-1) + { + + if ( $this->col_info ) + { + if ( $col_offset == -1 ) + { + $i=0; + foreach($this->col_info as $col ) + { + $new_array[$i] = $col->{$info_type}; + $i++; + } + return $new_array; + } + else + { + return $this->col_info[$col_offset]->{$info_type}; + } + + } + + } + + function query_start($query) + { + // For reg expressions + $query = trim($query); + + // Query was an insert, delete, update, replace + if ( preg_match("/^(insert|delete|update|replace)\s+/i",$query) ) + { + return false; + } + + $this->savedqueries[] = $query; + + // Flush cached values.. + $this->flush(); + + // Log how the function was called + $this->func_call = "\$db->query_start(\"$query\")"; + + // Keep track of the last query for debug.. + $this->last_query = $query; + + // Perform the query via std mysql_query function.. + $this->result = $this->dbh->query($query); + $this->num_queries++; + + // If there is an error then take note of it.. + if ( !$this->result ) + { + $this->print_error(); + return false; + } + + // Take note of column info + $col_count = $this->result->columnCount(); + + for ( $i=0 ; $i < $col_count ; $i++ ) + { + if ( $meta = $this->result->getColumnMeta($i) ) + { + $this->col_info[$i]->name = $meta['name']; + $this->col_info[$i]->type = $meta['native_type']; + $this->col_info[$i]->max_length = ''; + } + else + { + $this->col_info[$i]->name = 'undefined'; + $this->col_info[$i]->type = 'undefined'; + $this->col_info[$i]->max_length = ''; + } + } + + $this->last_result = array(); + $this->num_rows = 0; + + // If debug ALL queries + $this->trace || $this->debug_all ? $this->debug() : null ; + + return true; + } + + function query_fetch($output=OBJECT) { + $row = $this->result->fetch($output); + if ($row) { + $this->num_rows++; + return $row; + } + return null; + } + + function query_fetch_all($output=OBJECT) { + $row = $this->result->fetchAll($output); + if ($row) { + return $row; + } + return null; + } + + function query_finish() { + if (isset($this->result)) { + unset($this->result); + } + } + + // ================================================================== + // Dumps the contents of any input variable to screen in a nicely + // formatted and easy to understand way - any type: Object, Var or Array + + function vardump($mixed='') + { + + echo "
";
+ echo " |
"; + + // Only show ezSQL credits once.. + if ( ! $this->debug_called ) + { + echo "ezSQL (v".EZSQL_VERSION.") Debug..".$this->donation()."\n"; + } + echo "Query [$this->num_queries] -- "; + echo "[$this->last_query]
"; + + echo "Query Result.."; + echo "
"; + + if ( $this->col_info ) + { + + // ===================================================== + // Results top rows + + echo ""; + echo "
"; + + } // if col_info + else + { + echo "No Results"; + } + + echo ""; + + // ====================================================== + // print main results + + if ( $this->last_result ) + { + + $i=0; + foreach ( $this->get_results(null,ARRAY_N) as $one_row ) + { + $i++; + echo " (row) "; + + + for ( $i=0; $i < count($this->col_info); $i++ ) + { + echo "{$this->col_info[$i]->type} {$this->col_info[$i]->max_length} "; + } + + echo "
{$this->col_info[$i]->name}"; + } + + } // if last result + else + { + echo " $i "; + + foreach ( $one_row as $item ) + { + echo "$item "; + } + + echo ""; + } + + echo " No Results