2 global $ADODB_INCLUDED_CSV;
3 $ADODB_INCLUDED_CSV = 1;
6 V4.20 22 Feb 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.
12 Latest version is available at http://php.weblogs.com/
14 Library for CSV serialization. This is used by the csv/proxy driver and is the
15 CacheExecute() serialization format.
18 Format documented at http://php.weblogs.com/ADODB_CSV
23 * convert a recordset into special format
25 * @param rs the recordset
27 * @return the CSV formated data
29 function _rs2serialize(&$rs,$conn=false,$sql='')
31 $max = ($rs) ?
$rs->FieldCount() : 0;
33 if ($sql) $sql = urlencode($sql);
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();
43 $text = "====-1,0,$sql\n";
46 $tt = ($rs->timeCreated
) ?
$rs->timeCreated
: time();
47 $line = "====0,$tt,$sql\n";
50 for($i=0; $i < $max; $i++
) {
51 $o = $rs->FetchField($i);
52 $line .= urlencode($o->name
).':'.$rs->MetaType($o->type
,$o->max_length
,$o).":$o->max_length,";
54 $text = substr($line,0,strlen($line)-1)."\n";
58 if ($rs->databaseType
== 'array') {
59 $text .= serialize($rs->_array
);
63 $rows[] = $rs->fields
;
66 $text .= serialize($rows);
74 * Open CSV file and convert it into Data.
76 * @param url file/ftp/http url
77 * @param err returns the error message
78 * @param timeout dispose if recordset has been alive for $timeout secs
80 * @return recordset, or false if error occured. If no
81 * error occurred in sql INSERT/UPDATE/DELETE,
82 * empty recordset is returned
84 function &csv2rs($url,&$err,$timeout=0)
87 $fp = @fopen
($url,'r');
89 $err = $url.' file/URL not found';
96 if ($meta = fgetcsv ($fp, 32000, ",")) {
97 // check if error message
98 if (substr($meta[0],0,4) === '****') {
99 $err = trim(substr($meta[0],4,1024));
103 // check for meta data
104 // $meta[0] is -1 means return an empty recordset
105 // $meta[1] contains a time
107 if (substr($meta[0],0,4) === '====') {
109 if ($meta[0] == "====-1") {
110 if (sizeof($meta) < 5) {
111 $err = "Corrupt first line for format -1";
118 $err = " Illegal Timeout $timeout ";
121 $rs->fields
= array();
122 $rs->timeCreated
= $meta[1];
123 $rs = new ADORecordSet($val=true);
126 $rs->sql
= urldecode($meta[2]);
127 $rs->affectedrows
= (integer)$meta[3];
128 $rs->insertid
= $meta[4];
131 # Under high volume loads, we want only 1 thread/process to _write_file
132 # so that we don't have 50 processes queueing to write the same data.
133 # Would require probabilistic blocking write
135 # -2 sec before timeout, give processes 1/16 chance of writing to file with blocking io
136 # -1 sec after timeout give processes 1/4 chance of writing with blocking
137 # +0 sec after timeout, give processes 100% chance writing with blocking
138 if (sizeof($meta) > 1) {
140 $tdiff = $meta[1]+
$timeout - time();
144 if ((rand() & 15) == 0) {
151 if ((rand() & 3) == 0) {
163 } // if check flush cache
168 $meta = fgetcsv($fp, 16000, ",");
171 $err = "Unexpected EOF 1";
176 // Get Column definitions
178 foreach($meta as $o) {
179 $o2 = explode(':',$o);
180 if (sizeof($o2)!=3) {
185 $fld = new ADOFieldObject();
186 $fld->name
= urldecode($o2[0]);
188 $fld->max_length
= $o2[2];
193 $err = "Recordset had unexpected EOF 2";
201 while ($txt = fread($fp,$MAXSIZE)) {
206 $arr = @unserialize
($text);
208 if (!is_array($arr)) {
209 $err = "Recordset had unexpected EOF (in serialized recordset)";
210 if (get_magic_quotes_runtime()) $err .= ". Magic Quotes Runtime should be disabled!";
213 $rs = new ADORecordSet_array();
214 $rs->timeCreated
= $ttl;
215 $rs->InitArrayFields($arr,$flds);