3 V4.92a 29 Aug 2006 (c) 2000-2006 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.
9 Latest version is available at http://adodb.sourceforge.net
11 Requires ODBC. Works on Windows and Unix.
14 Where is float/decimal type in pdo_param_type
15 LOB handling for CLOB/BLOB differs significantly
17 // security - hide paths
18 if (!defined('ADODB_DIR')) die();
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
30 /* get_col ptr should point to start of the string buffer
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
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
42 /* get_col ptr should point to a zend_bool
46 /* magic flag to denote a parameter as being input/output
47 PDO::PARAM_INPUT_OUTPUT = 0x80000000
51 function adodb_pdo_type($t)
54 case 2: return 'VARCHAR';
55 case 3: return 'BLOB';
56 default: return 'NUMERIC';
60 /*--------------------------------------------------------------------------------------
61 --------------------------------------------------------------------------------------*/
63 ////////////////////////////////////////////////
67 class ADODB_pdo_base
extends ADODB_pdo
{
70 var $sysTimeStamp = "'?'";
73 function _init($parentDriver)
75 $parentDriver->_bindInputArray
= true;
76 #$parentDriver->_connectionID->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY,true);
81 return ADOConnection
::ServerInfo();
84 function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
86 $ret = ADOConnection
::SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
95 function MetaColumns()
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;
115 var $_errormsg = false;
116 var $_errorno = false;
125 function _UpdatePDO()
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
;
142 if (!empty($this->_driver
->_hasdual
)) $sql = "select $this->sysTimeStamp from dual";
143 else $sql = "select $this->sysTimeStamp";
145 $rs =& $this->_Execute($sql);
146 if ($rs && !$rs->EOF
) return $this->UnixTimeStamp(reset($rs->fields
));
151 // returns true or false
152 function _connect($argDSN, $argUsername, $argPassword, $argDatabasename, $persist=false)
154 $at = strpos($argDSN,':');
155 $this->dsnType
= substr($argDSN,0,$at);
157 if ($argDatabasename) {
158 $argDSN .= ';dbname='.$argDatabasename;
161 $this->_connectionID
= new PDO($argDSN, $argUsername, $argPassword);
162 } catch (Exception
$e) {
163 $this->_connectionID
= false;
164 $this->_errorno
= -1;
166 $this->_errormsg
= 'Connection attempt failed: '.$e->getMessage();
170 if ($this->_connectionID
) {
171 switch(ADODB_ASSOC_CASE
){
172 case 0: $m = PDO
::CASE_LOWER
; break;
173 case 1: $m = PDO
::CASE_UPPER
; break;
175 case 2: $m = PDO
::CASE_NATURAL
; break;
178 //$this->_connectionID->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_SILENT );
179 $this->_connectionID
->setAttribute(PDO
::ATTR_CASE
,$m);
181 $class = 'ADODB_pdo_'.$this->dsnType
;
182 //$this->_connectionID->setAttribute(PDO::ATTR_AUTOCOMMIT,true);
183 switch($this->dsnType
) {
188 include_once(ADODB_DIR
.'/drivers/adodb-pdo_'.$this->dsnType
.'.inc.php');
191 if (class_exists($class))
192 $this->_driver
= new $class();
194 $this->_driver
= new ADODB_pdo_base();
196 $this->_driver
->_connectionID
= $this->_connectionID
;
200 $this->_driver
= new ADODB_pdo_base();
204 // returns true or false
205 function _pconnect($argDSN, $argUsername, $argPassword, $argDatabasename)
207 return $this->_connect($argDSN, $argUsername, $argPassword, $argDatabasename, true);
210 /*------------------------------------------------------------------------------*/
213 function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
215 $save = $this->_driver
->fetchMode
;
216 $this->_driver
->fetchMode
= $this->fetchMode
;
217 $this->_driver
->debug
= $this->debug
;
218 $ret = $this->_driver
->SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
219 $this->_driver
->fetchMode
= $save;
224 function ServerInfo()
226 return $this->_driver
->ServerInfo();
229 function MetaTables($ttype=false,$showSchema=false,$mask=false)
231 return $this->_driver
->MetaTables($ttype,$showSchema,$mask);
234 function MetaColumns($table,$normalize=true)
236 return $this->_driver
->MetaColumns($table,$normalize);
239 function InParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
242 if ($type) $obj->bindParam($name,$var,$type,$maxLen);
243 else $obj->bindParam($name, $var);
249 if ($this->_errormsg
!== false) return $this->_errormsg
;
250 if (!empty($this->_stmt
)) $arr = $this->_stmt
->errorInfo();
251 else if (!empty($this->_connectionID
)) $arr = $this->_connectionID
->errorInfo();
252 else return 'No Connection Established';
256 if (sizeof($arr)<2) return '';
257 if ((integer)$arr[1]) return $arr[2];
265 if ($this->_errorno
!== false) return $this->_errorno
;
266 if (!empty($this->_stmt
)) $err = $this->_stmt
->errorCode();
267 else if (!empty($this->_connectionID
)) {
268 $arr = $this->_connectionID
->errorInfo();
269 if (isset($arr[0])) $err = $arr[0];
274 if ($err == '00000') return 0; // allows empty check
278 function BeginTrans()
280 if (!$this->hasTransactions
) return false;
281 if ($this->transOff
) return true;
282 $this->transCnt +
= 1;
283 $this->_autocommit
= false;
284 $this->_connectionID
->setAttribute(PDO
::ATTR_AUTOCOMMIT
,false);
285 return $this->_connectionID
->beginTransaction();
288 function CommitTrans($ok=true)
290 if (!$this->hasTransactions
) return false;
291 if ($this->transOff
) return true;
292 if (!$ok) return $this->RollbackTrans();
293 if ($this->transCnt
) $this->transCnt
-= 1;
294 $this->_autocommit
= true;
296 $ret = $this->_connectionID
->commit();
297 $this->_connectionID
->setAttribute(PDO
::ATTR_AUTOCOMMIT
,true);
301 function RollbackTrans()
303 if (!$this->hasTransactions
) return false;
304 if ($this->transOff
) return true;
305 if ($this->transCnt
) $this->transCnt
-= 1;
306 $this->_autocommit
= true;
308 $ret = $this->_connectionID
->rollback();
309 $this->_connectionID
->setAttribute(PDO
::ATTR_AUTOCOMMIT
,true);
313 function Prepare($sql)
315 $this->_stmt
= $this->_connectionID
->prepare($sql);
316 if ($this->_stmt
) return array($sql,$this->_stmt
);
321 function PrepareStmt($sql)
323 $stmt = $this->_connectionID
->prepare($sql);
324 if (!$stmt) return false;
325 $obj = new ADOPDOStatement($stmt,$this);
330 /* returns queryID or false */
331 function _query($sql,$inputarr=false)
333 if (is_array($sql)) {
336 $stmt = $this->_connectionID
->prepare($sql);
339 #var_dump($this->_bindInputArray);
341 $this->_driver
->debug
= $this->debug
;
342 if ($inputarr) $ok = $stmt->execute($inputarr);
343 else $ok = $stmt->execute();
347 $this->_errormsg
= false;
348 $this->_errorno
= false;
351 $this->_stmt
= $stmt;
357 $arr = $stmt->errorinfo();
358 if ((integer)$arr[1]) {
359 $this->_errormsg
= $arr[2];
360 $this->_errorno
= $arr[1];
364 $this->_errormsg
= false;
365 $this->_errorno
= false;
370 // returns true or false
373 $this->_stmt
= false;
377 function _affectedrows()
379 return ($this->_stmt
) ?
$this->_stmt
->rowCount() : 0;
384 return ($this->_connectionID
) ?
$this->_connectionID
->lastInsertId() : 0;
388 class ADOPDOStatement
{
390 var $databaseType = "pdo";
391 var $dataProvider = "pdo";
395 function ADOPDOStatement($stmt,$connection)
397 $this->_stmt
= $stmt;
398 $this->_connectionID
= $connection;
401 function Execute($inputArr=false)
403 $savestmt = $this->_connectionID
->_stmt
;
404 $rs = $this->_connectionID
->Execute(array(false,$this->_stmt
),$inputArr);
405 $this->_connectionID
->_stmt
= $savestmt;
409 function InParameter(&$var,$name,$maxLen=4000,$type=false)
412 if ($type) $this->_stmt
->bindParam($name,$var,$type,$maxLen);
413 else $this->_stmt
->bindParam($name, $var);
416 function Affected_Rows()
418 return ($this->_stmt
) ?
$this->_stmt
->rowCount() : 0;
423 if ($this->_stmt
) $arr = $this->_stmt
->errorInfo();
424 else $arr = $this->_connectionID
->errorInfo();
426 if (is_array($arr)) {
427 if ((integer) $arr[0] && isset($arr[2])) return $arr[2];
434 return ($this->_stmt
) ?
$this->_stmt
->columnCount() : 0;
439 if ($this->_stmt
) return $this->_stmt
->errorCode();
440 else return $this->_connectionID
->errorInfo();
444 /*--------------------------------------------------------------------------------------
445 Class Name: Recordset
446 --------------------------------------------------------------------------------------*/
448 class ADORecordSet_pdo
extends ADORecordSet
{
451 var $databaseType = "pdo";
452 var $dataProvider = "pdo";
454 function ADORecordSet_pdo($id,$mode=false)
456 if ($mode === false) {
457 global $ADODB_FETCH_MODE;
458 $mode = $ADODB_FETCH_MODE;
460 $this->adodbFetchMode
= $mode;
462 case ADODB_FETCH_NUM
: $mode = PDO
::FETCH_NUM
; break;
463 case ADODB_FETCH_ASSOC
: $mode = PDO
::FETCH_ASSOC
; break;
465 case ADODB_FETCH_BOTH
:
466 default: $mode = PDO
::FETCH_BOTH
; break;
468 $this->fetchMode
= $mode;
470 $this->_queryID
= $id;
471 $this->ADORecordSet($id);
477 if ($this->_inited
) return;
478 $this->_inited
= true;
479 if ($this->_queryID
) @$this->_initrs();
481 $this->_numOfRows
= 0;
482 $this->_numOfFields
= 0;
484 if ($this->_numOfRows
!= 0 && $this->_currentRow
== -1) {
485 $this->_currentRow
= 0;
486 if ($this->EOF
= ($this->_fetch() === false)) {
487 $this->_numOfRows
= 0; // _numOfRows could be -1
496 global $ADODB_COUNTRECS;
498 $this->_numOfRows
= ($ADODB_COUNTRECS) ?
@$this->_queryID
->rowCount() : -1;
499 if (!$this->_numOfRows
) $this->_numOfRows
= -1;
500 $this->_numOfFields
= $this->_queryID
->columnCount();
503 // returns the field object
504 function &FetchField($fieldOffset = -1)
506 $off=$fieldOffset+
1; // offsets begin at 1
508 $o= new ADOFieldObject();
509 $arr = @$this->_queryID
->getColumnMeta($fieldOffset);
511 $o->name
= 'bad getColumnMeta()';
513 $o->type
= 'VARCHAR';
519 $o->name
= $arr['name'];
520 if (isset($arr['native_type'])) $o->type
= $arr['native_type'];
521 else $o->type
= adodb_pdo_type($arr['pdo_type']);
522 $o->max_length
= $arr['len'];
523 $o->precision
= $arr['precision'];
525 if (ADODB_ASSOC_CASE
== 0) $o->name
= strtolower($o->name
);
526 else if (ADODB_ASSOC_CASE
== 1) $o->name
= strtoupper($o->name
);
537 if (!$this->_queryID
) return false;
539 $this->fields
= $this->_queryID
->fetch($this->fetchMode
);
540 return !empty($this->fields
);
545 $this->_queryID
= false;
548 function Fields($colname)
550 if ($this->adodbFetchMode
!= ADODB_FETCH_NUM
) return @$this->fields
[$colname];
553 $this->bind
= array();
554 for ($i=0; $i < $this->_numOfFields
; $i++
) {
555 $o = $this->FetchField($i);
556 $this->bind
[strtoupper($o->name
)] = $i;
559 return $this->fields
[$this->bind
[strtoupper($colname)]];