| gère un set contenant les notices contenues |--------->| |--------------------------| | | dans des paniers de notices | | | gère un cache de valeurs | | '---------------------------------------------' | '--------------------------' | | hérite de ^ | .---------------------------------------------. | | | | connector_out_set_explcaddie | | | | |---------------------------------------------| | .-------------------------------. |-------------->| gère un set contenant les notices contenues |--------->| | connector_out_setcache_notice | | | dans des paniers d'exemplaires | | |-------------------------------| | '---------------------------------------------' | | gère un cache d'une | | | | liste de notices | | .------------------------------------------------. | '-------------------------------' | | connector_out_set_emprcaddie | | | |------------------------------------------------| | |-------------->| gère un set contenant les emprunteurs contenus |------>| | | dans des paniers d'emprunteurs | | | '------------------------------------------------' | | | **************************************** | .---------------------------------------------------. | * function:new_connector_out_set_typed * | | connector_out_set_noticemulticritere | | **************************************** | |---------------------------------------------------| | * instantie la bonne classe d'un *----------------------->| gère un set contenant les notices contenues |----' * set selon son id * instantie au | dans les résultats d'une recherche multi-critères | **************************************** choix '---------------------------------------------------' | .................................. | . external_services_searchcache . | .................................. | . effectue des recherches et les .<-----' . met en cache . utilise .................................. ==================================================================================================================================== */ require_once ($class_path."/caddie.class.php"); require_once ($class_path."/empr_caddie.class.php"); require_once ($class_path."/search.class.php"); require_once ($class_path."/external_services_searchcache.class.php"); require_once ($class_path."/search_perso.class.php"); require_once ($class_path."/equation.class.php"); require_once($include_path."/connecteurs_out_common.inc.php"); $connector_out_set_types = array( 1, //Paniers de notices 2, //Recherche multi-critères de notices 3, //Paniers d'exemplaires 4 //Paniers de lecteurs ); $connector_out_set_types_msgs = array( 1 => "connector_out_set_types_msg_1", 2 => "connector_out_set_types_msg_2", 3 => "connector_out_set_types_msg_3", 4 => "connector_out_set_types_msg_4" ); $connector_out_set_types_classes = array( 1 => "connector_out_set_noticecaddie", 2 => "connector_out_set_noticemulticritere", 3 => "connector_out_set_explcaddie", 4 => "connector_out_set_emprcaddie" ); class connector_out_set { var $id=0; var $caption=""; var $type=0; var $config=array(); var $cache=NULL; var $error=""; function connector_out_set($id, $nocache=false) { //nocache permet de ne pas instancier le cache, si une classe fille veut le faire d'elle même global $dbh; $id+=0; $sql = "SELECT * FROM connectors_out_sets WHERE connector_out_set_id = ".$id; $row = mysql_fetch_assoc(mysql_query($sql, $dbh)); $this->id = $row["connector_out_set_id"]; $this->caption = $row["connector_out_set_caption"]; $this->type = $row["connector_out_set_type"]; $this->config = unserialize($row["connector_out_set_config"]); $this->config = stripslashes_array($this->config); if (!$nocache) $this->cache = new connector_out_setcache($id); } static function caption_exists($caption) { global $dbh; $sql = "SELECT connector_out_set_id FROM connectors_out_sets WHERE connector_out_set_caption = '".addslashes($caption)."'"; $res = mysql_query($sql, $dbh); return mysql_num_rows($res) > 0 ? mysql_result($res, 0, 0) : 0; } static function add_new() { global $dbh; $sql = "INSERT INTO connectors_out_sets () VALUES ()"; $res = mysql_query($sql, $dbh); $new_set_id = mysql_insert_id($dbh); $cache = connector_out_setcache::add($new_set_id); return new connector_out_set($new_set_id); } function commit_to_db() { global $dbh; //on oublie pas que includes/global_vars.inc.php s'amuse à tout addslasher tout seul donc on le fait pas ici $this->type+=0; $this->config = addslashes_array($this->config); $serialized = serialize($this->config); $sql = "UPDATE connectors_out_sets SET connector_out_set_caption = '".addslashes($this->caption)."', connector_out_set_type = ".$this->type.", connector_out_set_config = '".addslashes($serialized)."' WHERE connector_out_set_id = ".$this->id.""; mysql_query($sql, $dbh); } function delete() { global $dbh; //Deletons le set $sql = "DELETE FROM connectors_out_sets WHERE connector_out_set_id = ".$this->id; mysql_query($sql, $dbh); } function get_config_form(&$out_of_form_result) { //$out_of_form_result: résultat à renvoyer qui devra être placé à l'extérieur du formulaire. Exemple: un autre formulaire. //rien return ""; } function update_config_from_form() { //rien return; } function get_third_column_info() { //rien return ""; } function update_if_expired() { if ($this->cache->is_cache_expired()) $this->update_cache(); } function update_cache() { //rien return ""; } function clear_cache($also_clear_date=false) { $this->cache->clear($also_clear_date); } function get_values($first=false, $count=false) { return $this->cache->get_values($first, $count); } function get_value_count() { return $this->cache->get_value_count(); } } //Set correspondant à des paniers de notices. class connector_out_set_noticecaddie extends connector_out_set { function connector_out_set_noticecaddie($id) { parent::connector_out_set($id, true); $this->cache = new connector_out_setcache_notice($id); } function get_config_form(&$out_of_form_result) { global $dbh, $msg, $charset; $config_form=""; $caddies=array(); $caddies_sql = "SELECT idcaddie FROM caddie WHERE type = 'NOTI'"; $caddies_res = mysql_query($caddies_sql, $dbh); while($row=mysql_fetch_assoc($caddies_res)) { $acaddie = new caddie($row["idcaddie"]); $caddies[] = $acaddie; } $config_form .= '
config["include_full_base"] ? 'checked' : '').' onclick="document.getElementById(\'set_included_caddies\').disabled=document.getElementById(\'set_includefullbase\').checked" id="set_includefullbase">
'; $config_form .= '

