File: biblio_mysql.inc.php

<?php

////////////////////////////////////////////////////////////////////////////////////////////////////////////
// FILENAME:    Biblio_mysql.inc.php                                                                      //
// LANGUAGE:    PHP                                                                                       //
// AUTHOR:      Penseur.martien                                                                           //
// EMAIL:       penseur.martien<nospam>@@ifrance.com                                                      //
// VERSION:     1.45                                                                                      //
// CREATION:    05/11/2003                                                                                //
////////////////////////////////////////////////////////////////////////////////////////////////////////////

////////////////////////////////////////////////////////////////////////////////////////////////////////////
// History:                                                                                               //
// --------                                                                                               //
//  Date        Version   Actions                                                                         //
// ------------------------------------------------------------------------------------------------------ //
//  05/11/2003  1.0       Tested & Final version                                                          //
//  05/11/2003  1.01      Delete the need of parametre_base                                               //
//  06/11/2003  1.1       Error message of mysql connection changed                                       //
//  11/11/2003  1.2       mysql_next_index: deleting search of hole in index serie                        //
//                        Now returning max(index)+1                                                      //
//  29/11/2003  1.3       in mysql_insert, if count(liste_champs)==count(liste_value)+1,                  //
//                        assuming to find the value of the first field                                   //
//                        by calling mysql_next_index                                                     //
//  05/12/2003  1.4       now mysql_select call mysqlrawquery with the good sql                           //
//              1.45      save lasted db to prevent for reconnect to the same db                          //
//                        in mysql_rawquery                                                               //
////////////////////////////////////////////////////////////////////////////////////////////////////////////

////////////////////////////////////////////////////////////////////////////////////////////////////////////
// Dependencies:                                                                                          //
// -------------                                                                                          //
// None                                                                                                   //
////////////////////////////////////////////////////////////////////////////////////////////////////////////

////////////////////////////////////////////////////////////////////////////////////////////////////////////
// What the functions does:                                                                               //
// ----------------------                                                                                 //
// Abstractions of SELECT, UPDATE, INSERT, DELETE MySQL queries                                           //
////////////////////////////////////////////////////////////////////////////////////////////////////////////


////////////////////////////////////////////////////////////////////////////////////////////////////////////
// Declaration                                                                                            //
// -----------                                                                                            //
// mysql_select($db_base,$fields,$tables,$where="",$order_by="",$group_by="",$having="",$limit="")        //
// mysql_rawquery($db_base,$query)                                                                        //
// mysql_insert($db_base,$table,$liste_champs,$liste_valeur)                                              //
// mysql_update($db_base,$table,$liste_champs,$liste_valeur,$where)                                       //
// mysql_delete($db_base,$table,$where)                                                                   //
// mysql_next_index($db_base,$index,$table)                                                               //
// mysql_select_diff($db_base,$query_plus,$query_moins)                                                   //
// mysql_select_value($db_base,$query,default="")                                                         //
////////////////////////////////////////////////////////////////////////////////////////////////////////////

