riak search

langzhe

浏览: 284729 次
性别:
来自: 北京

最近访客更多访客>>

WoKo_Jb

perfect_control

u012781923

apple8422

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

riak

现在search查询还是空

Simon 11:53:44

这数据库太新，不好把握，还是用成熟一点的比较好吧

建完bucket，附带了precommit属性，才会建索引

之前的数据是查不出的

Simon 11:54:59

索引里面没有

建索引的时候不会遍历老数据

Android郎哲<langxianzhe@163.com> 11:55:30

我发你我创建的过程你看看，哪里不对

Android郎哲<langxianzhe@163.com> 11:57:56

第一步

Client:set_bucket(<<"g2">>,[{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).

第二步

f(O0),O0 = riak_object:new(<<"g2">>, <<"mine">>, <<"bread">>).

第三步

(riak@127.0.0.1)108> C:put(O0).

我的理解是以上三步就可以完成了

Android郎哲<langxianzhe@163.com> 11:59:36

以下是执行

search的结果

(riak@127.0.0.1)109> search:search_doc(<<"g2">>, <<"bread">>)

(riak@127.0.0.1)109> .

{1,"0.353553",

[{riak_idx_doc,<<"g2">>,<<"mine">>,

[{<<"value">>,<<"bread">>,[{<<"bread">>,[0]}]}],

[],[],true}]}

(riak@127.0.0.1)110> search:search_doc(<<"g2">>, <<"bre">>)

(riak@127.0.0.1)110> .

{0,"0.0",[]}

(riak@127.0.0.1)111> search:search_doc(<<"g2">>)

(riak@127.0.0.1)111> .

{0,"0.0",[]}

(riak@127.0.0.1)112> search:search(<<"g2">>, <<"bread">>)

(riak@127.0.0.1)112> .

{1,

[{<<"g2">>,<<"mine">>,

[{p,[0]},{score,0.35355339059327373}]}]}

(riak@127.0.0.1)113> search:search(<<"g2">>, "bread")

(riak@127.0.0.1)113> .

{1,

[{<<"g2">>,<<"mine">>,

[{p,[0]},{score,0.35355339059327373}]}]}

(riak@127.0.0.1)114> search:search(<<"g2">>, "bre")

(riak@127.0.0.1)114> .

{0,[]}

(riak@127.0.0.1)115> search:search(<<"g2">>)

(riak@127.0.0.1)115> .

{0,[]}

Android郎哲<langxianzhe@163.com> 12:01:15

为什么 search:search(<<"g2">>)和search:search_doc(<<"g2">>) 返回是空的

Simon 12:01:46

不是已经能查出来了吗

(riak@127.0.0.1)112> search:search(<<"g2">>, <<"bread">>)

(riak@127.0.0.1)112> .

{1,

[{<<"g2">>,<<"mine">>,

[{p,[0]},{score,0.35355339059327373}]}]}

Android郎哲<langxianzhe@163.com> 12:02:44

这个是根据具体的key查出来的，模糊的key还查不出来

Simon 12:03:02

模糊查询？

Android郎哲<langxianzhe@163.com> 12:03:07

对

这个不是全文检索功能吗

Simon 12:03:45

试试<<"bre*">>

Android郎哲<langxianzhe@163.com> 12:04:54

<<"bre*">>

可以查出

<<"*re*">>查不出

Simon 12:05:26

我想起来了，反向索引就是用bread这个值建了一个key

Android郎哲<langxianzhe@163.com> 12:05:41

什么意思请详解

Simon 12:05:54

然后把值为bread的key当成一个列表存起来

底层原理就是这样

Android郎哲<langxianzhe@163.com> 12:07:48

你是说它把存储的value当做key索引存储了一边

Simon 12:07:58

让我哭的就是，你想查出值为bread的所有记录，他只是返回key列表，你还得根据这个列表挨个找出value

是的

Android郎哲<langxianzhe@163.com> 12:09:05

再根据Key查找value也好，

<<*re*>>

查不出来如何解释

Simon 12:12:32

一个桶的底层存储结构是这样：

key value

{key, <<"g2">>, <<"mine">>} <<"bread">>

{key, <<"g2">>, <<"you">>} <<"bread">>

{index, <<"g2">>, <<"bread">>} [<<"mine">>,<<"you">>]

只是示意一下，实际的你得看key的组成规则

Android郎哲<langxianzhe@163.com> 12:15:10

嗯明白

Android郎哲<langxianzhe@163.com> 12:16:24

search:search(<<"g2">>)查询为什么查询不到索引呢，现在仍然是空

(riak@127.0.0.1)144> search:search(<<"g2">>).

{0,[]}

-----26> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("<<\"orange\">>:<<\"bread\">>"),[],5000).

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},

