Datenbankfehler:
\n
";
echo "MySQL-Fehler:\n $this->Errno \n";
die("
DB-Verbindung wurde aus Sicherheitsgründen gestoppt !");
}
function connect() { //Verbinsdungsaufbau
if ($this->db_link_ID == 0) { //Test, ob db_link_ID bereits existiert
$this->db_link_ID = mysql_pconnect($this->db_host,$this->db_user,$this->db_password);
if (!$this->db_link_ID) { //Falls nicht existent, neuer Aufbau
$this->halt("Link-ID == false, Verbindungsaufbau fehlgeschlagen");
}
if (!mysql_query(sprintf("use %s",$this->db_database),$this->db_link_ID)) {
$this->halt("kann Datenbank nicht verwenden ".$this->db_database);
}
}
}
/*
//Nur aktivieren, falls keine Persistenten Verbindungen gewünscht werden
function disconnect() {
//mysql_close($this->db_link_ID);
//if (!disconnect()) {
if (!mysql_close($this->db_link_ID)) {
$this->Errno = mysql_errno();
$this->Error = mysql_error();
$this->halt("Fehler aufgetreten:");
//} else {
//$disconnect = "beendet";
//return $disconnect;
}
}
*/
function query($query) { //ausführen des Querys
$this->connect();
$this->query_ID = mysql_query($query,$this->db_link_ID);
//nur ausführen, wenn Select abfrage oder delete!
if (eregi("select",$query)) {
$this->result_sets = mysql_num_rows($this->query_ID);
}
$this->row = 0;
$this->Errno = mysql_errno();
$this->Error = mysql_error();
if (!$this->query_ID) {
$this->halt("Ungültige Abfrage: ".$query);
}
return $this->query_ID;
}
function num_row($query) { //noch todo
$this->connect();
$tmp_query = $query; //Übertragen der DB-Abfrage
//Ermitteln der Abzufragendend Tabelle
$tmp_pos = strpos($tmp_query,"FROM") + 5; //lokalisieren -> Spalte
$tmp_pos2 = strpos($tmp_query," ",$tmp_pos); //lokalisieren -> Spalte
$tmp_diff = $tmp_pos2-$tmp_pos;
$final = (substr($tmp_query,$tmp_pos,$tmp_diff));
$tmp_query_ID = mysql_query("SELECT * FROM $final",$this->db_link_ID); //Abfrage mit ->Spalte
$this->Errno = mysql_errno();
$this->Error = mysql_error();
if (!$tmp_query_ID) {
$this->halt("Fehler aufgetreten:");
}
$this->num_row = mysql_num_rows($tmp_query_ID);
return $this->num_row;
}
function next_record() { //Datensätze ausgeben
$this->record = mysql_fetch_array($this->query_ID);
$this->row += 1;
$this->Errno = mysql_errno();
$this->Error = mysql_error();
$stat = is_array($this->record);
if (!$stat) {
mysql_free_result($this->query_ID);
$this->query_ID = 0;
}
return $stat;
}
}
?>