oracleStatement.php

Go to the documentation of this file.

<?php

require 'oracleResultset.php';

/**
 * Oracle server query statement class
 *
 * @package objSQL
 * @version 2.1.0
 * @author MT Jordan <mtjo62@gmail.com>
 * @link http://objsql.sourceforge.net
 * @copyright 2004-2010 openSource Partners
 * @license LGPL
 * @revision $Id: oracleStatement.php,v 1.5 2008-01-26 22:31:55-05 mt_jordan Exp $
 */

class oracleStatement
{
    /**********************************************
     * Internal variables
     *********************************************/

    /**
     * Autocommit transaction flag - false: transaction initiated
     *
     * @access private
     * @var    bool
     */
    private $objAutoCommit;

    /**
     * Database connection object
     *
     * @access private
     * @var    mixed
     */
    private $objConnection;

    /**
     * Select query limit value
     *
     * @access private
     * @var    int
     */
    private $objLimit = false;

    /**
     * Select query offset value
     *
     * @access private
     * @var    int
     */
    private $objOffset = false;

    /**
     * Prepared statement binding parameters
     *
     * @access private
     * @var    array
     */
    private $objParameters = array();

    /**
     * Query resultset object
     *
     * @access private
     * @var    mixed
     */
    private $objResult = false;

    /**
     * Sequence name
     *
     * @access private
     * @var    str
     */
    private $objSequence = false;

    /**
     * Query string
     *
     * @access public
     * @var    str
     */
    private $objQuery;

    /**********************************************
     * Class methods
     *********************************************/

    /**
     * Constructor
     *
     * @access public
     * @param  str   $query
     * @param  mixed $connection
     * @param  bool  $autocommit
     */
    public function __construct( $query, $connection, $autocommit )
    {
        $this->objAutoCommit = $autocommit;
        $this->objConnection = $connection;
        $this->objQuery      = $query;
    }

    /**
     * Escape query parameters
     *
     * @access public
     * @param  mixed $param
     * @param  bool  $no_quotes
     */
    public function bind( $param, $no_quotes=false )
    {
        if ( ( is_string( $param ) && !is_numeric( $param ) ) && !$no_quotes && substr_count( strtolower( $param ), 'nextval' ) == 0 )
        {
            if ( get_magic_quotes_gpc() )
                $param = stripslashes( $param );

            $param = str_replace( "'", "''", $param );
            $param = "'" . $param . "'";
        }

        $this->objParameters[] = $param;
    }

    /**
     * Execute prepared statement and return resultset methods
     *
     * @access public
     * @return mixed
     */
    public function execute()
    {
        $this->objResult = oci_parse( $this->objConnection->connection(), $this->objPrepareSQL() );

        if ( !$this->objResult )
        {
            $objError = oci_error( $this->objConnection->connection() );
            trigger_error( $objError['message'], E_USER_WARNING );
        }

        if ( !$this->objAutoCommit )
            $objStmt = oci_execute( $this->objResult, OCI_DEFAULT );
        else
            $objStmt = oci_execute( $this->objResult );

        if ( !$objStmt )
        {
            $objError = oci_error( $this->objResult );
            trigger_error( $objError['message'], E_USER_WARNING );
        }

        return new oracleResultset( $this->objResult, $this->objConnection->connection() );

    }

    /**
     * Set limit int value
     *
     * @access public
     * @param  int $limit
     */
    public function limit( $limit )
    {
        //make sure $limit is an unsigned int > 0
        $this->objLimit = ( is_numeric( $limit ) && $limit > 0 ) ? ( int )$limit : 1;
    }

    /**
     * Execute non-prepared query and return resultset methods
     *
     * @access public
     * @return mixed
     */
    public function objExecuteNonPrepared()
    {
        $this->objResult = oci_parse( $this->objConnection->connection(), $this->objQuery );

        if ( !$this->objResult )
        {
            $objError = oci_error( $this->objConnection->connection() );
            trigger_error( $objError['message'], E_USER_WARNING );
        }

        if ( !$this->objAutoCommit )
            $objStmt = oci_execute( $this->objResult, OCI_DEFAULT );
        else
            $objStmt = oci_execute( $this->objResult );

        if ( !$objStmt )
        {
            $objError = oci_error( $this->objResult );
            trigger_error( $objError['message'], E_USER_WARNING );
        }

        return new oracleResultset( $this->objResult, $this->objConnection->connection() );
    }

    /**
     * Prepare query string and bind parameters
     *
     * @access private
     * @return str
     */
    private function objPrepareSQL()
    {
        $objSqlParts = explode( '?', $this->objQuery );
        $objQuery = $objSqlParts[0];

        for ( $i = 1; $i < count( $objSqlParts ); $i++ )
            $objQuery .= $this->objParameters[$i - 1] . $objSqlParts[$i];

        $objQuery = ( ( $this->objLimit && $this->objOffset ) && substr_count( strtolower( $objQuery ), ':offset' ) ) ? str_ireplace( ':limit', ( $this->objLimit + $this->objOffset ) - 1, $objQuery ) : $objQuery;
        $objQuery = ( ( $this->objLimit && !$this->objOffset ) || ( ( $this->objLimit && $this->objOffset ) && !substr_count( strtolower( $objQuery ), ':offset' ) ) ) ? str_ireplace( ':limit', $this->objLimit, $objQuery ) : $objQuery;
        $objQuery = ( $this->objOffset ) ? str_ireplace( ':offset', $this->objOffset, $objQuery ) : $objQuery;
        $objQuery = ( $this->objSequence ) ? str_ireplace( ':seq', $this->objSequence, $objQuery ) : $objQuery;

        return $objQuery;
    }

    /**
     * Set offset int value
     *
     * @access public
     * @param  int $offset
     */
    public function offset( $offset )
    {
        //make sure $offset is an unsigned int > 0
        $this->objOffset = ( is_numeric( $offset ) && $offset > 0 ) ? ( int )$offset : 1;
    }

    /**
     * Set property for named sequence
     *
     * @access public
     * @param  str $sequence
     */
    public function sequence( $sequence )
    {
         $this->objSequence = $sequence . '.NEXTVAL';
    }

}

?>