[Summary view] [Print] [Text view]

   1  <?php
   2  /*
   3  V5.19  23-Apr-2014  (c) 2000-2014 John Lim (jlim#natsoft.com). All rights reserved.
   4    Released under both BSD license and Lesser GPL library license.
   5    Whenever there is any discrepancy between the two licenses,
   6    the BSD license will take precedence.
   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    Limitation of url length. For IIS, see MaxClientRequestBuffer registry value.
  14  
  15        http://support.microsoft.com/default.aspx?scid=kb;en-us;260694
  16  */
  17  
  18  // security - hide paths
  19  if (!defined('ADODB_DIR')) die();
  20  
  21  if (! defined("_ADODB_CSV_LAYER")) {
  22   define("_ADODB_CSV_LAYER", 1 );
  23  
  24  include_once (ADODB_DIR.'/adodb-csvlib.inc.php');
  25  
  26  class ADODB_csv extends ADOConnection {
  27      var $databaseType = 'csv';
  28      var $databaseProvider = 'csv';
  29      var $hasInsertID = true;
  30      var $hasAffectedRows = true;
  31      var $fmtTimeStamp = "'Y-m-d H:i:s'";
  32      var $_affectedrows=0;
  33      var $_insertid=0;
  34      var $_url;
  35      var $replaceQuote = "''"; // string to use to replace quotes
  36      var $hasTransactions = false;
  37      var $_errorNo = false;
  38  
  39  	function ADODB_csv()
  40      {
  41      }
  42  
  43  	function _insertid()
  44      {
  45              return $this->_insertid;
  46      }
  47  
  48  	function _affectedrows()
  49      {
  50              return $this->_affectedrows;
  51      }
  52  
  53    	function MetaDatabases()
  54      {
  55          return false;
  56      }
  57  
  58  
  59      // returns true or false
  60  	function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
  61      {
  62          if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
  63          $this->_url = $argHostname;
  64          return true;
  65      }
  66  
  67      // returns true or false
  68  	function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
  69      {
  70          if (strtolower(substr($argHostname,0,7)) !== 'http://') return false;
  71          $this->_url = $argHostname;
  72          return true;
  73      }
  74  
  75   	function MetaColumns($table, $normalize=true)
  76      {
  77          return false;
  78      }
  79  
  80  
  81      // parameters use PostgreSQL convention, not MySQL
  82  	function SelectLimit($sql,$nrows=-1,$offset=-1)
  83      {
  84      global $ADODB_FETCH_MODE;
  85  
  86          $url = $this->_url.'?sql='.urlencode($sql)."&nrows=$nrows&fetch=".
  87              (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE).
  88              "&offset=$offset";
  89          $err = false;
  90          $rs = csv2rs($url,$err,false);
  91  
  92          if ($this->debug) print "$url<br><i>$err</i><br>";
  93  
  94          $at = strpos($err,'::::');
  95          if ($at === false) {
  96              $this->_errorMsg = $err;
  97              $this->_errorNo = (integer)$err;
  98          } else {
  99              $this->_errorMsg = substr($err,$at+4,1024);
 100              $this->_errorNo = -9999;
 101          }
 102          if ($this->_errorNo)
 103              if ($fn = $this->raiseErrorFn) {
 104                  $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,'');
 105              }
 106  
 107          if (is_object($rs)) {
 108  
 109              $rs->databaseType='csv';
 110              $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;
 111              $rs->connection = $this;
 112          }
 113          return $rs;
 114      }
 115  
 116      // returns queryID or false
 117  	function _Execute($sql,$inputarr=false)
 118      {
 119      global $ADODB_FETCH_MODE;
 120  
 121          if (!$this->_bindInputArray && $inputarr) {
 122              $sqlarr = explode('?',$sql);
 123              $sql = '';
 124              $i = 0;
 125              foreach($inputarr as $v) {
 126  
 127                  $sql .= $sqlarr[$i];
 128                  if (gettype($v) == 'string')
 129                      $sql .= $this->qstr($v);
 130                  else if ($v === null)
 131                      $sql .= 'NULL';
 132                  else
 133                      $sql .= $v;
 134                  $i += 1;
 135  
 136              }
 137              $sql .= $sqlarr[$i];
 138              if ($i+1 != sizeof($sqlarr))
 139                  print "Input Array does not match ?: ".htmlspecialchars($sql);
 140              $inputarr = false;
 141          }
 142  
 143          $url =  $this->_url.'?sql='.urlencode($sql)."&fetch=".
 144              (($this->fetchMode !== false)?$this->fetchMode : $ADODB_FETCH_MODE);
 145          $err = false;
 146  
 147  
 148          $rs = csv2rs($url,$err,false);
 149          if ($this->debug) print urldecode($url)."<br><i>$err</i><br>";
 150          $at = strpos($err,'::::');
 151          if ($at === false) {
 152              $this->_errorMsg = $err;
 153              $this->_errorNo = (integer)$err;
 154          } else {
 155              $this->_errorMsg = substr($err,$at+4,1024);
 156              $this->_errorNo = -9999;
 157          }
 158  
 159          if ($this->_errorNo)
 160              if ($fn = $this->raiseErrorFn) {
 161                  $fn($this->databaseType,'EXECUTE',$this->ErrorNo(),$this->ErrorMsg(),$sql,$inputarr);
 162              }
 163          if (is_object($rs)) {
 164              $rs->fetchMode = ($this->fetchMode !== false) ?  $this->fetchMode : $ADODB_FETCH_MODE;
 165  
 166              $this->_affectedrows = $rs->affectedrows;
 167              $this->_insertid = $rs->insertid;
 168              $rs->databaseType='csv';
 169              $rs->connection = $this;
 170          }
 171          return $rs;
 172      }
 173  
 174      /*    Returns: the last error message from previous database operation    */
 175  	function ErrorMsg()
 176      {
 177              return $this->_errorMsg;
 178      }
 179  
 180      /*    Returns: the last error number from previous database operation    */
 181  	function ErrorNo()
 182      {
 183          return $this->_errorNo;
 184      }
 185  
 186      // returns true or false
 187  	function _close()
 188      {
 189          return true;
 190      }
 191  } // class
 192  
 193  class ADORecordset_csv extends ADORecordset {
 194  	function ADORecordset_csv($id,$mode=false)
 195      {
 196          $this->ADORecordset($id,$mode);
 197      }
 198  
 199  	function _close()
 200      {
 201          return true;
 202      }
 203  }
 204  
 205  } // define