'; if (!isset($this->config["included_caddies"])) $this->config["included_caddies"]=array(); if (!isset($this->config["include_full_base"])) $this->config["include_full_base"] = false; $config_form .= '

'; $config_form .= ''; $config_form .= '
'; return $config_form; } function update_config_from_form() { global $set_included_caddies, $set_includefullbase; if (!is_array($set_included_caddies)) $set_included_caddies=array($set_included_caddies); array_walk($set_included_caddies, create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $this->config["included_caddies"] = !$this->config["include_full_base"] ? $set_included_caddies : array(); $this->config["include_full_base"] = isset($set_includefullbase); return; } function get_third_column_info() { global $msg; if (isset($this->config["include_full_base"]) && $this->config["include_full_base"]) return sprintf($msg["admin_connecteurs_set_noticecaddie_includedcount_fullbase"], $this->cache->get_value_count()); else return sprintf($msg["admin_connecteurs_set_noticecaddie_includedcount"], count($this->config["included_caddies"]), $this->cache->get_value_count()); } function update_cache() { global $dbh; //Valeurs par défault if (!isset($this->config["included_caddies"])) $this->config["included_caddies"]=array(); if (!isset($this->config["include_full_base"])) $this->config["include_full_base"] = false; //On remplit if ($this->config["include_full_base"]) { $sql = "SELECT ".$this->cache->id.", notice_id FROM notices"; } else { array_walk($this->config["included_caddies"], create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $sql = "SELECT ".$this->cache->id.", object_id FROM caddie_content WHERE caddie_id IN (".implode(",", $this->config["included_caddies"]).")"; } $this->cache->updatedb_from_sqlselect($sql); } static function get_notice_setlist($notice_id) { global $dbh; $sql = "SELECT connectors_out_setcache_setnum FROM connectors_out_setcache_values LEFT JOIN connectors_out_setcaches ON (connectors_out_setcache_id =connectors_out_setcache_values_cachenum) WHERE connectors_out_setcache_values_value = ".$notice_id; $res = mysql_query($sql, $dbh); $results = array(); while($row=mysql_fetch_assoc($res)) $results[] = $row["connectors_out_setcache_setnum"]; return $results; } function get_values($first=false, $count=false, $datefrom=false, $dateuntil=false) { return $this->cache->get_values($first, $count, $datefrom, $dateuntil); } function get_value_count($datefrom=false, $dateuntil=false) { return $this->cache->get_value_count($datefrom, $dateuntil); } //Fonction qui renvoie la date de modification la plus vieille (pour l'oai) function get_earliest_updatedate() { global $dbh; return $this->cache->get_earliest_updatedate(); } } //Set correspondant à des paniers d'exemplaires. class connector_out_set_noticemulticritere extends connector_out_set { function connector_out_set_noticemulticritere($id) { parent::connector_out_set($id, true); $this->cache = new connector_out_setcache_notice($id); } function get_config_form(&$out_of_form_result) { global $dbh, $msg, $charset; $config_form=""; if (!isset($this->config["search"])) $this->config["search"] = ""; $serialized_search = $this->config["search"]; if ($serialized_search) { $sc = new search(false); $sc->unserialize_search($serialized_search); $human_query = $sc->make_human_query(); } else $human_query = $msg["admin_connecteurs_set_multicritere_searchis_none"]; //Recherche humaine $button_modif_requete = ""; $config_form .= '

