00001 <?php
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00035 if (!defined('_ADODB_LAYER')) {
00036 define('_ADODB_LAYER',1);
00037
00038
00039
00040
00041
00042
00047 if (!defined('ADODB_DIR')) define('ADODB_DIR',dirname(__FILE__));
00048
00049
00050
00051
00052
00053 GLOBAL
00054 $ADODB_vers,
00055 $ADODB_COUNTRECS,
00056 $ADODB_CACHE_DIR,
00057 $ADODB_EXTENSION,
00058 $ADODB_COMPAT_FETCH,
00059 $ADODB_FETCH_MODE;
00060
00061
00062
00063
00064
00065 $ADODB_EXTENSION = defined('ADODB_EXTENSION');
00066
00067
00068
00069
00070
00071
00072
00073
00074
00075
00076
00077 define('ADODB_FORCE_IGNORE',0);
00078 define('ADODB_FORCE_NULL',1);
00079 define('ADODB_FORCE_EMPTY',2);
00080 define('ADODB_FORCE_VALUE',3);
00081
00082
00083
00084 if (!$ADODB_EXTENSION || ADODB_EXTENSION < 4.0) {
00085
00086 define('ADODB_BAD_RS','<p>Bad $rs in %s. Connection or SQL invalid. Try using $connection->debug=true;</p>');
00087
00088
00089 define('ADODB_TABLE_REGEX','([]0-9a-z_\:\"\`\.\@\[-]*)');
00090
00091 // prefetching used by oracle
00092 if (!defined('ADODB_PREFETCH_ROWS')) define('ADODB_PREFETCH_ROWS',10);
00093
00094
00095 /*
00096 Controls ADODB_FETCH_ASSOC field-name case. Default is 2, use native case-names.
00097 This currently works only with mssql, odbc, oci8po and ibase derived drivers.
00098
00099 0 = assoc lowercase field names. $rs->fields['orderid']
00100 1 = assoc uppercase field names. $rs->fields['ORDERID']
00101 2 = use native-case field names. $rs->fields['OrderID']
00102 */
00103
00104 define('ADODB_FETCH_DEFAULT',0);
00105 define('ADODB_FETCH_NUM',1);
00106 define('ADODB_FETCH_ASSOC',2);
00107 define('ADODB_FETCH_BOTH',3);
00108
00109 if (!defined('TIMESTAMP_FIRST_YEAR')) define('TIMESTAMP_FIRST_YEAR',100);
00110
00111 // PHP's version scheme makes converting to numbers difficult - workaround
00112 $_adodb_ver = (float) PHP_VERSION;
00113 if ($_adodb_ver >= 5.2) {
00114 define('ADODB_PHPVER',0x5200);
00115 } else if ($_adodb_ver >= 5.0) {
00116 define('ADODB_PHPVER',0x5000);
00117 } else if ($_adodb_ver > 4.299999) { # 4.3
00118 define('ADODB_PHPVER',0x4300);
00119 } else if ($_adodb_ver > 4.199999) { # 4.2
00120 define('ADODB_PHPVER',0x4200);
00121 } else if (strnatcmp(PHP_VERSION,'4.0.5')>=0) {
00122 define('ADODB_PHPVER',0x4050);
00123 } else {
00124 define('ADODB_PHPVER',0x4000);
00125 }
00126 }
00127
00128 //if (!defined('ADODB_ASSOC_CASE')) define('ADODB_ASSOC_CASE',2);
00129
00130
00134 function ADODB_str_replace($src, $dest, $data)
00135 {
00136 if (ADODB_PHPVER >= 0x4050) return str_replace($src,$dest,$data);
00137
00138 $s = reset($src);
00139 $d = reset($dest);
00140 while ($s !== false) {
00141 $data = str_replace($s,$d,$data);
00142 $s = next($src);
00143 $d = next($dest);
00144 }
00145 return $data;
00146 }
00147
00148 function ADODB_Setup()
00149 {
00150 GLOBAL
00151 $ADODB_vers, // database version
00152 $ADODB_COUNTRECS, // count number of records returned - slows down query
00153 $ADODB_CACHE_DIR, // directory to cache recordsets
00154 $ADODB_FETCH_MODE,
00155 $ADODB_FORCE_TYPE;
00156
00157 $ADODB_FETCH_MODE = ADODB_FETCH_DEFAULT;
00158 $ADODB_FORCE_TYPE = ADODB_FORCE_VALUE;
00159
00160
00161 if (!isset($ADODB_CACHE_DIR)) {
00162 $ADODB_CACHE_DIR = '/tmp'; //(isset($_ENV['TMP'])) ? $_ENV['TMP'] : '/tmp';
00163 } else {
00164 // do not accept url based paths, eg. http:/ or ftp:/
00165 if (strpos($ADODB_CACHE_DIR,'://') !== false)
00166 die("Illegal path http:
00167 }
00168
00169
00170
00171
00172 srand(((double)microtime())*1000000);
00173
00177 $ADODB_vers = 'V4.93 10 Oct 2006 (c) 2000-2006 John Lim (jlim#natsoft.com.my). All rights reserved. Released BSD & LGPL.';
00178
00184 if (!isset($ADODB_COUNTRECS)) $ADODB_COUNTRECS = true;
00185 }
00186
00187
00188
00189
00190
00191
00192 ADODB_Setup();
00193
00194
00195
00196
00200 class ADOFieldObject {
00201 var $name = '';
00202 var $max_length=0;
00203 var $type="";
00204
00205
00206
00207
00208
00209
00210
00211
00212
00213
00214 }
00215
00216
00217
00218 function ADODB_TransMonitor($dbms, $fn, $errno, $errmsg, $p1, $p2, &$thisConnection)
00219 {
00220
00221 $thisConnection->_transOK = false;
00222 if ($thisConnection->_oldRaiseFn) {
00223 $fn = $thisConnection->_oldRaiseFn;
00224 $fn($dbms, $fn, $errno, $errmsg, $p1, $p2,$thisConnection);
00225 }
00226 }
00227
00228
00229
00230
00231
00235 class ADOConnection {
00236
00237
00238
00239 var $dataProvider = 'native';
00240 var $databaseType = '';
00241 var $database = '';
00242 var $host = '';
00243 var $user = '';
00244 var $password = '';
00245 var $debug = false;
00246 var $maxblobsize = 262144;
00247 var $concat_operator = '+';
00248 var $substr = 'substr';
00249 var $length = 'length';
00250 var $random = 'rand()';
00251 var $upperCase = 'upper';
00252 var $fmtDate = "'Y-m-d'";
00253 var $fmtTimeStamp = "'Y-m-d, h:i:s A'";
00254 var $true = '1';
00255 var $false = '0';
00256 var $replaceQuote = "\\'";
00257 var $nameQuote = '"';
00258 var $charSet=false;
00259 var $metaDatabasesSQL = '';
00260 var $metaTablesSQL = '';
00261 var $uniqueOrderBy = false;
00262 var $emptyDate = ' ';
00263 var $emptyTimeStamp = ' ';
00264 var $lastInsID = false;
00265
00266 var $hasInsertID = false;
00267 var $hasAffectedRows = false;
00268 var $hasTop = false;
00269 var $hasLimit = false;
00270 var $readOnly = false;
00271 var $hasMoveFirst = false;
00272 var $hasGenID = false;
00273 var $hasTransactions = true;
00274
00275 var $genID = 0;
00276 var $raiseErrorFn = false;
00277 var $isoDates = false;
00278 var $cacheSecs = 3600;
00279
00280
00281 var $memCache = false;
00282 var $memCacheHost;
00283 var $memCachePort = 11211;
00284 var $memCacheCompress = false;
00285
00286 var $sysDate = false;
00287 var $sysTimeStamp = false;
00288 var $arrayClass = 'ADORecordSet_array';
00289
00290 var $noNullStrings = false;
00291 var $numCacheHits = 0;
00292 var $numCacheMisses = 0;
00293 var $pageExecuteCountRows = true;
00294 var $uniqueSort = false;
00295 var $leftOuter = false;
00296 var $rightOuter = false;
00297 var $ansiOuter = false;
00298 var $autoRollback = false;
00299 var $poorAffectedRows = false;
00300
00301 var $fnExecute = false;
00302 var $fnCacheExecute = false;
00303 var $blobEncodeType = false;
00304 var $rsPrefix = "ADORecordSet_";
00305
00306 var $autoCommit = true;
00307 var $transOff = 0;
00308 var $transCnt = 0;
00309
00310 var $fetchMode=false;
00311
00312 var $null2null = 'null';
00313
00314
00315
00316 var $_oldRaiseFn = false;
00317 var $_transOK = null;
00318 var $_connectionID = false;
00319 var $_errorMsg = false;
00320
00321 var $_errorCode = false;
00322 var $_queryID = false;
00323
00324 var $_isPersistentConnection = false;
00325 var $_bindInputArray = false;
00326 var $_evalAll = false;
00327 var $_affected = false;
00328 var $_logsql = false;
00329 var $_transmode = '';
00330
00331
00332
00336 function ADOConnection()
00337 {
00338 die('Virtual Class -- cannot instantiate');
00339 }
00340
00341 function Version()
00342 {
00343 global $ADODB_vers;
00344
00345 return (float) substr($ADODB_vers,1);
00346 }
00347
00354 function ServerInfo()
00355 {
00356 return array('description' => '', 'version' => '');
00357 }
00358
00359 function IsConnected()
00360 {
00361 return !empty($this->_connectionID);
00362 }
00363
00364 function _findvers($str)
00365 {
00366 if (preg_match('/([0-9]+\.([0-9\.])+)/',$str, $arr)) return $arr[1];
00367 else return '';
00368 }
00369
00374 function outp($msg,$newline=true)
00375 {
00376 global $ADODB_FLUSH,$ADODB_OUTP;
00377
00378 if (defined('ADODB_OUTP')) {
00379 $fn = ADODB_OUTP;
00380 $fn($msg,$newline);
00381 return;
00382 } else if (isset($ADODB_OUTP)) {
00383 $fn = $ADODB_OUTP;
00384 $fn($msg,$newline);
00385 return;
00386 }
00387
00388 if ($newline) $msg .= "<br>\n";
00389
00390 if (isset($_SERVER['HTTP_USER_AGENT']) || !$newline) echo $msg;
00391 else echo strip_tags($msg);
00392
00393
00394 if (!empty($ADODB_FLUSH) && ob_get_length() !== false) flush();
00395
00396 }
00397
00398 function Time()
00399 {
00400 $rs =& $this->_Execute("select $this->sysTimeStamp");
00401 if ($rs && !$rs->EOF) return $this->UnixTimeStamp(reset($rs->fields));
00402
00403 return false;
00404 }
00405
00417 function Connect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "", $forceNew = false)
00418 {
00419 if ($argHostname != "") $this->host = $argHostname;
00420 if ($argUsername != "") $this->user = $argUsername;
00421 if ($argPassword != "") $this->password = $argPassword;
00422 if ($argDatabaseName != "") $this->database = $argDatabaseName;
00423
00424 $this->_isPersistentConnection = false;
00425 if ($forceNew) {
00426 if ($rez=$this->_nconnect($this->host, $this->user, $this->password, $this->database)) return true;
00427 } else {
00428 if ($rez=$this->_connect($this->host, $this->user, $this->password, $this->database)) return true;
00429 }
00430 if (isset($rez)) {
00431 $err = $this->ErrorMsg();
00432 if (empty($err)) $err = "Connection error to server '$argHostname' with user '$argUsername'";
00433 $ret = false;
00434 } else {
00435 $err = "Missing extension for ".$this->dataProvider;
00436 $ret = 0;
00437 }
00438 if ($fn = $this->raiseErrorFn)
00439 $fn($this->databaseType,'CONNECT',$this->ErrorNo(),$err,$this->host,$this->database,$this);
00440
00441
00442 $this->_connectionID = false;
00443 if ($this->debug) ADOConnection::outp( $this->host.': '.$err);
00444 return $ret;
00445 }
00446
00447 function _nconnect($argHostname, $argUsername, $argPassword, $argDatabaseName)
00448 {
00449 return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabaseName);
00450 }
00451
00452
00463 function NConnect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "")
00464 {
00465 return $this->Connect($argHostname, $argUsername, $argPassword, $argDatabaseName, true);
00466 }
00467
00478 function PConnect($argHostname = "", $argUsername = "", $argPassword = "", $argDatabaseName = "")
00479 {
00480 if (defined('ADODB_NEVER_PERSIST'))
00481 return $this->Connect($argHostname,$argUsername,$argPassword,$argDatabaseName);
00482
00483 if ($argHostname != "") $this->host = $argHostname;
00484 if ($argUsername != "") $this->user = $argUsername;
00485 if ($argPassword != "") $this->password = $argPassword;
00486 if ($argDatabaseName != "") $this->database = $argDatabaseName;
00487
00488 $this->_isPersistentConnection = true;
00489 if ($rez = $this->_pconnect($this->host, $this->user, $this->password, $this->database)) return true;
00490 if (isset($rez)) {
00491 $err = $this->ErrorMsg();
00492 if (empty($err)) $err = "Connection error to server '$argHostname' with user '$argUsername'";
00493 $ret = false;
00494 } else {
00495 $err = "Missing extension for ".$this->dataProvider;
00496 $ret = 0;
00497 }
00498 if ($fn = $this->raiseErrorFn) {
00499 $fn($this->databaseType,'PCONNECT',$this->ErrorNo(),$err,$this->host,$this->database,$this);
00500 }
00501
00502 $this->_connectionID = false;
00503 if ($this->debug) ADOConnection::outp( $this->host.': '.$err);
00504 return $ret;
00505 }
00506
00507
00508 function SQLDate($fmt, $col=false)
00509 {
00510 if (!$col) $col = $this->sysDate;
00511 return $col;
00512 }
00513
00529 function Prepare($sql)
00530 {
00531 return $sql;
00532 }
00533
00548 function PrepareSP($sql,$param=true)
00549 {
00550 return $this->Prepare($sql,$param);
00551 }
00552
00556 function Quote($s)
00557 {
00558 return $this->qstr($s,false);
00559 }
00560
00564 function QMagic($s)
00565 {
00566 return $this->qstr($s,get_magic_quotes_gpc());
00567 }
00568
00569 function q(&$s)
00570 {
00571 #if (!empty($this->qNull)) if ($s == 'null') return $s;
00572 $s = $this->qstr($s,false);
00573 }
00574
00578 function ErrorNative()
00579 {
00580 return $this->ErrorNo();
00581 }
00582
00583
00587 function nextId($seq_name)
00588 {
00589 return $this->GenID($seq_name);
00590 }
00591
00599 function RowLock($table,$where)
00600 {
00601 return false;
00602 }
00603
00604 function CommitLock($table)
00605 {
00606 return $this->CommitTrans();
00607 }
00608
00609 function RollbackLock($table)
00610 {
00611 return $this->RollbackTrans();
00612 }
00613
00623 function SetFetchMode($mode)
00624 {
00625 $old = $this->fetchMode;
00626 $this->fetchMode = $mode;
00627
00628 if ($old === false) {
00629 global $ADODB_FETCH_MODE;
00630 return $ADODB_FETCH_MODE;
00631 }
00632 return $old;
00633 }
00634
00635
00639 function &Query($sql, $inputarr=false)
00640 {
00641 $rs = &$this->Execute($sql, $inputarr);
00642 if (!$rs && defined('ADODB_PEAR')) return ADODB_PEAR_Error();
00643 return $rs;
00644 }
00645
00646
00650 function &LimitQuery($sql, $offset, $count, $params=false)
00651 {
00652 $rs = &$this->SelectLimit($sql, $count, $offset, $params);
00653 if (!$rs && defined('ADODB_PEAR')) return ADODB_PEAR_Error();
00654 return $rs;
00655 }
00656
00657
00661 function Disconnect()
00662 {
00663 return $this->Close();
00664 }
00665
00666
00667
00668
00669
00670
00671
00672
00673
00674
00675 function Param($name,$type='C')
00676 {
00677 return '?';
00678 }
00679
00680
00681
00682
00683 function InParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
00684 {
00685 return $this->Parameter($stmt,$var,$name,false,$maxLen,$type);
00686 }
00687
00688
00689
00690 function OutParameter(&$stmt,&$var,$name,$maxLen=4000,$type=false)
00691 {
00692 return $this->Parameter($stmt,$var,$name,true,$maxLen,$type);
00693
00694 }
00695
00696
00697
00698
00699
00700
00701
00702
00703
00704
00705
00706
00707
00708
00709
00710
00711
00712 function Parameter(&$stmt,&$var,$name,$isOutput=false,$maxLen=4000,$type=false)
00713 {
00714 return false;
00715 }
00716
00717
00718 function IgnoreErrors($saveErrs=false)
00719 {
00720 if (!$saveErrs) {
00721 $saveErrs = array($this->raiseErrorFn,$this->_transOK);
00722 $this->raiseErrorFn = false;
00723 return $saveErrs;
00724 } else {
00725 $this->raiseErrorFn = $saveErrs[0];
00726 $this->_transOK = $saveErrs[1];
00727 }
00728 }
00729
00740 function StartTrans($errfn = 'ADODB_TransMonitor')
00741 {
00742 if ($this->transOff > 0) {
00743 $this->transOff += 1;
00744 return;
00745 }
00746
00747 $this->_oldRaiseFn = $this->raiseErrorFn;
00748 $this->raiseErrorFn = $errfn;
00749 $this->_transOK = true;
00750
00751 if ($this->debug && $this->transCnt > 0) ADOConnection::outp("Bad Transaction: StartTrans called within BeginTrans");
00752 $this->BeginTrans();
00753 $this->transOff = 1;
00754 }
00755
00756
00765 function CompleteTrans($autoComplete = true)
00766 {
00767 if ($this->transOff > 1) {
00768 $this->transOff -= 1;
00769 return true;
00770 }
00771 $this->raiseErrorFn = $this->_oldRaiseFn;
00772
00773 $this->transOff = 0;
00774 if ($this->_transOK && $autoComplete) {
00775 if (!$this->CommitTrans()) {
00776 $this->_transOK = false;
00777 if ($this->debug) ADOConnection::outp("Smart Commit failed");
00778 } else
00779 if ($this->debug) ADOConnection::outp("Smart Commit occurred");
00780 } else {
00781 $this->_transOK = false;
00782 $this->RollbackTrans();
00783 if ($this->debug) ADOCOnnection::outp("Smart Rollback occurred");
00784 }
00785
00786 return $this->_transOK;
00787 }
00788
00789
00790
00791
00792 function FailTrans()
00793 {
00794 if ($this->debug)
00795 if ($this->transOff == 0) {
00796 ADOConnection::outp("FailTrans outside StartTrans/CompleteTrans");
00797 } else {
00798 ADOConnection::outp("FailTrans was called");
00799 adodb_backtrace();
00800 }
00801 $this->_transOK = false;
00802 }
00803
00807 function HasFailedTrans()
00808 {
00809 if ($this->transOff > 0) return $this->_transOK == false;
00810 return false;
00811 }
00812
00820 function &Execute($sql,$inputarr=false)
00821 {
00822 if ($this->fnExecute) {
00823 $fn = $this->fnExecute;
00824 $ret =& $fn($this,$sql,$inputarr);
00825 if (isset($ret)) return $ret;
00826 }
00827 if ($inputarr) {
00828 if (!is_array($inputarr)) $inputarr = array($inputarr);
00829
00830 $element0 = reset($inputarr);
00831 # is_object check because oci8 descriptors can be passed in
00832 $array_2d = is_array($element0) && !is_object(reset($element0));
00833
00834 unset($element0);
00835
00836 if (!is_array($sql) && !$this->_bindInputArray) {
00837 $sqlarr = explode('?',$sql);
00838
00839 if (!$array_2d) $inputarr = array($inputarr);
00840 foreach($inputarr as $arr) {
00841 $sql = ''; $i = 0;
00842
00843 while(list(, $v) = each($arr)) {
00844 $sql .= $sqlarr[$i];
00845
00846
00847 $typ = gettype($v);
00848 if ($typ == 'string')
00849
00850 $sql .= $this->qstr($v);
00851 else if ($typ == 'double')
00852 $sql .= str_replace(',','.',$v);
00853 else if ($typ == 'boolean')
00854 $sql .= $v ? $this->true : $this->false;
00855 else if ($typ == 'object') {
00856 if (method_exists($v, '__toString')) $sql .= $this->qstr($v->__toString());
00857 else $sql .= $this->qstr((string) $v);
00858 } else if ($v === null)
00859 $sql .= 'NULL';
00860 else
00861 $sql .= $v;
00862 $i += 1;
00863 }
00864 if (isset($sqlarr[$i])) {
00865 $sql .= $sqlarr[$i];
00866 if ($i+1 != sizeof($sqlarr)) ADOConnection::outp( "Input Array does not match ?: ".htmlspecialchars($sql));
00867 } else if ($i != sizeof($sqlarr))
00868 ADOConnection::outp( "Input array does not match ?: ".htmlspecialchars($sql));
00869
00870 $ret =& $this->_Execute($sql);
00871 if (!$ret) return $ret;
00872 }
00873 } else {
00874 if ($array_2d) {
00875 if (is_string($sql))
00876 $stmt = $this->Prepare($sql);
00877 else
00878 $stmt = $sql;
00879
00880 foreach($inputarr as $arr) {
00881 $ret =& $this->_Execute($stmt,$arr);
00882 if (!$ret) return $ret;
00883 }
00884 } else {
00885 $ret =& $this->_Execute($sql,$inputarr);
00886 }
00887 }
00888 } else {
00889 $ret =& $this->_Execute($sql,false);
00890 }
00891
00892 return $ret;
00893 }
00894
00895
00896 function &_Execute($sql,$inputarr=false)
00897 {
00898 if ($this->debug) {
00899 global $ADODB_INCLUDED_LIB;
00900 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
00901 $this->_queryID = _adodb_debug_execute($this, $sql,$inputarr);
00902 } else {
00903 $this->_queryID = @$this->_query($sql,$inputarr);
00904 }
00905
00906
00907
00908
00909
00910 if ($this->_queryID === false) {
00911 if ($this->debug == 99) adodb_backtrace(true,5);
00912 $fn = $this->raiseErrorFn;
00913 if ($fn) {
00914 $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,$inputarr,$this);
00915 }
00916 $false = false;
00917 return $false;
00918 }
00919
00920 if ($this->_queryID === true) {
00921 $rs =& new ADORecordSet_empty();
00922 return $rs;
00923 }
00924
00925
00926 $rsclass = $this->rsPrefix.$this->databaseType;
00927 $rs = new $rsclass($this->_queryID,$this->fetchMode);
00928 $rs->connection = &$this;
00929 $rs->Init();
00930 if (is_array($sql)) $rs->sql = $sql[0];
00931 else $rs->sql = $sql;
00932 if ($rs->_numOfRows <= 0) {
00933 global $ADODB_COUNTRECS;
00934 if ($ADODB_COUNTRECS) {
00935 if (!$rs->EOF) {
00936 $rs = &$this->_rs2rs($rs,-1,-1,!is_array($sql));
00937 $rs->_queryID = $this->_queryID;
00938 } else
00939 $rs->_numOfRows = 0;
00940 }
00941 }
00942 return $rs;
00943 }
00944
00945 function CreateSequence($seqname='adodbseq',$startID=1)
00946 {
00947 if (empty($this->_genSeqSQL)) return false;
00948 return $this->Execute(sprintf($this->_genSeqSQL,$seqname,$startID));
00949 }
00950
00951 function DropSequence($seqname='adodbseq')
00952 {
00953 if (empty($this->_dropSeqSQL)) return false;
00954 return $this->Execute(sprintf($this->_dropSeqSQL,$seqname));
00955 }
00956
00965 function GenID($seqname='adodbseq',$startID=1)
00966 {
00967 if (!$this->hasGenID) {
00968 return 0;
00969 }
00970
00971 $getnext = sprintf($this->_genIDSQL,$seqname);
00972
00973 $holdtransOK = $this->_transOK;
00974
00975 $save_handler = $this->raiseErrorFn;
00976 $this->raiseErrorFn = '';
00977 @($rs = $this->Execute($getnext));
00978 $this->raiseErrorFn = $save_handler;
00979
00980 if (!$rs) {
00981 $this->_transOK = $holdtransOK;
00982 $createseq = $this->Execute(sprintf($this->_genSeqSQL,$seqname,$startID));
00983 $rs = $this->Execute($getnext);
00984 }
00985 if ($rs && !$rs->EOF) $this->genID = reset($rs->fields);
00986 else $this->genID = 0;
00987
00988 if ($rs) $rs->Close();
00989
00990 return $this->genID;
00991 }
00992
00998 function Insert_ID($table='',$column='')
00999 {
01000 if ($this->_logsql && $this->lastInsID) return $this->lastInsID;
01001 if ($this->hasInsertID) return $this->_insertid($table,$column);
01002 if ($this->debug) {
01003 ADOConnection::outp( '<p>Insert_ID error</p>');
01004 adodb_backtrace();
01005 }
01006 return false;
01007 }
01008
01009
01016 function PO_Insert_ID($table="", $id="")
01017 {
01018 if ($this->hasInsertID){
01019 return $this->Insert_ID($table,$id);
01020 } else {
01021 return $this->GetOne("SELECT MAX($id) FROM $table");
01022 }
01023 }
01024
01028 function Affected_Rows()
01029 {
01030 if ($this->hasAffectedRows) {
01031 if ($this->fnExecute === 'adodb_log_sql') {
01032 if ($this->_logsql && $this->_affected !== false) return $this->_affected;
01033 }
01034 $val = $this->_affectedrows();
01035 return ($val < 0) ? false : $val;
01036 }
01037
01038 if ($this->debug) ADOConnection::outp( '<p>Affected_Rows error</p>',false);
01039 return false;
01040 }
01041
01042
01046 function ErrorMsg()
01047 {
01048 if ($this->_errorMsg) return '!! '.strtoupper($this->dataProvider.' '.$this->databaseType).': '.$this->_errorMsg;
01049 else return '';
01050 }
01051
01052
01056 function ErrorNo()
01057 {
01058 return ($this->_errorMsg) ? -1 : 0;
01059 }
01060
01061 function MetaError($err=false)
01062 {
01063 include_once(ADODB_DIR."/adodb-error.inc.php");
01064 if ($err === false) $err = $this->ErrorNo();
01065 return adodb_error($this->dataProvider,$this->databaseType,$err);
01066 }
01067
01068 function MetaErrorMsg($errno)
01069 {
01070 include_once(ADODB_DIR."/adodb-error.inc.php");
01071 return adodb_errormsg($errno);
01072 }
01073
01077 function MetaPrimaryKeys($table, $owner=false)
01078 {
01079
01080 $p = array();
01081 $objs =& $this->MetaColumns($table);
01082 if ($objs) {
01083 foreach($objs as $v) {
01084 if (!empty($v->primary_key))
01085 $p[] = $v->name;
01086 }
01087 }
01088 if (sizeof($p)) return $p;
01089 if (function_exists('ADODB_VIEW_PRIMARYKEYS'))
01090 return ADODB_VIEW_PRIMARYKEYS($this->databaseType, $this->database, $table, $owner);
01091 return false;
01092 }
01093
01097 function MetaForeignKeys($table, $owner=false, $upper=false)
01098 {
01099 return false;
01100 }
01107 function SelectDB($dbName)
01108 {return false;}
01109
01110
01130 function &SelectLimit($sql,$nrows=-1,$offset=-1, $inputarr=false,$secs2cache=0)
01131 {
01132 if ($this->hasTop && $nrows > 0) {
01133
01134
01135 $ismssql = (strpos($this->databaseType,'mssql') !== false);
01136 if ($ismssql) $isaccess = false;
01137 else $isaccess = (strpos($this->databaseType,'access') !== false);
01138
01139 if ($offset <= 0) {
01140
01141
01142 if ($isaccess) {
01143 $sql = preg_replace(
01144 '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);
01145
01146 if ($secs2cache != 0) {
01147 $ret =& $this->CacheExecute($secs2cache, $sql,$inputarr);
01148 } else {
01149 $ret =& $this->Execute($sql,$inputarr);
01150 }
01151 return $ret;
01152 } else if ($ismssql){
01153 $sql = preg_replace(
01154 '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);
01155 } else {
01156 $sql = preg_replace(
01157 '/(^\s*select\s)/i','\\1 '.$this->hasTop.' '.((integer)$nrows).' ',$sql);
01158 }
01159 } else {
01160 $nn = $nrows + $offset;
01161 if ($isaccess || $ismssql) {
01162 $sql = preg_replace(
01163 '/(^\s*select\s+(distinctrow|distinct)?)/i','\\1 '.$this->hasTop.' '.$nn.' ',$sql);
01164 } else {
01165 $sql = preg_replace(
01166 '/(^\s*select\s)/i','\\1 '.$this->hasTop.' '.$nn.' ',$sql);
01167 }
01168 }
01169 }
01170
01171
01172
01173 global $ADODB_COUNTRECS;
01174
01175 $savec = $ADODB_COUNTRECS;
01176 $ADODB_COUNTRECS = false;
01177
01178 if ($offset>0){
01179 if ($secs2cache != 0) $rs = &$this->CacheExecute($secs2cache,$sql,$inputarr);
01180 else $rs = &$this->Execute($sql,$inputarr);
01181 } else {
01182 if ($secs2cache != 0) $rs = &$this->CacheExecute($secs2cache,$sql,$inputarr);
01183 else $rs = &$this->Execute($sql,$inputarr);
01184 }
01185 $ADODB_COUNTRECS = $savec;
01186 if ($rs && !$rs->EOF) {
01187 $rs =& $this->_rs2rs($rs,$nrows,$offset);
01188 }
01189
01190 return $rs;
01191 }
01192
01198 function &SerializableRS(&$rs)
01199 {
01200 $rs2 =& $this->_rs2rs($rs);
01201 $ignore = false;
01202 $rs2->connection =& $ignore;
01203
01204 return $rs2;
01205 }
01206
01217 function &_rs2rs(&$rs,$nrows=-1,$offset=-1,$close=true)
01218 {
01219 if (! $rs) {
01220 $false = false;
01221 return $false;
01222 }
01223 $dbtype = $rs->databaseType;
01224 if (!$dbtype) {
01225 $rs = &$rs;
01226 return $rs;
01227 }
01228 if (($dbtype == 'array' || $dbtype == 'csv') && $nrows == -1 && $offset == -1) {
01229 $rs->MoveFirst();
01230 $rs = &$rs;
01231 return $rs;
01232 }
01233 $flds = array();
01234 for ($i=0, $max=$rs->FieldCount(); $i < $max; $i++) {
01235 $flds[] = $rs->FetchField($i);
01236 }
01237
01238 $arr =& $rs->GetArrayLimit($nrows,$offset);
01239
01240 if ($close) $rs->Close();
01241
01242 $arrayClass = $this->arrayClass;
01243
01244 $rs2 = new $arrayClass();
01245 $rs2->connection = &$this;
01246 $rs2->sql = $rs->sql;
01247 $rs2->dataProvider = $this->dataProvider;
01248 $rs2->InitArrayFields($arr,$flds);
01249 $rs2->fetchMode = isset($rs->adodbFetchMode) ? $rs->adodbFetchMode : $rs->fetchMode;
01250 return $rs2;
01251 }
01252
01253
01254
01255
01256 function &GetAll($sql, $inputarr=false)
01257 {
01258 $arr =& $this->GetArray($sql,$inputarr);
01259 return $arr;
01260 }
01261
01262 function &GetAssoc($sql, $inputarr=false,$force_array = false, $first2cols = false)
01263 {
01264 $rs =& $this->Execute($sql, $inputarr);
01265 if (!$rs) {
01266 $false = false;
01267 return $false;
01268 }
01269 $arr =& $rs->GetAssoc($force_array,$first2cols);
01270 return $arr;
01271 }
01272
01273 function &CacheGetAssoc($secs2cache, $sql=false, $inputarr=false,$force_array = false, $first2cols = false)
01274 {
01275 if (!is_numeric($secs2cache)) {
01276 $first2cols = $force_array;
01277 $force_array = $inputarr;
01278 }
01279 $rs =& $this->CacheExecute($secs2cache, $sql, $inputarr);
01280 if (!$rs) {
01281 $false = false;
01282 return $false;
01283 }
01284 $arr =& $rs->GetAssoc($force_array,$first2cols);
01285 return $arr;
01286 }
01287
01295 function GetOne($sql,$inputarr=false)
01296 {
01297 global $ADODB_COUNTRECS;
01298 $crecs = $ADODB_COUNTRECS;
01299 $ADODB_COUNTRECS = false;
01300
01301 $ret = false;
01302 $rs = &$this->Execute($sql,$inputarr);
01303 if ($rs) {
01304 if (!$rs->EOF) $ret = reset($rs->fields);
01305 $rs->Close();
01306 }
01307 $ADODB_COUNTRECS = $crecs;
01308 return $ret;
01309 }
01310
01311 function CacheGetOne($secs2cache,$sql=false,$inputarr=false)
01312 {
01313 $ret = false;
01314 $rs = &$this->CacheExecute($secs2cache,$sql,$inputarr);
01315 if ($rs) {
01316 if (!$rs->EOF) $ret = reset($rs->fields);
01317 $rs->Close();
01318 }
01319
01320 return $ret;
01321 }
01322
01323 function GetCol($sql, $inputarr = false, $trim = false)
01324 {
01325 $rv = false;
01326 $rs = &$this->Execute($sql, $inputarr);
01327 if ($rs) {
01328 $rv = array();
01329 if ($trim) {
01330 while (!$rs->EOF) {
01331 $rv[] = trim(reset($rs->fields));
01332 $rs->MoveNext();
01333 }
01334 } else {
01335 while (!$rs->EOF) {
01336 $rv[] = reset($rs->fields);
01337 $rs->MoveNext();
01338 }
01339 }
01340 $rs->Close();
01341 }
01342 return $rv;
01343 }
01344
01345 function CacheGetCol($secs, $sql = false, $inputarr = false,$trim=false)
01346 {
01347 $rv = false;
01348 $rs = &$this->CacheExecute($secs, $sql, $inputarr);
01349 if ($rs) {
01350 if ($trim) {
01351 while (!$rs->EOF) {
01352 $rv[] = trim(reset($rs->fields));
01353 $rs->MoveNext();
01354 }
01355 } else {
01356 while (!$rs->EOF) {
01357 $rv[] = reset($rs->fields);
01358 $rs->MoveNext();
01359 }
01360 }
01361 $rs->Close();
01362 }
01363 return $rv;
01364 }
01365
01366 function &Transpose(&$rs)
01367 {
01368 $rs2 =& $this->_rs2rs($rs);
01369 $false = false;
01370 if (!$rs2) return $false;
01371
01372 $rs2->_transpose();
01373 return $rs2;
01374 }
01375
01376
01377
01378
01379
01380
01381
01382
01383 function OffsetDate($dayFraction,$date=false)
01384 {
01385 if (!$date) $date = $this->sysDate;
01386 return '('.$date.'+'.$dayFraction.')';
01387 }
01388
01389
01395 function &GetArray($sql,$inputarr=false)
01396 {
01397 global $ADODB_COUNTRECS;
01398
01399 $savec = $ADODB_COUNTRECS;
01400 $ADODB_COUNTRECS = false;
01401 $rs =& $this->Execute($sql,$inputarr);
01402 $ADODB_COUNTRECS = $savec;
01403 if (!$rs)
01404 if (defined('ADODB_PEAR')) {
01405 $cls = ADODB_PEAR_Error();
01406 return $cls;
01407 } else {
01408 $false = false;
01409 return $false;
01410 }
01411 $arr =& $rs->GetArray();
01412 $rs->Close();
01413 return $arr;
01414 }
01415
01416 function &CacheGetAll($secs2cache,$sql=false,$inputarr=false)
01417 {
01418 $arr =& $this->CacheGetArray($secs2cache,$sql,$inputarr);
01419 return $arr;
01420 }
01421
01422 function &CacheGetArray($secs2cache,$sql=false,$inputarr=false)
01423 {
01424 global $ADODB_COUNTRECS;
01425
01426 $savec = $ADODB_COUNTRECS;
01427 $ADODB_COUNTRECS = false;
01428 $rs =& $this->CacheExecute($secs2cache,$sql,$inputarr);
01429 $ADODB_COUNTRECS = $savec;
01430
01431 if (!$rs)
01432 if (defined('ADODB_PEAR')) {
01433 $cls = ADODB_PEAR_Error();
01434 return $cls;
01435 } else {
01436 $false = false;
01437 return $false;
01438 }
01439 $arr =& $rs->GetArray();
01440 $rs->Close();
01441 return $arr;
01442 }
01443
01444
01445
01452 function &GetRow($sql,$inputarr=false)
01453 {
01454 global $ADODB_COUNTRECS;
01455 $crecs = $ADODB_COUNTRECS;
01456 $ADODB_COUNTRECS = false;
01457
01458 $rs =& $this->Execute($sql,$inputarr);
01459
01460 $ADODB_COUNTRECS = $crecs;
01461 if ($rs) {
01462 if (!$rs->EOF) $arr = $rs->fields;
01463 else $arr = array();
01464 $rs->Close();
01465 return $arr;
01466 }
01467
01468 $false = false;
01469 return $false;
01470 }
01471
01472 function &CacheGetRow($secs2cache,$sql=false,$inputarr=false)
01473 {
01474 $rs =& $this->CacheExecute($secs2cache,$sql,$inputarr);
01475 if ($rs) {
01476 $arr = false;
01477 if (!$rs->EOF) $arr = $rs->fields;
01478 $rs->Close();
01479 return $arr;
01480 }
01481 $false = false;
01482 return $false;
01483 }
01484
01505 function Replace($table, $fieldArray, $keyCol, $autoQuote=false, $has_autoinc=false)
01506 {
01507 global $ADODB_INCLUDED_LIB;
01508 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
01509
01510 return _adodb_replace($this, $table, $fieldArray, $keyCol, $autoQuote, $has_autoinc);
01511 }
01512
01513
01532 function &CacheSelectLimit($secs2cache,$sql,$nrows=-1,$offset=-1,$inputarr=false)
01533 {
01534 if (!is_numeric($secs2cache)) {
01535 if ($sql === false) $sql = -1;
01536 if ($offset == -1) $offset = false;
01537
01538 $rs =& $this->SelectLimit($secs2cache,$sql,$nrows,$offset,$this->cacheSecs);
01539 } else {
01540 if ($sql === false) ADOConnection::outp( "Warning: \$sql missing from CacheSelectLimit()");
01541 $rs =& $this->SelectLimit($sql,$nrows,$offset,$inputarr,$secs2cache);
01542 }
01543 return $rs;
01544 }
01545
01546
01556 function CacheFlush($sql=false,$inputarr=false)
01557 {
01558 global $ADODB_CACHE_DIR;
01559
01560 if ($this->memCache) {
01561 global $ADODB_INCLUDED_MEMCACHE;
01562
01563 $key = false;
01564 if (empty($ADODB_INCLUDED_MEMCACHE)) include(ADODB_DIR.'/adodb-memcache.lib.inc.php');
01565 if ($sql) $key = $this->_gencachename($sql.serialize($inputarr),false,true);
01566 FlushMemCache($key, $this->memCacheHost, $this->memCachePort, $this->debug);
01567 return;
01568 }
01569
01570 if (strlen($ADODB_CACHE_DIR) > 1 && !$sql) {
01571
01572
01573
01574 $dir = $ADODB_CACHE_DIR;
01575
01576 if ($this->debug) {
01577 ADOConnection::outp( "CacheFlush: $dir<br><pre>\n", $this->_dirFlush($dir),"</pre>");
01578 } else {
01579 $this->_dirFlush($dir);
01580 }
01581 return;
01582 }
01583
01584 global $ADODB_INCLUDED_CSV;
01585 if (empty($ADODB_INCLUDED_CSV)) include(ADODB_DIR.'/adodb-csvlib.inc.php');
01586
01587 $f = $this->_gencachename($sql.serialize($inputarr),false);
01588 adodb_write_file($f,'');
01589 if (!@unlink($f)) {
01590 if ($this->debug) ADOConnection::outp( "CacheFlush: failed for $f");
01591 }
01592 }
01593
01600 function _dirFlush($dir, $kill_top_level = false) {
01601 if(!$dh = @opendir($dir)) return;
01602
01603 while (($obj = readdir($dh))) {
01604 if($obj=='.' || $obj=='..')
01605 continue;
01606
01607 if (!@unlink($dir.'/'.$obj))
01608 $this->_dirFlush($dir.'/'.$obj, true);
01609 }
01610 if ($kill_top_level === true)
01611 @rmdir($dir);
01612 return true;
01613 }
01614
01615
01616 function xCacheFlush($sql=false,$inputarr=false)
01617 {
01618 global $ADODB_CACHE_DIR;
01619
01620 if ($this->memCache) {
01621 global $ADODB_INCLUDED_MEMCACHE;
01622 $key = false;
01623 if (empty($ADODB_INCLUDED_MEMCACHE)) include(ADODB_DIR.'/adodb-memcache.lib.inc.php');
01624 if ($sql) $key = $this->_gencachename($sql.serialize($inputarr),false,true);
01625 flushmemCache($key, $this->memCacheHost, $this->memCachePort, $this->debug);
01626 return;
01627 }
01628
01629 if (strlen($ADODB_CACHE_DIR) > 1 && !$sql) {
01630 if (strncmp(PHP_OS,'WIN',3) === 0) {
01631 $cmd = 'del /s '.str_replace('/','\\',$ADODB_CACHE_DIR).'\adodb_*.cache';
01632 } else {
01633
01634 $cmd = 'rm -rf '.$ADODB_CACHE_DIR.'/[0-9a-f][0-9a-f]/';
01635
01636 }
01637 if ($this->debug) {
01638 ADOConnection::outp( "CacheFlush: $cmd<br><pre>\n", system($cmd),"</pre>");
01639 } else {
01640 exec($cmd);
01641 }
01642 return;
01643 }
01644
01645 global $ADODB_INCLUDED_CSV;
01646 if (empty($ADODB_INCLUDED_CSV)) include(ADODB_DIR.'/adodb-csvlib.inc.php');
01647
01648 $f = $this->_gencachename($sql.serialize($inputarr),false);
01649 adodb_write_file($f,'');
01650 if (!@unlink($f)) {
01651 if ($this->debug) ADOConnection::outp( "CacheFlush: failed for $f");
01652 }
01653 }
01654
01669 function _gencachename($sql,$createdir,$memcache=false)
01670 {
01671 global $ADODB_CACHE_DIR;
01672 static $notSafeMode;
01673
01674 if ($this->fetchMode === false) {
01675 global $ADODB_FETCH_MODE;
01676 $mode = $ADODB_FETCH_MODE;
01677 } else {
01678 $mode = $this->fetchMode;
01679 }
01680 $m = md5($sql.$this->databaseType.$this->database.$this->user.$mode);
01681 if ($memcache) return $m;
01682
01683 if (!isset($notSafeMode)) $notSafeMode = !ini_get('safe_mode');
01684 $dir = ($notSafeMode) ? $ADODB_CACHE_DIR.'/'.substr($m,0,2) : $ADODB_CACHE_DIR;
01685
01686 if ($createdir && $notSafeMode && !file_exists($dir)) {
01687 $oldu = umask(0);
01688 if (!mkdir($dir,0771))
01689 if ($this->debug) ADOConnection::outp( "Unable to mkdir $dir for $sql");
01690 umask($oldu);
01691 }
01692 return $dir.'/adodb_'.$m.'.cache';
01693 }
01694
01695
01705 function &CacheExecute($secs2cache,$sql=false,$inputarr=false)
01706 {
01707
01708
01709 if (!is_numeric($secs2cache)) {
01710 $inputarr = $sql;
01711 $sql = $secs2cache;
01712 $secs2cache = $this->cacheSecs;
01713 }
01714
01715 if (is_array($sql)) {
01716 $sqlparam = $sql;
01717 $sql = $sql[0];
01718 } else
01719 $sqlparam = $sql;
01720
01721 if ($this->memCache) {
01722 global $ADODB_INCLUDED_MEMCACHE;
01723 if (empty($ADODB_INCLUDED_MEMCACHE)) include(ADODB_DIR.'/adodb-memcache.lib.inc.php');
01724 $md5file = $this->_gencachename($sql.serialize($inputarr),false,true);
01725 } else {
01726 global $ADODB_INCLUDED_CSV;
01727 if (empty($ADODB_INCLUDED_CSV)) include(ADODB_DIR.'/adodb-csvlib.inc.php');
01728 $md5file = $this->_gencachename($sql.serialize($inputarr),true);
01729 }
01730
01731 $err = '';
01732
01733 if ($secs2cache > 0){
01734 if ($this->memCache)
01735 $rs = &getmemCache($md5file,$err,$secs2cache, $this->memCacheHost, $this->memCachePort);
01736 else
01737 $rs = &csv2rs($md5file,$err,$secs2cache,$this->arrayClass);
01738 $this->numCacheHits += 1;
01739 } else {
01740 $err='Timeout 1';
01741 $rs = false;
01742 $this->numCacheMisses += 1;
01743 }
01744 if (!$rs) {
01745
01746 if ($this->debug) {
01747 if (get_magic_quotes_runtime() && !$this->memCache) {
01748 ADOConnection::outp("Please disable magic_quotes_runtime - it corrupts cache files :(");
01749 }
01750 if ($this->debug !== -1) ADOConnection::outp( " $md5file cache failure: $err (see sql below)");
01751 }
01752
01753 $rs = &$this->Execute($sqlparam,$inputarr);
01754
01755 if ($rs && $this->memCache) {
01756 $rs = &$this->_rs2rs($rs);
01757 if(!putmemCache($md5file, $rs, $this->memCacheHost, $this->memCachePort, $this->memCacheCompress, $this->debug)) {
01758 if ($fn = $this->raiseErrorFn)
01759 $fn($this->databaseType,'CacheExecute',-32000,"Cache write error",$md5file,$sql,$this);
01760 if ($this->debug) ADOConnection::outp( " Cache write error");
01761 }
01762 } else
01763 if ($rs) {
01764 $eof = $rs->EOF;
01765 $rs = &$this->_rs2rs($rs);
01766 $txt = _rs2serialize($rs,false,$sql);
01767
01768 if (!adodb_write_file($md5file,$txt,$this->debug)) {
01769 if ($fn = $this->raiseErrorFn) {
01770 $fn($this->databaseType,'CacheExecute',-32000,"Cache write error",$md5file,$sql,$this);
01771 }
01772 if ($this->debug) ADOConnection::outp( " Cache write error");
01773 }
01774 if ($rs->EOF && !$eof) {
01775 $rs->MoveFirst();
01776
01777 $rs->connection = &$this;
01778 }
01779
01780 } else
01781 if (!$this->memCache)
01782 @unlink($md5file);
01783 } else {
01784 $this->_errorMsg = '';
01785 $this->_errorCode = 0;
01786
01787 if ($this->fnCacheExecute) {
01788 $fn = $this->fnCacheExecute;
01789 $fn($this, $secs2cache, $sql, $inputarr);
01790 }
01791
01792 $rs->connection = &$this;
01793 if ($this->debug){
01794
01795 $inBrowser = isset($_SERVER['HTTP_USER_AGENT']);
01796 $ttl = $rs->timeCreated + $secs2cache - time();
01797 $s = is_array($sql) ? $sql[0] : $sql;
01798 if ($inBrowser) $s = '<i>'.htmlspecialchars($s).'</i>';
01799
01800 ADOConnection::outp( " $md5file reloaded, ttl=$ttl [ $s ]");
01801 }
01802 }
01803 return $rs;
01804 }
01805
01806
01807
01808
01809
01810
01811
01812
01813
01814 function& AutoExecute($table, $fields_values, $mode = 'INSERT', $where = FALSE, $forceUpdate=true, $magicq=false)
01815 {
01816 $false = false;
01817 $sql = 'SELECT * FROM '.$table;
01818 if ($where!==FALSE) $sql .= ' WHERE '.$where;
01819 else if ($mode == 'UPDATE' || $mode == 2 ) {
01820 ADOConnection::outp('AutoExecute: Illegal mode=UPDATE with empty WHERE clause');
01821 return $false;
01822 }
01823
01824 $rs =& $this->SelectLimit($sql,1);
01825 if (!$rs) return $false;
01826 $rs->tableName = $table;
01827
01828 switch((string) $mode) {
01829 case 'UPDATE':
01830 case '2':
01831 $sql = $this->GetUpdateSQL($rs, $fields_values, $forceUpdate, $magicq);
01832 break;
01833 case 'INSERT':
01834 case '1':
01835 $sql = $this->GetInsertSQL($rs, $fields_values, $magicq);
01836 break;
01837 default:
01838 ADOConnection::outp("AutoExecute: Unknown mode=$mode");
01839 return $false;
01840 }
01841 $ret = false;
01842 if ($sql) $ret = $this->Execute($sql);
01843 if ($ret) $ret = true;
01844 return $ret;
01845 }
01846
01847
01859 function GetUpdateSQL(&$rs, $arrFields,$forceUpdate=false,$magicq=false,$force=null)
01860 {
01861 global $ADODB_INCLUDED_LIB;
01862
01863
01864
01865
01866 if (!isset($force)) {
01867 global $ADODB_FORCE_TYPE;
01868 $force = $ADODB_FORCE_TYPE;
01869 }
01870
01871
01872 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
01873 return _adodb_getupdatesql($this,$rs,$arrFields,$forceUpdate,$magicq,$force);
01874 }
01875
01884 function GetInsertSQL(&$rs, $arrFields,$magicq=false,$force=null)
01885 {
01886 global $ADODB_INCLUDED_LIB;
01887 if (!isset($force)) {
01888 global $ADODB_FORCE_TYPE;
01889 $force = $ADODB_FORCE_TYPE;
01890
01891 }
01892 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
01893 return _adodb_getinsertsql($this,$rs,$arrFields,$magicq,$force);
01894 }
01895
01896
01916 function UpdateBlob($table,$column,$val,$where,$blobtype='BLOB')
01917 {
01918 return $this->Execute("UPDATE $table SET $column=? WHERE $where",array($val)) != false;
01919 }
01920
01930 function UpdateBlobFile($table,$column,$path,$where,$blobtype='BLOB')
01931 {
01932 $fd = fopen($path,'rb');
01933 if ($fd === false) return false;
01934 $val = fread($fd,filesize($path));
01935 fclose($fd);
01936 return $this->UpdateBlob($table,$column,$val,$where,$blobtype);
01937 }
01938
01939 function BlobDecode($blob)
01940 {
01941 return $blob;
01942 }
01943
01944 function BlobEncode($blob)
01945 {
01946 return $blob;
01947 }
01948
01949 function SetCharSet($charset)
01950 {
01951 return false;
01952 }
01953
01954 function IfNull( $field, $ifNull )
01955 {
01956 return " CASE WHEN $field is null THEN $ifNull ELSE $field END ";
01957 }
01958
01959 function LogSQL($enable=true)
01960 {
01961 include_once(ADODB_DIR.'/adodb-perf.inc.php');
01962
01963 if ($enable) $this->fnExecute = 'adodb_log_sql';
01964 else $this->fnExecute = false;
01965
01966 $old = $this->_logsql;
01967 $this->_logsql = $enable;
01968 if ($enable && !$old) $this->_affected = false;
01969 return $old;
01970 }
01971
01972 function GetCharSet()
01973 {
01974 return false;
01975 }
01976
01984 function UpdateClob($table,$column,$val,$where)
01985 {
01986 return $this->UpdateBlob($table,$column,$val,$where,'CLOB');
01987 }
01988
01989
01990
01991 function MetaType($t,$len=-1,$fieldobj=false)
01992 {
01993
01994 if (empty($this->_metars)) {
01995 $rsclass = $this->rsPrefix.$this->databaseType;
01996 $this->_metars =& new $rsclass(false,$this->fetchMode);
01997 $this->_metars->connection =& $this;
01998 }
01999 return $this->_metars->MetaType($t,$len,$fieldobj);
02000 }
02001
02002
02007 function SetDateLocale($locale = 'En')
02008 {
02009 $this->locale = $locale;
02010 switch (strtoupper($locale))
02011 {
02012 case 'EN':
02013 $this->fmtDate="'Y-m-d'";
02014 $this->fmtTimeStamp = "'Y-m-d H:i:s'";
02015 break;
02016
02017 case 'US':
02018 $this->fmtDate = "'m-d-Y'";
02019 $this->fmtTimeStamp = "'m-d-Y H:i:s'";
02020 break;
02021
02022 case 'NL':
02023 case 'FR':
02024 case 'RO':
02025 case 'IT':
02026 $this->fmtDate="'d-m-Y'";
02027 $this->fmtTimeStamp = "'d-m-Y H:i:s'";
02028 break;
02029
02030 case 'GE':
02031 $this->fmtDate="'d.m.Y'";
02032 $this->fmtTimeStamp = "'d.m.Y H:i:s'";
02033 break;
02034
02035 default:
02036 $this->fmtDate="'Y-m-d'";
02037 $this->fmtTimeStamp = "'Y-m-d H:i:s'";
02038 break;
02039 }
02040 }
02041
02042 function &GetActiveRecordsClass($class, $table,$whereOrderBy=false,$bindarr=false, $primkeyArr=false)
02043 {
02044 global $_ADODB_ACTIVE_DBS;
02045
02046 $save = $this->SetFetchMode(ADODB_FETCH_NUM);
02047 if (empty($whereOrderBy)) $whereOrderBy = '1=1';
02048 $rows = $this->GetAll("select * from ".$table.' WHERE '.$whereOrderBy,$bindarr);
02049 $this->SetFetchMode($save);
02050
02051 $false = false;
02052
02053 if ($rows === false) {
02054 return $false;
02055 }
02056
02057
02058 if (!isset($_ADODB_ACTIVE_DBS)) {
02059 include(ADODB_DIR.'/adodb-active-record.inc.php');
02060 }
02061 if (!class_exists($class)) {
02062 ADOConnection::outp("Unknown class $class in GetActiveRcordsClass()");
02063 return $false;
02064 }
02065 $arr = array();
02066 foreach($rows as $row) {
02067
02068 $obj =& new $class($table,$primkeyArr,$this);
02069 if ($obj->ErrorMsg()){
02070 $this->_errorMsg = $obj->ErrorMsg();
02071 return $false;
02072 }
02073 $obj->Set($row);
02074 $arr[] =& $obj;
02075 }
02076 return $arr;
02077 }
02078
02079 function &GetActiveRecords($table,$where=false,$bindarr=false,$primkeyArr=false)
02080 {
02081 $arr =& $this->GetActiveRecordsClass('ADODB_Active_Record', $table, $where, $bindarr, $primkeyArr);
02082 return $arr;
02083 }
02084
02088 function Close()
02089 {
02090 $rez = $this->_close();
02091 $this->_connectionID = false;
02092 return $rez;
02093 }
02094
02100 function BeginTrans() {return false;}
02101
02102
02103 function SetTransactionMode( $transaction_mode )
02104 {
02105 $transaction_mode = $this->MetaTransaction($transaction_mode, $this->dataProvider);
02106 $this->_transmode = $transaction_mode;
02107 }
02108
02109
02110
02111
02112
02113
02114 function MetaTransaction($mode,$db)
02115 {
02116 $mode = strtoupper($mode);
02117 $mode = str_replace('ISOLATION LEVEL ','',$mode);
02118
02119 switch($mode) {
02120
02121 case 'READ UNCOMMITTED':
02122 switch($db) {
02123 case 'oci8':
02124 case 'oracle':
02125 return 'ISOLATION LEVEL READ COMMITTED';
02126 default:
02127 return 'ISOLATION LEVEL READ UNCOMMITTED';
02128 }
02129 break;
02130
02131 case 'READ COMMITTED':
02132 return 'ISOLATION LEVEL READ COMMITTED';
02133 break;
02134
02135 case 'REPEATABLE READ':
02136 switch($db) {
02137 case 'oci8':
02138 case 'oracle':
02139 return 'ISOLATION LEVEL SERIALIZABLE';
02140 default:
02141 return 'ISOLATION LEVEL REPEATABLE READ';
02142 }
02143 break;
02144
02145 case 'SERIALIZABLE':
02146 return 'ISOLATION LEVEL SERIALIZABLE';
02147 break;
02148
02149 default:
02150 return $mode;
02151 }
02152 }
02153
02161 function CommitTrans($ok=true)
02162 { return true;}
02163
02164
02170 function RollbackTrans()
02171 { return false;}
02172
02173
02180 function MetaDatabases()
02181 {
02182 global $ADODB_FETCH_MODE;
02183
02184 if ($this->metaDatabasesSQL) {
02185 $save = $ADODB_FETCH_MODE;
02186 $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
02187
02188 if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
02189
02190 $arr = $this->GetCol($this->metaDatabasesSQL);
02191 if (isset($savem)) $this->SetFetchMode($savem);
02192 $ADODB_FETCH_MODE = $save;
02193
02194 return $arr;
02195 }
02196
02197 return false;
02198 }
02199
02200
02211 function &MetaTables($ttype=false,$showSchema=false,$mask=false)
02212 {
02213 global $ADODB_FETCH_MODE;
02214
02215
02216 $false = false;
02217 if ($mask) {
02218 return $false;
02219 }
02220 if ($this->metaTablesSQL) {
02221 $save = $ADODB_FETCH_MODE;
02222 $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
02223
02224 if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
02225
02226 $rs = $this->Execute($this->metaTablesSQL);
02227 if (isset($savem)) $this->SetFetchMode($savem);
02228 $ADODB_FETCH_MODE = $save;
02229
02230 if ($rs === false) return $false;
02231 $arr =& $rs->GetArray();
02232 $arr2 = array();
02233
02234 if ($hast = ($ttype && isset($arr[0][1]))) {
02235 $showt = strncmp($ttype,'T',1);
02236 }
02237
02238 for ($i=0; $i < sizeof($arr); $i++) {
02239 if ($hast) {
02240 if ($showt == 0) {
02241 if (strncmp($arr[$i][1],'T',1) == 0) $arr2[] = trim($arr[$i][0]);
02242 } else {
02243 if (strncmp($arr[$i][1],'V',1) == 0) $arr2[] = trim($arr[$i][0]);
02244 }
02245 } else
02246 $arr2[] = trim($arr[$i][0]);
02247 }
02248 $rs->Close();
02249 return $arr2;
02250 }
02251 return $false;
02252 }
02253
02254
02255 function _findschema(&$table,&$schema)
02256 {
02257 if (!$schema && ($at = strpos($table,'.')) !== false) {
02258 $schema = substr($table,0,$at);
02259 $table = substr($table,$at+1);
02260 }
02261 }
02262
02273 function &MetaColumns($table,$normalize=true)
02274 {
02275 global $ADODB_FETCH_MODE;
02276
02277 $false = false;
02278
02279 if (!empty($this->metaColumnsSQL)) {
02280
02281 $schema = false;
02282 $this->_findschema($table,$schema);
02283
02284 $save = $ADODB_FETCH_MODE;
02285 $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
02286 if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
02287 $rs = $this->Execute(sprintf($this->metaColumnsSQL,($normalize)?strtoupper($table):$table));
02288 if (isset($savem)) $this->SetFetchMode($savem);
02289 $ADODB_FETCH_MODE = $save;
02290 if ($rs === false || $rs->EOF) return $false;
02291
02292 $retarr = array();
02293 while (!$rs->EOF) {
02294 $fld = new ADOFieldObject();
02295 $fld->name = $rs->fields[0];
02296 $fld->type = $rs->fields[1];
02297 if (isset($rs->fields[3]) && $rs->fields[3]) {
02298 if ($rs->fields[3]>0) $fld->max_length = $rs->fields[3];
02299 $fld->scale = $rs->fields[4];
02300 if ($fld->scale>0) $fld->max_length += 1;
02301 } else
02302 $fld->max_length = $rs->fields[2];
02303
02304 if ($ADODB_FETCH_MODE == ADODB_FETCH_NUM) $retarr[] = $fld;
02305 else $retarr[strtoupper($fld->name)] = $fld;
02306 $rs->MoveNext();
02307 }
02308 $rs->Close();
02309 return $retarr;
02310 }
02311 return $false;
02312 }
02313
02332 function &MetaIndexes($table, $primary = false, $owner = false)
02333 {
02334 $false = false;
02335 return $false;
02336 }
02337
02344 function &MetaColumnNames($table, $numIndexes=false,$useattnum=false )
02345 {
02346 $objarr =& $this->MetaColumns($table);
02347 if (!is_array($objarr)) {
02348 $false = false;
02349 return $false;
02350 }
02351 $arr = array();
02352 if ($numIndexes) {
02353 $i = 0;
02354 if ($useattnum) {
02355 foreach($objarr as $v)
02356 $arr[$v->attnum] = $v->name;
02357
02358 } else
02359 foreach($objarr as $v) $arr[$i++] = $v->name;
02360 } else
02361 foreach($objarr as $v) $arr[strtoupper($v->name)] = $v->name;
02362
02363 return $arr;
02364 }
02365
02376 function Concat()
02377 {
02378 $arr = func_get_args();
02379 return implode($this->concat_operator, $arr);
02380 }
02381
02382
02390 function DBDate($d)
02391 {
02392 if (empty($d) && $d !== 0) return 'null';
02393
02394 if (is_string($d) && !is_numeric($d)) {
02395 if ($d === 'null' || strncmp($d,"'",1) === 0) return $d;
02396 if ($this->isoDates) return "'$d'";
02397 $d = ADOConnection::UnixDate($d);
02398 }
02399
02400 return adodb_date($this->fmtDate,$d);
02401 }
02402
02403 function BindDate($d)
02404 {
02405 $d = $this->DBDate($d);
02406 if (strncmp($d,"'",1)) return $d;
02407
02408 return substr($d,1,strlen($d)-2);
02409 }
02410
02411 function BindTimeStamp($d)
02412 {
02413 $d = $this->DBTimeStamp($d);
02414 if (strncmp($d,"'",1)) return $d;
02415
02416 return substr($d,1,strlen($d)-2);
02417 }
02418
02419
02427 function DBTimeStamp($ts)
02428 {
02429 if (empty($ts) && $ts !== 0) return 'null';
02430
02431 # strlen(14) allows YYYYMMDDHHMMSS format
02432 if (!is_string($ts) || (is_numeric($ts) && strlen($ts)<14))
02433 return adodb_date($this->fmtTimeStamp,$ts);
02434
02435 if ($ts === 'null') return $ts;
02436 if ($this->isoDates && strlen($ts) !== 14) return "'$ts'";
02437
02438 $ts = ADOConnection::UnixTimeStamp($ts);
02439 return adodb_date($this->fmtTimeStamp,$ts);
02440 }
02441
02448 function UnixDate($v)
02449 {
02450 if (is_object($v)) {
02451
02452
02453 return adodb_mktime($v->hour,$v->minute,$v->second,$v->month,$v->day, $v->year);
02454 }
02455
02456 if (is_numeric($v) && strlen($v) !== 8) return $v;
02457 if (!preg_match( "|^([0-9]{4})[-/\.]?([0-9]{1,2})[-/\.]?([0-9]{1,2})|",
02458 ($v), $rr)) return false;
02459
02460 if ($rr[1] <= TIMESTAMP_FIRST_YEAR) return 0;
02461
02462 return @adodb_mktime(0,0,0,$rr[2],$rr[3],$rr[1]);
02463 }
02464
02465
02472 function UnixTimeStamp($v)
02473 {
02474 if (is_object($v)) {
02475
02476
02477 return adodb_mktime($v->hour,$v->minute,$v->second,$v->month,$v->day, $v->year);
02478 }
02479
02480 if (!preg_match(
02481 "|^([0-9]{4})[-/\.]?([0-9]{1,2})[-/\.]?([0-9]{1,2})[ ,-]*(([0-9]{1,2}):?([0-9]{1,2}):?([0-9\.]{1,4}))?|",
02482 ($v), $rr)) return false;
02483
02484 if ($rr[1] <= TIMESTAMP_FIRST_YEAR && $rr[2]<= 1) return 0;
02485
02486
02487 if (!isset($rr[5])) return adodb_mktime(0,0,0,$rr[2],$rr[3],$rr[1]);
02488 return @adodb_mktime($rr[5],$rr[6],$rr[7],$rr[2],$rr[3],$rr[1]);
02489 }
02490
02502 function UserDate($v,$fmt='Y-m-d',$gmt=false)
02503 {
02504 $tt = $this->UnixDate($v);
02505
02506
02507 if (($tt === false || $tt == -1) && $v != false) return $v;
02508 else if ($tt == 0) return $this->emptyDate;
02509 else if ($tt == -1) {
02510 }
02511
02512 return ($gmt) ? adodb_gmdate($fmt,$tt) : adodb_date($fmt,$tt);
02513
02514 }
02515
02523 function UserTimeStamp($v,$fmt='Y-m-d H:i:s',$gmt=false)
02524 {
02525 if (!isset($v)) return $this->emptyTimeStamp;
02526 # strlen(14) allows YYYYMMDDHHMMSS format
02527 if (is_numeric($v) && strlen($v)<14) return ($gmt) ? adodb_gmdate($fmt,$v) : adodb_date($fmt,$v);
02528 $tt = $this->UnixTimeStamp($v);
02529
02530 if (($tt === false || $tt == -1) && $v != false) return $v;
02531 if ($tt == 0) return $this->emptyTimeStamp;
02532 return ($gmt) ? adodb_gmdate($fmt,$tt) : adodb_date($fmt,$tt);
02533 }
02534
02535 function escape($s,$magic_quotes=false)
02536 {
02537 return $this->addq($s,$magic_quotes);
02538 }
02539
02543 function addq($s,$magic_quotes=false)
02544 {
02545 if (!$magic_quotes) {
02546
02547 if ($this->replaceQuote[0] == '\\'){
02548
02549 $s = adodb_str_replace(array('\\',"\0"),array('\\\\',"\\\0"),$s);
02550
02551 }
02552 return str_replace("'",$this->replaceQuote,$s);
02553 }
02554
02555
02556 $s = str_replace('\\"','"',$s);
02557
02558 if ($this->replaceQuote == "\\'")
02559 return $s;
02560 else {
02561 $s = str_replace('\\\\','\\',$s);
02562 return str_replace("\\'",$this->replaceQuote,$s);
02563 }
02564 }
02565
02577 function qstr($s,$magic_quotes=false)
02578 {
02579 if (!$magic_quotes) {
02580
02581 if ($this->replaceQuote[0] == '\\'){
02582
02583 $s = adodb_str_replace(array('\\',"\0"),array('\\\\',"\\\0"),$s);
02584
02585 }
02586 return "'".str_replace("'",$this->replaceQuote,$s)."'";
02587 }
02588
02589
02590 $s = str_replace('\\"','"',$s);
02591
02592 if ($this->replaceQuote == "\\'")
02593 return "'$s'";
02594 else {
02595 $s = str_replace('\\\\','\\',$s);
02596 return "'".str_replace("\\'",$this->replaceQuote,$s)."'";
02597 }
02598 }
02599
02600
02618 function &PageExecute($sql, $nrows, $page, $inputarr=false, $secs2cache=0)
02619 {
02620 global $ADODB_INCLUDED_LIB;
02621 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
02622 if ($this->pageExecuteCountRows) $rs =& _adodb_pageexecute_all_rows($this, $sql, $nrows, $page, $inputarr, $secs2cache);
02623 else $rs =& _adodb_pageexecute_no_last_page($this, $sql, $nrows, $page, $inputarr, $secs2cache);
02624 return $rs;
02625 }
02626
02627
02640 function &CachePageExecute($secs2cache, $sql, $nrows, $page,$inputarr=false)
02641 {
02642
02643
02644
02645
02646
02647
02648 $rs =& $this->PageExecute($sql,$nrows,$page,$inputarr,$secs2cache);
02649 return $rs;
02650 }
02651
02652 }
02653
02654
02655
02656
02657
02658
02659
02663 class ADOFetchObj {
02664 };
02665
02666
02667
02668
02669
02673 class ADORecordSet_empty
02674 {
02675 var $dataProvider = 'empty';
02676 var $databaseType = false;
02677 var $EOF = true;
02678 var $_numOfRows = 0;
02679 var $fields = false;
02680 var $connection = false;
02681 function RowCount() {return 0;}
02682 function RecordCount() {return 0;}
02683 function PO_RecordCount(){return 0;}
02684 function Close(){return true;}
02685 function FetchRow() {return false;}
02686 function FieldCount(){ return 0;}
02687 function Init() {}
02688 }
02689
02690
02691
02692
02693 if (!defined('ADODB_DATE_VERSION')) include(ADODB_DIR.'/adodb-time.inc.php');
02694
02695
02696
02697
02698
02699 if (PHP_VERSION < 5) include_once(ADODB_DIR.'/adodb-php4.inc.php');
02700 else include_once(ADODB_DIR.'/adodb-iterator.inc.php');
02707 class ADORecordSet extends ADODB_BASE_RS {
02708
02709
02710
02711 var $dataProvider = "native";
02712 var $fields = false;
02713 var $blobSize = 100;
02714
02715 var $canSeek = false;
02716 var $sql;
02717 var $EOF = false;
02718
02719 var $emptyTimeStamp = ' ';
02720 var $emptyDate = ' ';
02721 var $debug = false;
02722 var $timeCreated=0;
02723
02724 var $bind = false;
02725 var $fetchMode;
02726 var $connection = false;
02727
02728
02729
02730 var $_numOfRows = -1;
02731 var $_numOfFields = -1;
02732 var $_queryID = -1;
02733 var $_currentRow = -1;
02734 var $_closed = false;
02735 var $_inited = false;
02736 var $_obj;
02737 var $_names;
02739 var $_currentPage = -1;
02740 var $_atFirstPage = false;
02741 var $_atLastPage = false;
02742 var $_lastPageNo = -1;
02743 var $_maxRecordCount = 0;
02744 var $datetime = false;
02745
02752 function ADORecordSet($queryID)
02753 {
02754 $this->_queryID = $queryID;
02755 }
02756
02757
02758
02759 function Init()
02760 {
02761 if ($this->_inited) return;
02762 $this->_inited = true;
02763 if ($this->_queryID) @$this->_initrs();
02764 else {
02765 $this->_numOfRows = 0;
02766 $this->_numOfFields = 0;
02767 }
02768 if ($this->_numOfRows != 0 && $this->_numOfFields && $this->_currentRow == -1) {
02769
02770 $this->_currentRow = 0;
02771 if ($this->EOF = ($this->_fetch() === false)) {
02772 $this->_numOfRows = 0;
02773 }
02774 } else {
02775 $this->EOF = true;
02776 }
02777 }
02778
02779
02800 function GetMenu($name,$defstr='',$blank1stItem=true,$multiple=false,
02801 $size=0, $selectAttr='',$compareFields0=true)
02802 {
02803 global $ADODB_INCLUDED_LIB;
02804 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
02805 return _adodb_getmenu($this, $name,$defstr,$blank1stItem,$multiple,
02806 $size, $selectAttr,$compareFields0);
02807 }
02808
02809
02810
02818 function GetMenu2($name,$defstr='',$blank1stItem=true,$multiple=false,$size=0, $selectAttr='')
02819 {
02820 return $this->GetMenu($name,$defstr,$blank1stItem,$multiple,
02821 $size, $selectAttr,false);
02822 }
02823
02824
02825
02826
02827 function GetMenu3($name,$defstr='',$blank1stItem=true,$multiple=false,
02828 $size=0, $selectAttr='')
02829 {
02830 global $ADODB_INCLUDED_LIB;
02831 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
02832 return _adodb_getmenu_gp($this, $name,$defstr,$blank1stItem,$multiple,
02833 $size, $selectAttr,false);
02834 }
02835
02843 function &GetArray($nRows = -1)
02844 {
02845 global $ADODB_EXTENSION; if ($ADODB_EXTENSION) {
02846 $results = adodb_getall($this,$nRows);
02847 return $results;
02848 }
02849 $results = array();
02850 $cnt = 0;
02851 while (!$this->EOF && $nRows != $cnt) {
02852 $results[] = $this->fields;
02853 $this->MoveNext();
02854 $cnt++;
02855 }
02856 return $results;
02857 }
02858
02859 function &GetAll($nRows = -1)
02860 {
02861 $arr =& $this->GetArray($nRows);
02862 return $arr;
02863 }
02864
02865
02866
02867
02868
02869 function NextRecordSet()
02870 {
02871 return false;
02872 }
02873
02883 function &GetArrayLimit($nrows,$offset=-1)
02884 {
02885 if ($offset <= 0) {
02886 $arr =& $this->GetArray($nrows);
02887 return $arr;
02888 }
02889
02890 $this->Move($offset);
02891
02892 $results = array();
02893 $cnt = 0;
02894 while (!$this->EOF && $nrows != $cnt) {
02895 $results[$cnt++] = $this->fields;
02896 $this->MoveNext();
02897 }
02898
02899 return $results;
02900 }
02901
02902
02910 function &GetRows($nRows = -1)
02911 {
02912 $arr =& $this->GetArray($nRows);
02913 return $arr;
02914 }
02915
02932 function &GetAssoc($force_array = false, $first2cols = false)
02933 {
02934 global $ADODB_EXTENSION;
02935
02936 $cols = $this->_numOfFields;
02937 if ($cols < 2) {
02938 $false = false;
02939 return $false;
02940 }
02941 $numIndex = isset($this->fields[0]);
02942 $results = array();
02943
02944 if (!$first2cols && ($cols > 2 || $force_array)) {
02945 if ($ADODB_EXTENSION) {
02946 if ($numIndex) {
02947 while (!$this->EOF) {
02948 $results[trim($this->fields[0])] = array_slice($this->fields, 1);
02949 adodb_movenext($this);
02950 }
02951 } else {
02952 while (!$this->EOF) {
02953
02954 $keys = array_slice(array_keys($this->fields), 1);
02955 $sliced_array = array();
02956
02957 foreach($keys as $key) {
02958 $sliced_array[$key] = $this->fields[$key];
02959 }
02960
02961 $results[trim(reset($this->fields))] = $sliced_array;
02962 adodb_movenext($this);
02963 }
02964 }
02965 } else {
02966 if ($numIndex) {
02967 while (!$this->EOF) {
02968 $results[trim($this->fields[0])] = array_slice($this->fields, 1);
02969 $this->MoveNext();
02970 }
02971 } else {
02972 while (!$this->EOF) {
02973
02974 $keys = array_slice(array_keys($this->fields), 1);
02975 $sliced_array = array();
02976
02977 foreach($keys as $key) {
02978 $sliced_array[$key] = $this->fields[$key];
02979 }
02980
02981 $results[trim(reset($this->fields))] = $sliced_array;
02982 $this->MoveNext();
02983 }
02984 }
02985 }
02986 } else {
02987 if ($ADODB_EXTENSION) {
02988
02989 if ($numIndex) {
02990 while (!$this->EOF) {
02991
02992 $results[trim(($this->fields[0]))] = $this->fields[1];
02993 adodb_movenext($this);
02994 }
02995 } else {
02996 while (!$this->EOF) {
02997
02998 $v1 = trim(reset($this->fields));
02999 $v2 = ''.next($this->fields);
03000 $results[$v1] = $v2;
03001 adodb_movenext($this);
03002 }
03003 }
03004 } else {
03005 if ($numIndex) {
03006 while (!$this->EOF) {
03007
03008 $results[trim(($this->fields[0]))] = $this->fields[1];
03009 $this->MoveNext();
03010 }
03011 } else {
03012 while (!$this->EOF) {
03013
03014 $v1 = trim(reset($this->fields));
03015 $v2 = ''.next($this->fields);
03016 $results[$v1] = $v2;
03017 $this->MoveNext();
03018 }
03019 }
03020 }
03021 }
03022
03023 $ref =& $results; # workaround accelerator incompat with PHP 4.4 :(
03024 return $ref;
03025 }
03026
03027
03035 function UserTimeStamp($v,$fmt='Y-m-d H:i:s')
03036 {
03037 if (is_numeric($v) && strlen($v)<14) return adodb_date($fmt,$v);
03038 $tt = $this->UnixTimeStamp($v);
03039
03040 if (($tt === false || $tt == -1) && $v != false) return $v;
03041 if ($tt === 0) return $this->emptyTimeStamp;
03042 return adodb_date($fmt,$tt);
03043 }
03044
03045
03052 function UserDate($v,$fmt='Y-m-d')
03053 {
03054 $tt = $this->UnixDate($v);
03055
03056 if (($tt === false || $tt == -1) && $v != false) return $v;
03057 else if ($tt == 0) return $this->emptyDate;
03058 else if ($tt == -1) {
03059 }
03060 return adodb_date($fmt,$tt);
03061 }
03062
03063
03069 function UnixDate($v)
03070 {
03071 return ADOConnection::UnixDate($v);
03072 }
03073
03074
03080 function UnixTimeStamp($v)
03081 {
03082 return ADOConnection::UnixTimeStamp($v);
03083 }
03084
03085
03089 function Free()
03090 {
03091 return $this->Close();
03092 }
03093
03094
03098 function NumRows()
03099 {
03100 return $this->_numOfRows;
03101 }
03102
03103
03107 function NumCols()
03108 {
03109 return $this->_numOfFields;
03110 }
03111
03118 function &FetchRow()
03119 {
03120 if ($this->EOF) {
03121 $false = false;
03122 return $false;
03123 }
03124 $arr = $this->fields;
03125 $this->_currentRow++;
03126 if (!$this->_fetch()) $this->EOF = true;
03127 return $arr;
03128 }
03129
03130
03137 function FetchInto(&$arr)
03138 {
03139 if ($this->EOF) return (defined('PEAR_ERROR_RETURN')) ? new PEAR_Error('EOF',-1): false;
03140 $arr = $this->fields;
03141 $this->MoveNext();
03142 return 1;
03143 }
03144
03145
03151 function MoveFirst()
03152 {
03153 if ($this->_currentRow == 0) return true;
03154 return $this->Move(0);
03155 }
03156
03157
03163 function MoveLast()
03164 {
03165 if ($this->_numOfRows >= 0) return $this->Move($this->_numOfRows-1);
03166 if ($this->EOF) return false;
03167 while (!$this->EOF) {
03168 $f = $this->fields;
03169 $this->MoveNext();
03170 }
03171 $this->fields = $f;
03172 $this->EOF = false;
03173 return true;
03174 }
03175
03176
03182 function MoveNext()
03183 {
03184 if (!$this->EOF) {
03185 $this->_currentRow++;
03186 if ($this->_fetch()) return true;
03187 }
03188 $this->EOF = true;
03189
03190
03191
03192
03193
03194
03195
03196 return false;
03197 }
03198
03199
03208 function Move($rowNumber = 0)
03209 {
03210 $this->EOF = false;
03211 if ($rowNumber == $this->_currentRow) return true;
03212 if ($rowNumber >= $this->_numOfRows)
03213 if ($this->_numOfRows != -1) $rowNumber = $this->_numOfRows-2;
03214
03215 if ($this->canSeek) {
03216
03217 if ($this->_seek($rowNumber)) {
03218 $this->_currentRow = $rowNumber;
03219 if ($this->_fetch()) {
03220 return true;
03221 }
03222 } else {
03223 $this->EOF = true;
03224 return false;
03225 }
03226 } else {
03227 if ($rowNumber < $this->_currentRow) return false;
03228 global $ADODB_EXTENSION;
03229 if ($ADODB_EXTENSION) {
03230 while (!$this->EOF && $this->_currentRow < $rowNumber) {
03231 adodb_movenext($this);
03232 }
03233 } else {
03234
03235 while (! $this->EOF && $this->_currentRow < $rowNumber) {
03236 $this->_currentRow++;
03237
03238 if (!$this->_fetch()) $this->EOF = true;
03239 }
03240 }
03241 return !($this->EOF);
03242 }
03243
03244 $this->fields = false;
03245 $this->EOF = true;
03246 return false;
03247 }
03248
03249
03258 function Fields($colname)
03259 {
03260 return $this->fields[$colname];
03261 }
03262
03263 function GetAssocKeys($upper=true)
03264 {
03265 $this->bind = array();
03266 for ($i=0; $i < $this->_numOfFields; $i++) {
03267 $o = $this->FetchField($i);
03268 if ($upper === 2) $this->bind[$o->name] = $i;
03269 else $this->bind[($upper) ? strtoupper($o->name) : strtolower($o->name)] = $i;
03270 }
03271 }
03272
03282 function &GetRowAssoc($upper=1)
03283 {
03284 $record = array();
03285
03286
03287 if (!$this->bind) {
03288 $this->GetAssocKeys($upper);
03289 }
03290
03291 foreach($this->bind as $k => $v) {
03292 $record[$k] = $this->fields[$v];
03293 }
03294
03295 return $record;
03296 }
03297
03298
03304 function Close()
03305 {
03306
03307
03308
03309 if (!$this->_closed) {
03310 $this->_closed = true;
03311 return $this->_close();
03312 } else
03313 return true;
03314 }
03315
03321 function RecordCount() {return $this->_numOfRows;}
03322
03323
03324
03325
03326
03327
03328 function MaxRecordCount()
03329 {
03330 return ($this->_maxRecordCount) ? $this->_maxRecordCount : $this->RecordCount();
03331 }
03332
03338 function RowCount() {return $this->_numOfRows;}
03339
03340
03349 function PO_RecordCount($table="", $condition="") {
03350
03351 $lnumrows = $this->_numOfRows;
03352
03353 if ($lnumrows == -1 && $this->connection) {
03354 IF ($table) {
03355 if ($condition) $condition = " WHERE " . $condition;
03356 $resultrows = &$this->connection->Execute("SELECT COUNT(*) FROM $table $condition");
03357 if ($resultrows) $lnumrows = reset($resultrows->fields);
03358 }
03359 }
03360 return $lnumrows;
03361 }
03362
03363
03367 function CurrentRow() {return $this->_currentRow;}
03368
03374 function AbsolutePosition() {return $this->_currentRow;}
03375
03380 function FieldCount() {return $this->_numOfFields;}
03381
03382
03390 function &FetchField($fieldoffset)
03391 {
03392
03393 }
03394
03399 function& FieldTypesArray()
03400 {
03401 $arr = array();
03402 for ($i=0, $max=$this->_numOfFields; $i < $max; $i++)
03403 $arr[] = $this->FetchField($i);
03404 return $arr;
03405 }
03406
03413 function &FetchObj()
03414 {
03415 $o =& $this->FetchObject(false);
03416 return $o;
03417 }
03418
03427 function &FetchObject($isupper=true)
03428 {
03429 if (empty($this->_obj)) {
03430 $this->_obj = new ADOFetchObj();
03431 $this->_names = array();
03432 for ($i=0; $i <$this->_numOfFields; $i++) {
03433 $f = $this->FetchField($i);
03434 $this->_names[] = $f->name;
03435 }
03436 }
03437 $i = 0;
03438 if (PHP_VERSION >= 5) $o = clone($this->_obj);
03439 else $o = $this->_obj;
03440
03441 for ($i=0; $i <$this->_numOfFields; $i++) {
03442 $name = $this->_names[$i];
03443 if ($isupper) $n = strtoupper($name);
03444 else $n = $name;
03445
03446 $o->$n = $this->Fields($name);
03447 }
03448 return $o;
03449 }
03450
03460 function &FetchNextObj()
03461 {
03462 $o =& $this->FetchNextObject(false);
03463 return $o;
03464 }
03465
03466
03478 function &FetchNextObject($isupper=true)
03479 {
03480 $o = false;
03481 if ($this->_numOfRows != 0 && !$this->EOF) {
03482 $o = $this->FetchObject($isupper);
03483 $this->_currentRow++;
03484 if ($this->_fetch()) return $o;
03485 }
03486 $this->EOF = true;
03487 return $o;
03488 }
03489
03514 function MetaType($t,$len=-1,$fieldobj=false)
03515 {
03516 if (is_object($t)) {
03517 $fieldobj = $t;
03518 $t = $fieldobj->type;
03519 $len = $fieldobj->max_length;
03520 }
03521
03522 static $typeMap = array(
03523 'VARCHAR' => 'C',
03524 'VARCHAR2' => 'C',
03525 'CHAR' => 'C',
03526 'C' => 'C',
03527 'STRING' => 'C',
03528 'NCHAR' => 'C',
03529 'NVARCHAR' => 'C',
03530 'VARYING' => 'C',
03531 'BPCHAR' => 'C',
03532 'CHARACTER' => 'C',
03533 'INTERVAL' => 'C', # Postgres
03534 'MACADDR' => 'C', # postgres
03535 ##
03536 'LONGCHAR' => 'X',
03537 'TEXT' => 'X',
03538 'NTEXT' => 'X',
03539 'M' => 'X',
03540 'X' => 'X',
03541 'CLOB' => 'X',
03542 'NCLOB' => 'X',
03543 'LVARCHAR' => 'X',
03544 ##
03545 'BLOB' => 'B',
03546 'IMAGE' => 'B',
03547 'BINARY' => 'B',
03548 'VARBINARY' => 'B',
03549 'LONGBINARY' => 'B',
03550 'B' => 'B',
03551 ##
03552 'YEAR' => 'D',
03553 'DATE' => 'D',
03554 'D' => 'D',
03555 ##
03556 'UNIQUEIDENTIFIER' => 'C', # MS SQL Server
03557 ##
03558 'TIME' => 'T',
03559 'TIMESTAMP' => 'T',
03560 'DATETIME' => 'T',
03561 'TIMESTAMPTZ' => 'T',
03562 'T' => 'T',
03563 'TIMESTAMP WITHOUT TIME ZONE' => 'T',
03564 ##
03565 'BOOL' => 'L',
03566 'BOOLEAN' => 'L',
03567 'BIT' => 'L',
03568 'L' => 'L',
03569 ##
03570 'COUNTER' => 'R',
03571 'R' => 'R',
03572 'SERIAL' => 'R',
03573 'INT IDENTITY' => 'R',
03574 ##
03575 'INT' => 'I',
03576 'INT2' => 'I',
03577 'INT4' => 'I',
03578 'INT8' => 'I',
03579 'INTEGER' => 'I',
03580 'INTEGER UNSIGNED' => 'I',
03581 'SHORT' => 'I',
03582 'TINYINT' => 'I',
03583 'SMALLINT' => 'I',
03584 'I' => 'I',
03585 ##
03586 'LONG' => 'N',
03587 'BIGINT' => 'N',
03588 'DECIMAL' => 'N',
03589 'DEC' => 'N',
03590 'REAL' => 'N',
03591 'DOUBLE' => 'N',
03592 'DOUBLE PRECISION' => 'N',
03593 'SMALLFLOAT' => 'N',
03594 'FLOAT' => 'N',
03595 'NUMBER' => 'N',
03596 'NUM' => 'N',
03597 'NUMERIC' => 'N',
03598 'MONEY' => 'N',
03599
03600 ## informix 9.2
03601 'SQLINT' => 'I',
03602 'SQLSERIAL' => 'I',
03603 'SQLSMINT' => 'I',
03604 'SQLSMFLOAT' => 'N',
03605 'SQLFLOAT' => 'N',
03606 'SQLMONEY' => 'N',
03607 'SQLDECIMAL' => 'N',
03608 'SQLDATE' => 'D',
03609 'SQLVCHAR' => 'C',
03610 'SQLCHAR' => 'C',
03611 'SQLDTIME' => 'T',
03612 'SQLINTERVAL' => 'N',
03613 'SQLBYTES' => 'B',
03614 'SQLTEXT' => 'X',
03615 ## informix 10
03616 "SQLINT8" => 'I8',
03617 "SQLSERIAL8" => 'I8',
03618 "SQLNCHAR" => 'C',
03619 "SQLNVCHAR" => 'C',
03620 "SQLLVARCHAR" => 'X',
03621 "SQLBOOL" => 'L'
03622 );
03623
03624 $tmap = false;
03625 $t = strtoupper($t);
03626 $tmap = (isset($typeMap[$t])) ? $typeMap[$t] : 'N';
03627 switch ($tmap) {
03628 case 'C':
03629
03630
03631 if ($this->blobSize >= 0) {
03632 if ($len > $this->blobSize) return 'X';
03633 } else if ($len > 250) {
03634 return 'X';
03635 }
03636 return 'C';
03637
03638 case 'I':
03639 if (!empty($fieldobj->primary_key)) return 'R';
03640 return 'I';
03641
03642 case false:
03643 return 'N';
03644
03645 case 'B':
03646 if (isset($fieldobj->binary))
03647 return ($fieldobj->binary) ? 'B' : 'X';
03648 return 'B';
03649
03650 case 'D':
03651 if (!empty($this->connection) && !empty($this->connection->datetime)) return 'T';
03652 return 'D';
03653
03654 default:
03655 if ($t == 'LONG' && $this->dataProvider == 'oci8') return 'B';
03656 return $tmap;
03657 }
03658 }
03659
03660
03661 function _close() {}
03662
03666 function AbsolutePage($page=-1)
03667 {
03668 if ($page != -1) $this->_currentPage = $page;
03669 return $this->_currentPage;
03670 }
03671
03675 function AtFirstPage($status=false)
03676 {
03677 if ($status != false) $this->_atFirstPage = $status;
03678 return $this->_atFirstPage;
03679 }
03680
03681 function LastPageNo($page = false)
03682 {
03683 if ($page != false) $this->_lastPageNo = $page;
03684 return $this->_lastPageNo;
03685 }
03686
03690 function AtLastPage($status=false)
03691 {
03692 if ($status != false) $this->_atLastPage = $status;
03693 return $this->_atLastPage;
03694 }
03695
03696 }
03697
03698
03699
03700
03701
03709 class ADORecordSet_array extends ADORecordSet
03710 {
03711 var $databaseType = 'array';
03712
03713 var $_array;
03714 var $_types;
03715 var $_colnames;
03716 var $_skiprow1;
03717 var $_fieldobjects;
03718 var $canSeek = true;
03719 var $affectedrows = false;
03720 var $insertid = false;
03721 var $sql = '';
03722 var $compat = false;
03727 function ADORecordSet_array($fakeid=1)
03728 {
03729 global $ADODB_FETCH_MODE,$ADODB_COMPAT_FETCH;
03730
03731
03732 $this->compat = !empty($ADODB_COMPAT_FETCH);
03733 $this->ADORecordSet($fakeid);
03734 $this->fetchMode = $ADODB_FETCH_MODE;
03735 }
03736
03737 function _transpose()
03738 {
03739 global $ADODB_INCLUDED_LIB;
03740
03741 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
03742 $hdr = true;
03743
03744 adodb_transpose($this->_array, $newarr, $hdr);
03745
03746
03747 $this->_skiprow1 = false;
03748 $this->_array =& $newarr;
03749 $this->_colnames = $hdr;
03750
03751 adodb_probetypes($newarr,$this->_types);
03752
03753 $this->_fieldobjects = array();
03754
03755 foreach($hdr as $k => $name) {
03756 $f = new ADOFieldObject();
03757 $f->name = $name;
03758 $f->type = $this->_types[$k];
03759 $f->max_length = -1;
03760 $this->_fieldobjects[] = $f;
03761
03762 }
03763 $this->fields = reset($this->_array);
03764
03765 $this->_initrs();
03766
03767 }
03768
03780 function InitArray($array,$typearr,$colnames=false)
03781 {
03782 $this->_array = $array;
03783 $this->_types = $typearr;
03784 if ($colnames) {
03785 $this->_skiprow1 = false;
03786 $this->_colnames = $colnames;
03787 } else {
03788 $this->_skiprow1 = true;
03789 $this->_colnames = $array[0];
03790 }
03791 $this->Init();
03792 }
03801 function InitArrayFields(&$array,&$fieldarr)
03802 {
03803 $this->_array =& $array;
03804 $this->_skiprow1= false;
03805 if ($fieldarr) {
03806 $this->_fieldobjects =& $fieldarr;
03807 }
03808 $this->Init();
03809 }
03810
03811 function &GetArray($nRows=-1)
03812 {
03813 if ($nRows == -1 && $this->_currentRow <= 0 && !$this->_skiprow1) {
03814 return $this->_array;
03815 } else {
03816 $arr =& ADORecordSet::GetArray($nRows);
03817 return $arr;
03818 }
03819 }
03820
03821 function _initrs()
03822 {
03823 $this->_numOfRows = sizeof($this->_array);
03824 if ($this->_skiprow1) $this->_numOfRows -= 1;
03825
03826 $this->_numOfFields =(isset($this->_fieldobjects)) ?
03827 sizeof($this->_fieldobjects):sizeof($this->_types);
03828 }
03829
03830
03831 function Fields($colname)
03832 {
03833 $mode = isset($this->adodbFetchMode) ? $this->adodbFetchMode : $this->fetchMode;
03834
03835 if ($mode & ADODB_FETCH_ASSOC) {
03836 if (!isset($this->fields[$colname])) $colname = strtolower($colname);
03837 return $this->fields[$colname];
03838 }
03839 if (!$this->bind) {
03840 $this->bind = array();
03841 for ($i=0; $i < $this->_numOfFields; $i++) {
03842 $o = $this->FetchField($i);
03843 $this->bind[strtoupper($o->name)] = $i;
03844 }
03845 }
03846 return $this->fields[$this->bind[strtoupper($colname)]];
03847 }
03848
03849 function &FetchField($fieldOffset = -1)
03850 {
03851 if (isset($this->_fieldobjects)) {
03852 return $this->_fieldobjects[$fieldOffset];
03853 }
03854 $o = new ADOFieldObject();
03855 $o->name = $this->_colnames[$fieldOffset];
03856 $o->type = $this->_types[$fieldOffset];
03857 $o->max_length = -1;
03858
03859 return $o;
03860 }
03861
03862 function _seek($row)
03863 {
03864 if (sizeof($this->_array) && 0 <= $row && $row < $this->_numOfRows) {
03865 $this->_currentRow = $row;
03866 if ($this->_skiprow1) $row += 1;
03867 $this->fields = $this->_array[$row];
03868 return true;
03869 }
03870 return false;
03871 }
03872
03873 function MoveNext()
03874 {
03875 if (!$this->EOF) {
03876 $this->_currentRow++;
03877
03878 $pos = $this->_currentRow;
03879
03880 if ($this->_numOfRows <= $pos) {
03881 if (!$this->compat) $this->fields = false;
03882 } else {
03883 if ($this->_skiprow1) $pos += 1;
03884 $this->fields = $this->_array[$pos];
03885 return true;
03886 }
03887 $this->EOF = true;
03888 }
03889
03890 return false;
03891 }
03892
03893 function _fetch()
03894 {
03895 $pos = $this->_currentRow;
03896
03897 if ($this->_numOfRows <= $pos) {
03898 if (!$this->compat) $this->fields = false;
03899 return false;
03900 }
03901 if ($this->_skiprow1) $pos += 1;
03902 $this->fields = $this->_array[$pos];
03903 return true;
03904 }
03905
03906 function _close()
03907 {
03908 return true;
03909 }
03910
03911 }
03912
03913
03914
03915
03916
03922 function ADOLoadDB($dbType)
03923 {
03924 return ADOLoadCode($dbType);
03925 }
03926
03930 function ADOLoadCode($dbType)
03931 {
03932 global $ADODB_LASTDB;
03933
03934 if (!$dbType) return false;
03935 $db = strtolower($dbType);
03936 switch ($db) {
03937 case 'ado':
03938 if (PHP_VERSION >= 5) $db = 'ado5';
03939 $class = 'ado';
03940 break;
03941 case 'ifx':
03942 case 'maxsql': $class = $db = 'mysqlt'; break;
03943 case 'postgres':
03944 case 'postgres8':
03945 case 'pgsql': $class = $db = 'postgres7'; break;
03946 default:
03947 $class = $db; break;
03948 }
03949
03950 $file = ADODB_DIR."/drivers/adodb-".$db.".inc.php";
03951 @include_once($file);
03952 $ADODB_LASTDB = $class;
03953 if (class_exists("ADODB_" . $class)) return $class;
03954
03955
03956 if (!file_exists($file)) ADOConnection::outp("Missing file: $file");
03957 else ADOConnection::outp("Syntax error in file: $file");
03958 return false;
03959 }
03960
03964 function &NewADOConnection($db='')
03965 {
03966 $tmp =& ADONewConnection($db);
03967 return $tmp;
03968 }
03969
03978 function &ADONewConnection($db='')
03979 {
03980 GLOBAL $ADODB_NEWCONNECTION, $ADODB_LASTDB;
03981
03982 if (!defined('ADODB_ASSOC_CASE')) define('ADODB_ASSOC_CASE',2);
03983 $errorfn = (defined('ADODB_ERROR_HANDLER')) ? ADODB_ERROR_HANDLER : false;
03984 $false = false;
03985 if ($at = strpos($db,':
03986 $origdsn = $db;
03987 if (PHP_VERSION < 5) $dsna = @parse_url($db);
03988 else {
03989 $fakedsn = 'fake'.substr($db,$at);
03990 $dsna = @parse_url($fakedsn);
03991 $dsna['scheme'] = substr($db,0,$at);
03992
03993 if (strncmp($db,'pdo',3) == 0) {
03994 $sch = explode('_',$dsna['scheme']);
03995 if (sizeof($sch)>1) {
03996 $dsna['host'] = isset($dsna['host']) ? rawurldecode($dsna['host']) : '';
03997 $dsna['host'] = rawurlencode($sch[1].':host='.rawurldecode($dsna['host']));
03998 $dsna['scheme'] = 'pdo';
03999 }
04000 }
04001 }
04002
04003 if (!$dsna) {
04004
04005 $db = str_replace('@/','@adodb-fakehost/',$db);
04006 $dsna = parse_url($db);
04007 if (!$dsna) return $false;
04008 $dsna['host'] = '';
04009 }
04010 $db = @$dsna['scheme'];
04011 if (!$db) return $false;
04012 $dsna['host'] = isset($dsna['host']) ? rawurldecode($dsna['host']) : '';
04013 $dsna['user'] = isset($dsna['user']) ? rawurldecode($dsna['user']) : '';
04014 $dsna['pass'] = isset($dsna['pass']) ? rawurldecode($dsna['pass']) : '';
04015 $dsna['path'] = isset($dsna['path']) ? rawurldecode(substr($dsna['path'],1)) : ''; # strip off initial /
04016
04017 if (isset($dsna['query'])) {
04018 $opt1 = explode('&',$dsna['query']);
04019 foreach($opt1 as $k => $v) {
04020 $arr = explode('=',$v);
04021 $opt[$arr[0]] = isset($arr[1]) ? rawurldecode($arr[1]) : 1;
04022 }
04023 } else $opt = array();
04024 }
04025
04026
04027
04028
04029
04030
04031
04032
04033
04034 if (!empty($ADODB_NEWCONNECTION)) {
04035 $obj = $ADODB_NEWCONNECTION($db);
04036
04037 } else {
04038
04039 if (!isset($ADODB_LASTDB)) $ADODB_LASTDB = '';
04040 if (empty($db)) $db = $ADODB_LASTDB;
04041
04042 if ($db != $ADODB_LASTDB) $db = ADOLoadCode($db);
04043
04044 if (!$db) {
04045 if (isset($origdsn)) $db = $origdsn;
04046 if ($errorfn) {
04047
04048 $ignore = false;
04049 $errorfn('ADONewConnection', 'ADONewConnection', -998,
04050 "could not load the database driver for '$db'",
04051 $db,false,$ignore);
04052 } else
04053 ADOConnection::outp( "<p>ADONewConnection: Unable to load database driver '$db'</p>",false);
04054
04055 return $false;
04056 }
04057
04058 $cls = 'ADODB_'.$db;
04059 if (!class_exists($cls)) {
04060 adodb_backtrace();
04061 return $false;
04062 }
04063
04064 $obj = new $cls();
04065 }
04066
04067 # constructor should not fail
04068 if ($obj) {
04069 if ($errorfn) $obj->raiseErrorFn = $errorfn;
04070 if (isset($dsna)) {
04071 if (isset($dsna['port'])) $obj->port = $dsna['port'];
04072 foreach($opt as $k => $v) {
04073 switch(strtolower($k)) {
04074 case 'new':
04075 $nconnect = true; $persist = true; break;
04076 case 'persist':
04077 case 'persistent': $persist = $v; break;
04078 case 'debug': $obj->debug = (integer) $v; break;
04079 #ibase
04080 case 'role': $obj->role = $v; break;
04081 case 'dialect': $obj->dialect = (integer) $v; break;
04082 case 'charset': $obj->charset = $v; $obj->charSet=$v; break;
04083 case 'buffers': $obj->buffers = $v; break;
04084 case 'fetchmode': $obj->SetFetchMode($v); break;
04085 #ado
04086 case 'charpage': $obj->charPage = $v; break;
04087 #mysql, mysqli
04088 case 'clientflags': $obj->clientFlags = $v; break;
04089 #mysql, mysqli, postgres
04090 case 'port': $obj->port = $v; break;
04091 #mysqli
04092 case 'socket': $obj->socket = $v; break;
04093 #oci8
04094 case 'nls_date_format': $obj->NLS_DATE_FORMAT = $v; break;
04095 }
04096 }
04097 if (empty($persist))
04098 $ok = $obj->Connect($dsna['host'], $dsna['user'], $dsna['pass'], $dsna['path']);
04099 else if (empty($nconnect))
04100 $ok = $obj->PConnect($dsna['host'], $dsna['user'], $dsna['pass'], $dsna['path']);
04101 else
04102 $ok = $obj->NConnect($dsna['host'], $dsna['user'], $dsna['pass'], $dsna['path']);
04103
04104 if (!$ok) return $false;
04105 }
04106 }
04107 return $obj;
04108 }
04109
04110
04111
04112
04113 function _adodb_getdriver($provider,$drivername,$perf=false)
04114 {
04115 switch ($provider) {
04116 case 'odbtp': if (strncmp('odbtp_',$drivername,6)==0) return substr($drivername,6);
04117 case 'odbc' : if (strncmp('odbc_',$drivername,5)==0) return substr($drivername,5);
04118 case 'ado' : if (strncmp('ado_',$drivername,4)==0) return substr($drivername,4);
04119 case 'native': break;
04120 default:
04121 return $provider;
04122 }
04123
04124 switch($drivername) {
04125 case 'mysqlt':
04126 case 'mysqli':
04127 $drivername='mysql';
04128 break;
04129 case 'postgres7':
04130 case 'postgres8':
04131 $drivername = 'postgres';
04132 break;
04133 case 'firebird15': $drivername = 'firebird'; break;
04134 case 'oracle': $drivername = 'oci8'; break;
04135 case 'access': if ($perf) $drivername = ''; break;
04136 case 'db2' : break;
04137 case 'sapdb' : break;
04138 default:
04139 $drivername = 'generic';
04140 break;
04141 }
04142 return $drivername;
04143 }
04144
04145 function &NewPerfMonitor(&$conn)
04146 {
04147 $false = false;
04148 $drivername = _adodb_getdriver($conn->dataProvider,$conn->databaseType,true);
04149 if (!$drivername || $drivername == 'generic') return $false;
04150 include_once(ADODB_DIR.'/adodb-perf.inc.php');
04151 @include_once(ADODB_DIR."/perf/perf-$drivername.inc.php");
04152 $class = "Perf_$drivername";
04153 if (!class_exists($class)) return $false;
04154 $perf = new $class($conn);
04155
04156 return $perf;
04157 }
04158
04159 function &NewDataDictionary(&$conn,$drivername=false)
04160 {
04161 $false = false;
04162 if (!$drivername) $drivername = _adodb_getdriver($conn->dataProvider,$conn->databaseType);
04163
04164 include_once(ADODB_DIR.'/adodb-lib.inc.php');
04165 include_once(ADODB_DIR.'/adodb-datadict.inc.php');
04166 $path = ADODB_DIR."/datadict/datadict-$drivername.inc.php";
04167
04168 if (!file_exists($path)) {
04169 ADOConnection::outp("Dictionary driver '$path' not available");
04170 return $false;
04171 }
04172 include_once($path);
04173 $class = "ADODB2_$drivername";
04174 $dict = new $class();
04175 $dict->dataProvider = $conn->dataProvider;
04176 $dict->connection = &$conn;
04177 $dict->upperName = strtoupper($drivername);
04178 $dict->quote = $conn->nameQuote;
04179 if (!empty($conn->_connectionID))
04180 $dict->serverInfo = $conn->ServerInfo();
04181
04182 return $dict;
04183 }
04184
04185
04186
04187
04188
04189
04190 function adodb_pr($var,$as_string=false)
04191 {
04192 if ($as_string) ob_start();
04193
04194 if (isset($_SERVER['HTTP_USER_AGENT'])) {
04195 echo " <pre>\n";print_r($var);echo "</pre>\n";
04196 } else
04197 print_r($var);
04198
04199 if ($as_string) {
04200 $s = ob_get_contents();
04201 ob_end_clean();
04202 return $s;
04203 }
04204 }
04205
04206
04207
04208
04209
04210
04211
04212 function adodb_backtrace($printOrArr=true,$levels=9999)
04213 {
04214 global $ADODB_INCLUDED_LIB;
04215 if (empty($ADODB_INCLUDED_LIB)) include(ADODB_DIR.'/adodb-lib.inc.php');
04216 return _adodb_backtrace($printOrArr,$levels);
04217 }
04218
04219
04220 }
04221 ?>
1.4.6