Updated adodb syysext to upstream version 5.0.8a.
[Packages/TYPO3.CMS.git] / typo3 / sysext / adodb / adodb / drivers / adodb-pdo.inc.php
1 <?php
2 /*
3 V5.08 6 Apr 2009 (c) 2000-2009 John Lim (jlim#natsoft.com). 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
68
69
70 class ADODB_pdo extends ADOConnection {
71 var $databaseType = "pdo";
72 var $dataProvider = "pdo";
73 var $fmtDate = "'Y-m-d'";
74 var $fmtTimeStamp = "'Y-m-d, h:i:sA'";
75 var $replaceQuote = "''"; // string to use to replace quotes
76 var $hasAffectedRows = true;
77 var $_bindInputArray = true;
78 var $_genSeqSQL = "create table %s (id integer)";
79 var $_autocommit = true;
80 var $_haserrorfunctions = true;
81 var $_lastAffectedRows = 0;
82
83 var $_errormsg = false;
84 var $_errorno = false;
85
86 var $dsnType = '';
87 var $stmt = false;
88
89 function ADODB_pdo()
90 {
91 }
92
93 function _UpdatePDO()
94 {
95 $d = $this->_driver;
96 $this->fmtDate = $d->fmtDate;
97 $this->fmtTimeStamp = $d->fmtTimeStamp;
98 $this->replaceQuote = $d->replaceQuote;
99 $this->sysDate = $d->sysDate;
100 $this->sysTimeStamp = $d->sysTimeStamp;
101 $this->random = $d->random;
102 $this->concat_operator = $d->concat_operator;
103 $this->nameQuote = $d->nameQuote;
104
105 $this->hasGenID = $d->hasGenID;
106 $this->_genIDSQL = $d->_genIDSQL;
107 $this->_genSeqSQL = $d->_genSeqSQL;
108 $this->_dropSeqSQL = $d->_dropSeqSQL;
109
110 $d->_init($this);
111 }
112
113 function Time()
114 {
115 if (!empty($this->_driver->_hasdual)) $sql = "select $this->sysTimeStamp from dual";
116 else $sql = "select $this->sysTimeStamp";
117
118 $rs = $this->_Execute($sql);
119 if ($rs && !$rs->EOF) return $this->UnixTimeStamp(reset($rs->fields));
120
121 return false;
122 }
123
124 // returns true or false
125 function _connect($argDSN, $argUsername, $argPassword, $argDatabasename, $persist=false)
126 {
127 $at = strpos($argDSN,':');
128 $this->dsnType = substr($argDSN,0,$at);
129
130 if ($argDatabasename) {
131 $argDSN .= ';dbname='.$argDatabasename;
132 }
133 try {
134 $this->_connectionID = new PDO($argDSN, $argUsername, $argPassword);
135 } catch (Exception $e) {
136 $this->_connectionID = false;
137 $this->_errorno = -1;
138 //var_dump($e);
139 $this->_errormsg = 'Connection attempt failed: '.$e->getMessage();
140 return false;
141 }
142
143 if ($this->_connectionID) {
144 switch(ADODB_ASSOC_CASE){
145 case 0: $m = PDO::CASE_LOWER; break;
146 case 1: $m = PDO::CASE_UPPER; break;
147 default:
148 case 2: $m = PDO::CASE_NATURAL; break;
149 }
150
151 //$this->_connectionID->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT );
152 $this->_connectionID->setAttribute(PDO::ATTR_CASE,$m);
153
154 $class = 'ADODB_pdo_'.$this->dsnType;
155 //$this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
156 switch($this->dsnType) {
157 case 'oci':
158 case 'mysql':
159 case 'pgsql':
160 case 'mssql':
161 case 'sqlite':
162 include_once(ADODB_DIR.'/drivers/adodb-pdo_'.$this->dsnType.'.inc.php');
163 break;
164 }
165 if (class_exists($class))
166 $this->_driver = new $class();
167 else
168 $this->_driver = new ADODB_pdo_base();
169
170 $this->_driver->_connectionID = $this->_connectionID;
171 $this->_UpdatePDO();
172 return true;
173 }
174 $this->_driver = new ADODB_pdo_base();
175 return false;
176 }
177
178 function Concat()
179 {
180 $args = func_get_args();
181 if(method_exists($this->_driver, 'Concat'))
182 return call_user_func_array(array($this->_driver, 'Concat'), $args);
183
184 return call_user_func_array(array($this,'parent::Concat'), $args);
185 }
186
187 // returns true or false
188 function _pconnect($argDSN, $argUsername, $argPassword, $argDatabasename)
189 {
190 return $this->_connect($argDSN, $argUsername, $argPassword, $argDatabasename, true);
191 }
192
193 /*------------------------------------------------------------------------------*/
194
195
196 function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
197 {
198 $save = $this->_driver->fetchMode;
199 $this->_driver->fetchMode = $this->fetchMode;
200 $this->_driver->debug = $this->debug;
201 $ret = $this->_driver->SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
202 $this->_driver->fetchMode = $save;
203 return $ret;
204 }
205
206
207 function ServerInfo()
208 {
209 return $this->_driver->ServerInfo();
210 }
211
212 function MetaTables($ttype=false,$showSchema=false,$mask=false)
213 {
214 return $this->_driver->MetaTables($ttype,$showSchema,$mask);
215 }
216
217 function MetaColumns($table,$normalize=true)
218 {
219 return $this->_driver->MetaColumns($table,$normalize);
220 }
221
222 function InParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
223 {
224 $obj = $stmt[1];
225 if ($type) $obj->bindParam($name,$var,$type,$maxLen);
226 else $obj->bindParam($name, $var);
227 }
228
229 function OffsetDate($dayFraction,$date=false)
230 {
231 return $this->_driver->OffsetDate($dayFraction,$date);
232 }
233
234 function ErrorMsg()
235 {
236 if ($this->_errormsg !== false) return $this->_errormsg;
237 if (!empty($this->_stmt)) $arr = $this->_stmt->errorInfo();
238 else if (!empty($this->_connectionID)) $arr = $this->_connectionID->errorInfo();
239 else return 'No Connection Established';
240
241
242 if ($arr) {
243 if (sizeof($arr)<2) return '';
244 if ((integer)$arr[1]) return $arr[2];
245 else return '';
246 } else return '-1';
247 }
248
249
250 function ErrorNo()
251 {
252 if ($this->_errorno !== false) return $this->_errorno;
253 if (!empty($this->_stmt)) $err = $this->_stmt->errorCode();
254 else if (!empty($this->_connectionID)) {
255 $arr = $this->_connectionID->errorInfo();
256 if (isset($arr[0])) $err = $arr[0];
257 else $err = -1;
258 } else
259 return 0;
260
261 if ($err == '00000') return 0; // allows empty check
262 return $err;
263 }
264
265 function SetTransactionMode($transaction_mode)
266 {
267 if(method_exists($this->_driver, 'SetTransactionMode'))
268 return $this->_driver->SetTransactionMode($transaction_mode);
269
270 return parent::SetTransactionMode($seqname);
271 }
272
273 function BeginTrans()
274 {
275 if(method_exists($this->_driver, 'BeginTrans'))
276 return $this->_driver->BeginTrans();
277
278 if (!$this->hasTransactions) return false;
279 if ($this->transOff) return true;
280 $this->transCnt += 1;
281 $this->_autocommit = false;
282 $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,false);
283 return $this->_connectionID->beginTransaction();
284 }
285
286 function CommitTrans($ok=true)
287 {
288 if(method_exists($this->_driver, 'CommitTrans'))
289 return $this->_driver->CommitTrans($ok);
290
291 if (!$this->hasTransactions) return false;
292 if ($this->transOff) return true;
293 if (!$ok) return $this->RollbackTrans();
294 if ($this->transCnt) $this->transCnt -= 1;
295 $this->_autocommit = true;
296
297 $ret = $this->_connectionID->commit();
298 $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
299 return $ret;
300 }
301
302 function RollbackTrans()
303 {
304 if(method_exists($this->_driver, 'RollbackTrans'))
305 return $this->_driver->RollbackTrans();
306
307 if (!$this->hasTransactions) return false;
308 if ($this->transOff) return true;
309 if ($this->transCnt) $this->transCnt -= 1;
310 $this->_autocommit = true;
311
312 $ret = $this->_connectionID->rollback();
313 $this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
314 return $ret;
315 }
316
317 function Prepare($sql)
318 {
319 $this->_stmt = $this->_connectionID->prepare($sql);
320 if ($this->_stmt) return array($sql,$this->_stmt);
321
322 return false;
323 }
324
325 function PrepareStmt($sql)
326 {
327 $stmt = $this->_connectionID->prepare($sql);
328 if (!$stmt) return false;
329 $obj = new ADOPDOStatement($stmt,$this);
330 return $obj;
331 }
332
333 function CreateSequence($seqname='adodbseq',$startID=1)
334 {
335 if(method_exists($this->_driver, 'CreateSequence'))
336 return $this->_driver->CreateSequence($seqname, $startID);
337
338 return parent::CreateSequence($seqname, $startID);
339 }
340
341 function DropSequence($seqname='adodbseq')
342 {
343 if(method_exists($this->_driver, 'DropSequence'))
344 return $this->_driver->DropSequence($seqname);
345
346 return parent::DropSequence($seqname);
347 }
348
349 function GenID($seqname='adodbseq',$startID=1)
350 {
351 if(method_exists($this->_driver, 'GenID'))
352 return $this->_driver->GenID($seqname, $startID);
353
354 return parent::GenID($seqname, $startID);
355 }
356
357
358 /* returns queryID or false */
359 function _query($sql,$inputarr=false)
360 {
361 if (is_array($sql)) {
362 $stmt = $sql[1];
363 } else {
364 $stmt = $this->_connectionID->prepare($sql);
365 }
366 #adodb_backtrace();
367 #var_dump($this->_bindInputArray);
368 if ($stmt) {
369 $this->_driver->debug = $this->debug;
370 if ($inputarr) $ok = $stmt->execute($inputarr);
371 else $ok = $stmt->execute();
372 }
373
374
375 $this->_errormsg = false;
376 $this->_errorno = false;
377
378 if ($ok) {
379 $this->_stmt = $stmt;
380 return $stmt;
381 }
382
383 if ($stmt) {
384
385 $arr = $stmt->errorinfo();
386 if ((integer)$arr[1]) {
387 $this->_errormsg = $arr[2];
388 $this->_errorno = $arr[1];
389 }
390
391 } else {
392 $this->_errormsg = false;
393 $this->_errorno = false;
394 }
395 return false;
396 }
397
398 // returns true or false
399 function _close()
400 {
401 $this->_stmt = false;
402 return true;
403 }
404
405 function _affectedrows()
406 {
407 return ($this->_stmt) ? $this->_stmt->rowCount() : 0;
408 }
409
410 function _insertid()
411 {
412 return ($this->_connectionID) ? $this->_connectionID->lastInsertId() : 0;
413 }
414 }
415
416 class ADODB_pdo_base extends ADODB_pdo {
417
418 var $sysDate = "'?'";
419 var $sysTimeStamp = "'?'";
420
421
422 function _init($parentDriver)
423 {
424 $parentDriver->_bindInputArray = true;
425 #$parentDriver->_connectionID->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY,true);
426 }
427
428 function ServerInfo()
429 {
430 return ADOConnection::ServerInfo();
431 }
432
433 function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
434 {
435 $ret = ADOConnection::SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
436 return $ret;
437 }
438
439 function MetaTables()
440 {
441 return false;
442 }
443
444 function MetaColumns()
445 {
446 return false;
447 }
448 }
449
450 class ADOPDOStatement {
451
452 var $databaseType = "pdo";
453 var $dataProvider = "pdo";
454 var $_stmt;
455 var $_connectionID;
456
457 function ADOPDOStatement($stmt,$connection)
458 {
459 $this->_stmt = $stmt;
460 $this->_connectionID = $connection;
461 }
462
463 function Execute($inputArr=false)
464 {
465 $savestmt = $this->_connectionID->_stmt;
466 $rs = $this->_connectionID->Execute(array(false,$this->_stmt),$inputArr);
467 $this->_connectionID->_stmt = $savestmt;
468 return $rs;
469 }
470
471 function InParameter(&$var,$name,$maxLen=4000,$type=false)
472 {
473
474 if ($type) $this->_stmt->bindParam($name,$var,$type,$maxLen);
475 else $this->_stmt->bindParam($name, $var);
476 }
477
478 function Affected_Rows()
479 {
480 return ($this->_stmt) ? $this->_stmt->rowCount() : 0;
481 }
482
483 function ErrorMsg()
484 {
485 if ($this->_stmt) $arr = $this->_stmt->errorInfo();
486 else $arr = $this->_connectionID->errorInfo();
487
488 if (is_array($arr)) {
489 if ((integer) $arr[0] && isset($arr[2])) return $arr[2];
490 else return '';
491 } else return '-1';
492 }
493
494 function NumCols()
495 {
496 return ($this->_stmt) ? $this->_stmt->columnCount() : 0;
497 }
498
499 function ErrorNo()
500 {
501 if ($this->_stmt) return $this->_stmt->errorCode();
502 else return $this->_connectionID->errorInfo();
503 }
504 }
505
506 /*--------------------------------------------------------------------------------------
507 Class Name: Recordset
508 --------------------------------------------------------------------------------------*/
509
510 class ADORecordSet_pdo extends ADORecordSet {
511
512 var $bind = false;
513 var $databaseType = "pdo";
514 var $dataProvider = "pdo";
515
516 function ADORecordSet_pdo($id,$mode=false)
517 {
518 if ($mode === false) {
519 global $ADODB_FETCH_MODE;
520 $mode = $ADODB_FETCH_MODE;
521 }
522 $this->adodbFetchMode = $mode;
523 switch($mode) {
524 case ADODB_FETCH_NUM: $mode = PDO::FETCH_NUM; break;
525 case ADODB_FETCH_ASSOC: $mode = PDO::FETCH_ASSOC; break;
526
527 case ADODB_FETCH_BOTH:
528 default: $mode = PDO::FETCH_BOTH; break;
529 }
530 $this->fetchMode = $mode;
531
532 $this->_queryID = $id;
533 $this->ADORecordSet($id);
534 }
535
536
537 function Init()
538 {
539 if ($this->_inited) return;
540 $this->_inited = true;
541 if ($this->_queryID) @$this->_initrs();
542 else {
543 $this->_numOfRows = 0;
544 $this->_numOfFields = 0;
545 }
546 if ($this->_numOfRows != 0 && $this->_currentRow == -1) {
547 $this->_currentRow = 0;
548 if ($this->EOF = ($this->_fetch() === false)) {
549 $this->_numOfRows = 0; // _numOfRows could be -1
550 }
551 } else {
552 $this->EOF = true;
553 }
554 }
555
556 function _initrs()
557 {
558 global $ADODB_COUNTRECS;
559
560 $this->_numOfRows = ($ADODB_COUNTRECS) ? @$this->_queryID->rowCount() : -1;
561 if (!$this->_numOfRows) $this->_numOfRows = -1;
562 $this->_numOfFields = $this->_queryID->columnCount();
563 }
564
565 // returns the field object
566 function FetchField($fieldOffset = -1)
567 {
568 $off=$fieldOffset+1; // offsets begin at 1
569
570 $o= new ADOFieldObject();
571 $arr = @$this->_queryID->getColumnMeta($fieldOffset);
572 if (!$arr) {
573 $o->name = 'bad getColumnMeta()';
574 $o->max_length = -1;
575 $o->type = 'VARCHAR';
576 $o->precision = 0;
577 # $false = false;
578 return $o;
579 }
580 //adodb_pr($arr);
581 $o->name = $arr['name'];
582 if (isset($arr['native_type']) && $arr['native_type'] <> "null") $o->type = $arr['native_type'];
583 else $o->type = adodb_pdo_type($arr['pdo_type']);
584 $o->max_length = $arr['len'];
585 $o->precision = $arr['precision'];
586
587 if (ADODB_ASSOC_CASE == 0) $o->name = strtolower($o->name);
588 else if (ADODB_ASSOC_CASE == 1) $o->name = strtoupper($o->name);
589 return $o;
590 }
591
592 function _seek($row)
593 {
594 return false;
595 }
596
597 function _fetch()
598 {
599 if (!$this->_queryID) return false;
600
601 $this->fields = $this->_queryID->fetch($this->fetchMode);
602 return !empty($this->fields);
603 }
604
605 function _close()
606 {
607 $this->_queryID = false;
608 }
609
610 function Fields($colname)
611 {
612 if ($this->adodbFetchMode != ADODB_FETCH_NUM) return @$this->fields[$colname];
613
614 if (!$this->bind) {
615 $this->bind = array();
616 for ($i=0; $i < $this->_numOfFields; $i++) {
617 $o = $this->FetchField($i);
618 $this->bind[strtoupper($o->name)] = $i;
619 }
620 }
621 return $this->fields[$this->bind[strtoupper($colname)]];
622 }
623
624 }
625
626 ?>