riak-playground

#!/usr/bin/env escript
%% -*- erlang -*-
%%! -sasl errlog_type error  -name tester -noshell  -setcookie riak
%%-kernel error_logger silent 
%define(D(S, T), io:format(S++"~n", T)).
-define(D(S), io:format("Debug : ~p~n", [S])).

main(_)->
  {ok, C} = riak:client_connect([email protected]),
  Mine = riak_object:new(<<"groceries">>, <<"mine">>, ["eggs", "bacon"]),
  C:put(Mine, 1),
  Yours = riak_object:new(<<"groceries">>, <<"yours">>, ["eggs", "wine"]),
  C:put(Yours, 2),
  d(C:list_keys(<<"groceries">>)),
  {ok, Oa} = C:get(<<"groceries">>, <<"mine">>, 2),
  d(riak_object:get_value(Oa)),
  d(dict:to_list(riak_object:get_metadata(Oa))),
  Ob = riak_object:update_value(Oa, ["ice cream"|riak_object:get_value(Oa)]),
  C:put(Ob, 2),
  
  Count = fun(G, undefined, none) ->
             [dict:from_list([{I, 1} || I <- riak_object:get_value(G)])]
           end,
  Merge = fun(Gcounts, none) ->
             [lists:foldl(fun(G, Acc) ->
                    dict:merge(fun(_, X, Y) -> X+Y end,
                            G, Acc)
                    end,
            dict:new(),Gcounts)]
           end,
  {ok, [R]} = C:mapred([{<<"groceries">>, <<"mine">>},{<<"groceries">>, <<"yours">>}],
                             [{map, {qfun, Count}, none, false},
                              {reduce, {qfun, Merge}, none, true}]),
   d(dict:to_list(R)),
  
  
  C:delete(<<"groceries">>, <<"mine">>, 1),
  C:delete(<<"groceries">>, <<"yours">>, 1),
  d(C:list_keys(<<"groceries">>)).
  
  
d({ok, V})->
  d(V);
d(V)->
  io:format("Output : ~p~n", [V]).