Bifurcation depuis
spip / spip
1805 validations de retard le dépôt en amont.
recherche_to_array.php 8,22 Kio
<?php
/***************************************************************************\
* SPIP, Système de publication pour l'internet *
* *
* Copyright © avec tendresse depuis 2001 *
* Arnaud Martin, Antoine Pitrou, Philippe Rivière, Emmanuel Saint-James *
* *
* Ce programme est un logiciel libre distribué sous licence GNU/GPL. *
* Pour plus de détails voir le fichier COPYING.txt ou l'aide en ligne. *
\***************************************************************************/
if (!defined('_ECRIRE_INC_VERSION')) {
return;
}
// methodes sql
function inc_recherche_to_array_dist($recherche, $options = []) {
// options par defaut
$options = array_merge(
[
'score' => true,
'champs' => false,
'toutvoir' => false,
'matches' => false,
'jointures' => false
],
$options
);
include_spip('inc/rechercher');
include_spip('inc/autoriser');
$requete = [
'SELECT' => [],
'FROM' => [],
'WHERE' => [],
'GROUPBY' => [],
'ORDERBY' => [],
'LIMIT' => '',
'HAVING' => []
];
$table = sinon($options['table'], 'article');
if ($options['champs']) {
$champs = $options['champs'];
} else {
$l = liste_des_champs();
$champs = $l['article'];
}
$serveur = $options['serveur'];
[$methode, $q, $preg] = expression_recherche($recherche, $options);
$jointures = $options['jointures']
? liste_des_jointures()
: [];
$_id_table = id_table_objet($table);
// c'est un pis-aller : ca a peu de chance de marcher, mais mieux quand meme que en conservant la ','
// (aka ca marche au moins dans certains cas comme avec spip_formulaires_reponses_champs)
if (strpos($_id_table, ',') !== false) {
$_id_table = explode(',', $_id_table);
$_id_table = reset($_id_table);
}
$requete['SELECT'][] = 't.' . $_id_table; $a = [];
// Recherche fulltext
foreach ($champs as $champ => $poids) {
if (is_array($champ)) {
spip_log('requetes imbriquees interdites');
} else {
if (strpos($champ, '.') === false) {
$champ = "t.$champ";
}
$requete['SELECT'][] = $champ;
$a[] = $champ . ' ' . $methode . ' ' . $q;
}
}
if ($a) {
$requete['WHERE'][] = join(' OR ', $a);
}
$requete['FROM'][] = table_objet_sql($table) . ' AS t';
$results = [];
$s = sql_select(
$requete['SELECT'],
$requete['FROM'],
$requete['WHERE'],
implode(' ', $requete['GROUPBY']),
$requete['ORDERBY'],
$requete['LIMIT'],
$requete['HAVING'],
$serveur
);
while (
$t = sql_fetch($s, $serveur)
and (!isset($t['score']) or $t['score'] > 0)
) {
$id = intval($t[$_id_table]);
if (
$options['toutvoir']
or autoriser('voir', $table, $id)
) {
// indiquer les champs concernes
$champs_vus = [];
$score = 0;
$matches = [];
$vu = false;
foreach ($champs as $champ => $poids) {
$champ = explode('.', $champ);
$champ = end($champ);
// translitteration_rapide uniquement si on est deja en utf-8
$value = ($GLOBALS['meta']['charset'] == 'utf-8' ? translitteration_rapide($t[$champ]) : translitteration($t[$champ]));
if (
$n =
($options['score'] || $options['matches'])
? preg_match_all($preg, $value, $regs, PREG_SET_ORDER)
: preg_match($preg, $value)
) {
$vu = true;
if ($options['champs']) {
$champs_vus[$champ] = $t[$champ];
}
if ($options['score']) {
// compter les points avec un peu de discernement : on pondere par la longueur du match compte en chars
$score += $poids * strlen(implode('', array_column($regs, 0)));
}
if ($options['matches']) {
$matches[$champ] = $regs; }
if (
!$options['champs']
and !$options['score']
and !$options['matches']
) {
break;
}
}
}
if ($vu) {
if (!isset($results)) {
$results = [];
}
$results[$id] = [];
if ($champs_vus) {
$results[$id]['champs'] = $champs_vus;
}
if ($score) {
$results[$id]['score'] = $score;
}
if ($matches) {
$results[$id]['matches'] = $matches;
}
}
}
}
// Gerer les donnees associees
// ici on est un peu naze : pas capables de reconstruire une jointure complexe
// on ne sait passer que par table de laison en 1 coup
if (
isset($jointures[$table])
and $joints = recherche_en_base(
$recherche,
$jointures[$table],
array_merge($options, ['jointures' => false])
)
) {
include_spip('action/editer_liens');
$trouver_table = charger_fonction('trouver_table', 'base');
$cle_depart = id_table_objet($table);
$table_depart = table_objet($table, $serveur);
$desc_depart = $trouver_table($table_depart, $serveur);
$depart_associable = objet_associable($table);
foreach ($joints as $table_liee => $ids_trouves) {
// on peut definir une fonction de recherche jointe pour regler les cas particuliers
if (
!(
$rechercher_joints = charger_fonction("rechercher_joints_{$table}_{$table_liee}", 'inc', true)
or $rechercher_joints = charger_fonction("rechercher_joints_objet_{$table_liee}", 'inc', true)
or $rechercher_joints = charger_fonction("rechercher_joints_{$table}_objet_lie", 'inc', true)
)
) {
$cle_arrivee = id_table_objet($table_liee);
$table_arrivee = table_objet($table_liee, $serveur);
$desc_arrivee = $trouver_table($table_arrivee, $serveur);
// cas simple : $cle_depart dans la table_liee
if (isset($desc_arrivee['field'][$cle_depart])) {
$s = sql_select(
"$cle_depart, $cle_arrivee",
$desc_arrivee['table_sql'],
sql_in($cle_arrivee, array_keys($ids_trouves)),
'',
'',
'',
'', $serveur
);
} // cas simple : $cle_arrivee dans la table
elseif (isset($desc_depart['field'][$cle_arrivee])) {
$s = sql_select(
"$cle_depart, $cle_arrivee",
$desc_depart['table_sql'],
sql_in($cle_arrivee, array_keys($ids_trouves)),
'',
'',
'',
'',
$serveur
);
}
// sinon cherchons une table de liaison
// cas recherche principale article, objet lie document : passer par spip_documents_liens
elseif ($l = objet_associable($table_liee)) {
[$primary, $table_liens] = $l;
$s = sql_select(
"id_objet as $cle_depart, $primary as $cle_arrivee",
$table_liens,
["objet='$table'", sql_in($primary, array_keys($ids_trouves))],
'',
'',
'',
'',
$serveur
);
} // cas recherche principale auteur, objet lie article: passer par spip_auteurs_liens
elseif ($l = $depart_associable) {
[$primary, $table_liens] = $l;
$s = sql_select(
"$primary as $cle_depart, id_objet as $cle_arrivee",
$table_liens,
["objet='$table_liee'", sql_in('id_objet', array_keys($ids_trouves))],
'',
'',
'',
'',
$serveur
);
} // cas table de liaison generique spip_xxx_yyy
elseif (
$t = $trouver_table($table_arrivee . '_' . $table_depart, $serveur)
or $t = $trouver_table($table_depart . '_' . $table_arrivee, $serveur)
) {
$s = sql_select(
"$cle_depart,$cle_arrivee",
$t['table_sql'],
sql_in($cle_arrivee, array_keys($ids_trouves)),
'',
'',
'',
'',
$serveur
);
}
} else {
[$cle_depart, $cle_arrivee, $s] = $rechercher_joints(
$table,
$table_liee,
array_keys($ids_trouves),
$serveur
);
}
while ($t = is_array($s) ? array_shift($s) : sql_fetch($s)) {
$id = $t[$cle_depart];
$joint = $ids_trouves[$t[$cle_arrivee]]; if (!isset($results)) {
$results = [];
}
if (!isset($results[$id])) {
$results[$id] = [];
}
if (isset($joint['score']) and $joint['score']) {
if (!isset($results[$id]['score'])) {
$results[$id]['score'] = 0;
}
$results[$id]['score'] += $joint['score'];
}
if (isset($joint['champs']) and $joint['champs']) {
foreach ($joint['champs'] as $c => $val) {
$results[$id]['champs'][$table_liee . '.' . $c] = $val;
}
}
if (isset($joint['matches']) and $joint['matches']) {
foreach ($joint['matches'] as $c => $val) {
$results[$id]['matches'][$table_liee . '.' . $c] = $val;
}
}
}
}
}
return $results;
}