connection = mysql_connect($this->host, $this->user, $this->password) or die (mysql_error()); // Connect mysql_select_db($this->database) or die (mysql_error()); } //************************* // Close connection //************************* function closeDB() { if($this->connection) { mysql_close($this->connection); // Close connection } } //------------------------- // Queries //------------------------- //************************* // Execute query //************************* function query_execDB($query) { $results = mysql_query($query) or die (mysql_error()); return $results; } //************************* // Count rows query //************************* function query_num_rowsDB($query) { $count = mysql_num_rows($this->query_execDB($query)); return $count; } //************************* // Fetch query //************************* function query_fetchDB($query) { $results = $this->query_execDB($query); if(mysql_num_rows($results) > 0) // Check if there are results { $i = -1; // Set start array '-1' while($row = mysql_fetch_array($results)) { $i++; $fetch[$i] = $row; } return $fetch; } else // No results -> Return FALSE { return FALSE; } } } ?>