Context Navigation

← Previous Revision
Latest Revision
Next Revision →
Annotate
Revision Log

adodb-mysql.inc.php @ 8222

Revision 8222, 22.8 KB checked in by angelo, 11 years ago (diff)
Ticket #3491 - Compatibilizar Expresso com novas versoes do PHP
Property svn:eol-style set to `native` Property svn:executable set to ``*

Line
1	<?php
2	/*
3	V5.18 3 Sep 2012 (c) 2000-2012 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 8.
8
9	MySQL code that does not support transactions. Use mysqlt if you need transactions.
10	Requires mysql client. Works on Windows and Unix.
11
12	28 Feb 2001: MetaColumns bug fix - suggested by Freek Dijkstra (phpeverywhere@macfreek.com)
13	*/
14
15	// security - hide paths
16	if (!defined('ADODB_DIR')) die();
17
18	if (! defined("_ADODB_MYSQL_LAYER")) {
19	define("_ADODB_MYSQL_LAYER", 1 );
20
21	class ADODB_mysql extends ADOConnection {
22	var $databaseType = 'mysql';
23	var $dataProvider = 'mysql';
24	var $hasInsertID = true;
25	var $hasAffectedRows = true;
26	var $metaTablesSQL = "SELECT TABLE_NAME, CASE WHEN TABLE_TYPE = 'VIEW' THEN 'V' ELSE 'T' END FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA=SCHEMA()";
27	var $metaColumnsSQL = "SHOW COLUMNS FROM `%s`";
28	var $fmtTimeStamp = "'Y-m-d H:i:s'";
29	var $hasLimit = true;
30	var $hasMoveFirst = true;
31	var $hasGenID = true;
32	var $isoDates = true; // accepts dates in ISO format
33	var $sysDate = 'CURDATE()';
34	var $sysTimeStamp = 'NOW()';
35	var $hasTransactions = false;
36	var $forceNewConnect = false;
37	var $poorAffectedRows = true;
38	var $clientFlags = 0;
39	var $charSet = '';
40	var $substr = "substring";
41	var $nameQuote = '`'; /// string to use to quote identifiers and names
42	var $compat323 = false; // true if compat with mysql 3.23
43
44	function ADODB_mysql()
45	{
46	if (defined('ADODB_EXTENSION')) $this->rsPrefix .= 'ext_';
47	}
48
49
50	// SetCharSet - switch the client encoding
51	function SetCharSet($charset_name)
52	{
53	if (!function_exists('mysql_set_charset'))
54	return false;
55
56	if ($this->charSet !== $charset_name) {
57	$ok = @mysql_set_charset($charset_name,$this->_connectionID);
58	if ($ok) {
59	$this->charSet = $charset_name;
60	return true;
61	}
62	return false;
63	}
64	return true;
65	}
66
67	function ServerInfo()
68	{
69	$arr['description'] = ADOConnection::GetOne("select version()");
70	$arr['version'] = ADOConnection::_findvers($arr['description']);
71	return $arr;
72	}
73
74	function IfNull( $field, $ifNull )
75	{
76	return " IFNULL($field, $ifNull) "; // if MySQL
77	}
78
79	function MetaProcedures($NamePattern = false, $catalog = null, $schemaPattern = null)
80	{
81	// save old fetch mode
82	global $ADODB_FETCH_MODE;
83
84	$false = false;
85	$save = $ADODB_FETCH_MODE;
86	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
87
88	if ($this->fetchMode !== FALSE) {
89	$savem = $this->SetFetchMode(FALSE);
90	}
91
92	$procedures = array ();
93
94	// get index details
95
96	$likepattern = '';
97	if ($NamePattern) {
98	$likepattern = " LIKE '".$NamePattern."'";
99	}
100	$rs = $this->Execute('SHOW PROCEDURE STATUS'.$likepattern);
101	if (is_object($rs)) {
102
103	// parse index data into array
104	while ($row = $rs->FetchRow()) {
105	$procedures[$row[1]] = array(
106	'type' => 'PROCEDURE',
107	'catalog' => '',
108
109	'schema' => '',
110	'remarks' => $row[7],
111	);
112	}
113	}
114
115	$rs = $this->Execute('SHOW FUNCTION STATUS'.$likepattern);
116	if (is_object($rs)) {
117	// parse index data into array
118	while ($row = $rs->FetchRow()) {
119	$procedures[$row[1]] = array(
120	'type' => 'FUNCTION',
121	'catalog' => '',
122	'schema' => '',
123	'remarks' => $row[7]
124	);
125	}
126	}
127
128	// restore fetchmode
129	if (isset($savem)) {
130	$this->SetFetchMode($savem);
131
132	}
133	$ADODB_FETCH_MODE = $save;
134
135
136	return $procedures;
137	}
138
139	function MetaTables($ttype=false,$showSchema=false,$mask=false)
140	{
141	$save = $this->metaTablesSQL;
142	if ($showSchema && is_string($showSchema)) {
143	$this->metaTablesSQL .= " from $showSchema";
144	}
145
146	if ($mask) {
147	$mask = $this->qstr($mask);
148	$this->metaTablesSQL .= " like $mask";
149	}
150	$ret = ADOConnection::MetaTables($ttype,$showSchema);
151
152	$this->metaTablesSQL = $save;
153	return $ret;
154	}
155
156
157	function MetaIndexes ($table, $primary = FALSE, $owner=false)
158	{
159	// save old fetch mode
160	global $ADODB_FETCH_MODE;
161
162	$false = false;
163	$save = $ADODB_FETCH_MODE;
164	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
165	if ($this->fetchMode !== FALSE) {
166	$savem = $this->SetFetchMode(FALSE);
167	}
168
169	// get index details
170	$rs = $this->Execute(sprintf('SHOW INDEX FROM %s',$table));
171
172	// restore fetchmode
173	if (isset($savem)) {
174	$this->SetFetchMode($savem);
175	}
176	$ADODB_FETCH_MODE = $save;
177
178	if (!is_object($rs)) {
179	return $false;
180	}
181
182	$indexes = array ();
183
184	// parse index data into array
185	while ($row = $rs->FetchRow()) {
186	if ($primary == FALSE AND $row[2] == 'PRIMARY') {
187	continue;
188	}
189
190	if (!isset($indexes[$row[2]])) {
191	$indexes[$row[2]] = array(
192	'unique' => ($row[1] == 0),
193	'columns' => array()
194	);
195	}
196
197	$indexes[$row[2]]['columns'][$row[3] - 1] = $row[4];
198	}
199
200	// sort columns by order in the index
201	foreach ( array_keys ($indexes) as $index )
202	{
203	ksort ($indexes[$index]['columns']);
204	}
205
206	return $indexes;
207	}
208
209
210	// if magic quotes disabled, use mysql_real_escape_string()
211	function qstr($s,$magic_quotes=false)
212	{
213	if (is_null($s)) return 'NULL';
214	if (!$magic_quotes) {
215
216	if (ADODB_PHPVER >= 0x4300) {
217	if (is_resource($this->_connectionID))
218	return "'".mysql_real_escape_string($s,$this->_connectionID)."'";
219	}
220	if ($this->replaceQuote[0] == '\\'){
221	$s = adodb_str_replace(array('\\',"\0"),array('\\\\',"\\\0"),$s);
222	}
223	return "'".str_replace("'",$this->replaceQuote,$s)."'";
224	}
225
226	// undo magic quotes for "
227	$s = str_replace('\\"','"',$s);
228	return "'$s'";
229	}
230
231	function _insertid()
232	{
233	return ADOConnection::GetOne('SELECT LAST_INSERT_ID()');
234	//return mysql_insert_id($this->_connectionID);
235	}
236
237	function GetOne($sql,$inputarr=false)
238	{
239	global $ADODB_GETONE_EOF;
240	if ($this->compat323 == false && strncasecmp($sql,'sele',4) == 0) {
241	$rs = $this->SelectLimit($sql,1,-1,$inputarr);
242	if ($rs) {
243	$rs->Close();
244	if ($rs->EOF) return $ADODB_GETONE_EOF;
245	return reset($rs->fields);
246	}
247	} else {
248	return ADOConnection::GetOne($sql,$inputarr);
249	}
250	return false;
251	}
252
253	function BeginTrans()
254	{
255	if ($this->debug) ADOConnection::outp("Transactions not supported in 'mysql' driver. Use 'mysqlt' or 'mysqli' driver");
256	}
257
258	function _affectedrows()
259	{
260	return mysql_affected_rows($this->_connectionID);
261	}
262
263	// See http://www.mysql.com/doc/M/i/Miscellaneous_functions.html
264	// Reference on Last_Insert_ID on the recommended way to simulate sequences
265	var $_genIDSQL = "update %s set id=LAST_INSERT_ID(id+1);";
266	var $_genSeqSQL = "create table %s (id int not null)";
267	var $_genSeqCountSQL = "select count(*) from %s";
268	var $_genSeq2SQL = "insert into %s values (%s)";
269	var $_dropSeqSQL = "drop table %s";
270
271	function CreateSequence($seqname='adodbseq',$startID=1)
272	{
273	if (empty($this->_genSeqSQL)) return false;
274	$u = strtoupper($seqname);
275
276	$ok = $this->Execute(sprintf($this->_genSeqSQL,$seqname));
277	if (!$ok) return false;
278	return $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
279	}
280
281
282	function GenID($seqname='adodbseq',$startID=1)
283	{
284	// post-nuke sets hasGenID to false
285	if (!$this->hasGenID) return false;
286
287	$savelog = $this->_logsql;
288	$this->_logsql = false;
289	$getnext = sprintf($this->_genIDSQL,$seqname);
290	$holdtransOK = $this->_transOK; // save the current status
291	$rs = @$this->Execute($getnext);
292	if (!$rs) {
293	if ($holdtransOK) $this->_transOK = true; //if the status was ok before reset
294	$u = strtoupper($seqname);
295	$this->Execute(sprintf($this->_genSeqSQL,$seqname));
296	$cnt = $this->GetOne(sprintf($this->_genSeqCountSQL,$seqname));
297	if (!$cnt) $this->Execute(sprintf($this->_genSeq2SQL,$seqname,$startID-1));
298	$rs = $this->Execute($getnext);
299	}
300
301	if ($rs) {
302	$this->genID = mysql_insert_id($this->_connectionID);
303	$rs->Close();
304	} else
305	$this->genID = 0;
306
307	$this->_logsql = $savelog;
308	return $this->genID;
309	}
310
311	function MetaDatabases()
312	{
313	$qid = mysql_list_dbs($this->_connectionID);
314	$arr = array();
315	$i = 0;
316	$max = mysql_num_rows($qid);
317	while ($i < $max) {
318	$db = mysql_tablename($qid,$i);
319	if ($db != 'mysql') $arr[] = $db;
320	$i += 1;
321	}
322	return $arr;
323	}
324
325
326	// Format date column in sql string given an input format that understands Y M D
327	function SQLDate($fmt, $col=false)
328	{
329	if (!$col) $col = $this->sysTimeStamp;
330	$s = 'DATE_FORMAT('.$col.",'";
331	$concat = false;
332	$len = strlen($fmt);
333	for ($i=0; $i < $len; $i++) {
334	$ch = $fmt[$i];
335	switch($ch) {
336
337	default:
338	if ($ch == '\\') {
339	$i++;
340	$ch = substr($fmt,$i,1);
341	}
342	/** FALL THROUGH */
343	case '-':
344	case '/':
345	$s .= $ch;
346	break;
347
348	case 'Y':
349	case 'y':
350	$s .= '%Y';
351	break;
352	case 'M':
353	$s .= '%b';
354	break;
355
356	case 'm':
357	$s .= '%m';
358	break;
359	case 'D':
360	case 'd':
361	$s .= '%d';
362	break;
363
364	case 'Q':
365	case 'q':
366	$s .= "'),Quarter($col)";
367
368	if ($len > $i+1) $s .= ",DATE_FORMAT($col,'";
369	else $s .= ",('";
370	$concat = true;
371	break;
372
373	case 'H':
374	$s .= '%H';
375	break;
376
377	case 'h':
378	$s .= '%I';
379	break;
380
381	case 'i':
382	$s .= '%i';
383	break;
384
385	case 's':
386	$s .= '%s';
387	break;
388
389	case 'a':
390	case 'A':
391	$s .= '%p';
392	break;
393
394	case 'w':
395	$s .= '%w';
396	break;
397
398	case 'W':
399	$s .= '%U';
400	break;
401
402	case 'l':
403	$s .= '%W';
404	break;
405	}
406	}
407	$s.="')";
408	if ($concat) $s = "CONCAT($s)";
409	return $s;
410	}
411
412
413	// returns concatenated string
414	// much easier to run "mysqld --ansi" or "mysqld --sql-mode=PIPES_AS_CONCAT" and use \|\| operator
415	function Concat()
416	{
417	$s = "";
418	$arr = func_get_args();
419
420	// suggestion by andrew005@mnogo.ru
421	$s = implode(',',$arr);
422	if (strlen($s) > 0) return "CONCAT($s)";
423	else return '';
424	}
425
426	function OffsetDate($dayFraction,$date=false)
427	{
428	if (!$date) $date = $this->sysDate;
429
430	$fraction = $dayFraction * 24 * 3600;
431	return '('. $date . ' + INTERVAL ' . $fraction.' SECOND)';
432
433	// return "from_unixtime(unix_timestamp($date)+$fraction)";
434	}
435
436	// returns true or false
437	function _connect($argHostname, $argUsername, $argPassword, $argDatabasename)
438	{
439	if (!empty($this->port)) $argHostname .= ":".$this->port;
440
441	if (ADODB_PHPVER >= 0x4300)
442	$this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword,
443	$this->forceNewConnect,$this->clientFlags);
444	else if (ADODB_PHPVER >= 0x4200)
445	$this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword,
446	$this->forceNewConnect);
447	else
448	$this->_connectionID = mysql_connect($argHostname,$argUsername,$argPassword);
449
450	if ($this->_connectionID === false) return false;
451	if ($argDatabasename) return $this->SelectDB($argDatabasename);
452	return true;
453	}
454
455	// returns true or false
456	function _pconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
457	{
458	if (!empty($this->port)) $argHostname .= ":".$this->port;
459
460	if (ADODB_PHPVER >= 0x4300)
461	$this->_connectionID = mysql_pconnect($argHostname,$argUsername,$argPassword,$this->clientFlags);
462	else
463	$this->_connectionID = mysql_pconnect($argHostname,$argUsername,$argPassword);
464	if ($this->_connectionID === false) return false;
465	if ($this->autoRollback) $this->RollbackTrans();
466	if ($argDatabasename) return $this->SelectDB($argDatabasename);
467	return true;
468	}
469
470	function _nconnect($argHostname, $argUsername, $argPassword, $argDatabasename)
471	{
472	$this->forceNewConnect = true;
473	return $this->_connect($argHostname, $argUsername, $argPassword, $argDatabasename);
474	}
475
476	function MetaColumns($table, $normalize=true)
477	{
478	$this->_findschema($table,$schema);
479	if ($schema) {
480	$dbName = $this->database;
481	$this->SelectDB($schema);
482	}
483	global $ADODB_FETCH_MODE;
484	$save = $ADODB_FETCH_MODE;
485	$ADODB_FETCH_MODE = ADODB_FETCH_NUM;
486
487	if ($this->fetchMode !== false) $savem = $this->SetFetchMode(false);
488	$rs = $this->Execute(sprintf($this->metaColumnsSQL,$table));
489
490	if ($schema) {
491	$this->SelectDB($dbName);
492	}
493
494	if (isset($savem)) $this->SetFetchMode($savem);
495	$ADODB_FETCH_MODE = $save;
496	if (!is_object($rs)) {
497	$false = false;
498	return $false;
499	}
500
501	$retarr = array();
502	while (!$rs->EOF){
503	$fld = new ADOFieldObject();
504	$fld->name = $rs->fields[0];
505	$type = $rs->fields[1];
506
507	// split type into type(length):
508	$fld->scale = null;
509	if (preg_match("/^(.+)\((\d+),(\d+)/", $type, $query_array)) {
510	$fld->type = $query_array[1];
511	$fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1;
512	$fld->scale = is_numeric($query_array[3]) ? $query_array[3] : -1;
513	} elseif (preg_match("/^(.+)\((\d+)/", $type, $query_array)) {
514	$fld->type = $query_array[1];
515	$fld->max_length = is_numeric($query_array[2]) ? $query_array[2] : -1;
516	} elseif (preg_match("/^(enum)$(.*)$$/i", $type, $query_array)) {
517	$fld->type = $query_array[1];
518	$arr = explode(",",$query_array[2]);
519	$fld->enums = $arr;
520	$zlen = max(array_map("strlen",$arr)) - 2; // PHP >= 4.0.6
521	$fld->max_length = ($zlen > 0) ? $zlen : 1;
522	} else {
523	$fld->type = $type;
524	$fld->max_length = -1;
525	}
526	$fld->not_null = ($rs->fields[2] != 'YES');
527	$fld->primary_key = ($rs->fields[3] == 'PRI');
528	$fld->auto_increment = (strpos($rs->fields[5], 'auto_increment') !== false);
529	$fld->binary = (strpos($type,'blob') !== false \|\| strpos($type,'binary') !== false);
530	$fld->unsigned = (strpos($type,'unsigned') !== false);
531	$fld->zerofill = (strpos($type,'zerofill') !== false);
532
533	if (!$fld->binary) {
534	$d = $rs->fields[4];
535	if ($d != '' && $d != 'NULL') {
536	$fld->has_default = true;
537	$fld->default_value = $d;
538	} else {
539	$fld->has_default = false;
540	}
541	}
542
543	if ($save == ADODB_FETCH_NUM) {
544	$retarr[] = $fld;
545	} else {
546	$retarr[strtoupper($fld->name)] = $fld;
547	}
548	$rs->MoveNext();
549	}
550
551	$rs->Close();
552	return $retarr;
553	}
554
555	// returns true or false
556	function SelectDB($dbName)
557	{
558	$this->database = $dbName;
559	$this->databaseName = $dbName; # obsolete, retained for compat with older adodb versions
560	if ($this->_connectionID) {
561	return @mysql_select_db($dbName,$this->_connectionID);
562	}
563	else return false;
564	}
565
566	// parameters use PostgreSQL convention, not MySQL
567	function SelectLimit($sql,$nrows=-1,$offset=-1,$inputarr=false,$secs=0)
568	{
569	$offsetStr =($offset>=0) ? ((integer)$offset)."," : '';
570	// jason judge, see http://phplens.com/lens/lensforum/msgs.php?id=9220
571	if ($nrows < 0) $nrows = '18446744073709551615';
572
573	if ($secs)
574	$rs = $this->CacheExecute($secs,$sql." LIMIT $offsetStr".((integer)$nrows),$inputarr);
575	else
576	$rs = $this->Execute($sql." LIMIT $offsetStr".((integer)$nrows),$inputarr);
577	return $rs;
578	}
579
580	// returns queryID or false
581	function _query($sql,$inputarr=false)
582	{
583	//global $ADODB_COUNTRECS;
584	//if($ADODB_COUNTRECS)
585	return mysql_query($sql,$this->_connectionID);
586	//else return @mysql_unbuffered_query($sql,$this->_connectionID); // requires PHP >= 4.0.6
587	}
588
589	/* Returns: the last error message from previous database operation */
590	function ErrorMsg()
591	{
592
593	if ($this->_logsql) return $this->_errorMsg;
594	if (empty($this->_connectionID)) $this->_errorMsg = @mysql_error();
595	else $this->_errorMsg = @mysql_error($this->_connectionID);
596	return $this->_errorMsg;
597	}
598
599	/* Returns: the last error number from previous database operation */
600	function ErrorNo()
601	{
602	if ($this->_logsql) return $this->_errorCode;
603	if (empty($this->_connectionID)) return @mysql_errno();
604	else return @mysql_errno($this->_connectionID);
605	}
606
607	// returns true or false
608	function _close()
609	{
610	@mysql_close($this->_connectionID);
611
612	$this->charSet = '';
613	$this->_connectionID = false;
614	}
615
616
617	/*
618	* Maximum size of C field
619	*/
620	function CharMax()
621	{
622	return 255;
623	}
624
625	/*
626	* Maximum size of X field
627	*/
628	function TextMax()
629	{
630	return 4294967295;
631	}
632
633	// "Innox - Juan Carlos Gonzalez" <jgonzalez#innox.com.mx>
634	function MetaForeignKeys( $table, $owner = FALSE, $upper = FALSE, $associative = FALSE )
635	{
636	global $ADODB_FETCH_MODE;
637	if ($ADODB_FETCH_MODE == ADODB_FETCH_ASSOC \|\| $this->fetchMode == ADODB_FETCH_ASSOC) $associative = true;
638
639	if ( !empty($owner) ) {
640	$table = "$owner.$table";
641	}
642	$a_create_table = $this->getRow(sprintf('SHOW CREATE TABLE %s', $table));
643	if ($associative) {
644	$create_sql = isset($a_create_table["Create Table"]) ? $a_create_table["Create Table"] : $a_create_table["Create View"];
645	} else $create_sql = $a_create_table[1];
646
647	$matches = array();
648
649	if (!preg_match_all("/FOREIGN KEY $`(.?)`$ REFERENCES `(.?)` $`(.*?)`$/", $create_sql, $matches)) return false;
650	$foreign_keys = array();
651	$num_keys = count($matches[0]);
652	for ( $i = 0; $i < $num_keys; $i ++ ) {
653	$my_field = explode('`, `', $matches[1][$i]);
654	$ref_table = $matches[2][$i];
655	$ref_field = explode('`, `', $matches[3][$i]);
656
657	if ( $upper ) {
658	$ref_table = strtoupper($ref_table);
659	}
660
661	// see https://sourceforge.net/tracker/index.php?func=detail&aid=2287278&group_id=42718&atid=433976
662	if (!isset($foreign_keys[$ref_table])) {
663	$foreign_keys[$ref_table] = array();
664	}
665	$num_fields = count($my_field);
666	for ( $j = 0; $j < $num_fields; $j ++ ) {
667	if ( $associative ) {
668	$foreign_keys[$ref_table][$ref_field[$j]] = $my_field[$j];
669	} else {
670	$foreign_keys[$ref_table][] = "{$my_field[$j]}={$ref_field[$j]}";
671	}
672	}
673	}
674
675	return $foreign_keys;
676	}
677
678
679	}
680
681	/*--------------------------------------------------------------------------------------
682	Class Name: Recordset
683	--------------------------------------------------------------------------------------*/
684
685
686	class ADORecordSet_mysql extends ADORecordSet{
687
688	var $databaseType = "mysql";
689	var $canSeek = true;
690
691	function ADORecordSet_mysql($queryID,$mode=false)
692	{
693	if ($mode === false) {
694	global $ADODB_FETCH_MODE;
695	$mode = $ADODB_FETCH_MODE;
696	}
697	switch ($mode)
698	{
699	case ADODB_FETCH_NUM: $this->fetchMode = MYSQL_NUM; break;
700	case ADODB_FETCH_ASSOC:$this->fetchMode = MYSQL_ASSOC; break;
701	case ADODB_FETCH_DEFAULT:
702	case ADODB_FETCH_BOTH:
703	default:
704	$this->fetchMode = MYSQL_BOTH; break;
705	}
706	$this->adodbFetchMode = $mode;
707	$this->ADORecordSet($queryID);
708	}
709
710	function _initrs()
711	{
712	//GLOBAL $ADODB_COUNTRECS;
713	// $this->_numOfRows = ($ADODB_COUNTRECS) ? @mysql_num_rows($this->_queryID):-1;
714	$this->_numOfRows = @mysql_num_rows($this->_queryID);
715	$this->_numOfFields = @mysql_num_fields($this->_queryID);
716	}
717
718	function FetchField($fieldOffset = -1)
719	{
720	if ($fieldOffset != -1) {
721	$o = @mysql_fetch_field($this->_queryID, $fieldOffset);
722	$f = @mysql_field_flags($this->_queryID,$fieldOffset);
723	if ($o) $o->max_length = @mysql_field_len($this->_queryID,$fieldOffset); // suggested by: Jim Nicholson (jnich#att.com)
724	//$o->max_length = -1; // mysql returns the max length less spaces -- so it is unrealiable
725	if ($o) $o->binary = (strpos($f,'binary')!== false);
726	}
727	else { /* The $fieldOffset argument is not provided thus its -1 */
728	$o = @mysql_fetch_field($this->_queryID);
729	//if ($o) $o->max_length = @mysql_field_len($this->_queryID); // suggested by: Jim Nicholson (jnich#att.com)
730	$o->max_length = -1; // mysql returns the max length less spaces -- so it is unrealiable
731	}
732
733	return $o;
734	}
735
736	function GetRowAssoc($upper=true)
737	{
738	if ($this->fetchMode == MYSQL_ASSOC && !$upper) $row = $this->fields;
739	else $row = ADORecordSet::GetRowAssoc($upper);
740	return $row;
741	}
742
743	/* Use associative array to get fields array */
744	function Fields($colname)
745	{
746	// added @ by "Michael William Miller" <mille562@pilot.msu.edu>
747	if ($this->fetchMode != MYSQL_NUM) return @$this->fields[$colname];
748
749	if (!$this->bind) {
750	$this->bind = array();
751	for ($i=0; $i < $this->_numOfFields; $i++) {
752	$o = $this->FetchField($i);
753	$this->bind[strtoupper($o->name)] = $i;
754	}
755	}
756	return $this->fields[$this->bind[strtoupper($colname)]];
757	}
758
759	function _seek($row)
760	{
761	if ($this->_numOfRows == 0) return false;
762	return @mysql_data_seek($this->_queryID,$row);
763	}
764
765	function MoveNext()
766	{
767	//return adodb_movenext($this);
768	//if (defined('ADODB_EXTENSION')) return adodb_movenext($this);
769	if (@$this->fields = mysql_fetch_array($this->_queryID,$this->fetchMode)) {
770	$this->_currentRow += 1;
771	return true;
772	}
773	if (!$this->EOF) {
774	$this->_currentRow += 1;
775	$this->EOF = true;
776	}
777	return false;
778	}
779
780	function _fetch()
781	{
782	$this->fields = @mysql_fetch_array($this->_queryID,$this->fetchMode);
783	return is_array($this->fields);
784	}
785
786	function _close() {
787	@mysql_free_result($this->_queryID);
788	$this->_queryID = false;
789	}
790
791	function MetaType($t,$len=-1,$fieldobj=false)
792	{
793	if (is_object($t)) {
794	$fieldobj = $t;
795	$t = $fieldobj->type;
796	$len = $fieldobj->max_length;
797	}
798
799	$len = -1; // mysql max_length is not accurate
800	switch (strtoupper($t)) {
801	case 'STRING':
802	case 'CHAR':
803	case 'VARCHAR':
804	case 'TINYBLOB':
805	case 'TINYTEXT':
806	case 'ENUM':
807	case 'SET':
808	if ($len <= $this->blobSize) return 'C';
809
810	case 'TEXT':
811	case 'LONGTEXT':
812	case 'MEDIUMTEXT':
813	return 'X';
814
815	// php_mysql extension always returns 'blob' even if 'text'
816	// so we have to check whether binary...
817	case 'IMAGE':
818	case 'LONGBLOB':
819	case 'BLOB':
820	case 'MEDIUMBLOB':
821	case 'BINARY':
822	return !empty($fieldobj->binary) ? 'B' : 'X';
823
824	case 'YEAR':
825	case 'DATE': return 'D';
826
827	case 'TIME':
828	case 'DATETIME':
829	case 'TIMESTAMP': return 'T';
830
831	case 'INT':
832	case 'INTEGER':
833	case 'BIGINT':
834	case 'TINYINT':
835	case 'MEDIUMINT':
836	case 'SMALLINT':
837
838	if (!empty($fieldobj->primary_key)) return 'R';
839	else return 'I';
840
841	default: return 'N';
842	}
843	}
844
845	}
846
847	class ADORecordSet_ext_mysql extends ADORecordSet_mysql {
848	function ADORecordSet_ext_mysql($queryID,$mode=false)
849	{
850	if ($mode === false) {
851	global $ADODB_FETCH_MODE;
852	$mode = $ADODB_FETCH_MODE;
853	}
854	switch ($mode)
855	{
856	case ADODB_FETCH_NUM: $this->fetchMode = MYSQL_NUM; break;
857	case ADODB_FETCH_ASSOC:$this->fetchMode = MYSQL_ASSOC; break;
858	case ADODB_FETCH_DEFAULT:
859	case ADODB_FETCH_BOTH:
860	default:
861	$this->fetchMode = MYSQL_BOTH; break;
862	}
863	$this->adodbFetchMode = $mode;
864	$this->ADORecordSet($queryID);
865	}
866
867	function MoveNext()
868	{
869	return @adodb_movenext($this);
870	}
871	}
872
873
874	}
875	?>

Note: See TracBrowser for help on using the repository browser.

Context Navigation

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

Download in other formats: