From: Greg Burri <greg.burri@gmail.com>
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ù