Class: Chewy::Query
- Includes:
- Loading, Pagination, Search::Scoping, Enumerable
- Defined in:
- lib/chewy/query.rb,
lib/chewy/query/compose.rb,
lib/chewy/query/filters.rb,
lib/chewy/query/loading.rb,
lib/chewy/query/criteria.rb,
lib/chewy/query/nodes/or.rb,
lib/chewy/query/nodes/and.rb,
lib/chewy/query/nodes/not.rb,
lib/chewy/query/nodes/raw.rb,
lib/chewy/query/nodes/base.rb,
lib/chewy/query/nodes/bool.rb,
lib/chewy/query/nodes/expr.rb,
lib/chewy/query/pagination.rb,
lib/chewy/query/nodes/equal.rb,
lib/chewy/query/nodes/field.rb,
lib/chewy/query/nodes/query.rb,
lib/chewy/query/nodes/range.rb,
lib/chewy/query/nodes/exists.rb,
lib/chewy/query/nodes/prefix.rb,
lib/chewy/query/nodes/regexp.rb,
lib/chewy/query/nodes/script.rb,
lib/chewy/query/nodes/missing.rb,
lib/chewy/query/nodes/has_child.rb,
lib/chewy/query/nodes/match_all.rb,
lib/chewy/query/nodes/has_parent.rb,
lib/chewy/query/nodes/has_relation.rb
Overview
Query allows you to create ES search requests with convenient chainable DSL. Queries are lazy evaluated and might be merged. The same DSL is used for whole index or individual types query build.
Defined Under Namespace
Modules: Compose, Loading, Nodes, Pagination Classes: Criteria, Filters
Constant Summary collapse
- DELEGATED_METHODS =
%i[ explain query_mode filter_mode post_filter_mode timeout limit offset highlight min_score rescore facets script_score boost_factor weight random_score field_value_factor decay aggregations suggest none strategy query filter post_filter boost_mode score_mode order reorder only types delete_all find total total_count total_entries unlimited script_fields track_scores preference ].to_set.freeze
Instance Attribute Summary collapse
-
#_indexes ⇒ Object
readonly
Returns the value of attribute _indexes.
-
#_types ⇒ Object
readonly
Returns the value of attribute _types.
-
#criteria ⇒ Object
readonly
Returns the value of attribute criteria.
-
#options ⇒ Object
readonly
Returns the value of attribute options.
Instance Method Summary collapse
-
#==(other) ⇒ Object
Comparation with other query or collection If other is collection - search request is executed and result is used for comparation.
- #_build_fqn_aggs ⇒ Object
-
#_build_named_aggs ⇒ Object
In this simplest of implementations each named aggregation must be uniquely named.
- #_get_fully_qualified_named_agg(str) ⇒ Object
-
#aggregations(params = nil) ⇒ Object
(also: #aggs)
Sets elasticsearch
aggregations
search request param. -
#boost_factor(factor, options = {}) ⇒ Object
Adds a boost factor to the search request.
-
#boost_mode(value) ⇒ Object
Sets the boost mode for custom scoring/boosting.
-
#decay(function, field, options = {}) ⇒ Object
Add a decay scoring to the search.
-
#delete_all ⇒ Object
Deletes all documents matching a query.
-
#exists? ⇒ Boolean
Returns true if there are at least one document that matches the query.
-
#explain(value = nil) ⇒ Object
Adds
explain
parameter to search request. -
#facets(params = nil) ⇒ Object
Adds facets section to the search request.
-
#field_value_factor(settings, options = {}) ⇒ Object
Add a field value scoring to the search.
-
#filter(params = nil, &block) ⇒ Object
Adds one or more filter to the search request Internally filters are stored as an array While the full query compilation this array compiles according to
:filter_mode
option value. -
#filter_mode(value) ⇒ Object
Sets query compilation mode for search request.
-
#find(*ids) ⇒ Object
Find all documents matching a query.
-
#highlight(value) ⇒ Object
Elasticsearch highlight query option support.
-
#initialize(*indexes_or_types_and_options) ⇒ Query
constructor
A new instance of Query.
-
#limit(value = nil, &block) ⇒ Object
Sets elasticsearch
size
search request param Default value is set in the elasticsearch and is 10. -
#merge(other) ⇒ Object
Merges two queries.
-
#min_score(value) ⇒ Object
Elasticsearch minscore option support.
-
#none ⇒ Object
Marks the criteria as having zero documents.
-
#offset(value = nil, &block) ⇒ Object
Sets elasticsearch
from
search request param. -
#only(*params) ⇒ Object
Sets search request field list.
-
#only!(*params) ⇒ Object
Cleans up previous search field list and sets the new one.
-
#order(*params) ⇒ Object
Sets search request sorting.
-
#post_filter(params = nil, &block) ⇒ Object
Adds one or more post_filter to the search request Internally post_filters are stored as an array While the full query compilation this array compiles according to
:post_filter_mode
option value. -
#post_filter_mode(value) ⇒ Object
Acts the same way as
filter_mode
, but used forpost_filter
. -
#preference(value) ⇒ Object
Sets
preference
for request. -
#query(params) ⇒ Object
Adds one or more query to the search request Internally queries are stored as an array While the full query compilation this array compiles according to
:query_mode
option value. -
#query_mode(value) ⇒ Object
Sets query compilation mode for search request.
-
#random_score(seed = Time.now, options = {}) ⇒ Object
Adds a random score to the search request.
-
#reorder(*params) ⇒ Object
Cleans up previous search sorting and sets the new one.
-
#rescore(value) ⇒ Object
Elasticsearch rescore query option support.
-
#score_mode(value) ⇒ Object
Sets the scoring mode for combining function scores/boosts Not used if no score functions are specified.
-
#script_fields(value) ⇒ Object
Adds
script_fields
parameter to search request. -
#script_score(script, options = {}) ⇒ Object
Adds a script function to score the search request.
-
#search_type(value) ⇒ Object
Sets
search_type
for request. -
#strategy(value = nil) ⇒ Object
Setups strategy for top-level filtered query.
-
#suggest(params = nil) ⇒ Object
Sets elasticsearch
suggest
search request param. -
#timed_out ⇒ Object
Returns request timed_out as reported by elasticsearch.
-
#timeout(value) ⇒ Object
A search timeout, bounding the search request to be executed within the specified time value and bail with the hits accumulated up to that point when expired.
-
#took ⇒ Object
Returns request total time elapsed as reported by elasticsearch.
-
#track_scores(value) ⇒ Object
Elasticsearch track_scores option support.
-
#types(*params) ⇒ Object
Specify types participating in the search result Works via
types
filter. -
#types!(*params) ⇒ Object
Acts the same way as
types
, but cleans up previously set types. -
#unlimited ⇒ Object
Sets limit to be equal to total documents count.
-
#weight(factor, options = {}) ⇒ Object
Add a weight scoring function to the search.
Methods included from Search::Scoping
Methods included from Pagination
Methods included from Loading
Constructor Details
#initialize(*indexes_or_types_and_options) ⇒ Query
Returns a new instance of Query.
35 36 37 38 39 40 41 |
# File 'lib/chewy/query.rb', line 35 def initialize(*) @options = . @_types = .select { |klass| klass < Chewy::Type } @_indexes = .select { |klass| klass < Chewy::Index } @_indexes |= @_types.map(&:index) @criteria = Criteria.new end |
Instance Attribute Details
#_indexes ⇒ Object (readonly)
Returns the value of attribute _indexes.
33 34 35 |
# File 'lib/chewy/query.rb', line 33 def _indexes @_indexes end |
#_types ⇒ Object (readonly)
Returns the value of attribute _types.
33 34 35 |
# File 'lib/chewy/query.rb', line 33 def _types @_types end |
#criteria ⇒ Object (readonly)
Returns the value of attribute criteria.
33 34 35 |
# File 'lib/chewy/query.rb', line 33 def criteria @criteria end |
#options ⇒ Object (readonly)
Returns the value of attribute options.
33 34 35 |
# File 'lib/chewy/query.rb', line 33 def @options end |
Instance Method Details
#==(other) ⇒ Object
Comparation with other query or collection If other is collection - search request is executed and result is used for comparation
52 53 54 |
# File 'lib/chewy/query.rb', line 52 def ==(other) super || other.is_a?(self.class) ? other.criteria == criteria : other == to_a end |
#_build_fqn_aggs ⇒ Object
589 590 591 592 593 594 595 596 597 598 599 600 601 |
# File 'lib/chewy/query.rb', line 589 def _build_fqn_aggs named_aggs = {} @_indexes.each do |index| named_aggs[index.to_s.downcase] ||= {} index.types.each do |type| named_aggs[index.to_s.downcase][type.to_s.downcase] ||= {} type._agg_defs.each do |agg_name, prc| named_aggs[index.to_s.downcase][type.to_s.downcase][agg_name.to_s.downcase] = prc.call end end end named_aggs end |
#_build_named_aggs ⇒ Object
In this simplest of implementations each named aggregation must be uniquely named
577 578 579 580 581 582 583 584 585 586 587 |
# File 'lib/chewy/query.rb', line 577 def _build_named_aggs named_aggs = {} @_indexes.each do |index| index.types.each do |type| type._agg_defs.each do |agg_name, prc| named_aggs[agg_name] = prc.call end end end named_aggs end |
#_get_fully_qualified_named_agg(str) ⇒ Object
603 604 605 606 607 608 609 |
# File 'lib/chewy/query.rb', line 603 def _get_fully_qualified_named_agg(str) parts = str.scan(/\A(\S+)#(\S+)\.(\S+)\z/).first idx = "#{parts[0]}index" type = "#{idx}::#{parts[1]}" agg_name = parts[2] @_fully_qualified_named_aggs[idx][type][agg_name] end |
#aggregations(params = nil) ⇒ Object Also known as: aggs
Sets elasticsearch aggregations
search request param
563 564 565 566 567 568 569 570 571 572 573 |
# File 'lib/chewy/query.rb', line 563 def aggregations(params = nil) @_named_aggs ||= _build_named_aggs @_fully_qualified_named_aggs ||= _build_fqn_aggs if params params = {params => @_named_aggs[params]} if params.is_a?(Symbol) params = {params => _get_fully_qualified_named_agg(params)} if params.is_a?(String) && params =~ /\A\S+#\S+\.\S+\z/ chain { criteria.update_aggregations params } else _response['aggregations'] || {} end end |
#boost_factor(factor, options = {}) ⇒ Object
Adds a boost factor to the search request. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
This probably only makes sense if you specify a filter for the boost factor as well
415 416 417 418 |
# File 'lib/chewy/query.rb', line 415 def boost_factor(factor, = {}) scoring = .merge(boost_factor: factor.to_i) chain { criteria.update_scores scoring } end |
#boost_mode(value) ⇒ Object
Sets the boost mode for custom scoring/boosting. Not used if no score functions are specified Possible values:
:multiply
Default value. Query score and function result are multiplied.:replace
Only function result is used, query score is ignored.:sum
Query score and function score are added.:avg
Average of query and function score.:max
Max of query and function score.:min
Min of query and function score.
Default value for :boost_mode
might be changed
with Chewy.score_mode
config option.
792 793 794 |
# File 'lib/chewy/query.rb', line 792 def boost_mode(value) chain { criteria. boost_mode: value } end |
#decay(function, field, options = {}) ⇒ Object
Add a decay scoring to the search. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
The parameters have default values, but those may not be very useful for most applications.
532 533 534 535 536 537 538 |
# File 'lib/chewy/query.rb', line 532 def decay(function, field, = {}) = .extract!(:origin, :scale, :offset, :decay).delete_if { |_, v| v.nil? } scoring = .merge(function => { field => }) chain { criteria.update_scores scoring } end |
#delete_all ⇒ Object
Deletes all documents matching a query.
975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 |
# File 'lib/chewy/query.rb', line 975 def delete_all if Runtime.version >= '2.0' plugins = Chewy.client.nodes.info(plugins: true)['nodes'].values.map { |item| item['plugins'] }.flatten raise PluginMissing, 'install delete-by-query plugin' unless plugins.find { |item| item['name'] == 'delete-by-query' } end request = chain { criteria. simple: true }.send(:_request) ActiveSupport::Notifications.instrument 'delete_query.chewy', request: request, indexes: _indexes, types: _types, index: _indexes.one? ? _indexes.first : _indexes, type: _types.one? ? _types.first : _types do if Runtime.version >= '2.0' path = Elasticsearch::API::Utils.__pathify( Elasticsearch::API::Utils.__listify(request[:index]), Elasticsearch::API::Utils.__listify(request[:type]), '/_query' ) Chewy.client.perform_request(Elasticsearch::API::HTTP_DELETE, path, {}, request[:body]).body else Chewy.client.delete_by_query(request) end end end |
#exists? ⇒ Boolean
Returns true if there are at least one document that matches the query
1028 1029 1030 |
# File 'lib/chewy/query.rb', line 1028 def exists? search_type(:count).total > 0 end |
#explain(value = nil) ⇒ Object
Adds explain
parameter to search request.
Calling explain without any arguments sets explanation flag to true.
With explain: true
, every result object has _explanation
method
70 71 72 |
# File 'lib/chewy/query.rb', line 70 def explain(value = nil) chain { criteria. explain: (value.nil? ? true : value) } end |
#facets(params = nil) ⇒ Object
Adds facets section to the search request. All the chained facets a merged and added to the search request
If called parameterless - returns result facets from ES performing request. Returns empty hash if no facets was requested or resulted.
365 366 367 368 369 370 371 372 |
# File 'lib/chewy/query.rb', line 365 def facets(params = nil) raise RemovedFeature, 'removed in elasticsearch 2.0' if Runtime.version >= '2.0' if params chain { criteria.update_facets params } else _response['facets'] || {} end end |
#field_value_factor(settings, options = {}) ⇒ Object
Add a field value scoring to the search. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
This function is only available in Elasticsearch 1.2 and greater
495 496 497 498 |
# File 'lib/chewy/query.rb', line 495 def field_value_factor(settings, = {}) scoring = .merge(field_value_factor: settings) chain { criteria.update_scores scoring } end |
#filter(params = nil, &block) ⇒ Object
Adds one or more filter to the search request
Internally filters are stored as an array
While the full query compilation this array compiles
according to :filter_mode
option value
By default it joins inside and
filter
See #filter_mode
chainable method for more info.
Also this method supports block DSL.
See Chewy::Query::Filters
for more info.
If only one filter was specified, it will become a result filter as is, without joining.
722 723 724 725 |
# File 'lib/chewy/query.rb', line 722 def filter(params = nil, &block) params = Filters.new(&block).__render__ if block chain { criteria.update_filters params } end |
#filter_mode(value) ⇒ Object
Sets query compilation mode for search request. Not used if only one filter for search is specified. Possible values:
:and
Default value. Filter compiles into anand
filter.:or
Filter compiles into anor
filter.:must
Filter compiles into a boolmust
filter.:should
Filter compiles into a boolshould
filter.Any acceptable
minimum_should_match
value (1, '2', '75%') Filter compiles into boolshould
filter withminimum_should_match
set.
Default value for :filter_mode
might be changed
with Chewy.filter_mode
config option.
220 221 222 |
# File 'lib/chewy/query.rb', line 220 def filter_mode(value) chain { criteria. filter_mode: value } end |
#find(*ids) ⇒ Object
Find all documents matching a query.
In all the previous examples find will return a single object. To get a collection - pass an array of ids.
1016 1017 1018 1019 1020 1021 |
# File 'lib/chewy/query.rb', line 1016 def find(*ids) results = chain { criteria. simple: true }.filter { _id == ids.flatten }.to_a raise Chewy::DocumentNotFound, "Could not find documents for ids #{ids.flatten}" if results.empty? ids.one? && !ids.first.is_a?(Array) ? results.first : results end |
#highlight(value) ⇒ Object
Elasticsearch highlight query option support
320 321 322 |
# File 'lib/chewy/query.rb', line 320 def highlight(value) chain { criteria. highlight: value } end |
#limit(value = nil, &block) ⇒ Object
Sets elasticsearch size
search request param
Default value is set in the elasticsearch and is 10.
298 299 300 |
# File 'lib/chewy/query.rb', line 298 def limit(value = nil, &block) chain { criteria. size: block || Integer(value) } end |
#merge(other) ⇒ Object
Merges two queries. Merges all the values in criteria with the same rules as values added manually.
963 964 965 |
# File 'lib/chewy/query.rb', line 963 def merge(other) chain { criteria.merge!(other.criteria) } end |
#min_score(value) ⇒ Object
Elasticsearch minscore option support
338 339 340 |
# File 'lib/chewy/query.rb', line 338 def min_score(value) chain { criteria. min_score: value } end |
#none ⇒ Object
Marks the criteria as having zero documents. This scope always returns empty array without touching the elasticsearch server. All the chained calls of methods don't affect the result
645 646 647 |
# File 'lib/chewy/query.rb', line 645 def none chain { criteria. none: true } end |
#offset(value = nil, &block) ⇒ Object
Sets elasticsearch from
search request param
311 312 313 |
# File 'lib/chewy/query.rb', line 311 def offset(value = nil, &block) chain { criteria. from: block || Integer(value) } end |
#only(*params) ⇒ Object
Sets search request field list
871 872 873 |
# File 'lib/chewy/query.rb', line 871 def only(*params) chain { criteria.update_fields params } end |
#only!(*params) ⇒ Object
Cleans up previous search field list and sets the new one
884 885 886 |
# File 'lib/chewy/query.rb', line 884 def only!(*params) chain { criteria.update_fields params, purge: true } end |
#order(*params) ⇒ Object
Sets search request sorting
845 846 847 |
# File 'lib/chewy/query.rb', line 845 def order(*params) chain { criteria.update_sort params } end |
#post_filter(params = nil, &block) ⇒ Object
Adds one or more post_filter to the search request
Internally post_filters are stored as an array
While the full query compilation this array compiles
according to :post_filter_mode
option value
By default it joins inside and
filter
See #post_filter_mode
chainable method for more info.
Also this method supports block DSL.
See Chewy::Query::Filters
for more info.
If only one post_filter was specified, it will become a result post_filter as is, without joining.
755 756 757 758 |
# File 'lib/chewy/query.rb', line 755 def post_filter(params = nil, &block) params = Filters.new(&block).__render__ if block chain { criteria.update_post_filters params } end |
#post_filter_mode(value) ⇒ Object
Acts the same way as filter_mode
, but used for post_filter
.
Note that it fallbacks by default to Chewy.filter_mode
if
Chewy.post_filter_mode
is nil.
233 234 235 |
# File 'lib/chewy/query.rb', line 233 def post_filter_mode(value) chain { criteria. post_filter_mode: value } end |
#preference(value) ⇒ Object
Sets preference
for request.
For instance, one can use preference=_primary
to execute only on the primary shards.
546 547 548 |
# File 'lib/chewy/query.rb', line 546 def preference(value) chain { criteria. preference: value } end |
#query(params) ⇒ Object
Adds one or more query to the search request
Internally queries are stored as an array
While the full query compilation this array compiles
according to :query_mode
option value
By default it joines inside must
query
See #query_mode
chainable method for more info.
If only one query was specified, it will become a result query as is, without joining.
688 689 690 |
# File 'lib/chewy/query.rb', line 688 def query(params) chain { criteria.update_queries params } end |
#query_mode(value) ⇒ Object
Sets query compilation mode for search request. Not used if only one filter for search is specified. Possible values:
:must
Default value. Query compiles into a boolmust
query.:should
Query compiles into a boolshould
query.Any acceptable
minimum_should_match
value (1, '2', '75%') Query compiles into a boolshould
query withminimum_should_match
set.:dis_max
Query compiles into adis_max
query.Any Float value (0.0, 0.7, 1.0) Query compiles into a
dis_max
query withtie_breaker
option set.
Default value for :query_mode
might be changed
with Chewy.query_mode
config option.
152 153 154 |
# File 'lib/chewy/query.rb', line 152 def query_mode(value) chain { criteria. query_mode: value } end |
#random_score(seed = Time.now, options = {}) ⇒ Object
Adds a random score to the search request. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
This probably only makes sense if you specify a filter for the random score as well.
If you do not pass in a seed value, Time.now will be used
463 464 465 466 |
# File 'lib/chewy/query.rb', line 463 def random_score(seed = Time.now, = {}) scoring = .merge(random_score: {seed: seed.to_i}) chain { criteria.update_scores scoring } end |
#reorder(*params) ⇒ Object
Cleans up previous search sorting and sets the new one
858 859 860 |
# File 'lib/chewy/query.rb', line 858 def reorder(*params) chain { criteria.update_sort params, purge: true } end |
#rescore(value) ⇒ Object
Elasticsearch rescore query option support
329 330 331 |
# File 'lib/chewy/query.rb', line 329 def rescore(value) chain { criteria. rescore: value } end |
#score_mode(value) ⇒ Object
Sets the scoring mode for combining function scores/boosts Not used if no score functions are specified. Possible values:
:multiply
Default value. Scores are multiplied.:sum
Scores are summed.:avg
Scores are averaged.:first
The first function that has a matching filter is applied.:max
Maximum score is used.:min
Minimum score is used
Default value for :score_mode
might be changed
with Chewy.score_mode
config option.
832 833 834 |
# File 'lib/chewy/query.rb', line 832 def score_mode(value) chain { criteria. score_mode: value } end |
#script_fields(value) ⇒ Object
Adds script_fields
parameter to search request.
86 87 88 |
# File 'lib/chewy/query.rb', line 86 def script_fields(value) chain { criteria.update_script_fields(value) } end |
#script_score(script, options = {}) ⇒ Object
Adds a script function to score the search request. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
392 393 394 395 |
# File 'lib/chewy/query.rb', line 392 def script_score(script, = {}) scoring = {script_score: {script: script}.merge()} chain { criteria.update_scores scoring } end |
#search_type(value) ⇒ Object
Sets search_type
for request.
For instance, one can use search_type=count
to fetch only total count of documents or to fetch only aggregations without fetching documents.
949 950 951 |
# File 'lib/chewy/query.rb', line 949 def search_type(value) chain { criteria. search_type: value } end |
#strategy(value = nil) ⇒ Object
Setups strategy for top-level filtered query
660 661 662 |
# File 'lib/chewy/query.rb', line 660 def strategy(value = nil) chain { criteria. strategy: value } end |
#suggest(params = nil) ⇒ Object
Sets elasticsearch suggest
search request param
625 626 627 628 629 630 631 |
# File 'lib/chewy/query.rb', line 625 def suggest(params = nil) if params chain { criteria.update_suggest params } else _response['suggest'] || {} end end |
#timed_out ⇒ Object
Returns request timed_out as reported by elasticsearch
The timed_out value tells us whether the query timed out or not.
By default, search requests do not timeout. If low response times are more important to you than complete results, you can specify a timeout as 10 or "10ms" (10 milliseconds), or "1s" (1 second). See #timeout method.
1063 1064 1065 |
# File 'lib/chewy/query.rb', line 1063 def timed_out _response['timed_out'] end |
#timeout(value) ⇒ Object
A search timeout, bounding the search request to be executed within the specified time value and bail with the hits accumulated up to that point when expired. Defaults to no timeout.
By default, the coordinating node waits to receive a response from all shards. If one node is having trouble, it could slow down the response to all search requests.
The timeout parameter tells the coordinating node how long it should wait before giving up and just returning the results that it already has. It can be better to return some results than none at all.
The response to a search request will indicate whether the search timed out and how many shards responded successfully:
The primary shard assigned to perform the index operation might not be available when the index operation is executed. Some reasons for this might be that the primary shard is currently recovering from a gateway or undergoing relocation. By default, the index operation will wait on the primary shard to become available for up to 1 minute before failing and responding with an error. The timeout parameter can be used to explicitly specify how long it waits.
Timeout is not a circuit breaker.
It should be noted that this timeout does not halt the execution of the query, it merely tells the coordinating node to return the results collected so far and to close the connection. In the background, other shards may still be processing the query even though results have been sent.
Use the timeout because it is important to your SLA, not because you want to abort the execution of long running queries.
284 285 286 |
# File 'lib/chewy/query.rb', line 284 def timeout(value) chain { criteria. timeout: value } end |
#took ⇒ Object
Returns request total time elapsed as reported by elasticsearch
1048 1049 1050 |
# File 'lib/chewy/query.rb', line 1048 def took _response['took'] end |
#track_scores(value) ⇒ Object
Elasticsearch track_scores option support
347 348 349 |
# File 'lib/chewy/query.rb', line 347 def track_scores(value) chain { criteria. track_scores: value } end |
#types(*params) ⇒ Object
Specify types participating in the search result
Works via types
filter. Always merged with another filters
with the and
filter.
921 922 923 |
# File 'lib/chewy/query.rb', line 921 def types(*params) chain { criteria.update_types params } end |
#types!(*params) ⇒ Object
Acts the same way as types
, but cleans up previously set types
934 935 936 |
# File 'lib/chewy/query.rb', line 934 def types!(*params) chain { criteria.update_types params, purge: true } end |
#unlimited ⇒ Object
Sets limit to be equal to total documents count
1038 1039 1040 1041 |
# File 'lib/chewy/query.rb', line 1038 def unlimited count_query = search_type(:count) offset(0).limit { count_query.total } end |
#weight(factor, options = {}) ⇒ Object
Add a weight scoring function to the search. All scores are
added to the search request and combinded according to
boost_mode
and score_mode
This probably only makes sense if you specify a filter for the weight as well.
438 439 440 441 |
# File 'lib/chewy/query.rb', line 438 def weight(factor, = {}) scoring = .merge(weight: factor.to_i) chain { criteria.update_scores scoring } end |