Guardar subconjunto de MongoDB colección a otra colección

Question

que tiene un conjunto como tal

{date: 20120101} 
{date: 20120103} 
{date: 20120104} 
{date: 20120005} 
{date: 20120105} 

¿Cómo puedo guardar un subconjunto de esos documentos con la fecha '20120105' a otra colección?

es decirdb.subset.save(db.full_set.find({date: "20120105"}));

Answer 1

Aquí está la versión de la shell:

db.full_set.find({date:"20120105"}).forEach(function(doc){ 
    db.subset.insert(doc); 
}); 

Nota: A partir de MongoDB 2.6, el marco de la agregación hace que sea posible hacer esto más rápido; ver la respuesta de melan para más detalles.

Answer 2

No hay equivalente directo de SQL de insert into ... select from ....

Tiene que encargarse usted mismo. Obtenga documentos de su interés y guárdelos en otra colección.

Puedes hacerlo en el shell, pero usaría un pequeño script externo en Ruby. Algo como esto:

require 'mongo' 

db = Mongo::Connection.new.db('mydb') 

source = db.collection('source_collection') 
target = db.collection('target_collection') 

source.find(date: "20120105").each do |doc| 
    target.insert doc 
end 

Answer 3

En realidad, hay un equivalente de SQL insert into ... select from en MongoDB. Primero, convierte varios documentos en una matriz de documentos; a continuación se inserta la matriz en la colección de destino

db.subset.insert(db.full_set.find({date:"20120105"}).toArray()) 

Answer 4

Como solución más reciente que aconsejaría a utilizar marco de agregación para el problema:

db.full_set.aggregate([ { $match: { date: "20120105" } }, { $out: "subset" } ]);

funciona cerca de 100 veces más rápido que forEach al menos en mi caso. Esto se debe a que toda la interconexión de agregación se ejecuta en el proceso mongod, mientras que una solución basada en find() y insert() debe enviar todos los documentos del servidor al cliente y luego volver. Esto tiene una penalización de rendimiento, incluso si el servidor y el cliente están en la misma máquina.

Answer 5

La solución más general es la siguiente:

uso

Hacer de la agregación (respuesta dada por @melan):

db.full_set.aggregate({$match:{your query here...}},{$out:"sample"}) 
db.sample.copyTo("subset") 

Esto funciona incluso cuando hay documentos en la "subconjunto" antes de la operación y Desea conservar esos documentos "antiguos" e inserte un nuevo subconjunto en él.

Se debe tener cuidado, porque el comando copyTo() reemplaza los documentos con el mismo _id.