0

構造 {id,name} を持つ「md」という名前のテーブル、md からレコードを読み取りたいページング クエリを使用します。以下のように mnesia:select/4 と mnesia:select/1 を試しました。

%% first use select/2: "ID < 10",returned [1,2,4,3,8,5,9,7,6]
(ejabberd@localhost)5> mnesia:activity(transaction,fun mnesia:select/2,md,                 [{{md,'$1','_'},[{'<','$1',10}],['$1']}]).
{atomic,[1,2,4,3,8,5,9,7,6]}

%%but when query with select/4,returned [6], why?
(ejabberd@localhost)7> {atomic,{R1,C1}}=mnesia:activity(transaction,fun mnesia:select/4,md,[{{md,'$1','_'},[{'<','$1',10}],['$1']}],5,read).
{atomic,{[6],
     {mnesia_select,md,
                    {tid,10535470,<0.460.0>},
                    ejabberd@localhost,disc_only_copies,
                    {dets_cont,select,5,
                               <<0,0,0,29,18,52,86,120,0,0,0,21,131,104,3,...>>,
                               {141720,148792,<<>>},
                               md,<0.130.0>,<<>>},
                    [],undefined,undefined,
                    [{{md,'$1','_'},[{'<','$1',10}],['$1']}]}}}
%% and then use mnesia:select/1 with continuation "C1",got wrong_transaction
(ejabberd@localhost)8> mnesia:activity(transaction,fun mnesia:select/1,C1).
{aborted,wrong_transaction}

ページング クエリに mnesia:select/4 と mnesia:select/1 を使用するには?

4

2 に答える 2

0

同じトランザクション内で select/1 を呼び出す必要があります。

そうしないと、select/4 と select/1 の呼び出しの間でテーブルが変わる可能性があります。

上記のように使用する場合は、ダーティ コンテキストを使用する必要があります。

于 2013-08-15T10:43:38.167 に答える
0

これが私の解決策です：トランザクションの代わりにasync_dirtyを使用してください 

{Record,Cont}=mnesia:activity(async_dirty, fun mnesia:select/4,[md,[{Match_head,[Guard],[Result]}],Limit,read])

次に、次のレコードの制限数を読み取ります。

mnesia:activity(async_dirty, fun mnesia:select/1,[Cont])

完全なコード:

-record(md,{id,name}).
batch_delete(Id,Limit) ->
    Match_head = #md{id='$1',name='$2'},
    Guard = {'<','$1',Id},
    Result = '$_',
    {Record,Cont} = mnesia:activity(async_dirty, fun mnesia:select/4,[md,[{Match_head,[Guard],[Result]}],Limit,read]),
    delete_next({Record,Cont}).

delete_next('$end_of_table') ->
    over;
delete_next({Record,Cont}) ->
    delete(Record),
    delete_next(mnesia:activity(async_dirty, fun mnesia:select/1,[Cont])).

delete(Records) ->
    io:format("delete(~p)~n",[Records]),
    F = fun() ->
        [ mnesia:delete_object(O) || O <- Records]
    end,
    mnesia:transaction(F).
于 2013-08-17T13:06:16.467 に答える