Clase: Mongoid::Criteria::Queryable::Pipeline

Hereda:
Arreglo
  • Objeto
Mostrar todo
Definido en:
lib/mongoid/criteria/queryable/pipeline.rb

Overview

Representa un pipeline de agregación.

Resumen de atributos de la instancia colapsar

Resumen del método de instancia colapsar

Detalles del constructor

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

Inicialice la nueva pipeline.

Ejemplos:

Inicialice la nueva pipeline.

Queryable::Pipeline.new(aliases)

Parámetros:

  • aliases (Hash) (por defecto: {}) —

    Un hash de asignaciones de alias a los nombres de campo reales en la base de datos.

Rendimientos:

  • (_self)

Parámetros de rendimiento:



48
49
50
51
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 48

def inicializar(aliases = {})
  @aliases = aliases
  rendimiento(sí mismo) si ¿block_given?
end

Detalles de los atributos de instancia

#aliases ⇒ Objeto (solo lectura)

Devuelve el valor del atributo aliases.



12
13
14
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 12

def aliases
  @aliases
end

#alias Los alias del campo.(Los alias del campo.) ⇒ objeto (solo lectura) 



12
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 12

attr_reader :aliases

Detalles del método de instancia

#__deep_copy__ ⇒ Pipeline

Haz una copia profunda del pipeline de agregación. Clonará todos los valores de la pipeline, así como la propia pipeline.

Ejemplos:

Copiar en profundidad el pipeline.

pipeline.__deep_copy__

Devuelve:



21
22
23
24
25
26
27
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 21

def __deep_copy__
  sí mismo.clase.Nuevo(aliases) hacer |copy|
    cada hacer |Entrada|
      copy.push(Entrada.__deep_copy__)
    end
  end
end

#group(entry) ⇒ pipeline

Agregue una operación de grupo al canal de agregación.

Ejemplos:

Agrega una operación de grupo.

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

Parámetros:

  • Entrada (encriptada) —

    La entrada del grupo.

Devuelve:



37
38
39
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 37

def group(Entrada)
  push("$group" => evolucionar(Entrada.__expand_complex__))
end

#proyecto(entrada) ⇒ Pipeline

Agrega una entrada $project al pipeline de agregación.

Ejemplos:

Agrega la proyección.

pipeline.project(name: 1)

Parámetros:

  • Entrada (encriptada) —

    La proyección.

Devuelve:



61
62
63
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 61

def Proyecto(Entrada)
  push("$project" => evolucionar(Entrada))
end

#unwind(field_or_doc) ⇒ Pipeline

Agrega la entrada $unwind a la pipeline.

Ejemplos:

Agrega la desenrolladura.

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

Parámetros:

  • campo_o_doc (String | Símbolo | Hash) —

    Un nombre de campo o un documento.

Devuelve:



75
76
77
78
79
80
81
82
83
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 75

def unwind(campo_o_doc)
  a menos que campo_o_doc.respond_to? :llaves
    normalizado = campo_o_doc.to_s
    Nombre = aliases[normalizado] || normalizado
    push("$unwind" => Nombre.__mongo_expression__)
  else
    push("$unwind" => campo_o_doc)
  end
end