WP File Manager

Current Path: /home/argothem/www/organecyberpresse/ecrire/src/Compilateur/Iterateur/

Name	Action
..
AbstractIterateur.php	Edit
Condition.php	Edit
Data.php	Edit
Decorator.php	Edit
Factory.php	Edit
Sql.php	Edit

Editing: Sql.php

<?php

namespace Spip\Compilateur\Iterateur;

use Iterator;

/**
 * Itérateur SQL.
 *
 * Permet d'itérer sur des données en base de données
 */
class Sql extends AbstractIterateur implements Iterator
{

/**
	 * Ressource sql.
	 *
	 * @var bool|object
	 */
	protected $sqlresult = false;

/**
	 * row sql courante.
	 *
	 * @var null|array
	 */
	protected $row;

protected bool $firstseek = false;

protected int $pos = -1;

/*
	 * array command: les commandes d'initialisation
	 * array info: les infos sur le squelette
	 */
	public function __construct(array $command, array $info = []) {
		$this->type = 'SQL';
		parent::__construct($command, $info);

$this->select();
	}

/**
	 * Rembobiner.
	 *
	 * @return bool
	 */
	public function rewind(): void {
		if ($this->pos > 0) {
			$this->seek(0);
		}
	}

/**
	 * Verifier l'etat de l'iterateur.
	 */
	public function valid(): bool {
		if ($this->err) {
			return false;
		}
		if (!$this->firstseek) {
			$this->next();
		}

return is_array($this->row);
	}

/**
	 * Valeurs sur la position courante.
	 *
	 * @return array
	 */
	#[\ReturnTypeWillChange]
	public function current() {
		return $this->row;
	}

#[\ReturnTypeWillChange]
	public function key() {
		return $this->pos;
	}

/**
	 * Sauter a une position absolue.
	 *
	 * @param int         $n
	 * @param null|string $continue
	 *
	 * @return bool
	 */
	public function seek($n = 0, $continue = null) {
		if (!sql_seek($this->sqlresult, $n, $this->command['connect'], $continue)) {
			// SQLite ne sait pas seek(), il faut relancer la query
			// si la position courante est apres la position visee
			// il faut relancer la requete
			if ($this->pos > $n) {
				$this->free();
				$this->select();
				$this->valid();
			}
			// et utiliser la methode par defaut pour se deplacer au bon endroit
			// (sera fait en cas d'echec de cette fonction)
			return false;
		}
		$this->row = sql_fetch($this->sqlresult, $this->command['connect']);
		$this->pos = min($n, $this->count());

return true;
	}

/**
	 * Avancer d'un cran.
	 */
	public function next(): void {
		$this->row = sql_fetch($this->sqlresult, $this->command['connect']);
		++$this->pos;
		$this->firstseek |= true;
	}

/**
	 * Avancer et retourner les donnees pour le nouvel element.
	 *
	 * @return null|array|bool
	 */
	public function fetch() {
		if ($this->valid()) {
			$r = $this->current();
			$this->next();
		} else {
			$r = false;
		}

return $r;
	}

/**
	 * liberer les ressources.
	 *
	 * @return bool
	 */
	public function free() {
		if (!$this->sqlresult) {
			return true;
		}
		$a = sql_free($this->sqlresult, $this->command['connect']);
		$this->sqlresult = null;

return $a;
	}

/**
	 * Compter le nombre de resultats.
	 *
	 * @return int
	 */
	public function count() {
		if (is_null($this->total)) {
			if (!$this->sqlresult) {
				$this->total = 0;
			} else {
				// cas count(*)
				if (in_array('count(*)', $this->command['select'])) {
					$this->valid();
					$s = $this->current();
					$this->total = $s['count(*)'];
				} else {
					$this->total = sql_count($this->sqlresult, $this->command['connect']);
				}
			}
		}

return $this->total;
	}

/**
	 * selectionner les donnees, ie faire la requete SQL.
	 */
	protected function select() {
		$this->row = null;
		$v = &$this->command;
		$limit = $v['limit'];
		$count_total_from_query = 0;
		if ($this->can_optimize_pagination($v)) {
			[$debut, $nombre] = $v['pagination'];
			$count_total_from_query = (intval($debut) + intval($nombre));
			$limit = '0,' . $count_total_from_query;
		}

$requete = preparer_calculer_select(
			$v['select'],
			$v['from'],
			$v['type'],
			$v['where'],
			$v['join'],
			$v['groupby'],
			$v['orderby'],
			$limit,
			$v['having'],
			$v['table'],
			$v['id'],
			$v['connect'],
			$this->info
		);

$this->sqlresult = executer_calculer_select($requete);
		$this->err = is_string($this->sqlresult) || !$this->sqlresult;
		if ($count_total_from_query && !$this->err) {
			$this->total = (int) sql_count($this->sqlresult, $this->command['connect']);
			if ($this->total === $count_total_from_query) {
				$this->total = compter_calculer_select($requete);
			}
		}
		$this->firstseek = false;
		$this->pos = -1;

// pas d'init a priori, le calcul ne sera fait qu'en cas de besoin (provoque une double requete souvent inutile en sqlite)
		//$this->total = $this->count();
	}

/**
	 * Vérifier si on peut optimiser les requêtes paginées
	 *
	 * On ne peut pas tout optimiser en faisant sql_countsel(),
	 * qui n’utilise pas la partie `select` de la boucle.
	 *
	 * Si la requête contient un select `champ AS xxx`,
	 * et que xxx est utilisé dans une des parties nécessaire au sql_countsel,
	 * typiquement groupby ou having, alors la requête échouera, puisqu’elle
	 * n’aura pas la définition de xxx.
	 *
	 * Également un simple `having id_article > 4` échoue sans la présence
	 * de `id_article` en SELECT ou en GROUP BY.
	 *
	 * On limite donc l’optimisation aux cas qui semblent pouvoir être traités.
	 *
	 * @param array $command tableau des commandes d'initialisation de la requete SQL
	 * @return bool
	 */
	private function can_optimize_pagination(array $command = []): bool {
		if (empty($command['pagination'])) {
			return false;
		}
		if (!empty($command['limit'])) {
			return false;
		}
		// having est trop complexe à gérer pour affiner plus loin.
		if (!empty($command['having'])) {
			return false;
		}

[$debut, $nombre] = $command['pagination'];
		if ($debut !== null && !is_numeric($debut)) {
			return false;
		}
		// liste complète demandée ?
		if ((int) $debut === -1) {
			return false;
		}

// si select contient un AS xxx
		// il faut vérifier s’il est utilisé dans un groupby ou having
		// car `select` n’est pas transmis à sql_countsel
		if (empty($command['groupby'])) {
			return true;
		}

// cas courant `groupby article.id_article`
		if (
			count($command['groupby']) === 1
			&& str_contains($command['groupby'][0], '.')
		) {
			return true;
		}

$as_list = $this->get_select_as_list($command['select']);
		if ($as_list === []) {
			return true;
		}

if (!empty($command['groupby'])) {
			foreach ($command['groupby'] as $groupby) {
				if (in_array($groupby, $as_list)) {
					return false;
				}
			}
		}

return true;
	}

/**
	 * Recherche dans une liste de champs à sélectionner ceux qui sont marqués avec un `AS`
	 * Et les renvoie sous forme de liste
	 *
	 * @param array $select
	 * @return array
	**/
	private function get_select_as_list(array $select): array {
		$list = [];
		foreach ($select as $sel) {
			if (stripos($sel, ' AS ') !== false) {
				if (preg_match_all("# AS (\w+)#i", $sel, $matches, \PREG_PATTERN_ORDER)) {
					$list = [...$list, ...$matches[1]];
				}
			}
		}
		return $list;
	}
}