// save of the last db connected
$db_last="";
	
	/**
	 * mysql_rawquery()   : make a mysql query
	 * 
	 * @param $db_base		: database to access
	 * @param $query			: query to launch
	 * @return 
	 */
	function mysql_rawquery($db_base,$query) {
		global $db_host,$db_user,$db_password,$db_last;
		if ($db_base!=$db_last) {
			mysql_connect($db_host[$db_base],$db_user[$db_base],$db_password[$db_base]) or die(mysql_error()." ".mysql_errno());
			mysql_select_db($db_base);
			$db_last=$db_base;
		}		
			  
		$db_result=@mysql_query($query) or die("Erreur n°".mysql_errno().": \""/*.mysql_error()*/."\" dans la requete: [".$query."]");
		if (strtoupper(substr($query,0,6))=="SELECT") { // have to process data to return because SELECT query
			$num_row=mysql_num_rows($db_result);
			for ($res=array(),$i=0;$i<$num_row;$i++)
					$res[$i]=mysql_fetch_assoc($db_result);
			return $res;
		}
	}
	
	/**
	 * mysql_select()     : make a mysql select
	 * 
	 * @param $db_base    : database to access
	 * @param $fields     : list of field to select
	 * @param $tables     : list names of the tables
	 * @param $where      : where condition
	 * @param $order_by   : fields to be ordered by
	 * @param $group_by   : fields to be groupered by
	 * @param $having     : having condition
	 * @param $limit      : limit clause
	 * @return 
	 */
	function mysql_select($db_base,$fields,$tables,$where="",$order_by="",$group_by="",$having="",$limit="") {
		$sql="SELECT $fields FROM $tables ";
		if (!empty($where)) $sql.="WHERE $where ";  
		if (!empty($group_by)) $sql.="GROUP BY $group_by ";  
		if (!empty($order_by)) $sql.="ORDER BY $order_by ";  
		if (!empty($having)) $sql.="HAVING $having ";  
		if (!empty($limit)) $sql.="LIMIT $limit ";
		return msyql_rawquery($db_base,$sql);
	}
	
	/**
	 * mysql_insert()				: make a mysql insert
	 * 
	 * @param $table				: name of the table
	 * @param $liste_champs : array of the field to insert
	 * @param $liste_valeur	: array of the valued of the field to insert
	 * @return 
	 */
	function mysql_insert($db_base,$table,$liste_champs,$liste_valeur) {
		$sql="INSERT INTO `$table` ";
		if (count($liste_champs)==count($liste_valeur)+1) // have to find next_id and insert in $liste_valeur
			array_unshift($liste_valeur,mysql_next_index($db_base,$liste_champs[0],$table));
		$temp1=implode("`,`",$liste_champs);
		$temp2=implode("','",$liste_valeur);
		$sql.="(`$temp1`) VALUES ('$temp2')";
		mysql_rawquery($db_base,$sql);
	}

	/**
	 * mysql_update()				: make a mysql update
	 * 
	 * @param $table				: name of the table
	 * @param $liste_champs	: array of the field to update
	 * @param $liste_valeur	: array of the valued of the field to update
	 * @param $where				: where condition
	 * @return 
	 */
	function mysql_update($db_base,$table,$liste_champs,$liste_valeur,$where) {
		if ($where!="") {
			$sql="UPDATE `$table` SET ";
			for ($i=0;$i<count($liste_champs);$i++)
				$sql.="`".$liste_champs[$i]."`='".$liste_valeur[$i]."'".(($i==count($liste_champs)-1)?"":" , ");
			$sql.=" WHERE ($where)";
			mysql_rawquery($db_base,$sql);
		}
	}
		
	/**
	 * mysql_delete()			: make a mysql delete
	 * 
	 * @param $db_base		: database to access
	 * @param $table			: name of the table
	 * @param $where			: where condition
	 * @return 
	 */
	function mysql_delete($db_base,$table,$where) {
		if ($where!="") {
			$sql="DELETE FROM `$table` WHERE ($where)";
			mysql_rawquery($db_base,$sql);
		}
	}
	
	
	/**
	 * mysql_next_index()	: find the most free little index of the table
	 * 
	 * @param $db_base		: database to access
	 * @param $index			: the name of the index column
	 * @param $table			: name of the table
	 * @return 
	 */
	function mysql_next_index($db_base,$index,$table) {
		$tab=mysql_rawquery($db_base,"SELECT $index FROM $table ORDER BY $index DESC LIMIT 0,1");
		//print_r($tab);
		if (count($tab)==0)
			return 0;
		else
			return $tab[0][$index]+1;
/*			if (count($tab)==$tab[count($tab)-1][$index]+1)
				return count($tab);
			else // pour l'instant recherche lineaire, ensuite voir une recherche dichotomique
				for ($i=0;true;$i++)
					if (($i!=$tab[$i][$index])&&($tab[$i][$index]!=-1))
						return $i;*/
	}
	
	/**
	 * mysql_select_diff()	: make a select a,b,c,d from table1 where (a not in select a from table2 where ())and/or()
	 * 
	 * @param $db_base			: database to access
	 * @param $query_plus		: select of the lines we want
	 * @param $query_moins: !! select of the lines we don't want (!! 1 column only)
	 * @return
	 * 
	 */
	function mysql_select_diff($db_base,$query_plus,$query_moins) {
		//echo $query_plus,"<br>",$query_moins,"<br>\n";
		$tab_plus=mysql_rawquery($db_base,$query_plus);
		if ($query_moins!="") {
			$tab_moins=mysql_rawquery($db_base,$query_moins);
			if (count($tab_moins)>0) {	
				$keys1=array_keys($tab_plus[0]);
				$keys2=array_keys($tab_moins[0]);
				for ($i=0,$res=array();$i<count($tab_plus);$i++) {
					for ($j=0,$find=false;$j<count($tab_moins);$j++)
						if ($tab_moins[$j][$keys2[0]]==$tab_plus[$i][$keys1[0]])
							$find=true;
					if (!$find)
						$res[]=$tab_plus[$i];
				}
				return $res;
			}
			else
				return $tab_plus;
		}
		else
			return $tab_plus;
	}
	
	/**
	 * mysql_select_value()
	 * 
	 * @param $db_base		: database to access
	 * @param $query: la requete avec seuleument 1 colonne selectionnée!!
	 * @param $default: default value to return if query return null result
	 * @return la valeur retournée en ligne 0 de la requete.
	 */
	function mysql_select_value($db_base,$query,$default="") {
		$tab=mysql_rawquery($db_base,$query." LIMIT 0,1");
		if (count($tab)==1) {
			$keys=array_keys($tab[0]);	
			return $tab[0][$keys[0]];
		}
		else
			return $default;
	}

?>