{<<"g2">>,

[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],

0.07724899798631668,2}}

27>

27> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("<<\"orange\">><<\"bread\">>"),[],5000).

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},

{<<"g2">>,

[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],

0.07724899798631668,2}}

* 2: syntax error before: '.'

35> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("orangebread"),[],5000).

{ok,{search_results,[],0.0,0}}

36> riakc_pb_socket:search(Pid,<<"g2">>, list_to_binary("orange\"\"bread"),[],5000).

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},

{<<"g2">>,

[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],

0.2959290146827698,2}}

53> riakc_pb_socket:search(Pid,<<"g2">>, "br*\"\"or*").

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"mine">>},{<<"value">>,<<"bread">>}]},

{<<"g2">>,

[{<<"id">>,<<"your">>},{<<"value">>,<<"orange">>}]}],

0.0,2}}

54>

73> riakc_pb_socket:search(Pid,<<"g2">>, HerBin).

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"her">>},

{<<"value">>,

<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,

2,...>>}]}],

0.35355299711227417,1}}

74> HerBin.

<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,2,

120,119,104,2,107,0,1,115,107,0,1,...>>

75> binary_to_term(HerBin).

[{"name","xw"},{"s","d"}]

76> riakc_pb_socket:search(Pid,<<"g2">>, HerBin).

{ok,{search_results,[{<<"g2">>,

[{<<"id">>,<<"her">>},

{<<"value">>,

<<131,108,0,0,0,2,104,2,107,0,4,110,97,109,101,107,0,

2,...>>}]}],

0.35355299711227417,1}}

77>

--------------------------------

(riak@127.0.0.1)43> lucene_scan:string("name:jason").

{ok,[{string,1,"name"},{scope,1,":"},{string,1,"jason"}],1}

(riak@127.0.0.1)45> lucene_scan:string("namejason*").

{ok,[{wildcard_glob,1,"namejason*"}],1}

[{'query',[{wildcard_glob,1,"namejason*"}]}, {'filter', []}];

[{'query', QueryOps}, {'filter', FilterOps}];

-----------------------------9> riakc_pb_socket:put(Pid,O).

50> riakc_pb_socket:list_buckets(Pid).

{ok,[<<"user">>]}

51> riakc_pb_socket:set_bucket(Pid, <<"user">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).

52> riakc_pb_socket:list_buckets(Pid).

{ok,[<<"user">>]}

53> f(O),O=riakc_obj:new(<<"user">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").

{riakc_obj,<<"user">>,<<"jason">>,undefined,[],

{dict,1,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},

{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},

<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}

54> riakc_pb_socket:put(Pid,O).

55> riakc_pb_socket:list_buckets(Pid).

{ok,[<<"user">>]}

56> riakc_pb_socket:set_bucket(Pid, <<"user">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).

57> riakc_pb_socket:set_bucket(Pid, <<"users">>, [{precommit, [{struct,[{<<"mod">>,<<"riak_search_kv_hook">>},{<<"fun">>,<<"precommit">>}]}]}]).

58> f(O),O=riakc_obj:new(<<"users">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").

{riakc_obj,<<"users">>,<<"jason">>,undefined,[],

{dict,1,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},

{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},

<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}

59> riakc_pb_socket:put(Pid,O).

60> f(O),O=riakc_obj:new(<<"user2">>, <<"jason">>, list_to_binary("[{\"name\":\"jason\"},{\"sex\":\"male\"}]"), "application/json").

{riakc_obj,<<"user2">>,<<"jason">>,undefined,[],

{dict,1,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],...},

{{[],[],[],[],[],[],[],[],[],[],[[<<...>>|...]],[],[],...}}},

<<"[{\"name\":\"jason\"},{\"sex\":\"male\"}]">>}

