lib/adodb/drivers/adodb-oci8po.inc.php

   1 <?php
   2 /*
   3 @version   v5.20.3  01-Jan-2016
   4 @copyright (c) 2000-2013 John Lim. All rights reserved.
   5 @copyright (c) 2014      Damien Regad, Mark Newnham and the ADOdb community
   6   Released under both BSD license and Lesser GPL library license.
   7   Whenever there is any discrepancy between the two licenses,
   8   the BSD license will take precedence.
   9
  10   Latest version is available at http://adodb.sourceforge.net
  11
  12   Portable version of oci8 driver, to make it more similar to other database drivers.
  13   The main differences are
  14
  15    1. that the OCI_ASSOC names are in lowercase instead of uppercase.
  16    2. bind variables are mapped using ? instead of :<bindvar>
  17
  18    Should some emulation of RecordCount() be implemented?
  19
  20 */
  21
  22 // security - hide paths
  23 if (!defined('ADODB_DIR')) die();
  24
  25 include_once(ADODB_DIR.'/drivers/adodb-oci8.inc.php');
  26
  27 class ADODB_oci8po extends ADODB_oci8 {
  28         var $databaseType = 'oci8po';
  29         var $dataProvider = 'oci8';
  30         var $metaColumnsSQL = "select lower(cname),coltype,width, SCALE, PRECISION, NULLS, DEFAULTVAL from col where tname='%s' order by colno"; //changed by smondino@users.sourceforge. net
  31         var $metaTablesSQL = "select lower(table_name),table_type from cat where table_type in ('TABLE','VIEW')";
  32
  33         function __construct()
  34         {
  35                 $this->_hasOCIFetchStatement = ADODB_PHPVER >= 0x4200;
  36                 # oci8po does not support adodb extension: adodb_movenext()
  37         }
  38
  39         function Param($name,$type='C')
  40         {
  41                 return '?';
  42         }
  43
  44         function Prepare($sql,$cursor=false)
  45         {
  46                 $sqlarr = explode('?',$sql);
  47                 $sql = $sqlarr[0];
  48                 for ($i = 1, $max = sizeof($sqlarr); $i < $max; $i++) {
  49                         $sql .=  ':'.($i-1) . $sqlarr[$i];
  50                 }
  51                 return ADODB_oci8::Prepare($sql,$cursor);
  52         }
  53
  54         function Execute($sql,$inputarr=false)
  55         {
  56                 return ADOConnection::Execute($sql,$inputarr);
  57         }
  58
  59         // emulate handling of parameters ? ?, replacing with :bind0 :bind1
  60         function _query($sql,$inputarr=false)
  61         {
  62                 if (is_array($inputarr)) {
  63                         $i = 0;
  64                         if (is_array($sql)) {
  65                                 foreach($inputarr as $v) {
  66                                         $arr['bind'.$i++] = $v;
  67                                 }
  68                         } else {
  69                                 // Need to identify if the ? is inside a quoted string, and if
  70                                 // so not use it as a bind variable
  71                                 preg_match_all('/".*\??"|\'.*\?.*?\'/', $sql, $matches);
  72                                 foreach($matches[0] as $qmMatch){
  73                                         $qmReplace = str_replace('?', '-QUESTIONMARK-', $qmMatch);
  74                                         $sql = str_replace($qmMatch, $qmReplace, $sql);
  75                                 }
  76
  77                                 $sqlarr = explode('?',$sql);
  78                                 $sql = $sqlarr[0];
  79
  80                                 foreach($inputarr as $k => $v) {
  81                                         $sql .=  ":$k" . $sqlarr[++$i];
  82                                 }
  83
  84                                 $sql = str_replace('-QUESTIONMARK-', '?', $sql);
  85                         }
  86                 }
  87                 return ADODB_oci8::_query($sql,$inputarr);
  88         }
  89 }
  90
  91 /*--------------------------------------------------------------------------------------
  92                  Class Name: Recordset
  93 --------------------------------------------------------------------------------------*/
  94
  95 class ADORecordset_oci8po extends ADORecordset_oci8 {
  96
  97         var $databaseType = 'oci8po';
  98
  99         function __construct($queryID,$mode=false)
 100         {
 101                 parent::__construct($queryID,$mode);
 102         }
 103
 104         function Fields($colname)
 105         {
 106                 if ($this->fetchMode & OCI_ASSOC) return $this->fields[$colname];
 107
 108                 if (!$this->bind) {
 109                         $this->bind = array();
 110                         for ($i=0; $i < $this->_numOfFields; $i++) {
 111                                 $o = $this->FetchField($i);
 112                                 $this->bind[strtoupper($o->name)] = $i;
 113                         }
 114                 }
 115                  return $this->fields[$this->bind[strtoupper($colname)]];
 116         }
 117
 118         // lowercase field names...
 119         function _FetchField($fieldOffset = -1)
 120         {
 121                 $fld = new ADOFieldObject;
 122                 $fieldOffset += 1;
 123                 $fld->name = OCIcolumnname($this->_queryID, $fieldOffset);
 124                 if (ADODB_ASSOC_CASE == ADODB_ASSOC_CASE_LOWER) {
 125                         $fld->name = strtolower($fld->name);
 126                 }
 127                 $fld->type = OCIcolumntype($this->_queryID, $fieldOffset);
 128                 $fld->max_length = OCIcolumnsize($this->_queryID, $fieldOffset);
 129                 if ($fld->type == 'NUMBER') {
 130                         $sc = OCIColumnScale($this->_queryID, $fieldOffset);
 131                         if ($sc == 0) {
 132                                 $fld->type = 'INT';
 133                         }
 134                 }
 135                 return $fld;
 136         }
 137
 138         // 10% speedup to move MoveNext to child class
 139         function MoveNext()
 140         {
 141                 $ret = @oci_fetch_array($this->_queryID,$this->fetchMode);
 142                 if($ret !== false) {
 143                 global $ADODB_ANSI_PADDING_OFF;
 144                         $this->fields = $ret;
 145                         $this->_currentRow++;
 146                         $this->_updatefields();
 147
 148                         if (!empty($ADODB_ANSI_PADDING_OFF)) {
 149                                 foreach($this->fields as $k => $v) {
 150                                         if (is_string($v)) $this->fields[$k] = rtrim($v);
 151                                 }
 152                         }
 153                         return true;
 154                 }
 155                 if (!$this->EOF) {
 156                         $this->EOF = true;
 157                         $this->_currentRow++;
 158                 }
 159                 return false;
 160         }
 161
 162         /* Optimize SelectLimit() by using OCIFetch() instead of OCIFetchInto() */
 163         function GetArrayLimit($nrows,$offset=-1)
 164         {
 165                 if ($offset <= 0) {
 166                         $arr = $this->GetArray($nrows);
 167                         return $arr;
 168                 }
 169                 for ($i=1; $i < $offset; $i++)
 170                         if (!@OCIFetch($this->_queryID)) {
 171                                 $arr = array();
 172                                 return $arr;
 173                         }
 174                 $ret = @oci_fetch_array($this->_queryID,$this->fetchMode);
 175                 if ($ret === false) {
 176                         $arr = array();
 177                         return $arr;
 178                 }
 179                 $this->fields = $ret;
 180                 $this->_updatefields();
 181                 $results = array();
 182                 $cnt = 0;
 183                 while (!$this->EOF && $nrows != $cnt) {
 184                         $results[$cnt++] = $this->fields;
 185                         $this->MoveNext();
 186                 }
 187
 188                 return $results;
 189         }
 190
 191         function _fetch()
 192         {
 193                 global $ADODB_ANSI_PADDING_OFF;
 194
 195                 $ret = @oci_fetch_array($this->_queryID,$this->fetchMode);
 196                 if ($ret) {
 197                         $this->fields = $ret;
 198                         $this->_updatefields();
 199
 200                         if (!empty($ADODB_ANSI_PADDING_OFF)) {
 201                                 foreach($this->fields as $k => $v) {
 202                                         if (is_string($v)) $this->fields[$k] = rtrim($v);
 203                                 }
 204                         }
 205                 }
 206                 return $ret !== false;
 207         }
 208
 209 }