WebSVN – Applications.gtt – Diff – /trunk/bibliotheque/pear/DB/oci8.php

 /**
  * The PEAR DB driver for PHP's oci8 extension
  * for interacting with Oracle databases
  *
- * PHP versions 4 and 5
+ * PHP version 5
+ *
  * LICENSE: This source file is subject to version 3.0 of the PHP license
  * that is available through the world-wide-web at the following URI:
  * http://www.php.net/license/3_0.txt.  If you did not receive a copy of
+ *
  * @category   Database
  * @package    DB
  * @author     James L. Pine <jlp@valinux.com>
  * @author     Daniel Convissor <danielc@php.net>
- * @copyright  1997-2005 The PHP Group
+ * @copyright  1997-2007 The PHP Group
  * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
- * @version    CVS: $Id: oci8.php,v 1.103 2005/04/11 15:10:22 danielc Exp $
+ * @version    CVS: $Id$
  * @link       http://pear.php.net/package/DB
  */
 /**
+ *
  * @category   Database
  * @package    DB
  * @author     James L. Pine <jlp@valinux.com>
  * @author     Daniel Convissor <danielc@php.net>
- * @copyright  1997-2005 The PHP Group
+ * @copyright  1997-2007 The PHP Group
  * @license    http://www.php.net/license/3_0.txt  PHP License 3.0
- * @version    Release: 1.7.6
+ * @version    Release: 1.9.2
  * @link       http://pear.php.net/package/DB
  */
 class DB_oci8 extends DB_common
+{
     // {{{ properties
     /**
      * A mapping of native error codes to DB error codes
      * @var array
      */
     var $errorcode_map = array(
 => DB_ERROR_CONSTRAINT,
 => DB_ERROR_SYNTAX,
 => DB_ERROR_NOSUCHFIELD,
 => DB_ERROR_VALUE_COUNT_ON_ROW,
 => DB_ERROR_SYNTAX,
 => DB_ERROR_SYNTAX,
 => DB_ERROR_NOSUCHTABLE,
 => DB_ERROR_ALREADY_EXISTS,
 => DB_ERROR_CONSTRAINT_NOT_NULL,
 => DB_ERROR_INVALID,
 => DB_ERROR_CONSTRAINT_NOT_NULL,
 => DB_ERROR_NOT_FOUND,
 => DB_ERROR_DIVZERO,
 => DB_ERROR_INVALID_NUMBER,
 => DB_ERROR_NOSUCHTABLE,
 => DB_ERROR_CONSTRAINT,
 => DB_ERROR_CONSTRAINT,
 => DB_ERROR_CONSTRAINT,
+=> DB_ERROR_INVALID,
     );
     /**
      * The raw database connection created by PHP
      * @var array
      * @access private
      */
     var $manip_query = array();
+    /**
+     * Store of prepared SQL queries.
+     * @var array
+     * @access private
+     */
+    var $_prepared_queries = array();
     // }}}
     // {{{ constructor
     /**
-     * This constructor calls <kbd>$this->DB_common()</kbd>
+     * This constructor calls <kbd>parent::__construct()</kbd>
      *
      * @return void
      */
-    function DB_oci8()
+    function __construct()
+    {
-        $this->DB_common();
+        parent::__construct();
         $this->dsn = $dsn;
         if ($dsn['dbsyntax']) {
             $this->dbsyntax = $dsn['dbsyntax'];
+        }
+        // Backwards compatibility with DB < 1.7.0
+        if (empty($dsn['database']) && !empty($dsn['hostspec'])) {
+            $db = $dsn['hostspec'];
+        } else {
+            $db = $dsn['database'];
+        }
         if (function_exists('oci_connect')) {
             if (isset($dsn['new_link'])
                 && ($dsn['new_link'] == 'true' || $dsn['new_link'] === true))
+            {
                 $connect_function = 'oci_new_connect';
             } else {
                 $connect_function = $persistent ? 'oci_pconnect'
                                     : 'oci_connect';
-            }
-            // Backwards compatibility with DB < 1.7.0
+            }
-            if (empty($dsn['database']) && !empty($dsn['hostspec'])) {
+            if (isset($this->dsn['port']) && $this->dsn['port']) {
-                $db = $dsn['hostspec'];
-            } else {
-                $db = $dsn['database'];
+                $db = '//'.$db.':'.$this->dsn['port'];
+            }
             $char = empty($dsn['charset']) ? null : $dsn['charset'];
                                                        null,
                                                        $char);
+            }
         } else {
             $connect_function = $persistent ? 'OCIPLogon' : 'OCILogon';
-            if ($dsn['hostspec']) {
+            if ($db) {
                 $this->connection = @$connect_function($dsn['username'],
                                                        $dsn['password'],
-                                                       $dsn['hostspec']);
+                                                       $db);
             } elseif ($dsn['username'] || $dsn['password']) {
                 $this->connection = @$connect_function($dsn['username'],
                                                        $dsn['password']);
+            }
+        }
+        }
         if (!$success) {
             return $this->oci8RaiseError($result);
+        }
         $this->last_stmt = $result;
