Packages
rocksdb
1.5.1
3.1.1
3.1.0
3.0.0
2.6.2
2.6.1
retired
2.6.0
retired
2.5.0
2.4.1
2.4.0
2.3.0
2.2.0
2.1.0
2.0.0
1.9.0
1.8.0
1.7.0
1.6.0
1.5.1
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.0
1.1.1
1.1.0
1.0.0
0.26.2
0.26.1
0.26.0
0.25.0
0.24.0
0.23.3
0.23.2
0.23.1
0.23.0
0.22.0
0.21.0
0.20.1
0.20.0
0.19.0
0.18.0
0.17.0
0.16.0
0.15.0
0.14.0
0.13.1
0.13.0
0.12.0
0.11.0
0.10.0
0.9.1
0.9.0
0.8.2
0.8.1
0.8.0
0.7.1
0.7.0
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
RocksDB for Erlang
Current section
Files
Jump to
Current section
Files
test/db_range.erl
%%%-------------------------------------------------------------------
%%% @author benoitc
%%% @copyright (C) 2017-2020, Benoit Chesneau
%%% @doc
%%%
%%% @end
%%% Created : 28. Aug 2017 20:39
%%%-------------------------------------------------------------------
-module(db_range).
-author("benoitc").
%% API
-include_lib("eunit/include/eunit.hrl").
delete_range_test() ->
rocksdb_test_util:rm_rf("ltest"), % NOTE
{ok, Ref} = rocksdb:open("ltest", [{create_if_missing, true}]),
try
rocksdb:put(Ref, <<"a">>, <<"1">>, []),
rocksdb:put(Ref, <<"b">>, <<"2">>, []),
rocksdb:put(Ref, <<"c">>, <<"3">>, []),
rocksdb:put(Ref, <<"d">>, <<"4">>, []),
rocksdb:put(Ref, <<"e">>, <<"5">>, []),
ok = rocksdb:delete_range(Ref, <<"b">>, <<"e">>, []),
[<<"a">>, <<"e">>] = lists:reverse(
rocksdb:fold_keys(
Ref,
fun(K, Acc) -> [K | Acc] end,
[],
[]
)
)
after
rocksdb:close(Ref),
rocksdb:destroy("ltest", []),
rocksdb_test_util:rm_rf("ltest")
end.
cf_delete_range_test() ->
rocksdb_test_util:rm_rf("ltest"), %% NOTE
{ok, Ref} = rocksdb:open("ltest", [{create_if_missing, true}]),
{ok, TestH} = rocksdb:create_column_family(Ref, "test", []),
try
rocksdb:put(Ref, TestH, <<"a">>, <<"1">>, []),
rocksdb:put(Ref, TestH, <<"b">>, <<"2">>, []),
rocksdb:put(Ref, TestH, <<"c">>, <<"3">>, []),
rocksdb:put(Ref, TestH, <<"d">>, <<"4">>, []),
rocksdb:put(Ref, TestH, <<"e">>, <<"5">>, []),
ok = rocksdb:delete_range(Ref, TestH, <<"b">>, <<"e">>, []),
[<<"a">>, <<"e">>] = lists:reverse(
rocksdb:fold_keys(
Ref,
TestH,
fun(K, Acc) -> [K | Acc] end,
[],
[]
)
)
after
rocksdb:close(Ref),
rocksdb:destroy("ltest", []),
rocksdb_test_util:rm_rf("ltest")
end.