oracleTransaction.php

Go to the documentation of this file.

<?php

/**
 * Oracle transaction 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: oracleTransaction.php,v 1.4 2008-01-19 14:47:20-05 mt_jordan Exp $
 */

class oracleTransaction
{
    /**********************************************
     * Internal variables
     *********************************************/

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

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

    /**
     * Constructor
     *
     * @access public
     * @param  mixed $connection
     */
    public function __construct( $connection )
    {
        $this->objConnection = $connection;
    }

    /**
     * Commit transaction
     *
     * @access public
     * @return bool
     */
    public function commit()
    {
        return oci_commit( $this->objConnection );
    }

    /**
     * Rollback transaction
     *
     * @access public
     * @param  str $savepoint
     * @return bool
     */
    public function rollback( $savepoint=false )
    {
        if ( !$savepoint )
        {
            return oci_rollback( $this->objConnection );
        }
        else
        {
            $objParse = oci_parse( $this->objConnection, 'ROLLBACK TO ' . $savepoint );

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

            $objStmt = oci_execute( $objParse, OCI_DEFAULT );

            if ( !$objStmt )
            {
                $objError = oci_error( $objParse );
                trigger_error( $objError['message'], E_USER_WARNING );
            }

            return $objStmt;
        }
    }

    /**
     * Create rollback savepoint
     *
     * @access public
     * @param  str $savepoint
     * @return bool
     */
    public function savepoint( $savepoint )
    {
        $objParse = oci_parse( $this->objConnection, 'SAVEPOINT ' . $savepoint );

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

        $objStmt = oci_execute( $objParse, OCI_DEFAULT );

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

        return $objStmt;
    }
}

?>