Class: Mongoid::Criteria::Queryable::Pipeline

Inherits:
Array
  • Object
show all
Defined in:
build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb

Overview

Represents an aggregation pipeline.

Since:

  • 2.0.0

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(aliases = {}) {|_self| ... } ⇒ Pipeline

Initialize the new pipeline.

Examples:

Initialize the new pipeline.

Queryable::Pipeline.new(aliases)

Parameters:

  • aliases (Hash) (defaults to: {})

    A hash of mappings from aliases to the actual field names in the database.

Yields:

  • (_self)

Yield Parameters:

Since:

  • 2.0.0



56
57
58
59
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 56

def initialize(aliases = {})
  @aliases = aliases
  yield(self) if block_given?
end

Instance Attribute Details

#aliasesObject (readonly)

Since:

  • 2.0.0



14
15
16
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 14

def aliases
  @aliases
end

#aliases The field aliases.(Thefieldaliases.) ⇒ Object (readonly)



14
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 14

attr_reader :aliases

Instance Method Details

#__deep_copy__Pipeline

Deep copy the aggregation pipeline. Will clone all the values in the pipeline as well as the pipeline itself.

Examples:

Deep copy the pipeline.

pipeline.__deep_copy__

Returns:

Since:

  • 2.0.0



25
26
27
28
29
30
31
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 25

def __deep_copy__
  self.class.new(aliases) do |copy|
    each do |entry|
      copy.push(entry.__deep_copy__)
    end
  end
end

#group(entry) ⇒ Pipeline

Add a group operation to the aggregation pipeline.

Examples:

Add a group operation.

pipeline.group(:_id => "foo", :count.sum => 1, :max.max => "likes")

Parameters:

  • entry (Hash)

    The group entry.

Returns:

Since:

  • 2.0.0



43
44
45
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 43

def group(entry)
  push("$group" => evolve(entry.__expand_complex__))
end

#project(entry) ⇒ Pipeline

Adds a $project entry to the aggregation pipeline.

Examples:

Add the projection.

pipeline.project(name: 1)

Parameters:

  • entry (Hash)

    The projection.

Returns:

Since:

  • 2.0.0



69
70
71
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 69

def project(entry)
  push("$project" => evolve(entry))
end

#unwind(field_or_doc) ⇒ Pipeline

Add the $unwind entry to the pipeline.

Examples:

Add the unwind.

pipeline.unwind(:field)
pipeline.unwind(document)

Parameters:

  • field_or_doc (String, Symbol, Hash)

    A field name or a document.

Returns:

Since:

  • 2.0.0



85
86
87
88
89
90
91
92
93
# File 'build/mongoid-7.3/lib/mongoid/criteria/queryable/pipeline.rb', line 85

def unwind(field_or_doc)
  unless field_or_doc.respond_to? :keys
    normalized = field_or_doc.to_s
    name = aliases[normalized] || normalized
    push("$unwind" => name.__mongo_expression__)
  else
    push("$unwind" => field_or_doc)
  end
end