diff --git a/include/basis_db.class.php b/include/basis_db.class.php index 35f5a292a..e6525c34a 100644 --- a/include/basis_db.class.php +++ b/include/basis_db.class.php @@ -4,6 +4,7 @@ require_once('basis.class.php'); abstract class db extends basis { protected static $db_conn=null; + protected $db_result=null; function __construct() { @@ -13,6 +14,8 @@ abstract class db extends basis abstract function db_connect(); abstract function db_query($sql); + abstract function db_num_rows(); + abstract function db_last_error(); } diff --git a/include/pgsql.class.php b/include/pgsql.class.php index 7e718972a..d9f3561f2 100644 --- a/include/pgsql.class.php +++ b/include/pgsql.class.php @@ -4,7 +4,7 @@ class basis_db extends db { function db_connect() { - $conn_str=CONN_STRING; + $conn_str='host='.DB_HOST.' port='.DB_PORT.' dbname='.DB_NAME.' user='.DB_USER.' password='.DB_PASSWORD; //Connection Herstellen if (DB_CONNECT_PERSISTENT) { @@ -20,18 +20,29 @@ class basis_db extends db function db_query($sql) { + //echo $sql.'
'; if ($this->db_result=pg_query(basis_db::$db_conn,$sql)) return true; else { - $this->errormsg='Abfrage in Datenbank fehlgeschlagen! '.$this->db_lasterror(); + $this->errormsg.='Abfrage in Datenbank fehlgeschlagen! '.$this->db_last_error(); return false; } } + function db_num_rows() + { + return pg_num_rows($this->db_result); + } + function db_fetch_object() { return pg_fetch_object($this->db_result); } + + function db_last_error() + { + return pg_last_error(); + } } ?> \ No newline at end of file