61> riakc_pb_socket:put(Pid,O).

62> riakc_pb_socket:search(Pid, <<"users">>, "sdf").

{ok,{search_results,[],0.0,0}}

63> riakc_pb_socket:search(Pid, <<"users">>, "name:jason").

{ok,{search_results,[],0.0,0}}

64> riakc_pb_socket:search(Pid, <<"users">>, <<"name:jason">>).

{ok,{search_results,[],0.0,0}}

65> riakc_pb_socket:search(Pid, <<"users">>, "\"name\":\"jason\"").

{ok,{search_results,[],0.0,0}}

66> riakc_pb_socket:search(Pid, <<"users">>, list_to_binary("\"name\":\"jason\"")).

{ok,{search_results,[],0.0,0}}

67> riakc_pb_socket:search(Pid, <<"user3">>, list_to_binary("\"name\":\"jason\"")).

{ok,{search_results,[],0.0,0}}

68> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"name\":\"jason\"")).

{ok,{search_results,[{<<"user2">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.35355299711227417,1}}

69> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).

{ok,{search_results,[{<<"user2">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.35355299711227417,1}}

70> riakc_pb_socket:search(Pid, <<"users">>, "\"name\":\"jason\"").

{ok,{search_results,[],0.0,0}}

71> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"name\":\"jason\"")).

{ok,{search_results,[{<<"user2">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.35355299711227417,1}}

72> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).

{ok,{search_results,[{<<"user2">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.35355299711227417,1}}

73> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"mal*\"")).

{ok,{search_results,[],0.0,0}}

74> riakc_pb_socket:search(Pid, <<"user2">>, list_to_binary("\"sex\":\"male\"")).

{ok,{search_results,[{<<"user2">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.35355299711227417,1}}

sss

-----------------------------------------------模糊匹配查询-------------------------------------------

(ejabberd@meta)56> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":\"jaso*\"")).

{ok,{search_results,[],0.0,0}}

(ejabberd@meta)57> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":jason*")).

{ok,{search_results,[{<<"user1">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.0,1}}

(ejabberd@meta)58> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":ja*")).

{ok,{search_results,[{<<"user1">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.0,1}}

(ejabberd@meta)59> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":*")).

{ok,{search_results,[],0.0,0}}

(ejabberd@meta)60> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":j*")).

{ok,{search_results,[],0.0,0}}

(ejabberd@meta)61> riakc_pb_socket:search(Pid, <<"user1">>, list_to_binary("\"name\":ja*")).

{ok,{search_results,[{<<"user1">>,

[{<<"id">>,<<"jason">>},

{<<"name">>,<<"jason">>},

{<<"sex">>,<<"male">>}]}],

0.0,1}}

(ejabberd@meta)62>

---------------------------------------

riak search 查询中文问题，查了好多资料也没有解决，最后我不得不把所有字段用base64来编码，查询也是把条件编码完在查询的

分享到：

riak erlanl client search 新特性 | [MapReduce] in state wait_for_input term ...

2012-10-09 15:53
浏览 1007
评论(0)
分类:编程语言
查看更多

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

riak search

评论

发表评论

相关推荐

最近访客 更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论

riak search

评论

发表评论

相关推荐

解决更新自定义mapreduce代码 需要riak重启问题

两个周前挖了一个坑，现在跳了进去<riak mapreduce 分析>,顺便能实现分页功能了

riak mapreduce worker_limit_reached 错误

riak mapreduce worker_limit_reached 错误

riak second index 组合键

Riak failed to start within 15 seconds

riak erlanl client search 新特性

[MapReduce] in state wait_for_input terminated with reason: processing_error

根据 Second Index和 mapred查询数据

The "modfun" input type is not widely used outside of Riak

riak MapReduce 中的 {index, bucket(), Index::binary(), key()} 使用方法

MapReduce riak

Secondary Indexes in nosql of riak

riak C:get() 后台跑出异常 > in state waiting_vnode_r terminated with re

最近访客更多访客>>

解决更新自定义mapreduce代码需要riak重启问题