'; $config_form .= $human_query." ".$button_modif_requete; $config_form .= '

'; //Changer la recherche $config_form .= '

'; $config_form .= '
'; //Garder la recherche actuelle $config_form .= '
'; $config_form .= '
'; //Copier une équation DSI $sql = "SELECT id_equation, nom_equation FROM equations WHERE proprio_equation = 0"; $res = mysql_query($sql, $dbh); while($row=mysql_fetch_assoc($res)) { $config_form .= ': '.htmlentities($row["nom_equation"] ,ENT_QUOTES, $charset); $config_form .= '
'; } $config_form .= '
'; $config_form .= '
'; //Form caché de la recherche $form_modif_requete = $this->make_hidden_search_form($serialized_search); //Mettons le dans $out_of_form_result comme ça il sera placé en dehors du formulaire $out_of_form_result = $form_modif_requete; return $config_form; } function update_config_from_form() { global $search_updateaction; //Si on ne change rien, on ne change rien if (!$search_updateaction || $search_updateaction == 'none') return; if (preg_match("/dsieq_(\d+)/", $search_updateaction, $m)) { $dsi_eq_id = $m[1]; $equation = new equation($dsi_eq_id); $this->config["search"] = $equation->requete; $this->clear_cache(true); } return; } function get_third_column_info() { global $msg; global $msg; return sprintf($msg["admin_connecteurs_set_multicritere_includedcount"], $this->cache->get_value_count()); } function update_cache() { global $dbh; if (!isset($this->config["search"])) $this->config["search"] = ""; //On ne va pas chercher à effectuer une recherche vide if (!$this->config["search"]) return; //on marque le set comme en cours de rafraississement $query = "update connectors_out_sets set being_refreshed = 1 where connector_out_set_id = ".$this->id; mysql_query($query,$dbh); //Utilisons la classe de caches de recherche pour effectuer la recherche. $cache_duration = $this->cache->cache_duration_in_seconds(); $es_search_cache = new external_services_searchcache('search_fields', '', -1, -1, $cache_duration, 'conset', true); $es_search_cache->unserialize_search($this->config["search"]); $es_search_cache->update(); $values = $es_search_cache->get_results(0, $es_search_cache->get_result_count()); $this->cache->values = $values; $this->cache->commit_values_into_db(); //on marque le set comme en cours de rafraississement $query = "update connectors_out_sets set being_refreshed = 0 where connector_out_set_id = ".$this->id; mysql_query($query,$dbh); } static function get_notice_setlist($notice_id) { global $dbh; $sql = "SELECT connectors_out_setcache_setnum FROM connectors_out_setcache_values LEFT JOIN connectors_out_setcaches ON (connectors_out_setcache_id = connectors_out_setcache_values_cachenum) WHERE connectors_out_setcache_values_value = ".$notice_id; $res = mysql_query($sql, $dbh); $results = array(); while($row=mysql_fetch_assoc($res)) $results[] = $row["connectors_out_setcache_setnum"]; return $results; } function get_values($first=false, $count=false, $datefrom=false, $dateuntil=false) { return $this->cache->get_values($first, $count, $datefrom, $dateuntil); } function get_value_count($datefrom=false, $dateuntil=false) { return $this->cache->get_value_count($datefrom, $dateuntil); } //Fonction qui renvoie la date de modification la plus vieille (pour l'oai) function get_earliest_updatedate() { global $dbh; return $this->cache->get_earliest_updatedate(); } //copié et adapté de equation.class.php function make_hidden_search_form($serialized_search) { global $search; global $charset; global $page; $url = "./catalog.php?categ=search&mode=6" ; // remplir $search $sc = new search(false); $sc->unserialize_search($serialized_search); $r="
"; for ($i=0; $i"; $r.=""; $r.=""; for ($j=0; $j"; } reset($fieldvar); while (list($var_name,$var_value)=each($fieldvar)) { for ($j=0; $j"; } } } $r.=""; $r.=""; return $r; } } //Set correspondant à des paniers d'exemplaires. class connector_out_set_explcaddie extends connector_out_set { function get_config_form(&$out_of_form_result) { global $dbh, $msg, $charset; $config_form=""; $caddies=array(); $caddies_sql = "SELECT idcaddie FROM caddie WHERE type = 'EXPL'"; $caddies_res = mysql_query($caddies_sql, $dbh); while($row=mysql_fetch_assoc($caddies_res)) { $acaddie = new caddie($row["idcaddie"]); $caddies[] = $acaddie; } $config_form .= '
config["include_full_base"] ? 'checked' : '').' onclick="document.getElementById(\'set_included_caddies\').disabled=document.getElementById(\'set_includefullbase\').checked" id="set_includefullbase">
'; $config_form .= '
'; if (!isset($this->config["included_caddies"])) $this->config["included_caddies"]=array(); if (!isset($this->config["include_full_base"])) $this->config["include_full_base"] = false; $config_form .= '

