lib/WikiDB/adodb/adodb-csvlib.inc.php

   1 <?php
   2 global $ADODB_INCLUDED_CSV;
   3 $ADODB_INCLUDED_CSV = 1;
   4
   5 /*
   6   V4.22 15 Apr 2004  (c) 2000-2004 John Lim (jlim@natsoft.com.my). All rights reserved.
   7   Released under both BSD license and Lesser GPL library license.
   8   Whenever there is any discrepancy between the two licenses,
   9   the BSD license will take precedence. See License.txt.
  10   Set tabs to 4 for best viewing.
  11
  12   Latest version is available at http://php.weblogs.com/
  13
  14   Library for CSV serialization. This is used by the csv/proxy driver and is the
  15   CacheExecute() serialization format.
  16
  17   ==== NOTE ====
  18   Format documented at http://php.weblogs.com/ADODB_CSV
  19   ==============
  20 */
  21
  22         /**
  23          * convert a recordset into special format
  24          *
  25          * @param rs    the recordset
  26          *
  27          * @return      the CSV formated data
  28          */
  29         function _rs2serialize(&$rs,$conn=false,$sql='')
  30         {
  31                 $max = ($rs) ? $rs->FieldCount() : 0;
  32
  33                 if ($sql) $sql = urlencode($sql);
  34                 // metadata setup
  35
  36                 if ($max <= 0 || $rs->dataProvider == 'empty') { // is insert/update/delete
  37                         if (is_object($conn)) {
  38                                 $sql .= ','.$conn->Affected_Rows();
  39                                 $sql .= ','.$conn->Insert_ID();
  40                         } else
  41                                 $sql .= ',,';
  42
  43                         $text = "====-1,0,$sql\n";
  44                         return $text;
  45                 }
  46                 $tt = ($rs->timeCreated) ? $rs->timeCreated : time();
  47
  48                 ## changed format from ====0 to ====1
  49                 $line = "====1,$tt,$sql\n";
  50
  51                 if ($rs->databaseType == 'array') {
  52                         $rows =& $rs->_array;
  53                 } else {
  54                         $rows = array();
  55                         while (!$rs->EOF) {
  56                                 $rows[] = $rs->fields;
  57                                 $rs->MoveNext();
  58                         }
  59                 }
  60
  61                 for($i=0; $i < $max; $i++) {
  62                         $o =& $rs->FetchField($i);
  63                         $flds[] = $o;
  64                 }
  65
  66                 $rs =& new ADORecordSet_array();
  67                 $rs->InitArrayFields($rows,$flds);
  68                 return $line.serialize($rs);
  69         }
  70
  71
  72 /**
  73 * Open CSV file and convert it into Data.
  74 *
  75 * @param url            file/ftp/http url
  76 * @param err            returns the error message
  77 * @param timeout        dispose if recordset has been alive for $timeout secs
  78 *
  79 * @return               recordset, or false if error occured. If no
  80 *                       error occurred in sql INSERT/UPDATE/DELETE,
  81 *                       empty recordset is returned
  82 */
  83         function &csv2rs($url,&$err,$timeout=0)
  84         {
  85                 $err = false;
  86                 $fp = @fopen($url,'r');
  87                 if (!$fp) {
  88                         $err = $url.' file/URL not found';
  89                         return false;
  90                 }
  91                 flock($fp, LOCK_SH);
  92                 $arr = array();
  93                 $ttl = 0;
  94
  95                 if ($meta = fgetcsv($fp, 32000, ",")) {
  96                         // check if error message
  97                         if (strncmp($meta[0],'****',4) === 0) {
  98                                 $err = trim(substr($meta[0],4,1024));
  99                                 fclose($fp);
 100                                 return false;
 101                         }
 102                         // check for meta data
 103                         // $meta[0] is -1 means return an empty recordset
 104                         // $meta[1] contains a time
 105
 106                         if (strncmp($meta[0], '====',4) === 0) {
 107
 108                                 if ($meta[0] == "====-1") {
 109                                         if (sizeof($meta) < 5) {
 110                                                 $err = "Corrupt first line for format -1";
 111                                                 fclose($fp);
 112                                                 return false;
 113                                         }
 114                                         fclose($fp);
 115
 116                                         if ($timeout > 0) {
 117                                                 $err = " Illegal Timeout $timeout ";
 118                                                 return false;
 119                                         }
 120                                         $rs->fields = array();
 121                                         $rs->timeCreated = $meta[1];
 122                                         $rs =& new ADORecordSet($val=true);
 123                                         $rs->EOF = true;
 124                                         $rs->_numOfFields=0;
 125                                         $rs->sql = urldecode($meta[2]);
 126                                         $rs->affectedrows = (integer)$meta[3];
 127                                         $rs->insertid = $meta[4];
 128                                         return $rs;
 129                                 }
 130                         # Under high volume loads, we want only 1 thread/process to _write_file
 131                         # so that we don't have 50 processes queueing to write the same data.
 132                         # We use probabilistic timeout, ahead of time.
 133                         #
 134                         # -4 sec before timeout, give processes 1/32 chance of timing out
 135                         # -2 sec before timeout, give processes 1/16 chance of timing out
 136                         # -1 sec after timeout give processes 1/4 chance of timing out
 137                         # +0 sec after timeout, give processes 100% chance of timing out
 138                                 if (sizeof($meta) > 1) {
 139                                         if($timeout >0){
 140                                                 $tdiff = (integer)( $meta[1]+$timeout - time());
 141                                                 if ($tdiff <= 2) {
 142                                                         switch($tdiff) {
 143                                                         case 4:
 144                                                         case 3:
 145                                                                 if ((rand() & 31) == 0) {
 146                                                                         fclose($fp);
 147                                                                         $err = "Timeout 3";
 148                                                                         return false;
 149                                                                 }
 150                                                                 break;
 151                                                         case 2:
 152                                                                 if ((rand() & 15) == 0) {
 153                                                                         fclose($fp);
 154                                                                         $err = "Timeout 2";
 155                                                                         return false;
 156                                                                 }
 157                                                                 break;
 158                                                         case 1:
 159                                                                 if ((rand() & 3) == 0) {
 160                                                                         fclose($fp);
 161                                                                         $err = "Timeout 1";
 162                                                                         return false;
 163                                                                 }
 164                                                                 break;
 165                                                         default:
 166                                                                 fclose($fp);
 167                                                                 $err = "Timeout 0";
 168                                                                 return false;
 169                                                         } // switch
 170
 171                                                 } // if check flush cache
 172                                         }// (timeout>0)
 173                                         $ttl = $meta[1];
 174                                 }
 175                                 //================================================
 176                                 // new cache format - use serialize extensively...
 177                                 if ($meta[0] === '====1') {
 178                                         // slurp in the data
 179                                         $MAXSIZE = 128000;
 180
 181                                         $text = fread($fp,$MAXSIZE);
 182                                         if (strlen($text) === $MAXSIZE) {
 183                                                 while ($txt = fread($fp,$MAXSIZE)) {
 184                                                         $text .= $txt;
 185                                                 }
 186                                         }
 187                                         fclose($fp);
 188                                         @$rs = unserialize($text);
 189                                         if (is_object($rs)) $rs->timeCreated = $ttl;
 190                                         return $rs;
 191                                 }
 192
 193                                 $meta = false;
 194                                 $meta = fgetcsv($fp, 32000, ",");
 195                                 if (!$meta) {
 196                                         fclose($fp);
 197                                         $err = "Unexpected EOF 1";
 198                                         return false;
 199                                 }
 200                         }
 201
 202                         // Get Column definitions
 203                         $flds = array();
 204                         foreach($meta as $o) {
 205                                 $o2 = explode(':',$o);
 206                                 if (sizeof($o2)!=3) {
 207                                         $arr[] = $meta;
 208                                         $flds = false;
 209                                         break;
 210                                 }
 211                                 $fld =& new ADOFieldObject();
 212                                 $fld->name = urldecode($o2[0]);
 213                                 $fld->type = $o2[1];
 214                                 $fld->max_length = $o2[2];
 215                                 $flds[] = $fld;
 216                         }
 217                 } else {
 218                         fclose($fp);
 219                         $err = "Recordset had unexpected EOF 2";
 220                         return false;
 221                 }
 222
 223                 // slurp in the data
 224                 $MAXSIZE = 128000;
 225
 226                 $text = '';
 227                 while ($txt = fread($fp,$MAXSIZE)) {
 228                         $text .= $txt;
 229                 }
 230
 231                 fclose($fp);
 232                 @$arr = unserialize($text);
 233                 //var_dump($arr);
 234                 if (!is_array($arr)) {
 235                         $err = "Recordset had unexpected EOF (in serialized recordset)";
 236                         if (get_magic_quotes_runtime()) $err .= ". Magic Quotes Runtime should be disabled!";
 237                         return false;
 238                 }
 239                 $rs =& new ADORecordSet_array();
 240                 $rs->timeCreated = $ttl;
 241                 $rs->InitArrayFields($arr,$flds);
 242                 return $rs;
 243         }
 244 ?>