Context Navigation

source: Dev/trunk/rdfapi/util/adodb/drivers/adodb-mysql.inc.php @ 12

Last change on this file since 12 was 12, checked in by basvannuland, 14 years ago
Added RAP RDF API Added RDF reader writer for save and load survey
File size: 21.0 KB

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

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

Download in other formats: