source: sandbox/2.5.1-evolucao/phpgwapi/inc/adodb/drivers/adodb-informix72.inc.php @ 8222

Revision 8222, 14.4 KB checked in by angelo, 11 years ago (diff)

Ticket #3491 - Compatibilizar Expresso com novas versoes do PHP
Line 
1<?php
2/*
3V5.18 3 Sep 2012  (c) 2000-2012 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
18if (!defined('ADODB_DIR')) die();
19
20if (!defined('IFX_SCROLL')) define('IFX_SCROLL',1);
21
22class 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,$col='1 as adodbignore')
127        {
128                if ($this->_autocommit) $this->BeginTrans();
129                return $this->GetOne("select $col 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 MetaProcedures($NamePattern = false, $catalog  = null, $schemaPattern  = null)
151    {
152        // save old fetch mode
153        global $ADODB_FETCH_MODE;
154
155        $false = false;
156        $save = $ADODB_FETCH_MODE;
157        $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
158        if ($this->fetchMode !== FALSE) {
159               $savem = $this->SetFetchMode(FALSE);
160
161        }
162        $procedures = array ();
163
164        // get index details
165
166        $likepattern = '';
167        if ($NamePattern) {
168           $likepattern = " WHERE procname LIKE '".$NamePattern."'";
169        }
170
171        $rs = $this->Execute('SELECT procname, isproc FROM sysprocedures'.$likepattern);
172
173        if (is_object($rs)) {
174            // parse index data into array
175
176            while ($row = $rs->FetchRow()) {
177                $procedures[$row[0]] = array(
178                        'type' => ($row[1] == 'f' ? 'FUNCTION' : 'PROCEDURE'),
179                        'catalog' => '',
180                        'schema' => '',
181                        'remarks' => ''
182                    );
183            }
184            }
185
186        // restore fetchmode
187        if (isset($savem)) {
188                $this->SetFetchMode($savem);
189        }
190        $ADODB_FETCH_MODE = $save;
191
192        return $procedures;
193    }
194   
195    function MetaColumns($table, $normalize=true)
196        {
197        global $ADODB_FETCH_MODE;
198       
199                $false = false;
200                if (!empty($this->metaColumnsSQL)) {
201                        $save = $ADODB_FETCH_MODE;
202                        $ADODB_FETCH_MODE = ADODB_FETCH_NUM;
203                        if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
204                        $rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
205                        if (isset($savem)) $this->SetFetchMode($savem);
206                        $ADODB_FETCH_MODE = $save;
207                        if ($rs === false) return $false;
208                        $rspkey = $this->Execute(sprintf($this->metaPrimaryKeySQL,$table)); //Added to get primary key colno items
209
210                        $retarr = array();
211                        while (!$rs->EOF) { //print_r($rs->fields);
212                                $fld = new ADOFieldObject();
213                                $fld->name = $rs->fields[0];
214/*  //!eos.
215                                                $rs->fields[1] is not the correct adodb type
216                                                $rs->fields[2] is not correct max_length, because can include not-null bit
217
218                                $fld->type = $rs->fields[1];
219                                $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields); //Added to set primary key flag
220                                $fld->max_length = $rs->fields[2];*/
221                                $pr=ifx_props($rs->fields[1],$rs->fields[2]); //!eos
222                                $fld->type = $pr[0] ;//!eos
223                                $fld->primary_key=$rspkey->fields && array_search($rs->fields[4],$rspkey->fields);
224                                $fld->max_length = $pr[1]; //!eos
225                                $fld->precision = $pr[2] ;//!eos
226                                $fld->not_null = $pr[3]=="N"; //!eos
227
228                                if (trim($rs->fields[3]) != "AAAAAA 0") {
229                                        $fld->has_default = 1;
230                                        $fld->default_value = $rs->fields[3];
231                                } else {
232                                        $fld->has_default = 0;
233                                }
234
235                $retarr[strtolower($fld->name)] = $fld;
236                                $rs->MoveNext();
237                        }
238
239                        $rs->Close();
240                        $rspkey->Close(); //!eos
241                        return $retarr;
242                }
243
244                return $false;
245        }
246       
247   function xMetaColumns($table)
248   {
249                return ADOConnection::MetaColumns($table,false);
250   }
251
252         function MetaForeignKeys($table, $owner=false, $upper=false) //!Eos
253        {
254                $sql = "
255                        select tr.tabname,updrule,delrule,
256                        i.part1 o1,i2.part1 d1,i.part2 o2,i2.part2 d2,i.part3 o3,i2.part3 d3,i.part4 o4,i2.part4 d4,
257                        i.part5 o5,i2.part5 d5,i.part6 o6,i2.part6 d6,i.part7 o7,i2.part7 d7,i.part8 o8,i2.part8 d8
258                        from systables t,sysconstraints s,sysindexes i,
259                        sysreferences r,systables tr,sysconstraints s2,sysindexes i2
260                        where t.tabname='$table'
261                        and s.tabid=t.tabid and s.constrtype='R' and r.constrid=s.constrid
262                        and i.idxname=s.idxname and tr.tabid=r.ptabid
263                        and s2.constrid=r.primary and i2.idxname=s2.idxname";
264
265                $rs = $this->Execute($sql);
266                if (!$rs || $rs->EOF)  return false;
267                $arr = $rs->GetArray();
268                $a = array();
269                foreach($arr as $v) {
270                        $coldest=$this->metaColumnNames($v["tabname"]);
271                        $colorig=$this->metaColumnNames($table);
272                        $colnames=array();
273                        for($i=1;$i<=8 && $v["o$i"] ;$i++) {
274                                $colnames[]=$coldest[$v["d$i"]-1]."=".$colorig[$v["o$i"]-1];
275                        }
276                        if($upper)
277                                $a[strtoupper($v["tabname"])] =  $colnames;
278                        else
279                                $a[$v["tabname"]] =  $colnames;
280                }
281                return $a;
282         }
283
284   function UpdateBlob($table, $column, $val, $where, $blobtype = 'BLOB')
285   {
286                $type = ($blobtype == 'TEXT') ? 1 : 0;
287                $blobid = ifx_create_blob($type,0,$val);
288                return $this->Execute("UPDATE $table SET $column=(?) WHERE $where",array($blobid));
289   }
290
291   function BlobDecode($blobid)
292   {
293                return function_exists('ifx_byteasvarchar') ? $blobid : @ifx_get_blob($blobid);
294   }
295   
296        // returns true or false
297   function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
298        {
299                if (!function_exists('ifx_connect')) return null;
300               
301                $dbs = $argDatabasename . "@" . $argHostname;
302                if ($argHostname) putenv("INFORMIXSERVER=$argHostname");
303                putenv("INFORMIXSERVER=".trim($argHostname));
304                $this->_connectionID = ifx_connect($dbs,$argUsername,$argPassword);
305                if ($this->_connectionID === false) return false;
306                #if ($argDatabasename) return $this->SelectDB($argDatabasename);
307                return true;
308        }
309
310        // returns true or false
311   function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
312        {
313                if (!function_exists('ifx_connect')) return null;
314               
315                $dbs = $argDatabasename . "@" . $argHostname;
316                putenv("INFORMIXSERVER=".trim($argHostname));
317                $this->_connectionID = ifx_pconnect($dbs,$argUsername,$argPassword);
318                if ($this->_connectionID === false) return false;
319                #if ($argDatabasename) return $this->SelectDB($argDatabasename);
320                return true;
321        }
322/*
323        // ifx_do does not accept bind parameters - weird ???
324        function Prepare($sql)
325        {
326                $stmt = ifx_prepare($sql);
327                if (!$stmt) return $sql;
328                else return array($sql,$stmt);
329        }
330*/
331        // returns query ID if successful, otherwise false
332        function _query($sql,$inputarr=false)
333        {
334        global $ADODB_COUNTRECS;
335       
336          // String parameters have to be converted using ifx_create_char
337          if ($inputarr) {
338                 foreach($inputarr as $v) {
339                        if (gettype($v) == 'string') {
340                           $tab[] = ifx_create_char($v);
341                        }
342                        else {
343                           $tab[] = $v;
344                        }
345                 }
346          }
347
348          // In case of select statement, we use a scroll cursor in order
349          // to be able to call "move", or "movefirst" statements
350          if (!$ADODB_COUNTRECS && preg_match("/^\s*select/is", $sql)) {
351                 if ($inputarr) {
352                        $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType, $tab);
353                 }
354                 else {
355                        $this->lastQuery = ifx_query($sql,$this->_connectionID, $this->cursorType);
356                 }
357          }
358          else {
359                 if ($inputarr) {
360                        $this->lastQuery = ifx_query($sql,$this->_connectionID, $tab);
361                 }
362                 else {
363                        $this->lastQuery = ifx_query($sql,$this->_connectionID);
364                 }
365          }
366
367          // Following line have been commented because autocommit mode is
368          // not supported by informix SE 7.2
369
370          //if ($this->_autocommit) ifx_query('COMMIT',$this->_connectionID);
371
372                return $this->lastQuery;
373        }
374
375        // returns true or false
376        function _close()
377        {
378                $this->lastQuery = false;
379                return ifx_close($this->_connectionID);
380        }
381}
382
383
384/*--------------------------------------------------------------------------------------
385         Class Name: Recordset
386--------------------------------------------------------------------------------------*/
387
388class ADORecordset_informix72 extends ADORecordSet {
389
390        var $databaseType = "informix72";
391        var $canSeek = true;
392        var $_fieldprops = false;
393
394        function ADORecordset_informix72($id,$mode=false)
395        {
396                if ($mode === false) {
397                        global $ADODB_FETCH_MODE;
398                        $mode = $ADODB_FETCH_MODE;
399                }
400                $this->fetchMode = $mode;
401                return $this->ADORecordSet($id);
402        }
403
404
405
406        /*      Returns: an object containing field information.
407                Get column information in the Recordset object. fetchField() can be used in order to obtain information about
408                fields in a certain query result. If the field offset isn't specified, the next field that wasn't yet retrieved by
409                fetchField() is retrieved.      */
410        function FetchField($fieldOffset = -1)
411        {
412                if (empty($this->_fieldprops)) {
413                        $fp = ifx_fieldproperties($this->_queryID);
414                        foreach($fp as $k => $v) {
415                                $o = new ADOFieldObject;
416                                $o->name = $k;
417                                $arr = explode(';',$v); //"SQLTYPE;length;precision;scale;ISNULLABLE"
418                                $o->type = $arr[0];
419                                $o->max_length = $arr[1];
420                                $this->_fieldprops[] = $o;
421                                $o->not_null = $arr[4]=="N";
422                        }
423                }
424                $ret = $this->_fieldprops[$fieldOffset];
425                return $ret;
426        }
427
428        function _initrs()
429        {
430                $this->_numOfRows = -1; // ifx_affected_rows not reliable, only returns estimate -- ($ADODB_COUNTRECS)? ifx_affected_rows($this->_queryID):-1;
431                $this->_numOfFields = ifx_num_fields($this->_queryID);
432        }
433
434        function _seek($row)
435        {
436                return @ifx_fetch_row($this->_queryID, (int) $row);
437        }
438
439   function MoveLast()
440   {
441          $this->fields = @ifx_fetch_row($this->_queryID, "LAST");
442          if ($this->fields) $this->EOF = false;
443          $this->_currentRow = -1;
444
445          if ($this->fetchMode == ADODB_FETCH_NUM) {
446                 foreach($this->fields as $v) {
447                        $arr[] = $v;
448                 }
449                 $this->fields = $arr;
450          }
451
452          return true;
453   }
454
455   function MoveFirst()
456        {
457          $this->fields = @ifx_fetch_row($this->_queryID, "FIRST");
458          if ($this->fields) $this->EOF = false;
459          $this->_currentRow = 0;
460
461          if ($this->fetchMode == ADODB_FETCH_NUM) {
462                 foreach($this->fields as $v) {
463                        $arr[] = $v;
464                 }
465                 $this->fields = $arr;
466          }
467
468          return true;
469   }
470
471   function _fetch($ignore_fields=false)
472   {
473
474                $this->fields = @ifx_fetch_row($this->_queryID);
475
476                if (!is_array($this->fields)) return false;
477
478                if ($this->fetchMode == ADODB_FETCH_NUM) {
479                        foreach($this->fields as $v) {
480                                $arr[] = $v;
481                        }
482                        $this->fields = $arr;
483                }
484                return true;
485        }
486
487        /*      close() only needs to be called if you are worried about using too much memory while your script
488                is running. All associated result memory for the specified result identifier will automatically be freed.       */
489        function _close()
490        {
491                return ifx_free_result($this->_queryID);
492        }
493
494}
495/** !Eos
496* Auxiliar function to Parse coltype,collength. Used by Metacolumns
497* return: array ($mtype,$length,$precision,$nullable) (similar to ifx_fieldpropierties)
498*/
499function ifx_props($coltype,$collength){
500        $itype=fmod($coltype+1,256);
501        $nullable=floor(($coltype+1) /256) ?"N":"Y";
502        $mtype=substr(" CIIFFNNDN TBXCC     ",$itype,1);
503        switch ($itype){
504                case 2:
505                        $length=4;
506                case 6:
507                case 9:
508                case 14:
509                        $length=floor($collength/256);
510                        $precision=fmod($collength,256);
511                        break;
512                default:
513                        $precision=0;
514                        $length=$collength;
515        }
516        return array($mtype,$length,$precision,$nullable);
517}
518
519
520?>
Note: See TracBrowser for help on using the repository browser.