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 (encriptada) (por defecto: {}) —

    Un mapa hash de mapeos de alias a los nombres reales de los campos en la base de datos.

Rendimientos:

  • (_self)

Parámetros de rendimiento:



45
46
47
48
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 45

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

Detalles de atributo de instancias

#aliases ⇒ Objeto (solo lectura)

Devuelve el valor del atributo aliases.



9
10
11
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 9

def aliases
  @aliases
end

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



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

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:



18
19
20
21
22
23
24
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 18

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

#group(entry) ⇒ pipeline

Agregar una operación grupal al pipeline 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:



34
35
36
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 34

def group(Entrada)
  push('$grupo' => 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:



58
59
60
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 58

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:



72
73
74
75
76
77
78
79
80
 
# Archivo 'lib/mongoid/criteria/queryable/pipeline.rb', línea 72

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