<?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_mysql extends SQLReactorEngine implements iSQLReactorEngine{
    public $escapeName = '`';
    
	public function open(){
		$this->connection->resource = mysql_connect( $this->connection->host, $this->connection->user, $this->connection->password );
		mysql_select_db( $this->connection->database, $this->connection->resource );
        
		return $this->connection->resource;
	}
	public function close(){
		return mysql_close( $this->connection->resource );
	}
	
	public function query( $query ){
		$result = mysql_query( $query, $this->connection->resource );
		$error = mysql_error( $this->connection->resource );
		if( $error ){
			throw new Exception( $error );
		}
		return $result;
	}
	public function fetch( $result ){
		return mysql_fetch_array( $result, MYSQL_ASSOC );
	}
    
	public function insert( &$table ){
        $table->connection->query( $table->getInsertSQL() );
        
        if( $table->class->_primaryKey == array( 'id' ) ){
            $id = mysql_insert_id( $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 );
	}
}
?>