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

   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 ?>