conn = ibase_connect($dbpath, $user, $pass); $class = __CLASS__."_manip"; $this->manip = new $class; } /** * Close the link to the database */ public function __destruct() { @ibase_close($this->conn); @ibase_free_result($this->statement); } /** * Empty a database table * * @param string $table */ public function truncate($table) { // Firebird lacka a truncate command $sql = 'DELETE FROM '.$table.'"'; $this->query($sql); } /** * Wrapper public function to better match PDO * * @param string $sql * @param array $params * @return resource */ public function query($sql) { $this->count = 0; $this->statement = ibase_query($this->conn, $sql); return $this->statement; } /** * Emulate PDO fetch public function * * @param int $fetch_style * @return mixed */ public function fetch($fetch_style=PDO::FETCH_ASSOC) { switch($fetch_style) { case PDO::FETCH_OBJ: return ibase_fetch_object($this->statement, IBASE_FETCH_BLOBS); break; case PDO::FETCH_NUM: return ibase_fetch_row($this->statement, IBASE_FETCH_BLOBS); break; default: return ibase_fetch_assoc($this->statement, IBASE_FETCH_BLOBS); break; } } /** * Emulate PDO fetchAll public function * * @param int $fetch_style * @return mixed */ public function fetchAll($fetch_style=PDO::FETCH_ASSOC) { $all = array(); while($row = $this->fetch($fetch_style)) { $all[] = $row; } $this->result = $all; return $all; } /** * Emulate PDO prepare * * @return resource */ public function prepare() { $this->statement = ibase_prepare($this->conn, $query); return $this->statement; } /** * List tables for the current database * * @return array */ public function get_tables() { $sql = <<statement = $this->query($sql); $tables = array(); while($row = $this->fetch(PDO::FETCH_ASSOC)) { $tables[] = $row['RDB$RELATION_NAME']; } return $tables; } /** * List system tables for the current database * * @return array */ public function get_system_tables() { $sql = <<statement = $this->query($sql); $tables = array(); while($row = $this->fetch(PDO::FETCH_ASSOC)) { $tables[] = $row['RDB$RELATION_NAME']; } return $tables; } /** * Return the number of rows affected by the previous query * * @return int */ public function affected_rows() { return ibase_affected_rows($this->conn); } /** * Return the number of rows returned for a SELECT query * * @return int */ public function num_rows() { // @todo: Redo this similar to the codeigniter driver $count = 0; if(isset($this->statement)) { while($row = $this->fetch()) { $count++; } } else { return FALSE; } return $count; } /** * Start a database transaction * * @return bool */ public function beginTransaction() { if(($this->trans = ibase_trans($this->conn)) !== NULL) { return TRUE; } return FALSE; } /** * Commit a database transaction * * @return bool */ public function commit() { return ibase_commit($this->trans); } /** * Rollback a transaction * * @return bool */ public function rollBack() { return ibase_rollback($this->trans); } /** * Run a prepared statement query * * @param array $args * @return bool */ public function execute($args) { // Is there a better way to do this? return eval("ibase_execute({$this->statement},".explode(',', $args).")"); } } // End of firebird.php