1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
|
module Groonga
class ScanInfoData
attr_accessor :start
attr_accessor :end
attr_accessor :op
attr_accessor :logical_op
attr_accessor :query
attr_accessor :args
attr_accessor :indexes
attr_accessor :flags
attr_accessor :max_interval
attr_accessor :similarity_threshold
def initialize(start)
@start = start
@end = 0
@op = 0
@logical_op = Operator::OR
@query = nil
@args = []
@indexes = []
@flags = ScanInfo::Flags::PUSH
@max_interval = nil
@similarity_threshold = nil
end
def match_resolve_index
if near_search?
match_near_resolve_index
elsif similar_search?
match_similar_resolve_index
else
match_generic_resolve_index
end
end
def call_relational_resolve_indexes
# better index resolving framework for functions should be implemented
@args.each do |arg|
call_relational_resolve_index(arg)
end
end
private
def near_search?
(@op == Operator::NEAR or @op == Operator::NEAR2) and @args.size == 3
end
def match_near_resolve_index
arg = @args[0]
case arg
when Expression
match_resolve_index_expression(arg)
when Accessor
match_resolve_index_accessor(arg)
when Object
match_resolve_index_db_obj(arg)
else
message =
"The first argument of NEAR/NEAR2 must be Expression, Accessor or Object: #{arg.class}"
raise message
end
self.query = @args[1]
self.max_interval = @args[2].value
end
def similar_search?
@op == Operator::SIMILAR and @args.size == 3
end
def match_similar_resolve_index
arg = @args[0]
case arg
when Expression
match_resolve_index_expression(arg)
when Accessor
match_resolve_index_accessor(arg)
when Object
match_resolve_index_db_obj(arg)
else
message =
"The first argument of SIMILAR must be Expression, Accessor or Object: #{arg.class}"
raise message
end
self.query = @args[1]
self.similarity_threshold = @args[2].value
end
def match_generic_resolve_index
@args.each do |arg|
case arg
when Expression
match_resolve_index_expression(arg)
when Accessor
match_resolve_index_accessor(arg)
when Object
match_resolve_index_db_obj(arg)
else
self.query = arg
end
end
end
def match_resolve_index_expression(expression)
codes = expression.codes
n_codes = codes.size
i = 0
while i < n_codes
code = codes[i]
value = code.value
case value
when Accessor
match_resolve_index_expression_accessor(code)
when FixedSizeColumn, VariableSizeColumn
match_resolve_index_expression_data_column(code)
when IndexColumn
section_id = 0
rest_n_codes = n_codes - i
if rest_n_codes >= 2 and
codes[i + 1].value.is_a?(Bulk) and
codes[i + 1].value.domain == ID::UINT32 and
codes[i + 2].op == Operator::GET_MEMBER
section_id = codes[i + 1].value.value + 1
code = codes[i + 2]
i += 2
end
put_index(value, section_id, code.weight)
end
i += 1
end
end
def match_resolve_index_expression_accessor(expr_code)
accessor = expr_code.value
self.flags |= ScanInfo::Flags::ACCESSOR
index_info = accessor.find_index(op)
return if index_info.nil?
if accessor.next
put_index(accessor, index_info.section_id, expr_code.weight)
else
put_index(index_info.index, index_info.section_id, expr_code.weight)
end
end
def match_resolve_index_expression_data_column(expr_code)
column = expr_code.value
index_info = column.find_index(op)
return if index_info.nil?
put_index(index_info.index, index_info.section_id, expr_code.weight)
end
def match_resolve_index_db_obj(db_obj)
index_info = db_obj.find_index(op)
return if index_info.nil?
put_index(index_info.index, index_info.section_id, 1)
end
def match_resolve_index_accessor(accessor)
self.flags |= ScanInfo::Flags::ACCESSOR
index_info = accessor.find_index(op)
return if index_info.nil?
if accessor.next
put_index(accessor, index_info.section_id, 1)
else
put_index(index_info.index, index_info.section_id, 1)
end
end
def call_relational_resolve_index(object)
case object
when Accessor
call_relational_resolve_index_accessor(object)
when Bulk
self.query = object
else
call_relational_resolve_index_db_obj(object)
end
end
def call_relational_resolve_index_db_obj(db_obj)
index_info = db_obj.find_index(op)
return if index_info.nil?
put_index(index_info.index, index_info.section_id, 1)
end
def call_relational_resolve_index_accessor(accessor)
self.flags |= ScanInfo::Flags::ACCESSOR
index_info = accessor.find_index(op)
return if index_info.nil?
put_index(index_info.index, index_info.section_id, 1)
end
def put_index(index, section_id, weight)
@indexes << [index, section_id, weight]
end
end
end
|
