Context Navigation

source: Dev/trunk/rdfapi/util/adodb/adodb-lib.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: 34.8 KB

Rev	Line
[12]	1	<?php
	2
	3	// security - hide paths
	4	if (!defined('ADODB_DIR')) die();
	5
	6	global $ADODB_INCLUDED_LIB;
	7	$ADODB_INCLUDED_LIB = 1;
	8
	9	/*
	10	@version V4.94 23 Jan 2007 (c) 2000-2007 John Lim (jlim\@natsoft.com.my). All rights reserved.
	11	Released under both BSD license and Lesser GPL library license.
	12	Whenever there is any discrepancy between the two licenses,
	13	the BSD license will take precedence. See License.txt.
	14	Set tabs to 4 for best viewing.
	15
	16	Less commonly used functions are placed here to reduce size of adodb.inc.php.
	17	*/
	18
	19	function adodb_probetypes(&$array,&$types,$probe=8)
	20	{
	21	// probe and guess the type
	22	$types = array();
	23	if ($probe > sizeof($array)) $max = sizeof($array);
	24	else $max = $probe;
	25
	26
	27	for ($j=0;$j < $max; $j++) {
	28	$row =& $array[$j];
	29	if (!$row) break;
	30	$i = -1;
	31	foreach($row as $v) {
	32	$i += 1;
	33
	34	if (isset($types[$i]) && $types[$i]=='C') continue;
	35
	36	//print " ($i ".$types[$i]. "$v) ";
	37	$v = trim($v);
	38
	39	if (!preg_match('/^[+-]{0,1}[0-9\.]+$/',$v)) {
	40	$types[$i] = 'C'; // once C, always C
	41
	42	continue;
	43	}
	44	if ($j == 0) {
	45	// If empty string, we presume is character
	46	// test for integer for 1st row only
	47	// after that it is up to testing other rows to prove
	48	// that it is not an integer
	49	if (strlen($v) == 0) $types[$i] = 'C';
	50	if (strpos($v,'.') !== false) $types[$i] = 'N';
	51	else $types[$i] = 'I';
	52	continue;
	53	}
	54
	55	if (strpos($v,'.') !== false) $types[$i] = 'N';
	56
	57	}
	58	}
	59
	60	}
	61
	62	function adodb_transpose(&$arr, &$newarr, &$hdr, &$fobjs)
	63	{
	64	$oldX = sizeof(reset($arr));
	65	$oldY = sizeof($arr);
	66
	67	if ($hdr) {
	68	$startx = 1;
	69	$hdr = array('Fields');
	70	for ($y = 0; $y < $oldY; $y++) {
	71	$hdr[] = $arr[$y][0];
	72	}
	73	} else
	74	$startx = 0;
	75
	76	for ($x = $startx; $x < $oldX; $x++) {
	77	if ($fobjs) {
	78	$o = $fobjs[$x];
	79	$newarr[] = array($o->name);
	80	} else
	81	$newarr[] = array();
	82
	83	for ($y = 0; $y < $oldY; $y++) {
	84	$newarr[$x-$startx][] = $arr[$y][$x];
	85	}
	86	}
	87	}
	88
	89	// Force key to upper.
	90	// See also http://www.php.net/manual/en/function.array-change-key-case.php
	91	function _array_change_key_case($an_array)
	92	{
	93	if (is_array($an_array)) {
	94	$new_array = array();
	95	foreach($an_array as $key=>$value)
	96	$new_array[strtoupper($key)] = $value;
	97
	98	return $new_array;
	99	}
	100
	101	return $an_array;
	102	}
	103
	104	function _adodb_replace(&$zthis, $table, $fieldArray, $keyCol, $autoQuote, $has_autoinc)
	105	{
	106	if (count($fieldArray) == 0) return 0;
	107	$first = true;
	108	$uSet = '';
	109
	110	if (!is_array($keyCol)) {
	111	$keyCol = array($keyCol);
	112	}
	113	foreach($fieldArray as $k => $v) {
	114	if ($autoQuote && !is_numeric($v) and strncmp($v,"'",1) !== 0 and strcasecmp($v,$zthis->null2null)!=0) {
	115	$v = $zthis->qstr($v);
	116	$fieldArray[$k] = $v;
	117	}
	118	if (in_array($k,$keyCol)) continue; // skip UPDATE if is key
	119
	120	if ($first) {
	121	$first = false;
	122	$uSet = "$k=$v";
	123	} else
	124	$uSet .= ",$k=$v";
	125	}
	126
	127	$where = false;
	128	foreach ($keyCol as $v) {
	129	if (isset($fieldArray[$v])) {
	130	if ($where) $where .= ' and '.$v.'='.$fieldArray[$v];
	131	else $where = $v.'='.$fieldArray[$v];
	132	}
	133	}
	134
	135	if ($uSet && $where) {
	136	$update = "UPDATE $table SET $uSet WHERE $where";
	137
	138	$rs = $zthis->Execute($update);
	139
	140
	141	if ($rs) {
	142	if ($zthis->poorAffectedRows) {
	143	/*
	144	The Select count(*) wipes out any errors that the update would have returned.
	145	http://phplens.com/lens/lensforum/msgs.php?id=5696
	146	*/
	147	if ($zthis->ErrorNo()<>0) return 0;
	148
	149	# affected_rows == 0 if update field values identical to old values
	150	# for mysql - which is silly.
	151
	152	$cnt = $zthis->GetOne("select count(*) from $table where $where");
	153	if ($cnt > 0) return 1; // record already exists
	154	} else {
	155	if (($zthis->Affected_Rows()>0)) return 1;
	156	}
	157	} else
	158	return 0;
	159	}
	160
	161	// print "<p>Error=".$this->ErrorNo().'<p>';
	162	$first = true;
	163	foreach($fieldArray as $k => $v) {
	164	if ($has_autoinc && in_array($k,$keyCol)) continue; // skip autoinc col
	165
	166	if ($first) {
	167	$first = false;
	168	$iCols = "$k";
	169	$iVals = "$v";
	170	} else {
	171	$iCols .= ",$k";
	172	$iVals .= ",$v";
	173	}
	174	}
	175	$insert = "INSERT INTO $table ($iCols) VALUES ($iVals)";
	176	$rs = $zthis->Execute($insert);
	177	return ($rs) ? 2 : 0;
	178	}
	179
	180	// Requires $ADODB_FETCH_MODE = ADODB_FETCH_NUM
	181	function _adodb_getmenu(&$zthis, $name,$defstr='',$blank1stItem=true,$multiple=false,
	182	$size=0, $selectAttr='',$compareFields0=true)
	183	{
	184	$hasvalue = false;
	185
	186	if ($multiple or is_array($defstr)) {
	187	if ($size==0) $size=5;
	188	$attr = ' multiple size="'.$size.'"';
	189	if (!strpos($name,'[]')) $name .= '[]';
	190	} else if ($size) $attr = ' size="'.$size.'"';
	191	else $attr ='';
	192
	193	$s = '<select name="'.$name.'"'.$attr.' '.$selectAttr.'>';
	194	if ($blank1stItem)
	195	if (is_string($blank1stItem)) {
	196	$barr = explode(':',$blank1stItem);
	197	if (sizeof($barr) == 1) $barr[] = '';
	198	$s .= "\n<option value=\"".$barr[0]."\">".$barr[1]."</option>";
	199	} else $s .= "\n<option></option>";
	200
	201	if ($zthis->FieldCount() > 1) $hasvalue=true;
	202	else $compareFields0 = true;
	203
	204	$value = '';
	205	$optgroup = null;
	206	$firstgroup = true;
	207	$fieldsize = $zthis->FieldCount();
	208	while(!$zthis->EOF) {
	209	$zval = rtrim(reset($zthis->fields));
	210
	211	if ($blank1stItem && $zval=="") {
	212	$zthis->MoveNext();
	213	continue;
	214	}
	215
	216	if ($fieldsize > 1) {
	217	if (isset($zthis->fields[1]))
	218	$zval2 = rtrim($zthis->fields[1]);
	219	else
	220	$zval2 = rtrim(next($zthis->fields));
	221	}
	222	$selected = ($compareFields0) ? $zval : $zval2;
	223
	224	$group = '';
	225	if ($fieldsize > 2) {
	226	$group = rtrim($zthis->fields[2]);
	227	}
	228	/*
	229	if ($optgroup != $group) {
	230	$optgroup = $group;
	231	if ($firstgroup) {
	232	$firstgroup = false;
	233	$s .="\n<optgroup label='". htmlspecialchars($group) ."'>";
	234	} else {
	235	$s .="\n</optgroup>";
	236	$s .="\n<optgroup label='". htmlspecialchars($group) ."'>";
	237	}
	238	}
	239	*/
	240	if ($hasvalue)
	241	$value = " value='".htmlspecialchars($zval2)."'";
	242
	243	if (is_array($defstr)) {
	244
	245	if (in_array($selected,$defstr))
	246	$s .= "\n<option selected='selected'$value>".htmlspecialchars($zval).'</option>';
	247	else
	248	$s .= "\n<option".$value.'>'.htmlspecialchars($zval).'</option>';
	249	}
	250	else {
	251	if (strcasecmp($selected,$defstr)==0)
	252	$s .= "\n<option selected='selected'$value>".htmlspecialchars($zval).'</option>';
	253	else
	254	$s .= "\n<option".$value.'>'.htmlspecialchars($zval).'</option>';
	255	}
	256	$zthis->MoveNext();
	257	} // while
	258
	259	// closing last optgroup
	260	if($optgroup != null) {
	261	$s .= "\n</optgroup>";
	262	}
	263	return $s ."\n</select>\n";
	264	}
	265
	266	// Requires $ADODB_FETCH_MODE = ADODB_FETCH_NUM
	267	function _adodb_getmenu_gp(&$zthis, $name,$defstr='',$blank1stItem=true,$multiple=false,
	268	$size=0, $selectAttr='',$compareFields0=true)
	269	{
	270	$hasvalue = false;
	271
	272	if ($multiple or is_array($defstr)) {
	273	if ($size==0) $size=5;
	274	$attr = ' multiple size="'.$size.'"';
	275	if (!strpos($name,'[]')) $name .= '[]';
	276	} else if ($size) $attr = ' size="'.$size.'"';
	277	else $attr ='';
	278
	279	$s = '<select name="'.$name.'"'.$attr.' '.$selectAttr.'>';
	280	if ($blank1stItem)
	281	if (is_string($blank1stItem)) {
	282	$barr = explode(':',$blank1stItem);
	283	if (sizeof($barr) == 1) $barr[] = '';
	284	$s .= "\n<option value=\"".$barr[0]."\">".$barr[1]."</option>";
	285	} else $s .= "\n<option></option>";
	286
	287	if ($zthis->FieldCount() > 1) $hasvalue=true;
	288	else $compareFields0 = true;
	289
	290	$value = '';
	291	$optgroup = null;
	292	$firstgroup = true;
	293	$fieldsize = sizeof($zthis->fields);
	294	while(!$zthis->EOF) {
	295	$zval = rtrim(reset($zthis->fields));
	296
	297	if ($blank1stItem && $zval=="") {
	298	$zthis->MoveNext();
	299	continue;
	300	}
	301
	302	if ($fieldsize > 1) {
	303	if (isset($zthis->fields[1]))
	304	$zval2 = rtrim($zthis->fields[1]);
	305	else
	306	$zval2 = rtrim(next($zthis->fields));
	307	}
	308	$selected = ($compareFields0) ? $zval : $zval2;
	309
	310	$group = '';
	311	if (isset($zthis->fields[2])) {
	312	$group = rtrim($zthis->fields[2]);
	313	}
	314
	315	if ($optgroup != $group) {
	316	$optgroup = $group;
	317	if ($firstgroup) {
	318	$firstgroup = false;
	319	$s .="\n<optgroup label='". htmlspecialchars($group) ."'>";
	320	} else {
	321	$s .="\n</optgroup>";
	322	$s .="\n<optgroup label='". htmlspecialchars($group) ."'>";
	323	}
	324	}
	325
	326	if ($hasvalue)
	327	$value = " value='".htmlspecialchars($zval2)."'";
	328
	329	if (is_array($defstr)) {
	330
	331	if (in_array($selected,$defstr))
	332	$s .= "\n<option selected='selected'$value>".htmlspecialchars($zval).'</option>';
	333	else
	334	$s .= "\n<option".$value.'>'.htmlspecialchars($zval).'</option>';
	335	}
	336	else {
	337	if (strcasecmp($selected,$defstr)==0)
	338	$s .= "\n<option selected='selected'$value>".htmlspecialchars($zval).'</option>';
	339	else
	340	$s .= "\n<option".$value.'>'.htmlspecialchars($zval).'</option>';
	341	}
	342	$zthis->MoveNext();
	343	} // while
	344
	345	// closing last optgroup
	346	if($optgroup != null) {
	347	$s .= "\n</optgroup>";
	348	}
	349	return $s ."\n</select>\n";
	350	}
	351
	352
	353	/*
	354	Count the number of records this sql statement will return by using
	355	query rewriting heuristics...
	356
	357	Does not work with UNIONs, except with postgresql and oracle.
	358
	359	Usage:
	360
	361	$conn->Connect(...);
	362	$cnt = _adodb_getcount($conn, $sql);
	363
	364	*/
	365	function _adodb_getcount(&$zthis, $sql,$inputarr=false,$secs2cache=0)
	366	{
	367	$qryRecs = 0;
	368
	369	if (!empty($zthis->_nestedSQL) \|\| preg_match("/^\s*SELECT\s+DISTINCT/is", $sql) \|\|
	370	preg_match('/\s+GROUP\s+BY\s+/is',$sql) \|\|
	371	preg_match('/\s+UNION\s+/is',$sql)) {
	372	// ok, has SELECT DISTINCT or GROUP BY so see if we can use a table alias
	373	// but this is only supported by oracle and postgresql...
	374	if ($zthis->dataProvider == 'oci8') {
	375
	376	$rewritesql = preg_replace('/(\sORDER\s+BY\s[^)]*)/is','',$sql);
	377
	378	// Allow Oracle hints to be used for query optimization, Chris Wrye
	379	if (preg_match('#/\\+.?\\*\\/#', $sql, $hint)) {
	380	$rewritesql = "SELECT ".$hint[0]." COUNT(*) FROM (".$rewritesql.")";
	381	} else
	382	$rewritesql = "SELECT COUNT(*) FROM (".$rewritesql.")";
	383
	384	} else if (strncmp($zthis->databaseType,'postgres',8) == 0) {
	385	$rewritesql = preg_replace('/(\sORDER\s+BY\s[^)]*)/is','',$sql);
	386	$rewritesql = "SELECT COUNT(*) FROM ($rewritesql) _ADODB_ALIAS_";
	387	}
	388	} else {
	389	// now replace SELECT ... FROM with SELECT COUNT(*) FROM
	390	$rewritesql = preg_replace(
	391	'/^\sSELECT\s.\s+FROM\s/Uis','SELECT COUNT(*) FROM ',$sql);
	392
	393
	394
	395	// fix by alexander zhukov, alex#unipack.ru, because count(*) and 'order by' fails
	396	// with mssql, access and postgresql. Also a good speedup optimization - skips sorting!
	397	// also see http://phplens.com/lens/lensforum/msgs.php?id=12752
	398	if (preg_match('/\sORDER\s+BY\s*\(/i',$rewritesql))
	399	$rewritesql = preg_replace('/(\sORDER\s+BY\s.*)/is','',$rewritesql);
	400	else
	401	$rewritesql = preg_replace('/(\sORDER\s+BY\s[^)]*)/is','',$rewritesql);
	402	}
	403
	404
	405
	406	if (isset($rewritesql) && $rewritesql != $sql) {
	407	if (preg_match('/\sLIMIT\s+[0-9]+/i',$sql,$limitarr)) $rewritesql .= $limitarr[1];
	408
	409	if ($secs2cache) {
	410	// we only use half the time of secs2cache because the count can quickly
	411	// become inaccurate if new records are added
	412	$qryRecs = $zthis->CacheGetOne($secs2cache/2,$rewritesql,$inputarr);
	413
	414	} else {
	415	$qryRecs = $zthis->GetOne($rewritesql,$inputarr);
	416	}
	417	if ($qryRecs !== false) return $qryRecs;
	418	}
	419	//--------------------------------------------
	420	// query rewrite failed - so try slower way...
	421
	422
	423	// strip off unneeded ORDER BY if no UNION
	424	if (preg_match('/\sUNION\s/is', $sql)) $rewritesql = $sql;
	425	else $rewritesql = preg_replace('/(\sORDER\s+BY\s.*)/is','',$sql);
	426
	427	if (preg_match('/\sLIMIT\s+[0-9]+/i',$sql,$limitarr)) $rewritesql .= $limitarr[0];
	428
	429	$rstest = &$zthis->Execute($rewritesql,$inputarr);
	430	if (!$rstest) $rstest = $zthis->Execute($sql,$inputarr);
	431
	432	if ($rstest) {
	433	$qryRecs = $rstest->RecordCount();
	434	if ($qryRecs == -1) {
	435	global $ADODB_EXTENSION;
	436	// some databases will return -1 on MoveLast() - change to MoveNext()
	437	if ($ADODB_EXTENSION) {
	438	while(!$rstest->EOF) {
	439	adodb_movenext($rstest);
	440	}
	441	} else {
	442	while(!$rstest->EOF) {
	443	$rstest->MoveNext();
	444	}
	445	}
	446	$qryRecs = $rstest->_currentRow;
	447	}
	448	$rstest->Close();
	449	if ($qryRecs == -1) return 0;
	450	}
	451	return $qryRecs;
	452	}
	453
	454	/*
	455	Code originally from "Cornel G" <conyg@fx.ro>
	456
	457	This code might not work with SQL that has UNION in it
	458
	459	Also if you are using CachePageExecute(), there is a strong possibility that
	460	data will get out of synch. use CachePageExecute() only with tables that
	461	rarely change.
	462	*/
	463	function &_adodb_pageexecute_all_rows(&$zthis, $sql, $nrows, $page,
	464	$inputarr=false, $secs2cache=0)
	465	{
	466	$atfirstpage = false;
	467	$atlastpage = false;
	468	$lastpageno=1;
	469
	470	// If an invalid nrows is supplied,
	471	// we assume a default value of 10 rows per page
	472	if (!isset($nrows) \|\| $nrows <= 0) $nrows = 10;
	473
	474	$qryRecs = false; //count records for no offset
	475
	476	$qryRecs = _adodb_getcount($zthis,$sql,$inputarr,$secs2cache);
	477	$lastpageno = (int) ceil($qryRecs / $nrows);
	478	$zthis->_maxRecordCount = $qryRecs;
	479
	480
	481
	482	// ***** Here we check whether $page is the last page or
	483	// whether we are trying to retrieve
	484	// a page number greater than the last page number.
	485	if ($page >= $lastpageno) {
	486	$page = $lastpageno;
	487	$atlastpage = true;
	488	}
	489
	490	// If page number <= 1, then we are at the first page
	491	if (empty($page) \|\| $page <= 1) {
	492	$page = 1;
	493	$atfirstpage = true;
	494	}
	495
	496	// We get the data we want
	497	$offset = $nrows * ($page-1);
	498	if ($secs2cache > 0)
	499	$rsreturn = &$zthis->CacheSelectLimit($secs2cache, $sql, $nrows, $offset, $inputarr);
	500	else
	501	$rsreturn = &$zthis->SelectLimit($sql, $nrows, $offset, $inputarr, $secs2cache);
	502
	503
	504	// Before returning the RecordSet, we set the pagination properties we need
	505	if ($rsreturn) {
	506	$rsreturn->_maxRecordCount = $qryRecs;
	507	$rsreturn->rowsPerPage = $nrows;
	508	$rsreturn->AbsolutePage($page);
	509	$rsreturn->AtFirstPage($atfirstpage);
	510	$rsreturn->AtLastPage($atlastpage);
	511	$rsreturn->LastPageNo($lastpageno);
	512	}
	513	return $rsreturn;
	514	}
	515
	516	// Iván Oliva version
	517	function &_adodb_pageexecute_no_last_page(&$zthis, $sql, $nrows, $page, $inputarr=false, $secs2cache=0)
	518	{
	519
	520	$atfirstpage = false;
	521	$atlastpage = false;
	522
	523	if (!isset($page) \|\| $page <= 1) { // If page number <= 1, then we are at the first page
	524	$page = 1;
	525	$atfirstpage = true;
	526	}
	527	if ($nrows <= 0) $nrows = 10; // If an invalid nrows is supplied, we assume a default value of 10 rows per page
	528
	529	// ***** Here we check whether $page is the last page or whether we are trying to retrieve a page number greater than
	530	// the last page number.
	531	$pagecounter = $page + 1;
	532	$pagecounteroffset = ($pagecounter * $nrows) - $nrows;
	533	if ($secs2cache>0) $rstest = &$zthis->CacheSelectLimit($secs2cache, $sql, $nrows, $pagecounteroffset, $inputarr);
	534	else $rstest = &$zthis->SelectLimit($sql, $nrows, $pagecounteroffset, $inputarr, $secs2cache);
	535	if ($rstest) {
	536	while ($rstest && $rstest->EOF && $pagecounter>0) {
	537	$atlastpage = true;
	538	$pagecounter--;
	539	$pagecounteroffset = $nrows * ($pagecounter - 1);
	540	$rstest->Close();
	541	if ($secs2cache>0) $rstest = &$zthis->CacheSelectLimit($secs2cache, $sql, $nrows, $pagecounteroffset, $inputarr);
	542	else $rstest = &$zthis->SelectLimit($sql, $nrows, $pagecounteroffset, $inputarr, $secs2cache);
	543	}
	544	if ($rstest) $rstest->Close();
	545	}
	546	if ($atlastpage) { // If we are at the last page or beyond it, we are going to retrieve it
	547	$page = $pagecounter;
	548	if ($page == 1) $atfirstpage = true; // We have to do this again in case the last page is the same as the first
	549	//... page, that is, the recordset has only 1 page.
	550	}
	551
	552	// We get the data we want
	553	$offset = $nrows * ($page-1);
	554	if ($secs2cache > 0) $rsreturn = &$zthis->CacheSelectLimit($secs2cache, $sql, $nrows, $offset, $inputarr);
	555	else $rsreturn = &$zthis->SelectLimit($sql, $nrows, $offset, $inputarr, $secs2cache);
	556
	557	// Before returning the RecordSet, we set the pagination properties we need
	558	if ($rsreturn) {
	559	$rsreturn->rowsPerPage = $nrows;
	560	$rsreturn->AbsolutePage($page);
	561	$rsreturn->AtFirstPage($atfirstpage);
	562	$rsreturn->AtLastPage($atlastpage);
	563	}
	564	return $rsreturn;
	565	}
	566
	567	function _adodb_getupdatesql(&$zthis,&$rs, $arrFields,$forceUpdate=false,$magicq=false,$force=2)
	568	{
	569	global $ADODB_QUOTE_FIELDNAMES;
	570
	571	if (!$rs) {
	572	printf(ADODB_BAD_RS,'GetUpdateSQL');
	573	return false;
	574	}
	575
	576	$fieldUpdatedCount = 0;
	577	$arrFields = _array_change_key_case($arrFields);
	578
	579	$hasnumeric = isset($rs->fields[0]);
	580	$setFields = '';
	581
	582	// Loop through all of the fields in the recordset
	583	for ($i=0, $max=$rs->FieldCount(); $i < $max; $i++) {
	584	// Get the field from the recordset
	585	$field = $rs->FetchField($i);
	586
	587	// If the recordset field is one
	588	// of the fields passed in then process.
	589	$upperfname = strtoupper($field->name);
	590	if (adodb_key_exists($upperfname,$arrFields,$force)) {
	591
	592	// If the existing field value in the recordset
	593	// is different from the value passed in then
	594	// go ahead and append the field name and new value to
	595	// the update query.
	596
	597	if ($hasnumeric) $val = $rs->fields[$i];
	598	else if (isset($rs->fields[$upperfname])) $val = $rs->fields[$upperfname];
	599	else if (isset($rs->fields[$field->name])) $val = $rs->fields[$field->name];
	600	else if (isset($rs->fields[strtolower($upperfname)])) $val = $rs->fields[strtolower($upperfname)];
	601	else $val = '';
	602
	603
	604	if ($forceUpdate \|\| strcmp($val, $arrFields[$upperfname])) {
	605	// Set the counter for the number of fields that will be updated.
	606	$fieldUpdatedCount++;
	607
	608	// Based on the datatype of the field
	609	// Format the value properly for the database
	610	$type = $rs->MetaType($field->type);
	611
	612
	613	if ($type == 'null') {
	614	$type = 'C';
	615	}
	616
	617	if ((strpos($upperfname,' ') !== false) \|\| ($ADODB_QUOTE_FIELDNAMES))
	618	$fnameq = $zthis->nameQuote.$upperfname.$zthis->nameQuote;
	619	else
	620	$fnameq = $upperfname;
	621
	622
	623	// is_null requires php 4.0.4
	624	//********************************************************//
	625	if (is_null($arrFields[$upperfname])
	626	\|\| (empty($arrFields[$upperfname]) && strlen($arrFields[$upperfname]) == 0)
	627	\|\| $arrFields[$upperfname] === $zthis->null2null
	628	)
	629	{
	630	switch ($force) {
	631
	632	//case 0:
	633	// //Ignore empty values. This is allready handled in "adodb_key_exists" function.
	634	//break;
	635
	636	case 1:
	637	//Set null
	638	$setFields .= $field->name . " = null, ";
	639	break;
	640
	641	case 2:
	642	//Set empty
	643	$arrFields[$upperfname] = "";
	644	$setFields .= _adodb_column_sql($zthis, 'U', $type, $upperfname, $fnameq,$arrFields, $magicq);
	645	break;
	646	default:
	647	case 3:
	648	//Set the value that was given in array, so you can give both null and empty values
	649	if (is_null($arrFields[$upperfname]) \|\| $arrFields[$upperfname] === $zthis->null2null) {
	650	$setFields .= $field->name . " = null, ";
	651	} else {
	652	$setFields .= _adodb_column_sql($zthis, 'U', $type, $upperfname, $fnameq,$arrFields, $magicq);
	653	}
	654	break;
	655	}
	656	//********************************************************//
	657	} else {
	658	//we do this so each driver can customize the sql for
	659	//DB specific column types.
	660	//Oracle needs BLOB types to be handled with a returning clause
	661	//postgres has special needs as well
	662	$setFields .= _adodb_column_sql($zthis, 'U', $type, $upperfname, $fnameq,
	663	$arrFields, $magicq);
	664	}
	665	}
	666	}
	667	}
	668
	669	// If there were any modified fields then build the rest of the update query.
	670	if ($fieldUpdatedCount > 0 \|\| $forceUpdate) {
	671	// Get the table name from the existing query.
	672	if (!empty($rs->tableName)) $tableName = $rs->tableName;
	673	else {
	674	preg_match("/FROM\s+".ADODB_TABLE_REGEX."/is", $rs->sql, $tableName);
	675	$tableName = $tableName[1];
	676	}
	677	// Get the full where clause excluding the word "WHERE" from
	678	// the existing query.
	679	preg_match('/\sWHERE\s(.*)/is', $rs->sql, $whereClause);
	680
	681	$discard = false;
	682	// not a good hack, improvements?
	683	if ($whereClause) {
	684	#var_dump($whereClause);
	685	if (preg_match('/\s(ORDER\s.*)/is', $whereClause[1], $discard));
	686	else if (preg_match('/\s(LIMIT\s.*)/is', $whereClause[1], $discard));
	687	else if (preg_match('/\s(FOR UPDATE.*)/is', $whereClause[1], $discard));
	688	else preg_match('/\s.(\) WHERE .)/is', $whereClause[1], $discard); # see http://sourceforge.net/tracker/index.php?func=detail&aid=1379638&group_id=42718&atid=433976
	689	} else
	690	$whereClause = array(false,false);
	691
	692	if ($discard)
	693	$whereClause[1] = substr($whereClause[1], 0, strlen($whereClause[1]) - strlen($discard[1]));
	694
	695	$sql = 'UPDATE '.$tableName.' SET '.substr($setFields, 0, -2);
	696	if (strlen($whereClause[1]) > 0)
	697	$sql .= ' WHERE '.$whereClause[1];
	698
	699	return $sql;
	700
	701	} else {
	702	return false;
	703	}
	704	}
	705
	706	function adodb_key_exists($key, &$arr,$force=2)
	707	{
	708	if ($force<=0) {
	709	// the following is the old behaviour where null or empty fields are ignored
	710	return (!empty($arr[$key])) \|\| (isset($arr[$key]) && strlen($arr[$key])>0);
	711	}
	712
	713	if (isset($arr[$key])) return true;
	714	## null check below
	715	if (ADODB_PHPVER >= 0x4010) return array_key_exists($key,$arr);
	716	return false;
	717	}
	718
	719	/**
	720	* There is a special case of this function for the oci8 driver.
	721	* The proper way to handle an insert w/ a blob in oracle requires
	722	* a returning clause with bind variables and a descriptor blob.
	723	*
	724	*
	725	*/
	726	function _adodb_getinsertsql(&$zthis,&$rs,$arrFields,$magicq=false,$force=2)
	727	{
	728	static $cacheRS = false;
	729	static $cacheSig = 0;
	730	static $cacheCols;
	731	global $ADODB_QUOTE_FIELDNAMES;
	732
	733	$tableName = '';
	734	$values = '';
	735	$fields = '';
	736	$recordSet = null;
	737	$arrFields = _array_change_key_case($arrFields);
	738	$fieldInsertedCount = 0;
	739
	740	if (is_string($rs)) {
	741	//ok we have a table name
	742	//try and get the column info ourself.
	743	$tableName = $rs;
	744
	745	//we need an object for the recordSet
	746	//because we have to call MetaType.
	747	//php can't do a $rsclass::MetaType()
	748	$rsclass = $zthis->rsPrefix.$zthis->databaseType;
	749	$recordSet = new $rsclass(-1,$zthis->fetchMode);
	750	$recordSet->connection = &$zthis;
	751
	752	if (is_string($cacheRS) && $cacheRS == $rs) {
	753	$columns =& $cacheCols;
	754	} else {
	755	$columns = $zthis->MetaColumns( $tableName );
	756	$cacheRS = $tableName;
	757	$cacheCols = $columns;
	758	}
	759	} else if (is_subclass_of($rs, 'adorecordset')) {
	760	if (isset($rs->insertSig) && is_integer($cacheRS) && $cacheRS == $rs->insertSig) {
	761	$columns =& $cacheCols;
	762	} else {
	763	for ($i=0, $max=$rs->FieldCount(); $i < $max; $i++)
	764	$columns[] = $rs->FetchField($i);
	765	$cacheRS = $cacheSig;
	766	$cacheCols = $columns;
	767	$rs->insertSig = $cacheSig++;
	768	}
	769	$recordSet =& $rs;
	770
	771	} else {
	772	printf(ADODB_BAD_RS,'GetInsertSQL');
	773	return false;
	774	}
	775
	776	// Loop through all of the fields in the recordset
	777	foreach( $columns as $field ) {
	778	$upperfname = strtoupper($field->name);
	779	if (adodb_key_exists($upperfname,$arrFields,$force)) {
	780	$bad = false;
	781	if ((strpos($upperfname,' ') !== false) \|\| ($ADODB_QUOTE_FIELDNAMES))
	782	$fnameq = $zthis->nameQuote.$upperfname.$zthis->nameQuote;
	783	else
	784	$fnameq = $upperfname;
	785
	786	$type = $recordSet->MetaType($field->type);
	787
	788	/********************************************************/
	789	if (is_null($arrFields[$upperfname])
	790	\|\| (empty($arrFields[$upperfname]) && strlen($arrFields[$upperfname]) == 0)
	791	\|\| $arrFields[$upperfname] === $zthis->null2null
	792	)
	793	{
	794	switch ($force) {
	795
	796	case 0: // we must always set null if missing
	797	$bad = true;
	798	break;
	799
	800	case 1:
	801	$values .= "null, ";
	802	break;
	803
	804	case 2:
	805	//Set empty
	806	$arrFields[$upperfname] = "";
	807	$values .= _adodb_column_sql($zthis, 'I', $type, $upperfname, $fnameq,$arrFields, $magicq);
	808	break;
	809
	810	default:
	811	case 3:
	812	//Set the value that was given in array, so you can give both null and empty values
	813	if (is_null($arrFields[$upperfname]) \|\| $arrFields[$upperfname] === $zthis->null2null) {
	814	$values .= "null, ";
	815	} else {
	816	$values .= _adodb_column_sql($zthis, 'I', $type, $upperfname, $fnameq, $arrFields, $magicq);
	817	}
	818	break;
	819	} // switch
	820
	821	/*********************************************************/
	822	} else {
	823	//we do this so each driver can customize the sql for
	824	//DB specific column types.
	825	//Oracle needs BLOB types to be handled with a returning clause
	826	//postgres has special needs as well
	827	$values .= _adodb_column_sql($zthis, 'I', $type, $upperfname, $fnameq,
	828	$arrFields, $magicq);
	829	}
	830
	831	if ($bad) continue;
	832	// Set the counter for the number of fields that will be inserted.
	833	$fieldInsertedCount++;
	834
	835
	836	// Get the name of the fields to insert
	837	$fields .= $fnameq . ", ";
	838	}
	839	}
	840
	841
	842	// If there were any inserted fields then build the rest of the insert query.
	843	if ($fieldInsertedCount <= 0) return false;
	844
	845	// Get the table name from the existing query.
	846	if (!$tableName) {
	847	if (!empty($rs->tableName)) $tableName = $rs->tableName;
	848	else if (preg_match("/FROM\s+".ADODB_TABLE_REGEX."/is", $rs->sql, $tableName))
	849	$tableName = $tableName[1];
	850	else
	851	return false;
	852	}
	853
	854	// Strip off the comma and space on the end of both the fields
	855	// and their values.
	856	$fields = substr($fields, 0, -2);
	857	$values = substr($values, 0, -2);
	858
	859	// Append the fields and their values to the insert query.
	860	return 'INSERT INTO '.$tableName.' ( '.$fields.' ) VALUES ( '.$values.' )';
	861	}
	862
	863
	864	/**
	865	* This private method is used to help construct
	866	* the update/sql which is generated by GetInsertSQL and GetUpdateSQL.
	867	* It handles the string construction of 1 column -> sql string based on
	868	* the column type. We want to do 'safe' handling of BLOBs
	869	*
	870	* @param string the type of sql we are trying to create
	871	* 'I' or 'U'.
	872	* @param string column data type from the db::MetaType() method
	873	* @param string the column name
	874	* @param array the column value
	875	*
	876	* @return string
	877	*
	878	*/
	879	function _adodb_column_sql_oci8(&$zthis,$action, $type, $fname, $fnameq, $arrFields, $magicq)
	880	{
	881	$sql = '';
	882
	883	// Based on the datatype of the field
	884	// Format the value properly for the database
	885	switch($type) {
	886	case 'B':
	887	//in order to handle Blobs correctly, we need
	888	//to do some magic for Oracle
	889
	890	//we need to create a new descriptor to handle
	891	//this properly
	892	if (!empty($zthis->hasReturningInto)) {
	893	if ($action == 'I') {
	894	$sql = 'empty_blob(), ';
	895	} else {
	896	$sql = $fnameq. '=empty_blob(), ';
	897	}
	898	//add the variable to the returning clause array
	899	//so the user can build this later in
	900	//case they want to add more to it
	901	$zthis->_returningArray[$fname] = ':xx'.$fname.'xx';
	902	} else if (empty($arrFields[$fname])){
	903	if ($action == 'I') {
	904	$sql = 'empty_blob(), ';
	905	} else {
	906	$sql = $fnameq. '=empty_blob(), ';
	907	}
	908	} else {
	909	//this is to maintain compatibility
	910	//with older adodb versions.
	911	$sql = _adodb_column_sql($zthis, $action, $type, $fname, $fnameq, $arrFields, $magicq,false);
	912	}
	913	break;
	914
	915	case "X":
	916	//we need to do some more magic here for long variables
	917	//to handle these correctly in oracle.
	918
	919	//create a safe bind var name
	920	//to avoid conflicts w/ dupes.
	921	if (!empty($zthis->hasReturningInto)) {
	922	if ($action == 'I') {
	923	$sql = ':xx'.$fname.'xx, ';
	924	} else {
	925	$sql = $fnameq.'=:xx'.$fname.'xx, ';
	926	}
	927	//add the variable to the returning clause array
	928	//so the user can build this later in
	929	//case they want to add more to it
	930	$zthis->_returningArray[$fname] = ':xx'.$fname.'xx';
	931	} else {
	932	//this is to maintain compatibility
	933	//with older adodb versions.
	934	$sql = _adodb_column_sql($zthis, $action, $type, $fname, $fnameq, $arrFields, $magicq,false);
	935	}
	936	break;
	937
	938	default:
	939	$sql = _adodb_column_sql($zthis, $action, $type, $fname, $fnameq, $arrFields, $magicq,false);
	940	break;
	941	}
	942
	943	return $sql;
	944	}
	945
	946	function _adodb_column_sql(&$zthis, $action, $type, $fname, $fnameq, $arrFields, $magicq, $recurse=true)
	947	{
	948
	949	if ($recurse) {
	950	switch($zthis->dataProvider) {
	951	case 'postgres':
	952	if ($type == 'L') $type = 'C';
	953	break;
	954	case 'oci8':
	955	return _adodb_column_sql_oci8($zthis, $action, $type, $fname, $fnameq, $arrFields, $magicq);
	956
	957	}
	958	}
	959
	960	switch($type) {
	961	case "C":
	962	case "X":
	963	case 'B':
	964	$val = $zthis->qstr($arrFields[$fname],$magicq);
	965	break;
	966
	967	case "D":
	968	$val = $zthis->DBDate($arrFields[$fname]);
	969	break;
	970
	971	case "T":
	972	$val = $zthis->DBTimeStamp($arrFields[$fname]);
	973	break;
	974
	975	default:
	976	$val = $arrFields[$fname];
	977	if (empty($val)) $val = '0';
	978	break;
	979	}
	980
	981	if ($action == 'I') return $val . ", ";
	982
	983
	984	return $fnameq . "=" . $val . ", ";
	985
	986	}
	987
	988
	989
	990	function _adodb_debug_execute(&$zthis, $sql, $inputarr)
	991	{
	992	$ss = '';
	993	if ($inputarr) {
	994	foreach($inputarr as $kk=>$vv) {
	995	if (is_string($vv) && strlen($vv)>64) $vv = substr($vv,0,64).'...';
	996	$ss .= "($kk=>'$vv') ";
	997	}
	998	$ss = "[ $ss ]";
	999	}
	1000	$sqlTxt = is_array($sql) ? $sql[0] : $sql;
	1001	/*str_replace(', ','##1#__^LF',is_array($sql) ? $sql[0] : $sql);
	1002	$sqlTxt = str_replace(',',', ',$sqlTxt);
	1003	$sqlTxt = str_replace('##1#__^LF', ', ' ,$sqlTxt);
	1004	*/
	1005	// check if running from browser or command-line
	1006	$inBrowser = isset($_SERVER['HTTP_USER_AGENT']);
	1007
	1008	$dbt = $zthis->databaseType;
	1009	if (isset($zthis->dsnType)) $dbt .= '-'.$zthis->dsnType;
	1010	if ($inBrowser) {
	1011	if ($ss) {
	1012	$ss = '<code>'.htmlspecialchars($ss).'</code>';
	1013	}
	1014	if ($zthis->debug === -1)
	1015	ADOConnection::outp( "<br />\n($dbt): ".htmlspecialchars($sqlTxt)."   $ss\n<br />\n",false);
	1016	else
	1017	ADOConnection::outp( "<hr />\n($dbt): ".htmlspecialchars($sqlTxt)."   $ss\n<hr />\n",false);
	1018	} else {
	1019	ADOConnection::outp("-----\n($dbt): ".$sqlTxt."\n-----\n",false);
	1020	}
	1021
	1022	$qID = $zthis->_query($sql,$inputarr);
	1023
	1024	/*
	1025	Alexios Fakios notes that ErrorMsg() must be called before ErrorNo() for mssql
	1026	because ErrorNo() calls Execute('SELECT @ERROR'), causing recursion
	1027	*/
	1028	if ($zthis->databaseType == 'mssql') {
	1029	// ErrorNo is a slow function call in mssql, and not reliable in PHP 4.0.6
	1030	if($emsg = $zthis->ErrorMsg()) {
	1031	if ($err = $zthis->ErrorNo()) ADOConnection::outp($err.': '.$emsg);
	1032	}
	1033	} else if (!$qID) {
	1034	ADOConnection::outp($zthis->ErrorNo() .': '. $zthis->ErrorMsg());
	1035	}
	1036
	1037	if ($zthis->debug === 99) _adodb_backtrace(true,9999,2);
	1038	return $qID;
	1039	}
	1040
	1041	# pretty print the debug_backtrace function
	1042	function _adodb_backtrace($printOrArr=true,$levels=9999,$skippy=0)
	1043	{
	1044	if (!function_exists('debug_backtrace')) return '';
	1045
	1046	$html = (isset($_SERVER['HTTP_USER_AGENT']));
	1047	$fmt = ($html) ? "</font><font color=#808080 size=-1> %% line %4d, file: <a href=\"file:/%s\">%s</a></font>" : "%% line %4d, file: %s";
	1048
	1049	$MAXSTRLEN = 128;
	1050
	1051	$s = ($html) ? '<pre align=left>' : '';
	1052
	1053	if (is_array($printOrArr)) $traceArr = $printOrArr;
	1054	else $traceArr = debug_backtrace();
	1055	array_shift($traceArr);
	1056	array_shift($traceArr);
	1057	$tabs = sizeof($traceArr)-2;
	1058
	1059	foreach ($traceArr as $arr) {
	1060	if ($skippy) {$skippy -= 1; continue;}
	1061	$levels -= 1;
	1062	if ($levels < 0) break;
	1063
	1064	$args = array();
	1065	for ($i=0; $i < $tabs; $i++) $s .= ($html) ? '   ' : "\t";
	1066	$tabs -= 1;
	1067	if ($html) $s .= '<font face="Courier New,Courier">';
	1068	if (isset($arr['class'])) $s .= $arr['class'].'.';
	1069	if (isset($arr['args']))
	1070	foreach($arr['args'] as $v) {
	1071	if (is_null($v)) $args[] = 'null';
	1072	else if (is_array($v)) $args[] = 'Array['.sizeof($v).']';
	1073	else if (is_object($v)) $args[] = 'Object:'.get_class($v);
	1074	else if (is_bool($v)) $args[] = $v ? 'true' : 'false';
	1075	else {
	1076	$v = (string) @$v;
	1077	$str = htmlspecialchars(substr($v,0,$MAXSTRLEN));
	1078	if (strlen($v) > $MAXSTRLEN) $str .= '...';
	1079	$args[] = $str;
	1080	}
	1081	}
	1082	$s .= $arr['function'].'('.implode(', ',$args).')';
	1083
	1084
	1085	$s .= @sprintf($fmt, $arr['line'],$arr['file'],basename($arr['file']));
	1086
	1087	$s .= "\n";
	1088	}
	1089	if ($html) $s .= '</pre>';
	1090	if ($printOrArr) print $s;
	1091
	1092	return $s;
	1093	}
	1094	/*
	1095	function _adodb_find_from($sql)
	1096	{
	1097
	1098	$sql = str_replace(array("\n","\r"), ' ', $sql);
	1099	$charCount = strlen($sql);
	1100
	1101	$inString = false;
	1102	$quote = '';
	1103	$parentheseCount = 0;
	1104	$prevChars = '';
	1105	$nextChars = '';
	1106
	1107
	1108	for($i = 0; $i < $charCount; $i++) {
	1109
	1110	$char = substr($sql,$i,1);
	1111	$prevChars = substr($sql,0,$i);
	1112	$nextChars = substr($sql,$i+1);
	1113
	1114	if((($char == "'" \|\| $char == '"' \|\| $char == '`') && substr($prevChars,-1,1) != '\\') && $inString === false) {
	1115	$quote = $char;
	1116	$inString = true;
	1117	}
	1118
	1119	elseif((($char == "'" \|\| $char == '"' \|\| $char == '`') && substr($prevChars,-1,1) != '\\') && $inString === true && $quote == $char) {
	1120	$quote = "";
	1121	$inString = false;
	1122	}
	1123
	1124	elseif($char == "(" && $inString === false)
	1125	$parentheseCount++;
	1126
	1127	elseif($char == ")" && $inString === false && $parentheseCount > 0)
	1128	$parentheseCount--;
	1129
	1130	elseif($parentheseCount <= 0 && $inString === false && $char == " " && strtoupper(substr($prevChars,-5,5)) == " FROM")
	1131	return $i;
	1132
	1133	}
	1134	}
	1135	*/
	1136
	1137	?>

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

Download in other formats: