MOD amélioration de la vitesse de la fonction euphorik_bd_conversation:conversations_...

[euphorik.git] / modules / erl / euphorik_minichat_conversation.erl

diff --git a/modules/erl/euphorik_minichat_conversation.erl b/modules/erl/euphorik_minichat_conversation.erl
index 2f932e2..4d0b3a8 100755 (executable)
--- 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\r
 % des messages auquels il répond\r
 % @type Message() = {#minichat, [int()]}\r
-% \r
-\r
+
 \r
 -module(euphorik_minichat_conversation).\r
 -export([\r
@@ -40,10 +39,8 @@
 ]).\r
 -include("../include/euphorik_bd.hrl").\r
 -include("../include/euphorik_defines.hrl").\r
--include_lib("stdlib/include/qlc.hrl").\r
 -import(lists, [reverse/1, any/2, map/2, sublist/3, filter/2]).\r
 -import(euphorik_bd, [resultat_transaction/1]).\r
--import(qlc, [e/2, q/1]).\r
 -import(mnesia, [table/1, transaction/1]).\r
   \r
    \r
@@ -111,26 +108,22 @@ mise_en_forme_conversation(Messages) ->
 % @spec conversations_detailees([{integer(), integer()}], integer(), integer(), integer()) -> [[{integer(), bool()}] | Conversation_detailee()]\r
 conversations_detailees(Racines, N, D, P) ->   \r
    Conversations = map(fun({Racine, P_conv, Dernier}) -> conversation(Racine, N, Dernier, P_conv) end, Racines),\r
-   Conversation_principale = resultat_transaction(transaction(fun() ->\r
-      Curseur = qlc:cursor(\r
-         qlc:sort(q([E#minichat.id || E <- table(minichat)]), [{order, descending}]),\r
-         [{tmpdir, ?KEY_SORT_TEMP_DIR}]\r
-      ),\r
-      {CP, Plus} = conversation_principale(Curseur, Conversations, N, P),\r
-      qlc:delete_cursor(Curseur),\r
+   Conversation_principale = resultat_transaction(transaction(fun() ->
+      Dernier_id = mnesia:last(minichat),\r
+      {CP, Plus} = conversation_principale(Dernier_id, Conversations, N, P),\r
       {[M || M <- CP, M > D], Plus} % filtre en fonction de D\r
    end)),\r
    [Conversation_principale | Conversations].\r
    \r
 \r
-% Construit la conversation principale en fonction d'un curseur C initialement placé sur le dernier message\r
+% Construit la conversation principale en fonction d'un id de message initialement placé sur le dernier message\r
 % et la liste de conversations.\r
 % N est le nombre de messages que l'on souhaite.\r
 % P est le numéro de la page (1, 2, 3...)\r
-% @spec conversation_principale(qlc:QueryCursor(), [Conversation_detailee()], integer(), integer()) -> {[integer()], bool()}\r
-conversation_principale(C, Conversations, N, P) ->\r
+% @spec conversation_principale(integer(), [Conversation_detailee()], integer(), integer()) -> {[integer()], bool()}\r
+conversation_principale(Id, Conversations, N, P) ->\r
    % on prend en message de plus pour savoir s'il y en a plus que ce que l'on désire\r
-   CP = reverse(conversation_principale2(C, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N)),\r
+   CP = reverse(conversation_principale2(Id, lists:flatten(map(fun({C2, _, X, _}) -> C2 -- X end, Conversations)), N + 1, (P - 1) * N)),\r
    Plus = length(CP) =:= N + 1,\r
    {\r
       if Plus ->\r
@@ -143,25 +136,25 @@ conversation_principale(C, Conversations, N, P) ->
    }.\r
       \r
       \r
-% C est le curseur (voir ci dessus)\r
+% Id est l'id d'un message, voir ce dessus\r
 % 'Messages' sont les messages que l'on doit enlever de la conversation\r
 % S est le nombre de messages qu'il faut sauter.\r
-% @spec conversation_principale2(qlc:QueryCursor(), [integer()], integer(), integer()) -> [integer()]\r
+% @spec conversation_principale2(integer(), [integer()], integer(), integer()) -> [integer()]\r
 conversation_principale2(_, _, 0, _) ->\r
+   [];
+conversation_principale2('$end_of_table', _, _, _) ->
    [];\r
-conversation_principale2(C, Messages, N, S) ->\r
-   case qlc:next_answers(C, 1) of\r
-      [] -> [];\r
-      [M] -> % traitement message par message (pas des plus performant :/)\r
-         Doit_etre_saute = any(fun(E) -> E == M end, Messages),\r
-         if  Doit_etre_saute -> \r
-               conversation_principale2(C, Messages, N, S); % le message ne fait pas partie de la conversation\r
-            S =:= 0 ->\r
-               [M | conversation_principale2(C, Messages, N - 1, S)]; % ok : le message fait partie de la conversation\r
-            true ->\r
-               conversation_principale2(C, Messages, N, S - 1) % on n'a pas encore atteint le début de la page\r
-         end\r
-   end.\r
+conversation_principale2(Id, Messages, N, S) ->
+   % traitement message par message (pas des plus performant :/)
+   Id_prev = mnesia:prev(minichat, Id),\r
+   Doit_etre_saute = any(fun(E) -> E == Id end, Messages),\r
+   if  Doit_etre_saute -> \r
+         conversation_principale2(Id_prev, Messages, N, S); % le message ne fait pas partie de la conversation\r
+      S =:= 0 ->\r
+         [Id | conversation_principale2(Id_prev, Messages, N - 1, S)]; % ok : le message fait partie de la conversation\r
+      true ->\r
+         conversation_principale2(Id_prev, Messages, N, S - 1) % on n'a pas encore atteint le début de la page\r
+      end.\r
    \r
    \r
 % Renvoie un tuple {C, Cn, X, Plus} où\r