<?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_sqlite extends SQLReactorEngine implements iSQLReactorEngine{

	public function open(){
        @$this->connection->resource = sqlite_open( $this->connection->database, 0666, $error );
        if( $error ){
			throw new Exception( $error );
		}
        
		return $this->connection->resource;
	}
	public function close(){
		return sqlite_close( $this->connection->resource );
	}
	
	public function query( $query ){
        @$result = sqlite_query ( $this->connection->resource, $query, SQLITE_ASSOC, $error );
		if( $error ){
			throw new Exception( $error );
		}
		return $result;
	}
	public function fetch( $result ){
		return sqlite_fetch_array( $result, SQLITE_ASSOC );
	}
    
	public function insert( &$table ){
        $table->connection->query( $table->getInsertSQL() );
        
        if( $table->class->_primaryKey == array( 'id' ) ){
            $id = sqlite_last_insert_rowid( $this->connection->resource );
            
            if( $id ){
                $table->class->setId( $id );
            }
        }
	}
    
	public function update( &$table ){
		$sql = $table->getUpdateSQL();
		if( is_null( $sql ) ) return;
        
		$this->connection->query( $sql );
	}
}
?>