Skip to content
Extraits de code Groupes Projets
Valider a6857312 rédigé par marcimat's avatar marcimat
Parcourir les fichiers

Permettre à SQLite de faire des requetes qu'il ne connait pas : ALTER TABLE... 

Permettre à SQLite de faire des requetes qu'il ne connait pas : ALTER TABLE table (DROP|CHANGE|MODIFY) column

Pour cela, la seule solution est : 
A) découpage de la requete en autant de sous requete s'il y a (cas des referers qui ont 3 modifications DROP, CHANGE, ADD dans une seule requete), puis 
B) executer la sous-requete, sauf pour des sous requetes DROP, CHANGE ou MODIFY :
1) créer une table temporaire avec le contenu table à modifier (long sur les grosses bases ?), 
2) supprimer la table à modifier,
3) recréer la table en tenant compte des changements
4) copier les contenus qui correspondent de la table teporaire à la table recrée (long?)
5) supprimer la table temporaire

Du coup, au vu du risque sur ces requetes pour les grosses bases lors d'une mise à jour de SPIP, je ne saurais que trop conseiller de ne pas oublier de faire un DUMP avant ! (Il est fréquent que les mises à jour de SPIP utilisent ALTER TABLE ... DROP|CHANGE|MODIFY ...
parent dfa792f2
Aucune branche associée trouvée
Aucune étiquette associée trouvée
Aucune requête de fusion associée trouvée
Masquer les modifications d'espaces
En ligne Côte à côte
ecrire/req/sqlite_generique.php
+ 300
− 52
Voir le fichier @ a6857312
...@@ -121,64 +121,121 @@ function spip_sqlite_query($query, $serveur='') { ...@@ -121,64 +121,121 @@ function spip_sqlite_query($query, $serveur='') {
#spip_log("spip_sqlite_query() > $query"); #spip_log("spip_sqlite_query() > $query");
_sqlite_init(); _sqlite_init();
if (!($sqlite = _sqlite_link($serveur)) && (_request('exec')!='install')){ $requete = new sqlite_traiter_requete($query, $serveur);
spip_log("Aucune connexion sqlite (link)"); $requete->traduire_requete(); // mysql -> sqlite
return false; return $requete->executer_requete();
} }
$connexion = $GLOBALS['connexions'][$serveur ? $serveur : 0];
$prefixe = $connexion['prefixe']; /* ordre alphabetique pour les autres */
$db = $connexion['db'];
function spip_sqlite_alter($query, $serveur=''){
// corriger la requete au format mysql->sqlite
// creer la requete de comptage (sqlite3) $query = _sqlite_remplacements_definitions_table($query);
$analyse = new sqlite_analyse_query($sqlite, $query, $db, $prefixe);
$analyse->creerLesRequetes(); $requete = new sqlite_traiter_requete("ALTER $query", $serveur);
$query = $analyse->query; // pas indispensable car $query par & $requete->traduire_requete(); // mysql -> sqlite
$queryCount = $analyse->queryCount; $query = $requete->query;
unset($analyse);
/*
* la il faut faire les transformations
* si ALTER TABLE x (DROP|CHANGE) y
*
* 1) recuperer "ALTER TABLE table "
* 2) spliter les sous requetes (,)
* 3) faire chaque requete independemment
*/
$t = !isset($_GET['var_profile']) ? 0 : trace_query_start(); // 1
#echo("<br /><b>spip_sqlite_query() $serveur >></b> $query"); // boum ? pourquoi ? if (preg_match("/\s*ALTER(\s*IGNORE)?\s*TABLE\s*([^\s]*)\s*/i", $query, $regs)){
if ($sqlite){ $debut = $regs[0];
if (_sqlite_is_version(3, $sqlite)) { $table = $regs[2];
$r = $sqlite->query($query); $suite = substr($query, strlen($debut));
// comptage : oblige de compter le nombre d'entrees retournees par la requete
// aucune autre solution ne donne le nombre attendu :( !
// particulierement s'il y a des LIMIT dans la requete.
if ($queryCount){
if ($r) {
$l = $sqlite->query($queryCount);
$r->spipSqliteRowCount = count($l->fetchAll());
} else {
$r->spipSqliteRowCount = 0;
}
}
} else {
$r = sqlite_query($sqlite, $query);
}
} else { } else {
$r = false; spip_log("SQLite : Probleme de ALTER TABLE mal forme dans $query", 'sqlite');
} return false;
#spip_log("spip_sqlite_query() >> $query"); // boum ? pourquoi ?
if (!$r){
echo "<br /><small>#erreur serveur '$serveur' dans &gt; $query</small><br />";
echo "<br />- ".spip_sqlite_error($query, $serveur);
} }
if (!$r && $e = spip_sqlite_errno($serveur)) // Log de l'erreur eventuelle
$e .= spip_sqlite_error($query, $serveur); // et du fautif
return $t ? trace_query_end($query, $t, $r, $e) : $r; // 2
} $todo = explode(',', $suite);
// 3
$resultats = array();
foreach ($todo as $do){
$do = trim($do);
if (!preg_match('/(DROP|CHANGE COLUMN|CHANGE|MODIFY|RENAME TO|ADD COLUMN|ADD)\s*([^\s]*)\s*(.*)?/', $do, $matches)){
spip_log("SQLite : Probleme de ALTER TABLE, utilisation non reconnue dans : $query", 'sqlite');
return false;
}
/* ordre alphabetique pour les autres */ $cle = strtoupper($matches[1]);
$colonne_origine = $matches[2];
$colonne_destination = '';
$def = $matches[3];
function spip_sqlite_alter($query, $serveur=''){ switch($cle){
$query = _sqlite_remplacements_definitions_table($query); // allez, on simule, on simule !
return spip_sqlite_query("ALTER ".$query, $serveur); case 'DROP':
if (!_sqlite_traiter_alter_table(
$table,
'DROP',
$colonne_origine,
'',
'',
$serveur)){
return false;
}
break;
case 'CHANGE COLUMN':
case 'CHANGE':
// recuperer le nom de la future colonne
$def = trim($def);
$colonne_destination = substr($def, 0, strpos($def,' '));
$def = substr($def, strlen($colonne_destination)+1);
if (!_sqlite_traiter_alter_table(
$table,
'CHANGE',
$colonne_origine,
$colonne_destination,
$def,
$serveur)){
return false;
}
break;
case 'MODIFY':
if (!_sqlite_traiter_alter_table(
$table,
'CHANGE',
$colonne_origine,
$colonne_origine, // un change sur la meme colonne
$def,
$serveur)){
return false;
}
break;
// RAS pour ceux la
case 'RENAME TO':
case 'ADD COLUMN':
case 'ADD':
default:
$requete = new sqlite_traiter_requete("$debut $do", $serveur);
if (!$requete->executer_requete()){
spip_log("SQLite : Erreur ALTER TABLE (ADD|RENAME) : $query", 'sqlite');
return false;
}
break;
}
// tout est bon, ouf !
spip_log("SQLite ($serveur) : Changements OK : $debut $do");
}
spip_log("SQLite ($serveur) : fin ALTER TABLE OK !");
return true;
} }
...@@ -923,6 +980,120 @@ function _sqlite_remplacements_definitions_table($query){ ...@@ -923,6 +980,120 @@ function _sqlite_remplacements_definitions_table($query){
return preg_replace(array_keys($remplace), $remplace, $query); return preg_replace(array_keys($remplace), $remplace, $query);
} }
/*
* Gestion des requetes ALTER non reconnues de SQLite :
* ALTER TABLE table DROP column
* ALTER TABLE table CHANGE [COLUMN] columnA columnB definition
* ALTER TABLE table MODIFY column definition
*
* (MODIFY transforme en CHANGE columnA columnA) par spip_sqlite_alter()
*/
function _sqlite_traiter_alter_table($table, $ordre, $colonne_origine, $colonne_destination='', $def='', $serveur=''){
// creer une table temporaire identique
$def_origine = sql_showtable($table, $serveur);
if (!sql_create(
$table_tmp = $table.'_tmp',
$def_origine['field'],
$def_origine['key'],
$autoinc=false,
$temporary=true,
$serveur)){
spip_log("SQLite : ALTER TABLE table $ordre column :"
.' La creation de la table temporaire a echouee','sqlite');
return false;
}
// y copier tous les champs
// Aie Aie Aie, risque de timeout ?
if (!sql_query("INSERT INTO $table_tmp SELECT * FROM $table")){
spip_log("SQLite : ALTER TABLE table $ordre column :"
.' La copie de la table d\'origine a echouee','sqlite');
return false;
}
// supprimer la table d'origine (gasp, gloups !)
if (!sql_query("DROP TABLE $table")){
// ouf, ca s'est mal passe ;)
spip_log('SQLite : ALTER TABLE table DROP column :'
.' La suppression de la table d\'origine a echouee','sqlite');
return false;
}
// recreer la table d'origine avec les modifications :
// - DROP : suppression de la colonne
// - CHANGE : modification de la colonne
// (foreach pour conserver l'ordre des champs)
// field
$fields = array();
// pour le INSERT INTO plus loin
// stocker la correspondance nouvelles->anciennes colonnes
$fields_correspondances = array();
foreach ($def_origine['field'] as $c=>$d){
if ($c == $colonne_origine) {
// si pas DROP
if ($colonne_destination){
$fields[$colonne_destination] = $def;
$fields_correspondances[$colonne_destination] = $c;
}
} else {
$fields[$c] = $d;
$fields_correspondances[$c] = $c;
}
}
// key
$keys = array();
foreach ($def_origine['key'] as $c=>$d){
if ($d == $colonne_origine) {
if ($colonne_destination){
$keys[$c] = $colonne_destination;
}
} else {
$keys[$c] = $d;
}
}
$def_destination = array('field'=>$fields, 'key'=>$keys);
if (!sql_create(
$table,
$def_destination['field'],
$def_destination['key'],
$autoinc=false,
$temporary=false,
$serveur)){
spip_log("SQLite : ALTER TABLE table $ordre column :"
.' La creation de la table nouvelle table a echouee','sqlite');
// si on arrive la, on est plutot mal barre !
return false;
}
// y copier les champs qui vont bien
$champs_dest = join(', ', array_keys($fields_correspondances));
$champs_ori = join(', ', $fields_correspondances);
if (!sql_query("INSERT INTO $table ($champs_dest) SELECT $champs_ori FROM $table_tmp")){
spip_log("SQLite : ALTER TABLE table $ordre column :"
.' La copie de la table temporaire vers la nouvelle table a echouee','sqlite');
return false;
}
// supprimer la table temporaire
if (!sql_query("DROP TABLE $table_tmp")){
spip_log("SQLite : ALTER TABLE table $ordre column :"
.' La suppression de la table temporaore a echouee','sqlite');
return false;
}
return true;
}
/* /*
* renvoyer la liste des versions sqlite disponibles * renvoyer la liste des versions sqlite disponibles
...@@ -935,7 +1106,82 @@ function spip_versions_sqlite(){ ...@@ -935,7 +1106,82 @@ function spip_versions_sqlite(){
/*
* Class pour partager les lancements de requete
* pour sql_query() et sql_alter()
*
*/
class sqlite_traiter_requete{
var $query = ''; // la requete
var $queryCount = ''; // la requete pour compter
var $serveur = ''; // le serveur
var $link = ''; // le link (ressource) sqlite
var $prefixe = ''; // le prefixe des tables
var $db = ''; // le nom de la base
/* constructeur */
function sqlite_traiter_requete($query, $serveur = ''){
$this->query = $query;
$this->serveur = $serveur;
if (!($this->link = _sqlite_link($this->serveur)) && (_request('exec')!='install')){
spip_log("Aucune connexion sqlite (link)");
return false;
}
$this->prefixe = $GLOBALS['connexions'][$this->serveur ? $this->serveur : 0]['prefixe'];
$this->db = $GLOBALS['connexions'][$this->serveur ? $this->serveur : 0]['db'];
}
/* transformer la requete pour sqlite */
function traduire_requete(){
$analyse = new sqlite_analyse_requete($this->link, $this->query, $this->db, $this->prefixe);
// transformer
$analyse->creerLesRequetes();
// renvoyer
$this->query = $analyse->query;
$this->queryCount = $analyse->queryCount;
}
/* lancer la requete $this->requete et faire le tracage si demande */
function executer_requete(){
$t = !isset($_GET['var_profile']) ? 0 : trace_query_start();
#echo("<br /><b>spip_sqlite_query() $serveur >></b> $query"); // boum ? pourquoi ?
if ($this->link){
if (_sqlite_is_version(3, $this->link)) {
$r = $this->link->query($this->query);
// comptage : oblige de compter le nombre d'entrees retournees par la requete
// aucune autre solution ne donne le nombre attendu :( !
// particulierement s'il y a des LIMIT dans la requete.
if ($this->queryCount){
if ($r) {
$l = $this->link->query($this->queryCount);
$r->spipSqliteRowCount = count($l->fetchAll());
} else {
$r->spipSqliteRowCount = 0;
}
}
} else {
$r = sqlite_query($this->link, $this->query);
}
} else {
$r = false;
}
#spip_log("spip_sqlite_query() >> $query"); // boum ? pourquoi ?
if (!$r){
echo "<br /><small>#erreur serveur '$this->serveur' dans &gt; $this->query</small><br />";
echo "<br />- ".spip_sqlite_error($this->query, $this->serveur);
}
if (!$r && $e = spip_sqlite_errno($this->serveur)) // Log de l'erreur eventuelle
$e .= spip_sqlite_error($this->query, $this->serveur); // et du fautif
return $t ? trace_query_end($this->query, $t, $r, $e) : $r;
}
}
/* /*
...@@ -945,7 +1191,7 @@ function spip_versions_sqlite(){ ...@@ -945,7 +1191,7 @@ function spip_versions_sqlite(){
* Du coup, je mets aussi les traitements a faire dedans * Du coup, je mets aussi les traitements a faire dedans
* *
*/ */
class sqlite_analyse_query { class sqlite_analyse_requete {
var $sqlite = ''; // la ressource link (ou objet pdo) var $sqlite = ''; // la ressource link (ou objet pdo)
var $query = ''; // la requete var $query = ''; // la requete
var $queryCount = ''; // la requete pour comptage des lignes select (sqlite3/PDO) var $queryCount = ''; // la requete pour comptage des lignes select (sqlite3/PDO)
...@@ -958,7 +1204,9 @@ class sqlite_analyse_query { ...@@ -958,7 +1204,9 @@ class sqlite_analyse_query {
var $codeEchappements = "%@##@%"; var $codeEchappements = "%@##@%";
function sqlite_analyse_query(&$link, &$query, $db, $prefixe){ function sqlite_analyse_requete(&$link, $query, $db, $prefixe){
$this->sqlite = $link; $this->sqlite = $link;
$this->query = $query; $this->query = $query;
$this->db = $db; $this->db = $db;
......
0% ou .
You are about to add 0 people to the discussion. Proceed with caution.
Terminez d'abord l'édition de ce message.
Veuillez vous inscrire ou vous pour commenter

Forge communautaire SPIP | Charte d'utilisation | Signaler un problème sur ce site