X-Git-Url: http://git.euphorik.ch/?a=blobdiff_plain;f=modules%2Ferl%2Feuphorik_bd_admin.erl;h=0abd2bdc2597c16475f0ba25c9a14fdce6b8008d;hb=79f0cfc91b7220d98e4caf50fbb3857807fc6bc4;hp=dca6c2d22c27746cca28837dc1e79d53502a2f86;hpb=3c3e08ee08628398811d850f23d8494340ae8b2c;p=euphorik.git diff --git a/modules/erl/euphorik_bd_admin.erl b/modules/erl/euphorik_bd_admin.erl index dca6c2d..0abd2bd 100644 --- a/modules/erl/euphorik_bd_admin.erl +++ b/modules/erl/euphorik_bd_admin.erl @@ -15,7 +15,7 @@ % % You should have received a copy of the GNU General Public License % along with Euphorik. If not, see . -% +% % Module mettant à disposition tout un tas de fonction pour l'administration de la base de données euphorik comme : % - Création de la BD % - Mise à jour de la BD @@ -33,11 +33,11 @@ connect/1, reset/0, update/0, - + backup/1, restore/1, change_node_name/4, - + toggle_ek_master/1, print_users/0, print_users/1, @@ -56,9 +56,9 @@ version_bd() -> mnesia:read({proprietes, version}) end )). - -% Instructions pour créer une nouvelle base : + +% Instructions pour créer une nouvelle base : % $erl -sname yaws -mnesia dir '"/projets/euphorik/BD"' % voir doc/installation.txt % >l(euphorik_bd). @@ -70,7 +70,7 @@ create() -> mnesia:start(), create_tables(), reset(). - + create_tables() -> mnesia:create_table(counter, [ {attributes, record_info(fields, counter)}, @@ -106,8 +106,8 @@ create_tables() -> {disc_copies, [node()]} ]), creer_indexes(). - - + + % mis à part car lors de la reprise de données avec load_textfile les indexes ne sont pas recréés creer_indexes() -> % commence par supprimer les anciens indexes @@ -117,17 +117,17 @@ creer_indexes() -> end, mnesia:table_info(T, index) ) - end, + end, ?TABLES ), mnesia:add_table_index(minichat, auteur_id), mnesia:add_table_index(reponse_minichat, cible), mnesia:add_table_index(user, cookie), mnesia:add_table_index(user, login), - mnesia:add_table_index(troll, date_post), + mnesia:add_table_index(troll, date_post), mnesia:add_table_index(troll, id_minichat). - - + + % Connexion à la base de données de yaws sur overnux connect() -> connect(yaws@flynux). @@ -149,13 +149,13 @@ reset() -> % crée l'utilisateur root mnesia:transaction(fun() -> mnesia:write(#proprietes{nom = version, valeur = ?VERSION_BD}), - User = #user{id = 0, profile = #profile{pseudo = "Sys"}, login = "Sys", date_creation = now(), date_derniere_connexion = now(), ek_master = true}, + User = #user{id = 0, profile = #profile{pseudo = "Sys"}, login = "Sys", date_creation = erlang:timestamp(), date_derniere_connexion = erlang:timestamp(), ek_master = true}, mnesia:write(User), User end), peupler_texte(). - - + + peupler_texte() -> mnesia:transaction(fun() -> mnesia:write(#texte{ id = 10, fr = "Login déjà existant"}), @@ -193,7 +193,7 @@ update() -> _ -> erreur end. - + % Mise à jour de la BD. % attention : il est nécessaire de se trouver dans une transaction. @@ -210,38 +210,38 @@ update(Version) -> end; {error, Raison} -> {error, lists:flatten(io_lib:format("Erreur de création du backup de la version ~w : ~w", [Version, Raison]))} end. - - + + % Applique une modification de la BD pour passer d'une version à la suivante. % crée un backup avant l'application du patch % dans BD/backups nommé "backup" où et le numéro de la version. % 1 -> 2 -patch(1) -> - % Prend un chemin vers la feuille de style de type "css/1/euphorik.css" - % et renvoie "styles/1/euphorik.css" +patch(1) -> + % Prend un chemin vers la feuille de style de type "css/1/euphorik.css" + % et renvoie "styles/1/euphorik.css" Transforme_css = fun("css" ++ Reste) -> - "styles" ++ Reste; - (F) -> F - end, - Traiter_message = fun(M, Racine) -> - F = fun(F, M2) -> % seul moyen à ma connaissance pour faire de la récursion dans une lambda fonction, voir : http://www.nabble.com/Auto-generated-functions-td15279499.html - % met à jour la racine de chaque message qui répond à M - lists:foreach( - fun(M3) -> - mnesia:write(M2#minichat{racine_id = Racine}), - F(F, M3) - end, - euphorik_bd:enfants(M#minichat.id) - ) - end, - F(F, M, Racine) + "styles" ++ Reste; + (F) -> F + end, + Traiter_message = fun(M, Racine) -> + F = fun(F, M2) -> % seul moyen à ma connaissance pour faire de la récursion dans une lambda fonction, voir : http://www.nabble.com/Auto-generated-functions-td15279499.html + % met à jour la racine de chaque message qui répond à M + lists:foreach( + fun(M3) -> + mnesia:write(M2#minichat{racine_id = Racine}), + F(F, M3) + end, + euphorik_bd:enfants(M#minichat.id) + ) + end, + F(F, M, Racine) end, mnesia:create_table(texte, [ {attributes, record_info(fields, texte)}, {disc_copies, [node()]} ]), peupler_texte(), - % traitement des users + % traitement des users mnesia:transform_table( user, fun({user, Id, Cookie, Pseudo, Login, Password, Email, Date_creation, Date_derniere_connexion, Css, Nick_format, View_times, View_tooltips, Indice_flood, _Page_principale, Conversations, Ek_master, Last_ip}) -> @@ -266,34 +266,34 @@ patch(1) -> ) of {aborted, Raison} -> {erreur, Raison}; {atomic, _} -> ok - end; -% 2 -> 3 -patch(2) -> - mnesia:transform_table( - troll, - fun({troll, Id_troll, Id_user, Date_create, Date_post, Content}) -> - % recherche le message associé s'il existe - Id_minichat = case e(q([M || M <- mnesia:table(minichat), element(7, M) =:= Id_troll]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of - [M] -> element(2, M); - _ -> undefined - end, - {troll, Id_troll, Id_user, Id_minichat, Date_create, Date_post, Content} - end, - record_info(fields, troll) - ), - %mnesia:del_table_index(minichat, troll_id), - mnesia:transform_table( - minichat, - fun({minichat, Id, Auteur_id, Date, Pseudo, Contenu, _Troll_id, Racine_id}) -> - {minichat, Id, Auteur_id, Date, Pseudo, Contenu, Racine_id, normal} - end, - record_info(fields, minichat) + end; +% 2 -> 3 +patch(2) -> + mnesia:transform_table( + troll, + fun({troll, Id_troll, Id_user, Date_create, Date_post, Content}) -> + % recherche le message associé s'il existe + Id_minichat = case e(q([M || M <- mnesia:table(minichat), element(7, M) =:= Id_troll]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of + [M] -> element(2, M); + _ -> undefined + end, + {troll, Id_troll, Id_user, Id_minichat, Date_create, Date_post, Content} + end, + record_info(fields, troll) + ), + %mnesia:del_table_index(minichat, troll_id), + mnesia:transform_table( + minichat, + fun({minichat, Id, Auteur_id, Date, Pseudo, Contenu, _Troll_id, Racine_id}) -> + {minichat, Id, Auteur_id, Date, Pseudo, Contenu, Racine_id, normal} + end, + record_info(fields, minichat) ), mnesia:transaction(fun() -> % comble les trous entre les id non-contigues lists:foreach(fun(Id) -> case mnesia:read({minichat, Id}) of - [] -> + [] -> {ok, #user{profile = Profile}} = euphorik_bd:user_by_id(0), mnesia:write(#minichat{id = Id, auteur_id = 0, date = undefined, pseudo = Profile#profile.pseudo, contenu = "Comblement...", racine_id = Id, status = deleted}); _ -> rien @@ -303,8 +303,8 @@ patch(2) -> ), % la table troll utilise maintenant son index et pas celui de la table minichat (correction d'un vieux bug) mnesia:write(#counter{key = troll, value = mnesia:table_info(minichat, size)}) - end), - creer_indexes(). % uniquement pour l'indice sur id_minichat de la table troll + end), + creer_indexes(). % uniquement pour l'indice sur id_minichat de la table troll % Renvoie le dossier dans lequel les backups sont effectué, ce dossier doit être en écriture. @@ -313,15 +313,15 @@ dossier_backups() -> % Renvoie le fichier (avec le chemin) correspondant à la version Version, par exemple : "/var/euphorik/BD/backups/backup1" -fichier_backup(Version) when is_integer(Version) -> +fichier_backup(Version) when is_integer(Version) -> dossier_backups() ++ "backup" ++ integer_to_list(Version). - + % crée un backup dont le nom est fournit dans le repertoire backups qui se trouve dans le repertoire de la BD. backup(Fichier) -> mnesia:backup(dossier_backups() ++ Fichier). - - + + % Restaure un backup de la BD. restore(Fichier) when is_list(Fichier) -> mnesia:restore(dossier_backups() ++ Fichier, []); @@ -329,7 +329,7 @@ restore(Fichier) when is_list(Fichier) -> % (les données insérées durant les versions plus récentes sont perdues). restore(Version) when is_integer(Version) -> mnesia:restore(fichier_backup(Version), []). % [{default_op, recreate_tables}]). - + % Change le nom du noeud d'un backup. % provient d'ici : http://www.erlang.org/doc/apps/mnesia/Mnesia_chap7.html#6.9 @@ -369,7 +369,7 @@ change_node_name(From, To, Source, Target) -> % Obsolète %~ backup_text(File) -> %~ mnesia:dump_to_textfile(File). -%~ restore_text(File) -> +%~ restore_text(File) -> %~ mnesia:stop(), %~ mnesia:delete_schema([node()]), %~ mnesia:start(), @@ -394,7 +394,7 @@ toggle_ek_master(User_id) -> end end )). - + % Affiche N user trié par leur date de dernière connexion. % Opt est une liste d'option d'affichage : @@ -404,7 +404,7 @@ print_users(N, Opt) -> euphorik_bd:resultat_transaction(mnesia:transaction(fun() -> C = cursor( qlc:keysort( - #user.date_derniere_connexion, + #user.date_derniere_connexion, if AfficheQueLesEkMaster -> q([E || E <- mnesia:table(user), E#user.ek_master =:= true]); true -> @@ -423,8 +423,8 @@ print_users(N, Opt) -> ), qlc:delete_cursor(C) end)). - - + + % Affiche tous les users. print_users(Opt) -> print_users(all_remaining, Opt). @@ -432,14 +432,14 @@ print_users(Opt) -> % Affiche tous les users. print_users() -> print_users(all_remaining, []). - + print_user(User) when is_record(User, user) -> #user{id = Id, profile = #profile{pseudo = Pseudo}, login = Login, ek_master = Ek_master, date_derniere_connexion = Date, last_ip = IP} = User, {{Annee, Mois, Jour}, {Heure, Min, _}} = calendar:now_to_local_time(Date), io:format( % id pseudo (login) IP Jour Mois Année Heure Minute "~4w : ~10.10..s(~10.10..s) ~s ~2w.~2.2.0w.~w - ~2wh~2.2.0w~n", - [ + [ Id, if Ek_master -> "*"; true -> "" end ++ Pseudo, Login, @@ -456,11 +456,10 @@ print_user(Login) when is_list(Login) -> {erreur, "Login pas trouvé : " ++ Login} end; % Affichage d'un user en fonction de son id -print_user(Id) when is_integer(Id) -> - case euphorik_bd:user_by_id(Id) of +print_user(Id) when is_integer(Id) -> + case euphorik_bd:user_by_id(Id) of {ok, User} -> print_user(User); _ -> {erreur, "Id pas trouvé : " ++ integer_to_list(Id)} end. - \ No newline at end of file