Home | Classes | Modules | Annotated | Hierarchy | Functions | Files

OCI8PreparedStatement.php

Go to the documentation of this file.

<?php
/*
 *  $Id: OCI8PreparedStatement.php,v 1.13 2004/03/20 04:16:50 hlellelid Exp $
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the LGPL. For more information please see
 * <http://creole.phpdb.org>.
 */
 
require_once 'creole/PreparedStatement.php';
require_once 'creole/common/PreparedStatementCommon.php';

class OCI8PreparedStatement extends PreparedStatementCommon implements PreparedStatement {

    private $lobDescriptors = array();
    
    private $lobs = array();        
    
    function close()
    {
         @OCIFreeStatement($this->stmt);
    }
    
    protected function escape($str)
    {
        return str_replace("'","''", $str);
    }

    public function executeQuery($p1 = null, $fetchmode = null)
    {
        $params = null;
        if ($fetchmode !== null) {
            $params = $p1;
        } elseif ($p1 !== null) {
            if (is_array($p1)) $params = $p1;
            else $fetchmode = $p1;
        }
        
        if ($params) {
            for($i=0,$cnt=count($params); $i < $cnt; $i++) {
                $this->set($i+1, $params[$i]);
            }
        }

        $this->updateCount = null; // reset        
                
        $sql = $this->sqlToOracleBindVars($sql);
        
        if ($this->limit > 0) {
            $this->conn->applyLimit($sql, $this->offset, $this->limit);
        } elseif ($offset > 0) {
            throw new SQLException('Cannot specify an offset without limit.');
        }
        
        $result = OCIParse($this->conn->getResource(), $sql);
        if (!$result) {
            throw new SQLException("Unable to prepare query", $this->conn->nativeError(), $this->sqlToOracleBindVars($sql));
        }
        
        // bind all variables
        $this->bindVars($result);
        
        $success = OCIExecute($result, OCI_DEFAULT);
        if (!$success) {
            throw new SQLException("Unable to execute query", $this->conn->nativeError($result), $this->sqlToOracleBindVars($sql));
        }
        
        $this->resultSet = new OCI8ResultSet($this->conn, $result, $fetchmode);
        
        return $this->resultSet;
    }
    
    public function executeUpdate($params = null) 
    {
        if ($params) {
            for($i=0,$cnt=count($params); $i < $cnt; $i++) {
                $this->set($i+1, $params[$i]);
            }
        }

        if($this->resultSet) $this->resultSet->close();
        $this->resultSet = null; // reset
        
        $stmt = OCIParse($this->conn->getResource(), $this->sqlToOracleBindVars($this->sql));
        if (!$stmt) {
            throw new SQLException("Unable to prepare update", $this->conn->nativeError(), $this->sqlToOracleBindVars($sql));
        }
        
        // bind all variables
        $this->bindVars($stmt);        

        // Even if autocommit is on, delay commit until after LOBS have been saved
        $success = OCIExecute($stmt, OCI_DEFAULT);
        if (!$success) {
            throw new SQLException("Unable to execute update", $this->conn->nativeError($stmt), $this->sqlToOracleBindVars($sql));
        }        

        // save data in any LOB descriptors, then free them
        foreach($this->lobDescriptors as $paramIndex => $lobster) {
            $lob = $this->lobs[$paramIndex]; // corresponding Blob/Clob
            if ($lob->isFromFile()) {
                $success = $lobster->savefile($lob->getInputFile());
            } else {
                $success = $lobster->save($lob->getContents());
            }
            if (!$success) {                
                $lobster->free();
                throw new SQLException("Error saving lob bound to " . $paramIndex);
            }
            $lobster->free();
        }

        if ($this->conn->getAutoCommit()) {
            OCICommit($this->conn->getResource()); // perform deferred commit
        }
        
        $this->updateCount = @OCIRowCount($stmt);

        return $this->updateCount;
    }

    private function bindVars($stmt)
    {
        foreach ($this->boundInVars as $idx => $val) {
            $idxName = ":var" . $idx;
            if (is_a($val, 'Blob') && !OCIBindByName($stmt, $idxName, $this->lobDescriptors[$idx], -1, OCI_B_BLOB)) {
                throw new SQLException("Erorr binding blob to placeholder " . $idx);
            } elseif (is_a($val, 'Clob') && !OCIBindByName($stmt, $idxName, $this->lobDescriptors[$idx], -1, OCI_B_CLOB)) {
                throw new SQLException("Erorr binding clob to placeholder " . $idx);
            } elseif (!OCIBindByName($stmt, $idxName, $val, -1)) {
                throw new SQLException("Erorr binding value to placeholder " . $idx);
            }            
        } // foreach
    }


    private function sqlToOracleBindVars($sql)
    {
        $out = "";
        $in_literal = 0;
        $idxNum = 1;
        for ($i = 0; $i < strlen($sql); $i++) {
            $char = $sql[$i];
            if (strcmp($char,"'")==0) {
                $in_literal = ~$in_literal;
            }
            if (strcmp($char,"?")==0 && !$in_literal) {
                $out .= ":var" . $idxNum++;
            } else {
                $out .= $char;
            }
        }
        return $out;
    }

    function setBlob($paramIndex, $blob) 
    {
        require_once 'creole/util/Blob.php';
        if (!($blob instanceof Blob)) {
            $b = new Blob();
            $b->setContents($blob);
            $blob = $b;
        }
        $this->lobDescriptors[$paramIndex] = OCINewDescriptor($this->conn->getResource(), OCI_D_LOB);
        $this->lobs[$paramIndex] = $blob;        
    }

    function setClob($paramIndex, $clob) 
    {
        require_once 'creole/util/Clob.php';
        if (!($clob instanceof Clob)) {
            $c = new Clob();
            $c->setContents($clob);
            $clob = $c;
        }
        $this->lobDescriptors[$paramIndex] = OCINewDescriptor($this->conn->getResource(), OCI_D_LOB);
        $this->lobs[$paramIndex] = $clob;        
    }

}

---

This file is part of the Creole[php5] library.