From: Greg Burri Date: Sat, 4 Oct 2008 14:51:41 +0000 (+0000) Subject: MOD amélioration de la vitesse de la fonction euphorik_bd_conversation:conversations_... X-Git-Tag: 1.1.3~22 X-Git-Url: http://git.euphorik.ch/index.cgi?a=commitdiff_plain;h=2b1fd1fef9cf628a19f6452ee8375f3091a9f1d4;p=euphorik.git MOD amélioration de la vitesse de la fonction euphorik_bd_conversation:conversations_detailees en évitant l'utilisation de qlc et d'un sort MOD mise à jour du num de version --- diff --git a/VERSION b/VERSION index 8428158..9c1218c 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.1.2 \ No newline at end of file +1.1.3 \ No newline at end of file diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl index 2f932e2..4d0b3a8 100755 --- a/modules/erl/euphorik_minichat_conversation.erl +++ b/modules/erl/euphorik_minichat_conversation.erl @@ -31,8 +31,7 @@ % Un message est un tuple représentant le message et la liste des id % des messages auquels il répond % @type Message() = {#minichat, [int()]} -% - + -module(euphorik_minichat_conversation). -export([ @@ -40,10 +39,8 @@ ]). -include("../include/euphorik_bd.hrl"). -include("../include/euphorik_defines.hrl"). --include_lib("stdlib/include/qlc.hrl"). -import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]). -import(euphorik_bd, [resultat_transaction/1]). --import(qlc, [e/2, q/1]). -import(mnesia, [table/1, transaction/1]). @@ -111,26 +108,22 @@ mise_en_forme_conversation(Messages) -> % @spec conversations_detailees([{integer(), integer()}], integer(), integer(), integer()) -> [[{integer(), bool()}] | Conversation_detailee()] conversations_detailees(Racines, N, D, P) -> Conversations = map(fun({Racine, P_conv, Dernier}) -> conversation(Racine, N, Dernier, P_conv) end, Racines), - Conversation_principale = resultat_transaction(transaction(fun() -> - Curseur = qlc:cursor( - qlc:sort(q([E#minichat.id || E <- table(minichat)]), [{order, descending}]), - [{tmpdir, ?KEY_SORT_TEMP_DIR}] - ), - {CP, Plus} = conversation_principale(Curseur, Conversations, N, P), - qlc:delete_cursor(Curseur), + Conversation_principale = resultat_transaction(transaction(fun() -> + Dernier_id = mnesia:last(minichat), + {CP, Plus} = conversation_principale(Dernier_id, Conversations, N, P), {[M || M <- CP, M > D], Plus} % filtre en fonction de D end)), [Conversation_principale | Conversations]. -% Construit la conversation principale en fonction d'un curseur C initialement placé sur le dernier message +% Construit la conversation principale en fonction d'un id de message initialement placé sur le dernier message % et la liste de conversations. % N est le nombre de messages que l'on souhaite. % P est le numéro de la page (1, 2, 3...) -% @spec conversation_principale(qlc:QueryCursor(), [Conversation_detailee()], integer(), integer()) -> {[integer()], bool()} -conversation_principale(C, Conversations, N, P) -> +% @spec conversation_principale(integer(), [Conversation_detailee()], integer(), integer()) -> {[integer()], bool()} +conversation_principale(Id, Conversations, N, P) -> % on prend en message de plus pour savoir s'il y en a plus que ce que l'on désire - CP = reverse(conversation_principale2(C, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N)), + CP = reverse(conversation_principale2(Id, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N)), Plus = length(CP) =:= N + 1, { if Plus -> @@ -143,25 +136,25 @@ conversation_principale(C, Conversations, N, P) -> }. -% C est le curseur (voir ci dessus) +% Id est l'id d'un message, voir ce dessus % 'Messages' sont les messages que l'on doit enlever de la conversation % S est le nombre de messages qu'il faut sauter. -% @spec conversation_principale2(qlc:QueryCursor(), [integer()], integer(), integer()) -> [integer()] +% @spec conversation_principale2(integer(), [integer()], integer(), integer()) -> [integer()] conversation_principale2(_, _, 0, _) -> + []; +conversation_principale2('$end_of_table', _, _, _) -> []; -conversation_principale2(C, Messages, N, S) -> - case qlc:next_answers(C, 1) of - [] -> []; - [M] -> % traitement message par message (pas des plus performant :/) - Doit_etre_saute = any(fun(E) -> E == M end, Messages), - if Doit_etre_saute -> - conversation_principale2(C, Messages, N, S); % le message ne fait pas partie de la conversation - S =:= 0 -> - [M | conversation_principale2(C, Messages, N - 1, S)]; % ok : le message fait partie de la conversation - true -> - conversation_principale2(C, Messages, N, S - 1) % on n'a pas encore atteint le début de la page - end - end. +conversation_principale2(Id, Messages, N, S) -> + % traitement message par message (pas des plus performant :/) + Id_prev = mnesia:prev(minichat, Id), + Doit_etre_saute = any(fun(E) -> E == Id end, Messages), + if Doit_etre_saute -> + conversation_principale2(Id_prev, Messages, N, S); % le message ne fait pas partie de la conversation + S =:= 0 -> + [Id | conversation_principale2(Id_prev, Messages, N - 1, S)]; % ok : le message fait partie de la conversation + true -> + conversation_principale2(Id_prev, Messages, N, S - 1) % on n'a pas encore atteint le début de la page + end. % Renvoie un tuple {C, Cn, X, Plus} où