library/adodb/drivers/adodb-csv.inc.php

   1 <?php
   2 /*
   3 V4.20 22 Feb 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   Set tabs to 4.
   8
   9   Currently unsupported: MetaDatabases, MetaTables and MetaColumns, and also inputarr in Execute.
  10   Native types have been converted to MetaTypes.
  11   Transactions not supported yet.
  12 */
  13
  14 if (! defined("_ADODB_CSV_LAYER")) {
  15  define("_ADODB_CSV_LAYER", 1 );
  16
  17 include_once(ADODB_DIR.'/adodb-csvlib.inc.php');
  18
  19 class ADODB_csv extends ADOConnection {
  20         var $databaseType = 'csv';
  21         var $databaseProvider = 'csv';
  22         var $hasInsertID = true;
  23         var $hasAffectedRows = true;
  24         var $fmtTimeStamp = "'Y-m-d H:i:s'";
  25         var $_affectedrows=0;
  26         var $_insertid=0;
  27         var $_url;
  28         var $replaceQuote = "''"; // string to use to replace quotes
  29         var $hasTransactions = false;
  30         var $_errorNo = false;
  31
  32         function ADODB_csv()
  33         {
  34         }
  35
  36         function _insertid()
  37         {
  38                         return $this->_insertid;
  39         }
  40
  41         function _affectedrows()
  42         {
  43                         return $this->_affectedrows;
  44         }
  45
  46         function &MetaDatabases()
  47         {
  48                 return false;
  49         }
  50
  51
  52         // returns true or false
  53         function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
  54         {
  55                 if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
  56                 $this->_url = $argHostname;
  57                 return true;
  58         }
  59
  60         // returns true or false
  61         function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
  62         {
  63                 if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
  64                 $this->_url = $argHostname;
  65                 return true;
  66         }
  67
  68         function &MetaColumns($table)
  69         {
  70                 return false;
  71         }
  72
  73
  74         // parameters use PostgreSQL convention, not MySQL
  75         function &SelectLimit($sql,$nrows=-1,$offset=-1)
  76         {
  77         global $ADODB_FETCH_MODE;
  78
  79                 $url = $this->_url.'?sql='.urlencode($sql)."&nrows=$nrows&fetch=".
  80                         (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE).
  81                         "&offset=$offset";
  82                 $err = false;
  83                 $rs = csv2rs($url,$err,false);
  84
  85                 if ($this->debug) print "$url<br><i>$err</i><br>";
  86
  87                 $at = strpos($err,'::::');
  88                 if ($at === false) {
  89                         $this->_errorMsg = $err;
  90                         $this->_errorNo = (integer)$err;
  91                 } else {
  92                         $this->_errorMsg = substr($err,$at+4,1024);
  93                         $this->_errorNo = -9999;
  94                 }
  95                 if ($this->_errorNo)
  96                         if ($fn = $this->raiseErrorFn) {
  97                                 $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,'');
  98                         }
  99
 100                 if (is_object($rs)) {
 101
 102                         $rs->databaseType='csv';
 103                         $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;
 104                         $rs->connection = &$this;
 105                 }
 106                 return $rs;
 107         }
 108
 109         // returns queryID or false
 110         function &_Execute($sql,$inputarr=false)
 111         {
 112         global $ADODB_FETCH_MODE;
 113
 114                 if (!$this->_bindInputArray && $inputarr) {
 115                         $sqlarr = explode('?',$sql);
 116                         $sql = '';
 117                         $i = 0;
 118                         foreach($inputarr as $v) {
 119
 120                                 $sql .= $sqlarr[$i];
 121                                 if (gettype($v) == 'string')
 122                                         $sql .= $this->qstr($v);
 123                                 else if ($v === null)
 124                                         $sql .= 'NULL';
 125                                 else
 126                                         $sql .= $v;
 127                                 $i += 1;
 128
 129                         }
 130                         $sql .= $sqlarr[$i];
 131                         if ($i+1 != sizeof($sqlarr))
 132                                 print "Input Array does not match ?: ".htmlspecialchars($sql);
 133                         $inputarr = false;
 134                 }
 135
 136                 $url =  $this->_url.'?sql='.urlencode($sql)."&fetch=".
 137                         (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE);
 138                 $err = false;
 139
 140
 141                 $rs = csv2rs($url,$err,false);
 142                 if ($this->debug) print urldecode($url)."<br><i>$err</i><br>";
 143                 $at = strpos($err,'::::');
 144                 if ($at === false) {
 145                         $this->_errorMsg = $err;
 146                         $this->_errorNo = (integer)$err;
 147                 } else {
 148                         $this->_errorMsg = substr($err,$at+4,1024);
 149                         $this->_errorNo = -9999;
 150                 }
 151
 152                 if ($this->_errorNo)
 153                         if ($fn = $this->raiseErrorFn) {
 154                                 $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,$inputarr);
 155                         }
 156                 if (is_object($rs)) {
 157                         $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;
 158
 159                         $this->_affectedrows = $rs->affectedrows;
 160                         $this->_insertid = $rs->insertid;
 161                         $rs->databaseType='csv';
 162                         $rs->connection = &$this;
 163                 }
 164                 return $rs;
 165         }
 166
 167         /*      Returns: the last error message from previous database operation        */
 168         function ErrorMsg()
 169         {
 170                         return $this->_errorMsg;
 171         }
 172
 173         /*      Returns: the last error number from previous database operation */
 174         function ErrorNo()
 175         {
 176                 return $this->_errorNo;
 177         }
 178
 179         // returns true or false
 180         function _close()
 181         {
 182                 return true;
 183         }
 184 } // class
 185
 186 class ADORecordset_csv extends ADORecordset {
 187         function ADORecordset_csv($id,$mode=false)
 188         {
 189                 $this->ADORecordset($id,$mode);
 190         }
 191
 192         function _close()
 193         {
 194                 return true;
 195         }
 196 }
 197
 198 } // define
 199
 200 ?>