conn = NULL;
}
/* Verbindung herstellen (wenn noch net besteht)*/
function _createConn(){
//print $this->conn."
";
if($this->conn === NULL){
$this->conn = pg_pconnect(Config::getPgConnString())
or die('Verbindungsaufbau fehlgeschlagen: ' . pg_last_error());
}
}
/* Verbindung schließen */
function closeConn(){
if($this->conn != NULL){
pg_close($this->conn);
$this->conn = NULL;
}
}
/* Eine Zeile holen */
function fetchQueryResultLine($query){
$this->_createConn();
$result = pg_query($this->conn, $query)
or die('Abfrage fehlgeschlagen: ' . pg_last_error(). "\n
\nquery: '".$query."'");
$array = pg_fetch_assoc($result);
//print_r($array);
return $array;
}
/* mehrere Zeilen holen */
function fetchQueryResultSet($query){
$returnArray = array();
$this->_createConn();
$result = pg_query($this->conn, $query)
or die('Abfrage fehlgeschlagen: ' . pg_last_error(). "\n
\nquery: '".$query."'");
while($array = pg_fetch_assoc($result))
$returnArray[] = $array;
return $returnArray;
}
/* Result roh zurueckgeben */
function &getRawResult($query){
$this->_createConn();
$result = pg_query($this->conn, $query)
or die('Abfrage fehlgeschlagen: ' . pg_last_error(). "\n
\nquery: '".$query."'");
return $result;
}
}
?>