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