[Sommaire] [Imprimer]

   1  <?php
   2  /* 
   3  V4.94 23 Jan 2007  (c) 2000-2007 John Lim (jlim#natsoft.com.my). All rights reserved.
   4    Released under both BSD license and Lesser GPL library license. 
   5    Whenever there is any discrepancy between the two licenses, 
   6    the BSD license will take precedence. 
   7  Set tabs to 4 for best viewing.
   8    
   9    Latest version is available at http://adodb.sourceforge.net
  10    
  11    Requires ODBC. Works on Windows and Unix.
  12  
  13      Problems: 
  14          Where is float/decimal type in pdo_param_type
  15          LOB handling for CLOB/BLOB differs significantly
  16  */
  17  // security - hide paths
  18  if (!defined('ADODB_DIR')) die();
  19  
  20  
  21  /*
  22  enum pdo_param_type {
  23  PDO::PARAM_NULL, 0
  24  
  25  /* int as in long (the php native int type).
  26   * If you mark a column as an int, PDO expects get_col to return
  27   * a pointer to a long 
  28  PDO::PARAM_INT, 1
  29  
  30  /* get_col ptr should point to start of the string buffer 
  31  PDO::PARAM_STR, 2
  32  
  33  /* get_col: when len is 0 ptr should point to a php_stream *,
  34   * otherwise it should behave like a string. Indicate a NULL field
  35   * value by setting the ptr to NULL 
  36  PDO::PARAM_LOB, 3
  37  
  38  /* get_col: will expect the ptr to point to a new PDOStatement object handle,
  39   * but this isn't wired up yet 
  40  PDO::PARAM_STMT, 4 /* hierarchical result set 
  41  
  42  /* get_col ptr should point to a zend_bool 
  43  PDO::PARAM_BOOL, 5
  44  
  45  
  46  /* magic flag to denote a parameter as being input/output 
  47  PDO::PARAM_INPUT_OUTPUT = 0x80000000
  48  };
  49  */
  50      
  51  function adodb_pdo_type($t)
  52  {
  53      switch($t) {
  54      case 2: return 'VARCHAR';
  55      case 3: return 'BLOB';
  56      default: return 'NUMERIC';
  57      }
  58  }
  59       
  60  /*--------------------------------------------------------------------------------------
  61  --------------------------------------------------------------------------------------*/
  62  
  63  ////////////////////////////////////////////////
  64  
  65  
  66  
  67  class ADODB_pdo_base extends ADODB_pdo {
  68  
  69      var $sysDate = "'?'";
  70      var $sysTimeStamp = "'?'";
  71      
  72  
  73  	function _init($parentDriver)
  74      {
  75          $parentDriver->_bindInputArray = true;
  76          #$parentDriver->_connectionID->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY,true);
  77      }
  78      
  79  	function ServerInfo()
  80      {
  81          return ADOConnection::ServerInfo();
  82      }
  83      
  84  	function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
  85      {
  86          $ret = ADOConnection::SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
  87          return $ret;
  88      }
  89      
  90  	function MetaTables()
  91      {
  92          return false;
  93      }
  94      
  95  	function MetaColumns()
  96      {
  97          return false;
  98      }
  99  }
 100  
 101  
 102  class ADODB_pdo extends ADOConnection {
 103      var $databaseType = "pdo";    
 104      var $dataProvider = "pdo";
 105      var $fmtDate = "'Y-m-d'";
 106      var $fmtTimeStamp = "'Y-m-d, h:i:sA'";
 107      var $replaceQuote = "''"; // string to use to replace quotes
 108      var $hasAffectedRows = true;
 109      var $_bindInputArray = true;    
 110      var $_genSeqSQL = "create table %s (id integer)";
 111      var $_autocommit = true;
 112      var $_haserrorfunctions = true;
 113      var $_lastAffectedRows = 0;
 114      
 115      var $_errormsg = false;
 116      var $_errorno = false;
 117      
 118      var $dsnType = '';
 119      var $stmt = false;
 120      
 121  	function ADODB_pdo()
 122      {
 123      }
 124      
 125  	function _UpdatePDO()
 126      {
 127          $d = &$this->_driver;
 128          $this->fmtDate = $d->fmtDate;
 129          $this->fmtTimeStamp = $d->fmtTimeStamp;
 130          $this->replaceQuote = $d->replaceQuote;
 131          $this->sysDate = $d->sysDate;
 132          $this->sysTimeStamp = $d->sysTimeStamp;
 133          $this->random = $d->random;
 134          $this->concat_operator = $d->concat_operator;
 135          $this->nameQuote = $d->nameQuote;
 136                  
 137          $this->hasGenID = $d->hasGenID;
 138          $this->_genIDSQL = $d->_genIDSQL;
 139          $this->_genSeqSQL = $d->_genSeqSQL;
 140          $this->_dropSeqSQL = $d->_dropSeqSQL;
 141  
 142          $d->_init($this);
 143      }
 144      
 145  	function Time()
 146      {
 147          if (!empty($this->_driver->_hasdual)) $sql = "select $this->sysTimeStamp from dual";
 148          else $sql = "select $this->sysTimeStamp";
 149          
 150          $rs =& $this->_Execute($sql);
 151          if ($rs && !$rs->EOF) return $this->UnixTimeStamp(reset($rs->fields));
 152          
 153          return false;
 154      }
 155      
 156      // returns true or false
 157  	function _connect($argDSN, $argUsername, $argPassword, $argDatabasename, $persist=false)
 158      {
 159          $at = strpos($argDSN,':');
 160          $this->dsnType = substr($argDSN,0,$at);
 161  
 162          if ($argDatabasename) {
 163              $argDSN .= ';dbname='.$argDatabasename;
 164          }
 165          try {
 166              $this->_connectionID = new PDO($argDSN, $argUsername, $argPassword);
 167          } catch (Exception $e) {
 168              $this->_connectionID = false;
 169              $this->_errorno = -1;
 170              //var_dump($e);
 171              $this->_errormsg = 'Connection attempt failed: '.$e->getMessage();
 172              return false;
 173          }
 174          
 175          if ($this->_connectionID) {
 176              switch(ADODB_ASSOC_CASE){
 177              case 0: $m = PDO::CASE_LOWER; break;
 178              case 1: $m = PDO::CASE_UPPER; break;
 179              default:
 180              case 2: $m = PDO::CASE_NATURAL; break;
 181              }
 182              
 183              //$this->_connectionID->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT );
 184              $this->_connectionID->setAttribute(PDO::ATTR_CASE,$m);
 185              
 186              $class = 'ADODB_pdo_'.$this->dsnType;
 187              //$this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
 188              switch($this->dsnType) {
 189              case 'oci':
 190              case 'mysql':
 191              case 'pgsql':
 192              case 'mssql':
 193                  include_once(ADODB_DIR.'/drivers/adodb-pdo_'.$this->dsnType.'.inc.php');
 194                  break;
 195              }
 196              if (class_exists($class))
 197                  $this->_driver = new $class();
 198              else
 199                  $this->_driver = new ADODB_pdo_base();
 200              
 201              $this->_driver->_connectionID = $this->_connectionID;
 202              $this->_UpdatePDO();
 203              return true;
 204          }
 205          $this->_driver = new ADODB_pdo_base();
 206          return false;
 207      }
 208      
 209      // returns true or false
 210  	function _pconnect($argDSN, $argUsername, $argPassword, $argDatabasename)
 211      {
 212          return $this->_connect($argDSN, $argUsername, $argPassword, $argDatabasename, true);
 213      }
 214      
 215      /*------------------------------------------------------------------------------*/
 216      
 217      
 218  	function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0) 
 219      {    
 220          $save = $this->_driver->fetchMode;
 221          $this->_driver->fetchMode = $this->fetchMode;
 222           $this->_driver->debug = $this->debug;
 223          $ret = $this->_driver->SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
 224          $this->_driver->fetchMode = $save;
 225          return $ret;
 226      }
 227      
 228      
 229  	function ServerInfo()
 230      {
 231          return $this->_driver->ServerInfo();
 232      }
 233      
 234  	function MetaTables($ttype=false,$showSchema=false,$mask=false)
 235      {
 236          return $this->_driver->MetaTables($ttype,$showSchema,$mask);
 237      }
 238      
 239  	function MetaColumns($table,$normalize=true)
 240      {
 241          return $this->_driver->MetaColumns($table,$normalize);
 242      }
 243      
 244  	function InParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
 245      {
 246          $obj = $stmt[1];
 247          if ($type) $obj->bindParam($name,$var,$type,$maxLen);
 248          else $obj->bindParam($name, $var);
 249      }
 250      
 251      
 252  	function ErrorMsg()
 253      {
 254          if ($this->_errormsg !== false) return $this->_errormsg;
 255          if (!empty($this->_stmt)) $arr = $this->_stmt->errorInfo();
 256          else if (!empty($this->_connectionID)) $arr = $this->_connectionID->errorInfo();
 257          else return 'No Connection Established';
 258          
 259          
 260          if ($arr) {
 261               if (sizeof($arr)<2) return '';
 262              if ((integer)$arr[1]) return $arr[2];
 263              else return '';
 264          } else return '-1';
 265      }
 266      
 267  
 268  	function ErrorNo()
 269      {
 270          if ($this->_errorno !== false) return $this->_errorno;
 271          if (!empty($this->_stmt)) $err = $this->_stmt->errorCode();
 272          else if (!empty($this->_connectionID)) {
 273              $arr = $this->_connectionID->errorInfo();
 274              if (isset($arr[0])) $err = $arr[0];
 275              else $err = -1;
 276          } else
 277              return 0;
 278              
 279          if ($err == '00000') return 0; // allows empty check
 280          return $err;
 281      }
 282  
 283  	function BeginTrans()
 284      {    
 285          if (!$this->hasTransactions) return false;
 286          if ($this->transOff) return true; 
 287          $this->transCnt += 1;
 288          $this->_autocommit = false;
 289          $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,false);
 290          return $this->_connectionID->beginTransaction();
 291      }
 292      
 293  	function CommitTrans($ok=true) 
 294      { 
 295          if (!$this->hasTransactions) return false;
 296          if ($this->transOff) return true; 
 297          if (!$ok) return $this->RollbackTrans();
 298          if ($this->transCnt) $this->transCnt -= 1;
 299          $this->_autocommit = true;
 300          
 301          $ret = $this->_connectionID->commit();
 302          $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
 303          return $ret;
 304      }
 305      
 306  	function RollbackTrans()
 307      {
 308          if (!$this->hasTransactions) return false;
 309          if ($this->transOff) return true; 
 310          if ($this->transCnt) $this->transCnt -= 1;
 311          $this->_autocommit = true;
 312          
 313          $ret = $this->_connectionID->rollback();
 314          $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
 315          return $ret;
 316      }
 317      
 318  	function Prepare($sql)
 319      {
 320          $this->_stmt = $this->_connectionID->prepare($sql);
 321          if ($this->_stmt) return array($sql,$this->_stmt);
 322          
 323          return false;
 324      }
 325      
 326  	function PrepareStmt($sql)
 327      {
 328          $stmt = $this->_connectionID->prepare($sql);
 329          if (!$stmt) return false;
 330          $obj = new ADOPDOStatement($stmt,$this);
 331          return $obj;
 332      }
 333      
 334      
 335      /* returns queryID or false */
 336  	function _query($sql,$inputarr=false) 
 337      {
 338          if (is_array($sql)) {
 339              $stmt = $sql[1];
 340          } else {
 341              $stmt = $this->_connectionID->prepare($sql);
 342          }
 343          #adodb_backtrace();
 344          #var_dump($this->_bindInputArray);
 345          if ($stmt) {
 346              $this->_driver->debug = $this->debug;
 347              if ($inputarr) $ok = $stmt->execute($inputarr);
 348              else $ok = $stmt->execute();
 349          } 
 350          
 351          
 352          $this->_errormsg = false;
 353          $this->_errorno = false;
 354              
 355          if ($ok) {
 356              $this->_stmt = $stmt;
 357              return $stmt;
 358          }
 359          
 360          if ($stmt) {
 361              
 362              $arr = $stmt->errorinfo();
 363              if ((integer)$arr[1]) {
 364                  $this->_errormsg = $arr[2];
 365                  $this->_errorno = $arr[1];
 366              }
 367  
 368          } else {
 369              $this->_errormsg = false;
 370              $this->_errorno = false;
 371          }
 372          return false;
 373      }
 374  
 375      // returns true or false
 376  	function _close()
 377      {
 378          $this->_stmt = false;
 379          return true;
 380      }
 381  
 382  	function _affectedrows()
 383      {
 384          return ($this->_stmt) ? $this->_stmt->rowCount() : 0;
 385      }
 386      
 387  	function _insertid()
 388      {
 389          return ($this->_connectionID) ? $this->_connectionID->lastInsertId() : 0;
 390      }
 391  }
 392  
 393  class ADOPDOStatement {
 394  
 395      var $databaseType = "pdo";        
 396      var $dataProvider = "pdo";
 397      var $_stmt;
 398      var $_connectionID;
 399      
 400  	function ADOPDOStatement($stmt,$connection)
 401      {
 402          $this->_stmt = $stmt;
 403          $this->_connectionID = $connection;
 404      }
 405      
 406  	function Execute($inputArr=false)
 407      {
 408          $savestmt = $this->_connectionID->_stmt;
 409          $rs = $this->_connectionID->Execute(array(false,$this->_stmt),$inputArr);
 410          $this->_connectionID->_stmt = $savestmt;
 411          return $rs;
 412      }
 413      
 414  	function InParameter(&$var,$name,$maxLen=4000,$type=false)
 415      {
 416  
 417          if ($type) $this->_stmt->bindParam($name,$var,$type,$maxLen);
 418          else $this->_stmt->bindParam($name, $var);
 419      }
 420      
 421  	function Affected_Rows()
 422      {
 423          return ($this->_stmt) ? $this->_stmt->rowCount() : 0;
 424      }
 425      
 426  	function ErrorMsg()
 427      {
 428          if ($this->_stmt) $arr = $this->_stmt->errorInfo();
 429          else $arr = $this->_connectionID->errorInfo();
 430  
 431          if (is_array($arr)) {
 432              if ((integer) $arr[0] && isset($arr[2])) return $arr[2];
 433              else return '';
 434          } else return '-1';
 435      }
 436      
 437  	function NumCols()
 438      {
 439          return ($this->_stmt) ? $this->_stmt->columnCount() : 0;
 440      }
 441      
 442  	function ErrorNo()
 443      {
 444          if ($this->_stmt) return $this->_stmt->errorCode();
 445          else return $this->_connectionID->errorInfo();
 446      }
 447  }
 448  
 449  /*--------------------------------------------------------------------------------------
 450       Class Name: Recordset
 451  --------------------------------------------------------------------------------------*/
 452  
 453  class ADORecordSet_pdo extends ADORecordSet {    
 454      
 455      var $bind = false;
 456      var $databaseType = "pdo";        
 457      var $dataProvider = "pdo";
 458      
 459  	function ADORecordSet_pdo($id,$mode=false)
 460      {
 461          if ($mode === false) {  
 462              global $ADODB_FETCH_MODE;
 463              $mode = $ADODB_FETCH_MODE;
 464          }
 465          $this->adodbFetchMode = $mode;
 466          switch($mode) {
 467          case ADODB_FETCH_NUM: $mode = PDO::FETCH_NUM; break;
 468          case ADODB_FETCH_ASSOC:  $mode = PDO::FETCH_ASSOC; break;
 469          
 470          case ADODB_FETCH_BOTH: 
 471          default: $mode = PDO::FETCH_BOTH; break;
 472          }
 473          $this->fetchMode = $mode;
 474          
 475          $this->_queryID = $id;
 476          $this->ADORecordSet($id);
 477      }
 478  
 479      
 480  	function Init()
 481      {
 482          if ($this->_inited) return;
 483          $this->_inited = true;
 484          if ($this->_queryID) @$this->_initrs();
 485          else {
 486              $this->_numOfRows = 0;
 487              $this->_numOfFields = 0;
 488          }
 489          if ($this->_numOfRows != 0 && $this->_currentRow == -1) {
 490              $this->_currentRow = 0;
 491              if ($this->EOF = ($this->_fetch() === false)) {
 492                  $this->_numOfRows = 0; // _numOfRows could be -1
 493              }
 494          } else {
 495              $this->EOF = true;
 496          }
 497      }
 498      
 499  	function _initrs()
 500      {
 501      global $ADODB_COUNTRECS;
 502      
 503          $this->_numOfRows = ($ADODB_COUNTRECS) ? @$this->_queryID->rowCount() : -1;
 504          if (!$this->_numOfRows) $this->_numOfRows = -1;
 505          $this->_numOfFields = $this->_queryID->columnCount();
 506      }
 507  
 508      // returns the field object
 509      function &FetchField($fieldOffset = -1) 
 510      {
 511          $off=$fieldOffset+1; // offsets begin at 1
 512          
 513          $o= new ADOFieldObject();
 514          $arr = @$this->_queryID->getColumnMeta($fieldOffset);
 515          if (!$arr) {
 516              $o->name = 'bad getColumnMeta()';
 517              $o->max_length = -1;
 518              $o->type = 'VARCHAR';
 519              $o->precision = 0;
 520      #        $false = false;
 521              return $o;
 522          }
 523          //adodb_pr($arr);
 524          $o->name = $arr['name'];
 525          if (isset($arr['native_type']) && $arr['native_type'] <> "null") $o->type = $arr['native_type'];
 526          else $o->type = adodb_pdo_type($arr['pdo_type']);
 527          $o->max_length = $arr['len'];
 528          $o->precision = $arr['precision'];
 529          
 530          if (ADODB_ASSOC_CASE == 0) $o->name = strtolower($o->name);
 531          else if (ADODB_ASSOC_CASE == 1) $o->name = strtoupper($o->name);
 532          return $o;
 533      }
 534      
 535  	function _seek($row)
 536      {
 537          return false;
 538      }
 539      
 540  	function _fetch()
 541      {
 542          if (!$this->_queryID) return false;
 543          
 544          $this->fields = $this->_queryID->fetch($this->fetchMode);
 545          return !empty($this->fields);
 546      }
 547      
 548  	function _close() 
 549      {
 550          $this->_queryID = false;
 551      }
 552      
 553  	function Fields($colname)
 554      {
 555          if ($this->adodbFetchMode != ADODB_FETCH_NUM) return @$this->fields[$colname];
 556          
 557          if (!$this->bind) {
 558              $this->bind = array();
 559              for ($i=0; $i < $this->_numOfFields; $i++) {
 560                  $o = $this->FetchField($i);
 561                  $this->bind[strtoupper($o->name)] = $i;
 562              }
 563          }
 564           return $this->fields[$this->bind[strtoupper($colname)]];
 565      }
 566  
 567  }
 568  
 569  ?>