X-Git-Url: http://git.cyclocoop.org/?p=velocampus%2Fweb%2Fwww.git;a=blobdiff_plain;f=www%2Fecrire%2Finc%2Fexport.php;fp=www%2Fecrire%2Finc%2Fexport.php;h=25afae2549f7fc6423b372e613ff60af978c68f9;hp=0000000000000000000000000000000000000000;hb=80b4d3e85f78d402ed2e73f8f5d1bf4c19962eed;hpb=aaf970bf4cdaf76689ecc10609048e18d073820c
diff --git a/www/ecrire/inc/export.php b/www/ecrire/inc/export.php
new file mode 100644
index 0000000..25afae2
--- /dev/null
+++ b/www/ecrire/inc/export.php
@@ -0,0 +1,352 @@
+ $all OR !$all){
+ return "end,$gz,$archive,$rub"; // c'est fini !
+ }
+
+ include_spip('inc/minipres');
+ @ini_set("zlib.output_compression","0"); // pour permettre l'affichage au fur et a mesure
+
+ echo ( install_debut_html(_T('info_sauvegarde') . " ($all)"));
+
+ if (!($timeout = ini_get('max_execution_time')*1000));
+ $timeout = 30000; // parions sur une valeur tellement courante ...
+ // le premier hit est moitie moins long car seulement une phase d'ecriture de morceaux
+ // sans ramassage
+ // sinon grosse ecriture au 1er hit, puis gros rammassage au deuxieme avec petite ecriture,... ca oscille
+ if ($start) $timeout = round($timeout/2);
+
+ // Les sauvegardes partielles prennent le temps d'indiquer les logos
+ // Instancier une fois pour toutes, car on va boucler un max.
+ // On complete jusqu'au secteur pour resituer dans l'arborescence)
+ if ($rub) {
+ $GLOBALS['chercher_logo'] = charger_fonction('chercher_logo', 'inc',true);
+ $les_rubriques = complete_fils(array($rub));
+ $les_meres = complete_secteurs(array($rub));
+ } else {
+ $GLOBALS['chercher_logo'] = false;
+ $les_rubriques = $les_meres = '';
+ }
+
+ // script de rechargement auto sur timeout
+ $redirect = generer_url_ecrire("export_all");
+ echo http_script("window.setTimeout('location.href=\"".$redirect."\";',$timeout)");
+
+ echo "\n";
+ $etape = 1;
+ foreach($tables_for_dump as $table){
+ if ($etape_actuelle > $etape) {
+ // sauter les deja faits, mais rappeler qu'ils sont fait
+ echo ( "\n
".$etape. '. '."". $tables_sauvegardees[$table]);
+ }
+ else {
+ echo ( "\n
".$etape. '. '. $table." ");
+ $r = sql_countsel($table);
+ flush();
+ if (!$r) $r = ( _T('texte_vide'));
+ else {
+ $f = $dir . $archive . '.part_' . sprintf('%03d',$etape);
+ $r = export_objets($table, $sous_etape, $r, $f, $les_rubriques, $les_meres, $meta);
+ $r += $sous_etape*_EXPORT_TRANCHES_LIMITE;
+ // info pas fiable si interruption+partiel
+ if ($rub AND $etape_actuelle > 1) $r = ">= $r";
+ }
+ echo " $r";
+ flush();
+ $sous_etape = 0;
+ // on utilise l'index comme ca c'est pas grave si on ecrit plusieurs fois la meme
+ $tables_sauvegardees[$table] = "$table ($r)";
+ ecrire_meta($metatable, serialize($tables_sauvegardees),'non');
+ }
+ $etape++;
+ $v = serialize(array($gz, $archive, $rub, $tables_for_dump, $etape,$sous_etape));
+ ecrire_meta($meta, $v,'non');
+ }
+ echo ( "
\n");
+ // si Javascript est dispo, anticiper le Time-out
+ echo ("\n");
+ echo (install_fin_html());
+ flush();
+ }
+}
+
+
+// http://doc.spip.org/@complete_secteurs
+function complete_secteurs($les_rubriques)
+{
+ $res = array();
+ foreach($les_rubriques as $r) {
+ do {
+ $r = sql_getfetsel("id_parent", "spip_rubriques", "id_rubrique=$r");
+ if ($r) {
+ if ((isset($les_rubriques[$r])) OR isset($res[$r]))
+ $r = false;
+ else $res[$r] = $r;
+ }
+ } while ($r);
+ }
+ return $res;
+}
+
+// http://doc.spip.org/@complete_fils
+function complete_fils($rubriques)
+{
+ $r = $rubriques;
+ do {
+ $q = sql_select("id_rubrique", "spip_rubriques", "id_parent IN (".join(',',$r).")");
+ $r = array();
+ while ($row = sql_fetch($q)) {
+ $r[]= $rubriques[] = $row['id_rubrique'];
+ }
+ } while ($r);
+
+
+ return $rubriques;
+}
+
+// Concatenation des tranches
+// Il faudrait ouvrir une seule fois le fichier, et d'abord sous un autre nom
+// et sans detruire les tranches: au final renommage+destruction massive pour
+// prevenir autant que possible un Time-out.
+
+// http://doc.spip.org/@ramasse_parties
+function ramasse_parties($dir, $archive)
+{
+ $files = preg_files($dir . $archive . ".part_[0-9]+_[0-9]+[.gz]?");
+
+ $ok = true;
+ $files_o = array();
+ $but = $dir . $archive;
+ foreach($files as $f) {
+ $contenu = "";
+ if (lire_fichier ($f, $contenu)) {
+ if (!ecrire_fichier($but,$contenu,false,false))
+ { $ok = false; break;}
+ }
+ spip_unlink($f);
+ $files_o[]=$f;
+ }
+ return $ok ? $files_o : false;
+}
+
+//
+// Exportation de table SQL au format xml
+// La constante ci-dessus determine la taille des tranches,
+// chaque tranche etant copiee immediatement dans un fichier
+// et son numero memorisee dans le serveur SQL.
+// En cas d'abandon sur Time-out, le travail pourra ainsi avancer.
+// Au final, on regroupera les tranches en un seul fichier
+// et on memorise dans le serveur qu'on va passer a la table suivante.
+// on prefere ne pas faire le ramassage ici de peur d'etre interrompu
+// par le timeout au mauvais moment
+// le ramassage aura lieu en debut de hit suivant,
+// et ne sera normalement pas interrompu car le temps pour ramasser
+// est plus court que le temps pour creer les parties
+
+// http://doc.spip.org/@export_objets
+function export_objets($table, $cpt, $total, $filetable, $les_rubriques, $les_meres, $meta) {
+ global $tables_principales;
+
+ $temp = $filetable . '.temp' . _EXTENSION_PARTIES;
+ $prim = isset($tables_principales[$table])
+ ? $tables_principales[$table]['key']["PRIMARY KEY"]
+ : '';
+ $debut = $cpt * _EXPORT_TRANCHES_LIMITE;
+ $effectifs = 0;
+
+ while (1){ // on ne connait pas le nb de paquets d'avance
+
+ $cpt++;
+ $tranche = build_while($debut, $table, $prim, $les_rubriques, $les_meres);
+ // attention: vide ne suffit pas a sortir
+ // car les sauvegardes partielles peuvent parcourir
+ // une table dont la portion qui les concerne sera vide..
+ if ($tranche) {
+ // on ecrit dans un fichier generique
+ // puis on le renomme pour avoir une operation atomique
+ ecrire_fichier ($temp, join('', $tranche));
+ $f = $filetable . sprintf('_%04d',$cpt) . _EXTENSION_PARTIES;
+ // le fichier destination peut deja exister
+ // si on sort d'un timeout entre le rename et le ecrire_meta
+ if (file_exists($f)) spip_unlink($f);
+ rename($temp, $f);
+ $effectifs += count($tranche);
+ }
+ // incrementer le numero de sous-etape
+ // au cas ou une interruption interviendrait
+ $v = unserialize($GLOBALS['meta'][$meta]);
+ $v[5]++;
+ ecrire_meta($meta, serialize($v));
+ $debut += _EXPORT_TRANCHES_LIMITE;
+ if ($debut >= $total) {break;}
+ /* pour tester la robustesse de la reprise sur interruption
+ decommenter ce qui suit.
+ if ($cpt && 1) {
+ spip_log("force interrup $s");
+ include_spip('inc/headers');
+ redirige_par_entete("./?exec=export_all&rub=$rub&x=$s");
+ } /* */
+ echo(". ");
+ flush();
+ }
+
+ return $effectifs;
+}
+
+
+// Construit la version xml des champs d'une table
+
+// http://doc.spip.org/@build_while
+function build_while($debut, $table, $prim, $les_rubriques, $les_meres) {
+ global $chercher_logo ;
+
+ // sauver par ordre croissant les tables avec cles primaires simples
+ // sinon les sequences PG seront pertubees a la restauration
+ // (a ameliorer)
+ $result = sql_select('*', $table, '', '', $prim, "$debut," . _EXPORT_TRANCHES_LIMITE);
+
+ $res = array();
+ while ($row = sql_fetch($result)) {
+ if (export_select($row, $les_rubriques, $les_meres)) {
+ $attributs = "";
+ if ($chercher_logo) {
+ if ($logo = $chercher_logo($row[$prim], $prim, 'on'))
+ $attributs .= ' on="' . $logo[3] . '"';
+ if ($logo = $chercher_logo($row[$prim], $prim, 'off'))
+ $attributs .= ' off="' . $logo[3] . '"';
+ }
+
+ $string = "<$table$attributs>\n";
+ foreach ($row as $k => $v) {
+ $string .= "<$k>" . text_to_xml($v) . "\n";
+ }
+ $string .= "\n\n";
+ $res[]= $string;
+ }
+ }
+ sql_free($result);
+ return $res;
+}
+
+// dit si Row est exportable,
+// en particulier quand on se restreint a certaines rubriques
+// Attention, la table articles doit etre au debut
+// et la table document_articles avant la table documents
+// (faudrait blinder, c'est un bug potentiel)
+
+// http://doc.spip.org/@export_select
+function export_select($row, $les_rubriques, $les_meres) {
+ static $articles = array();
+ static $documents = array();
+
+ if (isset($row['impt']) AND $row['impt'] !='oui') return false;
+ if (!$les_rubriques) return true;
+
+ // numero de rubrique non determinant pour les forums (0 � 99%)
+ if (isset($row['id_rubrique']) AND $row['id_rubrique']) {
+ if (in_array($row['id_rubrique'], $les_rubriques)) {
+ if (isset($row['id_article']))
+ $articles[] = $row['id_article'];
+ if (isset($row['id_document']))
+ $documents[]=$row['id_document'];
+ return true;
+ }
+ if (!in_array($row['id_rubrique'], $les_meres))
+ return false;
+ // la rubrique, mais rien d'autre
+ return (!isset($row['id_article'])
+ AND !isset($row['id_mot'])
+ AND !isset($row['id_document'])
+ AND !isset($row['id_breve']));
+ }
+ // dependances d'articles (mots, petitions, signatures et documents)
+ if (isset($row['id_article']) AND $row['id_article']) {
+ if (in_array($row['id_article'], $articles)) {
+ if (isset($row['id_document']))
+ $documents[]= $row['id_document'];
+ return true;
+ }
+ return false;
+ }
+ if (isset($row['id_objet']) AND isset($row['objet'])) {
+ if ($row['objet'] == 'article') {
+ if (in_array($row['id_objet'], $articles)) {
+ if (isset($row['id_document']))
+ $documents[]= $row['id_document'];
+ return true;
+ }
+ return false;
+ }
+ if ($row['objet'] == 'rubrique') {
+ if (in_array($row['id_objet'], $les_rubriques)) {
+ if (isset($row['id_document']))
+ $documents[]=$row['id_document'];
+ return true;
+ }
+ return false;
+ }
+ }
+
+ if (isset($row['id_document']) AND $row['id_document']) {
+ return array_search($row['id_document'], $documents);
+ }
+ // a la louche pour le reste, mais c'est a peu pres ca.
+ return (isset($row['id_groupe']) OR isset($row['id_mot']) OR isset($row['mime_type']));
+}
+
+// Conversion texte -> xml (ajout d'entites)
+// http://doc.spip.org/@text_to_xml
+function text_to_xml($string) {
+ return str_replace(array('&','<','>'), array('&','<','>'), $string);
+}
+
+?>