lib/WikiDB/adodb/drivers/adodb-sqlite.inc.php

   1 <?php
   2 /*
   3 V4.22 15 Apr 2004  (c) 2000-2004 John Lim (jlim@natsoft.com.my). All rights reserved.
   4   Released under both BSD license and Lesser GPL library license.
   5   Whenever there is any discrepancy between the two licenses,
   6   the BSD license will take precedence.
   7
   8   Latest version is available at http://php.weblogs.com/
   9
  10   SQLite info: http://www.hwaci.com/sw/sqlite/
  11
  12   Install Instructions:
  13   ====================
  14   1. Place this in adodb/drivers
  15   2. Rename the file, remove the .txt prefix.
  16 */
  17
  18 class ADODB_sqlite extends ADOConnection {
  19     var $databaseType = "sqlite";
  20     var $replaceQuote = "''"; // string to use to replace quotes
  21     var $concat_operator='||';
  22     var $_errorNo = 0;
  23     var $hasLimit = true;
  24     var $hasInsertID = true;            /// supports autoincrement ID?
  25     var $hasAffectedRows = true;        /// supports affected rows for update/delete?
  26     var $metaTablesSQL = "SELECT name FROM sqlite_master WHERE type='table' ORDER BY name";
  27     var $sysDate = "adodb_date('Y-m-d')";
  28     var $sysTimeStamp = "adodb_date('Y-m-d H:i:s')";
  29     var $fmtTimeStamp = "'Y-m-d H:i:s'";
  30
  31     function ADODB_sqlite()
  32     {
  33     }
  34
  35 /*
  36   function __get($name)
  37   {
  38       switch($name) {
  39     case 'sysDate': return "'".date($this->fmtDate)."'";
  40     case 'sysTimeStamp' : return "'".date($this->sysTimeStamp)."'";
  41     }
  42   }*/
  43
  44     function ServerInfo()
  45     {
  46         $arr['version'] = sqlite_libversion();
  47         $arr['description'] = 'SQLite ';
  48         $arr['encoding'] = sqlite_libencoding();
  49         return $arr;
  50     }
  51
  52     function BeginTrans()
  53     {
  54          if ($this->transOff) return true;
  55          $ret = $this->Execute("BEGIN TRANSACTION");
  56          $this->transCnt += 1;
  57          return true;
  58     }
  59
  60     function CommitTrans($ok=true)
  61     {
  62         if ($this->transOff) return true;
  63         if (!$ok) return $this->RollbackTrans();
  64         $ret = $this->Execute("COMMIT");
  65         if ($this->transCnt>0)$this->transCnt -= 1;
  66         return !empty($ret);
  67     }
  68
  69     function RollbackTrans()
  70     {
  71         if ($this->transOff) return true;
  72         $ret = $this->Execute("ROLLBACK");
  73         if ($this->transCnt>0)$this->transCnt -= 1;
  74         return !empty($ret);
  75     }
  76
  77     function _insertid()
  78     {
  79         return sqlite_last_insert_rowid($this->_connectionID);
  80     }
  81
  82     function _affectedrows()
  83     {
  84         return sqlite_changes($this->_connectionID);
  85     }
  86
  87     function ErrorMsg()
  88      {
  89         if ($this->_logsql) return $this->_errorMsg;
  90         return ($this->_errorNo) ? sqlite_error_string($this->_errorNo) : '';
  91     }
  92
  93     function ErrorNo()
  94     {
  95         return $this->_errorNo;
  96     }
  97
  98     function SQLDate($fmt, $col=false)
  99     {
 100         $fmt = $this->qstr($fmt);
 101         return ($col) ? "adodb_date2($fmt,$col)" : "adodb_date($fmt)";
 102     }
 103
 104     function &MetaColumns($tab)
 105     {
 106     global $ADODB_FETCH_MODE;
 107
 108         $rs = $this->Execute("select * from $tab limit 1");
 109         if (!$rs) return false;
 110         $arr = array();
 111         for ($i=0,$max=$rs->_numOfFields; $i < $max; $i++) {
 112             $fld =& $rs->FetchField($i);
 113             if ($ADODB_FETCH_MODE == ADODB_FETCH_NUM) $retarr[] =& $fld;
 114             else $arr[strtoupper($fld->name)] =& $fld;
 115         }
 116         $rs->Close();
 117         return $arr;
 118     }
 119
 120     function _createFunctions()
 121     {
 122         @sqlite_create_function($this->_connectionID, 'adodb_date', 'adodb_date', 1);
 123         @sqlite_create_function($this->_connectionID, 'adodb_date2', 'adodb_date2', 2);
 124     }
 125
 126
 127     // returns true or false
 128     function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
 129     {
 130         if (!function_exists('sqlite_open')) return false;
 131
 132         $this->_connectionID = sqlite_open($argDatabasename);
 133         if ($this->_connectionID === false) return false;
 134         $this->_createFunctions();
 135         return true;
 136     }
 137
 138     // returns true or false
 139     function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
 140     {
 141         if (!function_exists('sqlite_popen')) return false;
 142
 143         $this->_connectionID = sqlite_popen($argDatabasename);
 144         if ($this->_connectionID === false) return false;
 145         $this->_createFunctions();
 146         return true;
 147     }
 148
 149     // returns query ID if successful, otherwise false
 150     function _query($sql,$inputarr=false)
 151     {
 152         $rez = sqlite_query($sql,$this->_connectionID);
 153         if (!$rez) {
 154             $this->_errorNo = sqlite_last_error($this->_connectionID);
 155         }
 156
 157         return $rez;
 158     }
 159
 160     function &SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs2cache=0)
 161     {
 162         $offsetStr = ($offset >= 0) ? " OFFSET $offset" : '';
 163         $limitStr  = ($nrows >= 0)  ? " LIMIT $nrows" : ($offset >= 0 ? ' LIMIT 999999999' : '');
 164           if ($secs2cache)
 165                $rs =& $this->CacheExecute($secs2cache,$sql."$limitStr$offsetStr",$inputarr);
 166           else
 167                $rs =& $this->Execute($sql."$limitStr$offsetStr",$inputarr);
 168
 169         return $rs;
 170     }
 171
 172     /*
 173         This algorithm is not very efficient, but works even if table locking
 174         is not available.
 175
 176         Will return false if unable to generate an ID after $MAXLOOPS attempts.
 177     */
 178     var $_genSeqSQL = "create table %s (id integer)";
 179
 180     function GenID($seq='adodbseq',$start=1)
 181     {
 182         // if you have to modify the parameter below, your database is overloaded,
 183         // or you need to implement generation of id's yourself!
 184         $MAXLOOPS = 100;
 185         //$this->debug=1;
 186         while (--$MAXLOOPS>=0) {
 187             $num = $this->GetOne("select id from $seq");
 188             if ($num === false) {
 189                 $this->Execute(sprintf($this->_genSeqSQL ,$seq));
 190                 $start -= 1;
 191                 $num = '0';
 192                 $ok = $this->Execute("insert into $seq values($start)");
 193                 if (!$ok) return false;
 194             }
 195             $this->Execute("update $seq set id=id+1 where id=$num");
 196
 197             if ($this->affected_rows() > 0) {
 198                 $num += 1;
 199                 $this->genID = $num;
 200                 return $num;
 201             }
 202         }
 203         if ($fn = $this->raiseErrorFn) {
 204             $fn($this->databaseType,'GENID',-32000,"Unable to generate unique id after $MAXLOOPS attempts",$seq,$num);
 205         }
 206         return false;
 207     }
 208
 209     function CreateSequence($seqname='adodbseq',$start=1)
 210     {
 211         if (empty($this->_genSeqSQL)) return false;
 212         $ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname));
 213         if (!$ok) return false;
 214         $start -= 1;
 215         return $this->Execute("insert into $seqname values($start)");
 216     }
 217
 218     var $_dropSeqSQL = 'drop table %s';
 219     function DropSequence($seqname)
 220     {
 221         if (empty($this->_dropSeqSQL)) return false;
 222         return $this->Execute(sprintf($this->_dropSeqSQL,$seqname));
 223     }
 224
 225     // returns true or false
 226     function _close()
 227     {
 228         return @sqlite_close($this->_connectionID);
 229     }
 230
 231
 232 }
 233
 234 /*--------------------------------------------------------------------------------------
 235          Class Name: Recordset
 236 --------------------------------------------------------------------------------------*/
 237
 238 class ADORecordset_sqlite extends ADORecordSet {
 239
 240     var $databaseType = "sqlite";
 241     var $bind = false;
 242
 243     function ADORecordset_sqlite($queryID,$mode=false)
 244     {
 245
 246         if ($mode === false) {
 247             global $ADODB_FETCH_MODE;
 248             $mode = $ADODB_FETCH_MODE;
 249         }
 250         switch($mode) {
 251         case ADODB_FETCH_NUM: $this->fetchMode = SQLITE_NUM; break;
 252         case ADODB_FETCH_ASSOC: $this->fetchMode = SQLITE_ASSOC; break;
 253         default: $this->fetchMode = SQLITE_BOTH; break;
 254         }
 255
 256         $this->_queryID = $queryID;
 257
 258         $this->_inited = true;
 259         $this->fields = array();
 260         if ($queryID) {
 261             $this->_currentRow = 0;
 262             $this->EOF = !$this->_fetch();
 263             @$this->_initrs();
 264         } else {
 265             $this->_numOfRows = 0;
 266             $this->_numOfFields = 0;
 267             $this->EOF = true;
 268         }
 269
 270         return $this->_queryID;
 271     }
 272
 273
 274     function &FetchField($fieldOffset = -1)
 275     {
 276         $fld = new ADOFieldObject;
 277         $fld->name = sqlite_field_name($this->_queryID, $fieldOffset);
 278         $fld->type = 'VARCHAR';
 279         $fld->max_length = -1;
 280         return $fld;
 281     }
 282
 283    function _initrs()
 284    {
 285         $this->_numOfRows = @sqlite_num_rows($this->_queryID);
 286         $this->_numOfFields = @sqlite_num_fields($this->_queryID);
 287    }
 288
 289     function Fields($colname)
 290     {
 291         if ($this->fetchMode != SQLITE_NUM) return $this->fields[$colname];
 292         if (!$this->bind) {
 293             $this->bind = array();
 294             for ($i=0; $i < $this->_numOfFields; $i++) {
 295                 $o = $this->FetchField($i);
 296                 $this->bind[strtoupper($o->name)] = $i;
 297             }
 298         }
 299
 300          return $this->fields[$this->bind[strtoupper($colname)]];
 301     }
 302
 303    function _seek($row)
 304    {
 305            return sqlite_seek($this->_queryID, $row);
 306    }
 307
 308     function _fetch($ignore_fields=false)
 309     {
 310         $this->fields = @sqlite_fetch_array($this->_queryID,$this->fetchMode);
 311         return !empty($this->fields);
 312     }
 313
 314     function _close()
 315     {
 316     }
 317
 318 }
 319 ?>