ChangeLog
[Packages/TYPO3.CMS.git] / typo3 / sysext / adodb / adodb / drivers / adodb-informix72.inc.php
1 <?php
2 /*
3 V4.90 8 June 2006 (c) 2000-2006 John Lim. 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 for best viewing.
8
9 Latest version is available at http://adodb.sourceforge.net
10
11 Informix port by Mitchell T. Young (mitch@youngfamily.org)
12
13 Further mods by "Samuel CARRIERE" <samuel_carriere@hotmail.com>
14
15 */
16
17 // security - hide paths
18 if (!defined('ADODB_DIR')) die();
19
20 if (!defined('IFX_SCROLL')) define('IFX_SCROLL',1);
21
22 class ADODB_informix72 extends ADOConnection {
23 var $databaseType = "informix72";
24 var $dataProvider = "informix";
25 var $replaceQuote = "''"; // string to use to replace quotes
26 var $fmtDate = "'Y-m-d'";
27 var $fmtTimeStamp = "'Y-m-d H:i:s'";
28 var $hasInsertID = true;
29 var $hasAffectedRows = true;
30 var $substr = 'substr';
31 var $metaTablesSQL="select tabname,tabtype from systables where tabtype in ('T','V') and owner!='informix'"; //Don't get informix tables and pseudo-tables
32
33
34 var $metaColumnsSQL =
35 "select c.colname, c.coltype, c.collength, d.default,c.colno
36 from syscolumns c, systables t,outer sysdefaults d
37 where c.tabid=t.tabid and d.tabid=t.tabid and d.colno=c.colno
38 and tabname='%s' order by c.colno";
39
40 var $metaPrimaryKeySQL =
41 "select part1,part2,part3,part4,part5,part6,part7,part8 from
42 systables t,sysconstraints s,sysindexes i where t.tabname='%s'
43 and s.tabid=t.tabid and s.constrtype='P'
44 and i.idxname=s.idxname";
45
46 var $concat_operator = '||';
47
48 var $lastQuery = false;
49 var $has_insertid = true;
50
51 var $_autocommit = true;
52 var $_bindInputArray = true; // set to true if ADOConnection.Execute() permits binding of array parameters.
53 var $sysDate = 'TODAY';
54 var $sysTimeStamp = 'CURRENT';
55 var $cursorType = IFX_SCROLL; // IFX_SCROLL or IFX_HOLD or 0
56
57 function ADODB_informix72()
58 {
59 // alternatively, use older method:
60 //putenv("DBDATE=Y4MD-");
61
62 // force ISO date format
63 putenv('GL_DATE=%Y-%m-%d');
64
65 if (function_exists('ifx_byteasvarchar')) {
66 ifx_byteasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
67 ifx_textasvarchar(1); // Mode "0" will return a blob id, and mode "1" will return a varchar with text content.
68 ifx_blobinfile_mode(0); // Mode "0" means save Byte-Blobs in memory, and mode "1" means save Byte-Blobs in a file.
69 }
70 }
71
72 function ServerInfo()
73 {
74 if (isset($this->version)) return $this->version;
75
76 $arr['description'] = $this->GetOne("select DBINFO('version','full') from systables where tabid = 1");
77 $arr['version'] = $this->GetOne("select DBINFO('version','major') || DBINFO('version','minor') from systables where tabid = 1");
78 $this->version = $arr;
79 return $arr;
80 }
81
82
83
84 function _insertid()
85 {
86 $sqlca =ifx_getsqlca($this->lastQuery);
87 return @$sqlca["sqlerrd1"];
88 }
89
90 function _affectedrows()
91 {
92 if ($this->lastQuery) {
93 return @ifx_affected_rows ($this->lastQuery);
94 }
95 return 0;
96 }
97
98 function BeginTrans()
99 {
100 if ($this->transOff) return true;
101 $this->transCnt += 1;
102 $this->Execute('BEGIN');
103 $this->_autocommit = false;
104 return true;
105 }
106
107 function CommitTrans($ok=true)
108 {
109 if (!$ok) return $this->RollbackTrans();
110 if ($this->transOff) return true;
111 if ($this->transCnt) $this->transCnt -= 1;
112 $this->Execute('COMMIT');
113 $this->_autocommit = true;
114 return true;
115 }
116
117 function RollbackTrans()
118 {
119 if ($this->transOff) return true;
120 if ($this->transCnt) $this->transCnt -= 1;
121 $this->Execute('ROLLBACK');
122 $this->_autocommit = true;
123 return true;
124 }
125
126 function RowLock($tables,$where,$flds='1 as ignore')
127 {
128 if ($this->_autocommit) $this->BeginTrans();
129 return $this->GetOne("select $flds from $tables where $where for update");
130 }
131
132 /* Returns: the last error message from previous database operation
133 Note: This function is NOT available for Microsoft SQL Server. */
134
135 function ErrorMsg()
136 {
137 if (!empty($this->_logsql)) return $this->_errorMsg;
138 $this->_errorMsg = ifx_errormsg();
139 return $this->_errorMsg;
140 }
141
142 function ErrorNo()
143 {
144 preg_match("/.*SQLCODE=([^\]]*)/",ifx_error(),$parse);
145 if (is_array($parse) && isset($parse[1])) return (int)$parse[1];
146 return 0;
147 }
148
149
150 function &MetaColumns($table)
151 {
152 global $ADODB_FETCH_MODE;
153
154 $false = false;
155 if (!empty($this->metaColumnsSQL)) {
156 $save = $ADODB_FETCH_MODE;
157 $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
158 if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
159 $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
160 if (isset($savem)) $this->SetFetchMode($savem);
161 $ADODB_FETCH_MODE = $save;
162 if ($rs === false) return $false;
163 $rspkey = $this->Execute(sprintf($this->metaPrimaryKeySQL,$table)); //Added to get primary key colno items
164
165 $retarr = array();
166 while (!$rs->EOF) { //print_r($rs->fields);
167 $fld = new ADOFieldObject();
168 $fld->name = $rs->fields[0];
169 /* //!eos.
170 $rs->fields[1] is not the correct adodb type
171 $rs->fields[2] is not correct max_length, because can include not-null bit
172
173 $fld->type = $rs->fields[1];
174 $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields); //Added to set primary key flag
175 $fld->max_length = $rs->fields[2];*/
176 $pr=ifx_props($rs->fields[1],$rs->fields[2]); //!eos
177 $fld->type = $pr[0] ;//!eos
178 $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields);
179 $fld->max_length = $pr[1]; //!eos
180 $fld->precision = $pr[2] ;//!eos
181 $fld->not_null = $pr[3]=="N"; //!eos
182
183 if (trim($rs->fields[3]) != "AAAAAA 0") {
184 $fld->has_default = 1;
185 $fld->default_value = $rs->fields[3];
186 } else {
187 $fld->has_default = 0;
188 }
189
190 $retarr[strtolower($fld->name)] = $fld;
191 $rs->MoveNext();
192 }
193
194 $rs->Close();
195 $rspKey->Close(); //!eos
196 return $retarr;
197 }
198
199 return $false;
200 }
201
202 function &xMetaColumns($table)
203 {
204 return ADOConnection::MetaColumns($table,false);
205 }
206
207 function MetaForeignKeys($table, $owner=false, $upper=false) //!Eos
208 {
209 $sql = "
210 select tr.tabname,updrule,delrule,
211 i.part1 o1,i2.part1 d1,i.part2 o2,i2.part2 d2,i.part3 o3,i2.part3 d3,i.part4 o4,i2.part4 d4,
212 i.part5 o5,i2.part5 d5,i.part6 o6,i2.part6 d6,i.part7 o7,i2.part7 d7,i.part8 o8,i2.part8 d8
213 from systables t,sysconstraints s,sysindexes i,
214 sysreferences r,systables tr,sysconstraints s2,sysindexes i2
215 where t.tabname='$table'
216 and s.tabid=t.tabid and s.constrtype='R' and r.constrid=s.constrid
217 and i.idxname=s.idxname and tr.tabid=r.ptabid
218 and s2.constrid=r.primary and i2.idxname=s2.idxname";
219
220 $rs = $this->Execute($sql);
221 if (!$rs || $rs->EOF) return false;
222 $arr =& $rs->GetArray();
223 $a = array();
224 foreach($arr as $v) {
225 $coldest=$this->metaColumnNames($v["tabname"]);
226 $colorig=$this->metaColumnNames($table);
227 $colnames=array();
228 for($i=1;$i<=8 && $v["o$i"] ;$i++) {
229 $colnames[]=$coldest[$v["d$i"]-1]."=".$colorig[$v["o$i"]-1];
230 }
231 if($upper)
232 $a[strtoupper($v["tabname"])] = $colnames;
233 else
234 $a[$v["tabname"]] = $colnames;
235 }
236 return $a;
237 }
238
239 function UpdateBlob($table, $column, $val, $where, $blobtype = 'BLOB')
240 {
241 $type = ($blobtype == 'TEXT') ? 1 : 0;
242 $blobid = ifx_create_blob($type,0,$val);
243 return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blobid));
244 }
245
246 function BlobDecode($blobid)
247 {
248 return function_exists('ifx_byteasvarchar') ? $blobid : @ifx_get_blob($blobid);
249 }
250
251 // returns true or false
252 function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
253 {
254 if (!function_exists('ifx_connect')) return null;
255
256 $dbs = $argDatabasename . "@" . $argHostname;
257 if ($argHostname) putenv("INFORMIXSERVER=$argHostname");
258 putenv("INFORMIXSERVER=".trim($argHostname));
259 $this->_connectionID = ifx_connect($dbs,$argUsername,$argPassword);
260 if ($this->_connectionID === false) return false;
261 #if ($argDatabasename) return $this->SelectDB($argDatabasename);
262 return true;
263 }
264
265 // returns true or false
266 function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
267 {
268 if (!function_exists('ifx_connect')) return null;
269
270 $dbs = $argDatabasename . "@" . $argHostname;
271 putenv("INFORMIXSERVER=".trim($argHostname));
272 $this->_connectionID = ifx_pconnect($dbs,$argUsername,$argPassword);
273 if ($this->_connectionID === false) return false;
274 #if ($argDatabasename) return $this->SelectDB($argDatabasename);
275 return true;
276 }
277 /*
278 // ifx_do does not accept bind parameters - weird ???
279 function Prepare($sql)
280 {
281 $stmt = ifx_prepare($sql);
282 if (!$stmt) return $sql;
283 else return array($sql,$stmt);
284 }
285 */
286 // returns query ID if successful, otherwise false
287 function _query($sql,$inputarr)
288 {
289 global $ADODB_COUNTRECS;
290
291 // String parameters have to be converted using ifx_create_char
292 if ($inputarr) {
293 foreach($inputarr as $v) {
294 if (gettype($v) == 'string') {
295 $tab[] = ifx_create_char($v);
296 }
297 else {
298 $tab[] = $v;
299 }
300 }
301 }
302
303 // In case of select statement, we use a scroll cursor in order
304 // to be able to call "move", or "movefirst" statements
305 if (!$ADODB_COUNTRECS && preg_match("/^\s*select/is", $sql)) {
306 if ($inputarr) {
307 $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType, $tab);
308 }
309 else {
310 $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType);
311 }
312 }
313 else {
314 if ($inputarr) {
315 $this->lastQuery = ifx_query($sql,$this->_connectionID, $tab);
316 }
317 else {
318 $this->lastQuery = ifx_query($sql,$this->_connectionID);
319 }
320 }
321
322 // Following line have been commented because autocommit mode is
323 // not supported by informix SE 7.2
324
325 //if ($this->_autocommit) ifx_query('COMMIT',$this->_connectionID);
326
327 return $this->lastQuery;
328 }
329
330 // returns true or false
331 function _close()
332 {
333 $this->lastQuery = false;
334 return ifx_close($this->_connectionID);
335 }
336 }
337
338
339 /*--------------------------------------------------------------------------------------
340 Class Name: Recordset
341 --------------------------------------------------------------------------------------*/
342
343 class ADORecordset_informix72 extends ADORecordSet {
344
345 var $databaseType = "informix72";
346 var $canSeek = true;
347 var $_fieldprops = false;
348
349 function ADORecordset_informix72($id,$mode=false)
350 {
351 if ($mode === false) {
352 global $ADODB_FETCH_MODE;
353 $mode = $ADODB_FETCH_MODE;
354 }
355 $this->fetchMode = $mode;
356 return $this->ADORecordSet($id);
357 }
358
359
360
361 /* Returns: an object containing field information.
362 Get column information in the Recordset object. fetchField() can be used in order to obtain information about
363 fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
364 fetchField() is retrieved. */
365 function &FetchField($fieldOffset = -1)
366 {
367 if (empty($this->_fieldprops)) {
368 $fp = ifx_fieldproperties($this->_queryID);
369 foreach($fp as $k => $v) {
370 $o = new ADOFieldObject;
371 $o->name = $k;
372 $arr = split(';',$v); //"SQLTYPE;length;precision;scale;ISNULLABLE"
373 $o->type = $arr[0];
374 $o->max_length = $arr[1];
375 $this->_fieldprops[] = $o;
376 $o->not_null = $arr[4]=="N";
377 }
378 }
379 $ret = $this->_fieldprops[$fieldOffset];
380 return $ret;
381 }
382
383 function _initrs()
384 {
385 $this->_numOfRows = -1; // ifx_affected_rows not reliable, only returns estimate -- ($ADODB_COUNTRECS)? ifx_affected_rows($this->_queryID):-1;
386 $this->_numOfFields = ifx_num_fields($this->_queryID);
387 }
388
389 function _seek($row)
390 {
391 return @ifx_fetch_row($this->_queryID, (int) $row);
392 }
393
394 function MoveLast()
395 {
396 $this->fields = @ifx_fetch_row($this->_queryID, "LAST");
397 if ($this->fields) $this->EOF = false;
398 $this->_currentRow = -1;
399
400 if ($this->fetchMode == ADODB_FETCH_NUM) {
401 foreach($this->fields as $v) {
402 $arr[] = $v;
403 }
404 $this->fields = $arr;
405 }
406
407 return true;
408 }
409
410 function MoveFirst()
411 {
412 $this->fields = @ifx_fetch_row($this->_queryID, "FIRST");
413 if ($this->fields) $this->EOF = false;
414 $this->_currentRow = 0;
415
416 if ($this->fetchMode == ADODB_FETCH_NUM) {
417 foreach($this->fields as $v) {
418 $arr[] = $v;
419 }
420 $this->fields = $arr;
421 }
422
423 return true;
424 }
425
426 function _fetch($ignore_fields=false)
427 {
428
429 $this->fields = @ifx_fetch_row($this->_queryID);
430
431 if (!is_array($this->fields)) return false;
432
433 if ($this->fetchMode == ADODB_FETCH_NUM) {
434 foreach($this->fields as $v) {
435 $arr[] = $v;
436 }
437 $this->fields = $arr;
438 }
439 return true;
440 }
441
442 /* close() only needs to be called if you are worried about using too much memory while your script
443 is running. All associated result memory for the specified result identifier will automatically be freed. */
444 function _close()
445 {
446 return ifx_free_result($this->_queryID);
447 }
448
449 }
450 /** !Eos
451 * Auxiliar function to Parse coltype,collength. Used by Metacolumns
452 * return: array ($mtype,$length,$precision,$nullable) (similar to ifx_fieldpropierties)
453 */
454 function ifx_props($coltype,$collength){
455 $itype=fmod($coltype+1,256);
456 $nullable=floor(($coltype+1) /256) ?"N":"Y";
457 $mtype=substr(" CIIFFNNDN TBXCC ",$itype,1);
458 switch ($itype){
459 case 2:
460 $length=4;
461 case 6:
462 case 9:
463 case 14:
464 $length=floor($collength/256);
465 $precision=fmod($collength,256);
466 break;
467 default:
468 $precision=0;
469 $length=$collength;
470 }
471 return array($mtype,$length,$precision,$nullable);
472 }
473
474
475 ?>