'; $config_form .= ''; $config_form .= '
'; return $config_form; } function update_config_from_form() { global $set_included_caddies, $set_includefullbase; if (!is_array($set_included_caddies)) $set_included_caddies=array($set_included_caddies); array_walk($set_included_caddies, create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $this->config["included_caddies"] = !$this->config["include_full_base"] ? $set_included_caddies : array(); $this->config["include_full_base"] = isset($set_includefullbase); return; } function get_third_column_info() { global $msg; if (isset($this->config["include_full_base"]) && $this->config["include_full_base"]) return sprintf($msg["admin_connecteurs_set_explcaddie_includedcount_fullbase"], $this->cache->get_value_count()); else return sprintf($msg["admin_connecteurs_set_explcaddie_includedcount"], count($this->config["included_caddies"]), $this->cache->get_value_count()); } function update_cache() { global $dbh; //Valeurs par défault if (!isset($this->config["included_caddies"])) $this->config["included_caddies"]=array(); if (!isset($this->config["include_full_base"])) $this->config["include_full_base"] = false; //On remplit if ($this->config["include_full_base"]) { $sql = "SELECT ".$this->cache->id.", expl_id FROM exemplaires"; } else { array_walk($this->config["included_caddies"], create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $sql = "SELECT ".$this->cache->id.", object_id FROM caddie_content WHERE caddie_id IN (".implode(",", $this->config["included_caddies"]).")"; } $this->cache->updatedb_from_sqlselect($sql); } } //Set correspondant à des paniers d'emprunteurs. class connector_out_set_emprcaddie extends connector_out_set { function get_config_form(&$out_of_form_result) { global $dbh, $msg, $charset; $config_form=""; $caddies=array(); $caddies_sql = "SELECT idemprcaddie FROM empr_caddie"; $caddies_res = mysql_query($caddies_sql, $dbh); while($row=mysql_fetch_assoc($caddies_res)) { $acaddie = new empr_caddie($row["idemprcaddie"]); $caddies[] = $acaddie; } if (!isset($this->config["included_caddies"])) $this->config["included_caddies"]=array(); $config_form .= '

'; $config_form .= ''; $config_form .= '
'; return $config_form; } function update_config_from_form() { global $set_included_caddies; if (!is_array($set_included_caddies)) $set_included_caddies=array($set_included_caddies); array_walk($set_included_caddies, create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $this->config["included_caddies"] = $set_included_caddies; return; } function get_third_column_info() { global $msg; return sprintf($msg["admin_connecteurs_set_emprcaddie_includedcount"], count($this->config["included_caddies"]), $this->cache->get_value_count()); } function update_cache() { global $dbh; array_walk($this->config["included_caddies"], create_function('&$a', '$a+=0;'));//Soyons sûr de ne stocker que des entiers dans le tableau. $sql = "SELECT ".$this->cache->id.", object_id FROM empr_caddie_content WHERE empr_caddie_id IN (".implode(",", $this->config["included_caddies"]).")"; $this->cache->updatedb_from_sqlselect($sql); } } function new_connector_out_set_typed($id, $type=0) { global $dbh; global $connector_out_set_types_classes; if (!$type) { $sql = "SELECT connector_out_set_type FROM connectors_out_sets WHERE connector_out_set_id = ".($id+0); $type = mysql_result(mysql_query($sql, $dbh), 0, 0); } if (!$type) $type=1; return new $connector_out_set_types_classes[$type]($id); } class connector_out_sets { var $sets=array(); function connector_out_sets() { global $dbh; $sql = "SELECT connector_out_set_id, connector_out_set_type FROM connectors_out_sets ORDER BY connector_out_set_type"; $res = mysql_query($sql, $dbh); while ($row=mysql_fetch_assoc($res)) { $aesuser = new_connector_out_set_typed($row["connector_out_set_id"], $row["connector_out_set_type"]); $this->sets[] = clone $aesuser; } } static function get_typed_set_count($type) { global $dbh; $sql = "SELECT COUNT(1) FROM connectors_out_sets WHERE connector_out_set_type = ".($type+0); $result = mysql_result(mysql_query($sql, $dbh), 0, 0); return $result; } } /* * Catégories * */ class connector_out_setcateg { var $id=0; var $name=""; var $sets=array(); function connector_out_setcateg($id) { $this->id = $id+0; //Main information $sql = "SELECT * FROM connectors_out_setcategs WHERE connectors_out_setcateg_id = ".($id+0); $res = mysql_query($sql); $row = mysql_fetch_assoc($res); $this->name = $row["connectors_out_setcateg_name"]; //Categ content $sql = "SELECT connectors_out_setcategset_setnum FROM connectors_out_setcateg_sets WHERE connectors_out_setcategset_categnum = ".($id+0); $res=mysql_query($sql); while($row=mysql_fetch_assoc($res)) { $this->sets[] = $row["connectors_out_setcategset_setnum"]; } } static function name_exists($name) { global $dbh; $sql = "SELECT connectors_out_setcateg_id FROM connectors_out_setcategs WHERE connectors_out_setcateg_name = '".addslashes($name)."'"; $res = mysql_query($sql, $dbh); return mysql_num_rows($res) > 0 ? mysql_result($res, 0, 0) : 0; } static function add_new() { global $dbh; $sql = "INSERT INTO connectors_out_setcategs () VALUES ()"; $res = mysql_query($sql, $dbh); $new_setcateg_id = mysql_insert_id($dbh); return new connector_out_setcateg($new_setcateg_id); } function commit_to_db() { global $dbh; //on oublie pas que includes/global_vars.inc.php s'amuse à tout addslasher tout seul donc on le fait pas ici $sql = "UPDATE connectors_out_setcategs SET connectors_out_setcateg_name = '".$this->name."' WHERE connectors_out_setcateg_id = ".$this->id.""; mysql_query($sql, $dbh); //Vidage de la catégorie $sql = "DELETE FROM connectors_out_setcateg_sets WHERE connectors_out_setcategset_categnum = ".$this->id; mysql_query($sql, $dbh); //Remplissage de la catégorie if (count($this->sets)) { $sql = "INSERT INTO connectors_out_setcateg_sets (connectors_out_setcategset_setnum ,connectors_out_setcategset_categnum) VALUES "; $values=array(); foreach ($this->sets as $asetid) { $asetid+=0;//Conversion en int. if (!$asetid) continue; $values[] = '('.$asetid.', '.$this->id.')'; } $sql .= implode(",", $values); mysql_query($sql, $dbh); } } function delete() { global $dbh; //Deletons l'user $sql = "DELETE FROM connectors_out_setcategs WHERE connectors_out_setcateg_id = ".$this->id; mysql_query($sql, $dbh); //Vidons la catégorie $sql = "DELETE FROM connectors_out_setcateg_sets WHERE connectors_out_setcategset_categnum = ".$this->id; mysql_query($sql, $dbh); } } class connector_out_setcategs { var $categs=array(); function connector_out_setcategs() { global $dbh; $sql = "SELECT connectors_out_setcateg_id FROM connectors_out_setcategs"; $res = mysql_query($sql, $dbh); while ($row=mysql_fetch_assoc($res)) { $acateg = new connector_out_setcateg($row["connectors_out_setcateg_id"]); $this->categs[] = clone $acateg; } } } /* * Cache * */ class connector_out_setcache { var $id=0; var $set_id=0; var $last_updated_date=''; var $life_lifeduration=0; var $life_lifeduration_unit=''; var $values=array(); function connector_out_setcache($set_id) { global $dbh; $set_id+=0; //Main information $sql = "SELECT * FROM connectors_out_setcaches WHERE connectors_out_setcache_setnum=".$set_id; $res = mysql_query($sql, $dbh); $row = mysql_fetch_assoc($res); $this->id = $row["connectors_out_setcache_id"]; $this->set_id = $set_id; $this->last_updated_date = $row["connectors_out_setcache_lastupdatedate"]; $this->life_lifeduration = $row["connectors_out_setcache_lifeduration"]; $this->life_lifeduration_unit = $row["connectors_out_setcache_lifeduration_unit"]; } static function add($set_id) { global $dbh; $sql = "INSERT INTO connectors_out_setcaches (connectors_out_setcache_setnum) VALUES (".$set_id.")"; $res = mysql_query($sql, $dbh); $new_row_id = mysql_insert_id($dbh); return new connector_out_setcache($set_id); } function delete() { global $dbh; //Deletons le cache $sql = "DELETE FROM connectors_out_setcaches WHERE connectors_out_setcache_id = ".$this->id; mysql_query($sql, $dbh); //Vidons le cache $sql = "DELETE FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id; mysql_query($sql, $dbh); } function clear($also_clear_date=false) { global $dbh; //Vidons le cache $sql = "DELETE FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id; mysql_query($sql, $dbh); if ($also_clear_date) { $sql = "UPDATE connectors_out_setcaches SET connectors_out_setcache_lastupdatedate = '0000-00-00 00:00:00' WHERE connectors_out_setcache_id = ".$this->id; mysql_query($sql, $dbh); } } function get_values($first=false, $count=false) { if ($this->values) { return $this->values; } global $dbh; //Values if ($first !== false && $count !== false) $limit = "LIMIT ".$first.", ".$count; else $limit = ""; $sql = "SELECT connectors_out_setcache_values_value FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id." ".$limit; $res = mysql_query($sql, $dbh); while($row=mysql_fetch_assoc($res)) { $this->values[] = $row["connectors_out_setcache_values_value"]; } return $this->values; } function get_value_count() { global $dbh; $sql = "SELECT count(1) FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id; return mysql_result(mysql_query($sql, $dbh), 0, 0); } function commit_to_db($also_commit_values=false) { global $dbh; $sql = "UPDATE connectors_out_setcaches SET connectors_out_setcache_lifeduration = ".$this->life_lifeduration.", connectors_out_setcache_lastupdatedate = '".$this->last_updated_date."', connectors_out_setcache_lifeduration_unit = '".$this->life_lifeduration_unit."' WHERE connectors_out_setcache_id = ".$this->id; mysql_query($sql, $dbh); } function commit_values_into_db() { global $dbh; //On vide $sql = "DELETE FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id; mysql_query($sql, $dbh); //Et on remplit //Des fois qu'il y en ait beaucoup on va pas tout mysqler d'un coup. Faisons des paquets de 100. $davalues = array_chunk($this->values, 100); foreach ($davalues as $some_values) { $sql = "INSERT INTO connectors_out_setcache_values (connectors_out_setcache_values_cachenum, connectors_out_setcache_values_value) VALUES "; $values=array(); foreach ($some_values as $avalue) { if (!$avalue) continue; $values[] = '('.$this->id.', '.$avalue.')'; } $sql .= implode(",", $values); mysql_query($sql, $dbh); } //On met à jour la date $sql = "UPDATE connectors_out_setcaches SET connectors_out_setcache_lastupdatedate = NOW() WHERE connectors_out_setcache_id = ".$this->id; mysql_query($sql, $dbh); } function updatedb_from_sqlselect($sql_select) { global $dbh; //on marque le set comme en cours de rafraississement $query = "update connectors_out_sets set being_refreshed = 1 where connector_out_set_id = ".$this->id; mysql_query($query,$dbh); //On vide $sql = "DELETE FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id; mysql_query($sql, $dbh); $sql = "INSERT INTO connectors_out_setcache_values (connectors_out_setcache_values_cachenum, connectors_out_setcache_values_value) ".$sql_select; mysql_query($sql, $dbh); //On met à jour la date $sql = "UPDATE connectors_out_setcaches SET connectors_out_setcache_lastupdatedate = NOW() WHERE connectors_out_setcache_id = ".$this->id; mysql_query($sql, $dbh); //rafraississement terminé, on retire le marqueur $query = "update connectors_out_sets set being_refreshed = 0 where connector_out_set_id = ".$this->id; mysql_query($query,$dbh); //Et on vide le cache actuel $this->values = array(); } function get_config_form() { global $msg, $charset; $this->life_lifeduration+=0; $config_form = ''; $config_form .= '

'; $config_form .= ' '; $config_form .= ''; $config_form .= '
'; return $config_form; } function update_from_form() { global $setcache_duration_unit, $setcache_duration_value; $this->life_lifeduration = $setcache_duration_value+0; $this->life_lifeduration_unit = $setcache_duration_unit; } function is_cache_expired() { global $dbh; $config_mysql_timemapping = array( "seconds" => "SECOND", "minutes" => "MINUTE", "hours" => "HOUR", "days" => "DAY", "weeks" => "WEEK", "months" => "MONTH" ); $sql = "SELECT IFNULL(DATE_ADD(connectors_out_setcache_lastupdatedate, INTERVAL ".$this->life_lifeduration." ".$config_mysql_timemapping[$this->life_lifeduration_unit].") < NOW(), 1) FROM connectors_out_setcaches WHERE connectors_out_setcache_id = ".$this->id; $expired = mysql_result(mysql_query($sql, $dbh), 0, 0); return $expired; } function cache_duration_in_seconds() { global $dbh; $config_mysql_timemapping = array( "seconds" => "SECOND", "minutes" => "MINUTE", "hours" => "HOUR", "days" => "DAY", "weeks" => "WEEK", "months" => "MONTH" ); $sql = "SELECT UNIX_TIMESTAMP(NOW() + INTERVAL ".$this->life_lifeduration." ".$config_mysql_timemapping[$this->life_lifeduration_unit].") - UNIX_TIMESTAMP(NOW())"; $seconds = mysql_result(mysql_query($sql, $dbh), 0, 0); return $seconds; } } class connector_out_setcache_notice extends connector_out_setcache { function get_values($first=false, $count=false, $datefrom=false, $dateuntil=false) { if ($this->values) { return $this->values; } global $dbh; //Values if ($first !== false && $count !== false) $limit = "LIMIT ".$first.", ".$count; else $limit = ""; if ($datefrom or $dateuntil) { $where_clauses = array(); if ($datefrom) $where_clauses[] .= "notices.update_date > FROM_UNIXTIME(".$datefrom.")"; if ($dateuntil) $where_clauses[] .= "notices.update_date < FROM_UNIXTIME(".$dateuntil.')'; $where_clause = implode(" AND ", $where_clauses); $sql = "SELECT connectors_out_setcache_values_value FROM connectors_out_setcache_values LEFT JOIN notices ON (notices.notice_id = connectors_out_setcache_values_value) WHERE ".$where_clause.($where_clause ? ' AND ' : '')." connectors_out_setcache_values_cachenum = ".$this->id." ".$limit; } else $sql = "SELECT connectors_out_setcache_values_value FROM connectors_out_setcache_values WHERE connectors_out_setcache_values_cachenum = ".$this->id." ".$limit; $res = mysql_query($sql, $dbh); while($row=mysql_fetch_assoc($res)) { $this->values[] = $row["connectors_out_setcache_values_value"]; } return $this->values; } function get_value_count($datefrom=false, $dateuntil=false) { global $dbh; $where_clause = ""; if ($datefrom or $dateuntil) { $where_clauses = array(); if ($datefrom) $where_clauses[] .= "notices.update_date > FROM_UNIXTIME(".$datefrom.")"; if ($dateuntil) $where_clauses[] .= "notices.update_date < FROM_UNIXTIME(".$dateuntil.')'; $where_clause = implode(" AND ", $where_clauses); } $sql = "SELECT count(1) FROM connectors_out_setcache_values LEFT JOIN notices ON (notices.notice_id = connectors_out_setcache_values_value) WHERE ".$where_clause.($where_clause ? ' AND ' : '')." connectors_out_setcache_values_cachenum = ".$this->id; return mysql_result(mysql_query($sql, $dbh), 0, 0); } //Fonction qui renvoie la date de modification la plus vieille (pour l'oai) function get_earliest_updatedate() { global $dbh; $sql = "SELECT UNIX_TIMESTAMP(MIN(update_date)) FROM connectors_out_setcache_values LEFT JOIN notices ON (notices.notice_id = connectors_out_setcache_values_value) WHERE connectors_out_setcache_values_cachenum = ".$this->id; $result = mysql_result(mysql_query($sql, $dbh), 0, 0); return $result; } } ?>