-        if (DB::isManip($query)) {
+        if ($this->_checkManip($query)) {
             return DB_OK;
         } else {
             @ocisetprefetch($result, $this->options['result_buffering']);
             return $result;
+        }
+     *
      * @see DB_result::free()
      */
     function freeResult($result)
+    {
-        return @OCIFreeStatement($result);
+        return is_resource($result) ? OCIFreeStatement($result) : false;
+    }
     /**
      * Frees the internal resources associated with a prepared query
             @ocifreestatement($stmt);
+        }
         if (isset($this->prepare_types[(int)$stmt])) {
             unset($this->prepare_types[(int)$stmt]);
             unset($this->manip_query[(int)$stmt]);
+            unset($this->_prepared_queries[(int)$stmt]);
         } else {
             return false;
+        }
         return true;
+    }
+        {
             $countquery = 'SELECT COUNT(*) FROM ('.$this->last_query.')';
             $save_query = $this->last_query;
             $save_stmt = $this->last_stmt;
-            if (count($this->_data)) {
-                $smt = $this->prepare('SELECT COUNT(*) FROM ('.$this->last_query.')');
-                $count = $this->execute($smt, $this->_data);
-            } else {
-                $count =& $this->query($countquery);
+            $count = $this->query($countquery);
+            // Restore the last query and statement.
+            $this->last_query = $save_query;
             $this->last_stmt = $save_stmt;
             if (DB::isError($count) ||
-                DB::isError($row = $count->fetchRow(DB_FETCHMODE_ORDERED)))
-            {
-                $this->last_query = $save_query;
+                DB::isError($row = $count->fetchRow(DB_FETCHMODE_ORDERED)))
                 $this->last_stmt = $save_stmt;
+                return $this->raiseError(DB_ERROR_NOT_CAPABLE);
                 return $this->raiseError(DB_ERROR_NOT_CAPABLE);
             return $row[0];
+        }
         if (!$stmt = @OCIParse($this->connection, $newquery)) {
             return $this->oci8RaiseError();
+        }
         $this->prepare_types[(int)$stmt] = $types;
         $this->manip_query[(int)$stmt] = DB::isManip($query);
+        $this->_prepared_queries[(int)$stmt] = $newquery;
         return $stmt;
+    }
     // }}}
      */
     function &execute($stmt, $data = array())
+    {
         $data = (array)$data;
         $this->last_parameters = $data;
+        $this->last_query = $this->_prepared_queries[(int)$stmt];
         $this->_data = $data;
-        $types =& $this->prepare_types[(int)$stmt];
+        $types = $this->prepare_types[(int)$stmt];
         if (count($types) != count($data)) {
-            $tmp =& $this->raiseError(DB_ERROR_MISMATCH);
+            $tmp = $this->raiseError(DB_ERROR_MISMATCH);
             return $tmp;
+        }
                 $data[$key] = preg_replace("/^'(.*)'$/", "\\1", $data[$key]);
                 $data[$key] = str_replace("''", "'", $data[$key]);
             } elseif ($types[$i] == DB_PARAM_OPAQUE) {
                 $fp = @fopen($data[$key], 'rb');
                 if (!$fp) {
-                    $tmp =& $this->raiseError(DB_ERROR_ACCESS_VIOLATION);
+                    $tmp = $this->raiseError(DB_ERROR_ACCESS_VIOLATION);
                     return $tmp;
+                }
                 $data[$key] = fread($fp, filesize($data[$key]));
                 fclose($fp);
+            } elseif ($types[$i] == DB_PARAM_SCALAR) {
+                // Floats have to be converted to a locale-neutral
+                // representation.
+                if (is_float($data[$key])) {
+                    $data[$key] = $this->quoteFloat($data[$key]);
+                }
+            }
             if (!@OCIBindByName($stmt, ':bind' . $i, $data[$key], -1)) {
                 $tmp = $this->oci8RaiseError($stmt);
                 return $tmp;
+            }
+            $this->last_query = preg_replace("/:bind$i(?!\d)/",
+                    $this->quoteSmart($data[$key]), $this->last_query, 1);
             $i++;
+        }
         if ($this->autocommit) {
             $success = @OCIExecute($stmt, OCI_COMMIT_ON_SUCCESS);
         } else {
         if (!$success) {
             $tmp = $this->oci8RaiseError($stmt);
             return $tmp;
+        }
         $this->last_stmt = $stmt;
+        if ($this->manip_query[(int)$stmt] || $this->_next_query_manip) {
-        if ($this->manip_query[(int)$stmt]) {
+            $this->_last_query_manip = true;
+            $this->_next_query_manip = false;
             $tmp = DB_OK;
         } else {
+            $this->_last_query_manip = false;
             @ocisetprefetch($stmt, $this->options['result_buffering']);
-            $tmp =& new DB_result($this, $stmt);
+            $tmp = new DB_result($this, $stmt);
+        }
         return $tmp;
+    }
         // coding a "home" SQL parser
         if (count($params)) {
             $result = $this->prepare("SELECT * FROM ($query) "
                                      . 'WHERE NULL = NULL');
-            $tmp =& $this->execute($result, $params);
+            $tmp = $this->execute($result, $params);
         } else {
             $q_fields = "SELECT * FROM ($query) WHERE NULL = NULL";
+    {
         $seqname = $this->getSequenceName($seq_name);
         $repeat = 0;
         do {
             $this->expectError(DB_ERROR_NOSUCHTABLE);
-            $result =& $this->query("SELECT ${seqname}.nextval FROM dual");
+            $result = $this->query("SELECT ${seqname}.nextval FROM dual");
             $this->popExpect();
             if ($ondemand && DB::isError($result) &&
                 $result->getCode() == DB_ERROR_NOSUCHTABLE) {
                 $repeat = 1;
                 $result = $this->createSequence($seq_name);
                 return $this->oci8RaiseError(DB_ERROR_NEED_MORE_DATA);
+            }
             if (!@OCIExecute($stmt, OCI_DEFAULT)) {
                 return $this->oci8RaiseError($stmt);
+            }
             $i = 0;
             while (@OCIFetch($stmt)) {
                 $res[$i] = array(
                     'table' => $case_func($result),
                     'name'  => $case_func(@OCIResult($stmt, 1)),
         switch ($type) {
             case 'tables':
                 return 'SELECT table_name FROM user_tables';
             case 'synonyms':
                 return 'SELECT synonym_name FROM user_synonyms';
+            case 'views':
+                return 'SELECT view_name FROM user_views';
             default:
                 return null;
+        }
+    }
+    // }}}
+    // {{{ quoteFloat()
+    /**
+     * Formats a float value for use within a query in a locale-independent
+     * manner.
+     *
+     * @param float the float value to be quoted.
+     * @return string the quoted string.
+     * @see DB_common::quoteSmart()
+     * @since Method available since release 1.7.8.
+     */
+    function quoteFloat($float) {
+        return $this->escapeSimple(str_replace(',', '.', strval(floatval($float))));
+    }
     // }}}
+}

Subversion Repositories Applications.gtt

(root)/trunk/bibliotheque/pear/DB/oci8.php – Rev 94 → 187