<?php
/*******************************************************************************
* Copyright 2008 Rafael Marques Martins
*
* This file is part of SQLReactor.
* 
* SQLReactor is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
* 
* SQLReactor is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU General Public License for more details.
* 
* You should have received a copy of the GNU General Public License
* along with SQLReactor; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
* 
*******************************************************************************/

class SQLReactorEngine_postgres extends SQLReactorEngine implements iSQLReactorEngine{
	public function open(){
		$connString  = "host={$this->connection->host}";
		$connString .= " dbname={$this->connection->database}";
		$connString .= $this->connection->user ? " user={$this->connection->user}" : "";
		$connString .= $this->connection->password ? " password={$this->connection->password}" : "";
		
		@$this->connection->resource = pg_connect( $connString );
		if( $php_errormsg ){
			throw new Exception( $php_errormsg );
		}
        
		return $this->connection->resource;
	}
	public function close(){
		return pg_close( $this->connection->resource );
	}
	
	public function query( $query ){
		@$result = pg_query( $this->connection->resource, $query );
		$error = pg_last_error();
		if( $error ){
			throw new Exception( $error );
		}
		return $result;
	}
	public function fetch( $result ){
		return pg_fetch_array( $result, null, PGSQL_ASSOC );
	}
    
	public function insert( &$table ){
		try{
			if( $table->class->_primaryKey == array( 'id' ) ){
				$result = $table->connection->query( "SELECT nextval( '{$table->columns->id->sequence}' ) AS \"id\"" );
				$rs = $table->connection->fetch( $result );
				
				
				$table->class->setId( $rs[ 'id' ] );
			}
            
			$table->connection->query( $table->getInsertSQL() );
			
		}catch( Exception $exception ){
			if( $table->class->_primaryKey == array( 'id' ) ){
				$table->class->setId( null );
			}
			throw $exception;
		}
	}
    
	public function update( &$table ){
		$sql = $table->getUpdateSQL();
		if( is_null( $sql ) ) return;
        
		$this->connection->query( $sql );
	}
}
?>