有没有一种简单的方法可以做到这一点?
最好的方法是先执行 mongodump
,然后执行 mongorestore
。您可以通过以下方式选择集合:
mongodump -d some_database -c some_collection
[可选地,压缩转储 (zip some_database.zip some_database/* -r
) 并在别处scp
]
然后恢复它:
mongorestore -d some_other_db -c some_or_other_collection dump/some_collection.bson
some_or_other_collection
中的现有数据将被保留。这样,您就可以将集合从一个数据库“附加”到另一个数据库。
在版本 2.4.3 之前,您还需要在复制数据后重新添加索引。从 2.4.3 开始,此过程是自动的,您可以使用 --noIndexRestore
禁用它。
目前 MongoDB 中没有可以执行此操作的命令。请注意JIRA ticket with related feature request。
您可以执行以下操作:
db.<collection_name>.find().forEach(function(d){ db.getSiblingDB('<new_database>')['<collection_name>'].insert(d); });
请注意,这样,两个数据库需要共享同一个 mongod 才能工作。
除此之外,您可以对一个数据库中的集合进行 mongodump,然后将集合 mongorestore 到另一个数据库。
实际上,有一个命令可以将集合从一个数据库移动到另一个数据库。它只是不称为“移动”或“复制”。
要复制一个集合,您可以在同一个数据库上克隆它,然后移动克隆的集合。
克隆:
> use db1
switched to db db1
> db.source_collection.find().forEach(
function(x){
db.collection_copy.insert(x)
}
);
移动:
> use admin
switched to db admin
> db.runCommand(
{
renameCollection: 'db1.source_collection',
to : 'db2.target_collection'
}
);
其他答案更适合复制集合,但如果您要移动它,这尤其有用。
'db1.source_collection'
中加上一个撇号
我会滥用 mongo cli mongo doc 中的连接功能。这意味着您可以启动一个或多个连接。如果您想将客户集合从 test 复制到同一服务器中的 test2。首先你启动 mongo shell
use test
var db2 = connect('localhost:27017/test2')
正常查找并将前 20 条记录复制到 test2。
db.customer.find().limit(20).forEach(function(p) { db2.customer.insert(p); });
或按某些标准过滤
db.customer.find({"active": 1}).forEach(function(p) { db2.customer.insert(p); });
只需将 localhost 更改为 IP 或主机名即可连接到远程服务器。我使用它将测试数据复制到测试数据库进行测试。
如果在两个远程 mongod 实例之间,请使用
{ cloneCollection: "<collection>", from: "<hostname>", query: { <query> }, copyIndexes: <true|false> }
请参阅http://docs.mongodb.org/manual/reference/command/cloneCollection/
copyIndexes
选项字段实际上不受尊重。索引总是被复制的。请参阅 SERVER-11418
我通常会这样做:
use sourcedatabase;
var docs=db.sourcetable.find();
use targetdatabase;
docs.forEach(function(doc) { db.targettable.insert(doc); });
对于大型集合,您可以使用 Bulk.insert()
var bulk = db.getSiblingDB(dbName)[targetCollectionName].initializeUnorderedBulkOp();
db.getCollection(sourceCollectionName).find().forEach(function (d) {
bulk.insert(d);
});
bulk.execute();
这将节省大量时间。就我而言,我正在复制包含 1219 个文档的集合:iter vs Bulk (67 secs vs 3 secs)
您可以使用聚合框架来解决您的问题
db.oldCollection.aggregate([{$out : "newCollection"}])
应该注意的是,oldCollection 中的索引不会复制到 newCollection 中。
newCollection
在插入新数据之前都会被删除。
有不同的方法来做收藏副本。请注意,复制可能发生在同一数据库、不同数据库、分片数据库或 mongod
实例中。一些工具可以有效地用于大型集合复制。
使用 $merge 进行聚合: 将聚合管道的结果写入指定的集合。请注意,复制可以跨数据库发生,甚至是分片集合。创建一个新集合或替换现有集合。 4.2 版中的新功能。示例:db.test.aggregate([ { $merge: { db: "newdb", coll: "newcoll" }} ])
使用 $out 进行聚合: 将聚合管道的结果写入指定的集合。请注意,复制只能发生在同一个数据库中。创建一个新集合或替换现有集合。示例:db.test.aggregate([ { $out: "newcoll" } ])
mongoexport 和 mongoimport: 这些是命令行工具。 mongoexport
生成集合数据的 JSON 或 CSV 导出。使用 mongoimport
将导出的输出用作目标集合的源。
mongodump 和 mongorestore: 这些是命令行工具。 mongodump
实用程序用于创建数据库或集合内容的二进制导出。 mongorestore
程序将数据从由 mongodump
创建的二进制数据库转储加载到目标中。
db.cloneCollection(): 将集合从远程 mongod
实例复制到当前 mongod
实例。自 4.2 版起已弃用。
db.collection.copyTo():将集合中的所有文档复制到新的集合中(在同一数据库中)。自 3.0 版起已弃用。从版本 4.2 开始,MongoDB 这条命令无效。
注意: 除非说上述命令从 mongo
shell 运行。
参考: The MongoDB Manual。
您还可以使用喜欢的编程语言(例如,Java)或环境(例如,NodeJS),使用适当的驱动程序软件编写程序来执行复制 - 这可能涉及使用查找和插入操作或其他方法。也可以从 mongo
shell 执行此查找插入。
您还可以使用 MongoDB Compass 等 GUI 程序进行收集复制。
令人难以置信的是,对于极其缓慢的逐个数据副本给予了多少赞成票。
正如其他答案中给出的那样,最快的解决方案应该是mongodump / mongorestore
。无需将转储保存到本地磁盘,您可以将转储直接通过管道传输到 mongorestore:
mongodump --db=some_database --collection=some_collection --archive=- | mongorestore --nsFrom="some_database.some_collection" --nsTo="some_or_other_database.some_or_other_collection" --archive=-
如果您运行分片集群,则默认情况下不会对新集合进行分片。所有数据最初都写入您的主分片。这可能会导致磁盘空间出现问题,并为您的集群增加 balancing 的负载。在导入数据之前,最好像这样pre-split您的集合:
sh.shardCollection("same_or_other_database.same_or_other_collection", { <shard_key>: 1 });
db.getSiblingDB("config").getCollection("chunks").aggregate([
{ $match: { ns: "some_database.some_collection"} },
{ $sort: { min: 1 } },
{ $skip: 1 }
], { allowDiskUse: true }).forEach(function (chunk) {
sh.splitAt("same_or_other_database.same_or_other_collection", chunk.min)
})
我知道这个问题已经得到解答,但是我个人不会回答@JasonMcCays,因为游标流式传输,如果仍在使用该集合,这可能会导致无限游标循环。相反,我会使用快照():
http://www.mongodb.org/display/DOCS/How+to+do+Snapshotted+Queries+in+the+Mongo+Database
@bens 答案也是一个很好的答案,不仅适用于集合的热备份,而且 mongorestore 不需要共享同一个 mongod。
这可能只是一个特例,但是对于具有两个随机字符串字段(长度为 15-20 个字符)的 100k 文档的集合,使用哑 mapreduce 的速度几乎是 find-insert/copyTo 的两倍:
db.coll.mapReduce(function() { emit(this._id, this); }, function(k,vs) { return vs[0]; }, { out : "coll2" })
使用 pymongo,您需要在同一个 mongod 上拥有两个数据库,我做了以下操作:
db = 原始数据库 db2 = 要复制到的数据库
cursor = db["<collection to copy from>"].find()
for data in cursor:
db2["<new collection>"].insert(data)
cursor = db['my-node-js'].collectioName.find()
。你可以理解 my-node-js 是数据库名称。我执行 print(cursor.toArray())
时得到的是 '[ ]' 并且 print(cursor.count())
打印 0。
如果 RAM 不是问题,则使用 insertMany
比 forEach
循环快得多。
var db1 = connect('<ip_1>:<port_1>/<db_name_1>')
var db2 = connect('<ip_2>:<port_2>/<db_name_2>')
var _list = db1.getCollection('collection_to_copy_from').find({})
db2.collection_to_copy_to.insertMany(_list.toArray())
这不会解决您的问题,但 mongodb shell 有一个 copyTo
方法,可将集合复制到同一数据库中的另一个:
db.mycoll.copyTo('my_other_collection');
它还从 BSON 转换为 JSON,因此正如其他人所说,mongodump
/mongorestore
是最好的方法。
万一有些heroku用户在这里绊倒了,像我一样想将一些数据从临时数据库复制到生产数据库,反之亦然,这就是你如何非常方便地做到这一点(注意我希望那里没有错别字,不能在atm检查它。,我会尽快确认代码的有效性):
to_app="The name of the app you want to migrate data to"
from_app="The name of the app you want to migrate data from"
collection="the collection you want to copy"
mongohq_url=`heroku config:get --app "$to_app" MONGOHQ_URL`
parts=(`echo $mongohq_url | sed "s_mongodb://heroku:__" | sed "s_[@/]_ _g"`)
to_token=${parts[0]}; to_url=${parts[1]}; to_db=${parts[2]}
mongohq_url=`heroku config:get --app "$from_app" MONGOHQ_URL`
parts=(`echo $mongohq_url | sed "s_mongodb://heroku:__" | sed "s_[@/]_ _g"`)
from_token=${parts[0]}; from_url=${parts[1]}; from_db=${parts[2]}
mongodump -h "$from_url" -u heroku -d "$from_db" -p"$from_token" -c "$collection" -o col_dump
mongorestore -h "$prod_url" -u heroku -d "$to_app" -p"$to_token" --dir col_dump/"$col_dump"/$collection".bson -c "$collection"
您可以随时使用 Robomongo。从 v0.8.3 开始,有一个工具可以通过右键单击集合并选择“将集合复制到数据库”来执行此操作
有关详细信息,请参阅http://blog.robomongo.org/whats-new-in-robomongo-0-8-3/
此功能是 removed in 0.8.5,因为它有缺陷,因此如果您想试用它,您必须使用 0.8.3 或 0.8.4。
这里有很多正确的答案。对于大型集合,我会以管道方式选择 mongodump
和 mongorestore
:
mongodump --db fromDB --gzip --archive | mongorestore --drop --gzip --archive --nsFrom "fromDB.collectionName" --nsTo "toDB.collectionName"
虽然如果我想做快速复制,它很慢但它有效:
use fromDB
db.collectionName.find().forEach(function(x){
db.getSiblingDB('toDB')['collectionName'].insert(x);
});"
mongorestore --uri mongodb+srv://iser:pass@test.sub1.mongodb.net --nsFrom "weblog.contractors" --nsTo "weblog.contractors_temp"
,但 它只是试图覆盖整个博客数据库。 在 mongorestore 之前我做了:mongodump --uri mongo+srv://asd:asda@asd.asd.com/weblog
。请小心。
就我而言,我必须在新集合中使用旧集合中的属性子集。所以我最终在新集合上调用 insert 时选择了这些属性。
db.<sourceColl>.find().forEach(function(doc) {
db.<newColl>.insert({
"new_field1":doc.field1,
"new_field2":doc.field2,
....
})
});`
要将集合 (myCollection1) 从一个数据库复制到 MongoDB 中的另一个数据库,
**Server1:**
myHost1.com
myDbUser1
myDbPasword1
myDb1
myCollection1
outputfile:
myfile.json
**Server2:**
myHost2.com
myDbUser2
myDbPasword2
myDb2
myCollection2
你可以这样做:
mongoexport --host myHost1.com --db myDb1 -u myDbUser1 -p myDbPasword1 --collection myCollection1 --out myfile.json
然后:
mongoimport --host myHost2.com --db myDb2 -u myDbUser2 -p myDbPasword2 --collection myCollection2 --file myfile.json
另一种情况,使用 CSV 文件:
Server1:
myHost1.com
myDbUser1
myDbPasword1
myDb1
myCollection1
fields.txt
fieldName1
fieldName2
outputfile:
myfile.csv
Server2:
myHost2.com
myDbUser2
myDbPasword2
myDb2
myCollection2
你可以这样做:
mongoexport --host myHost1.com --db myDb1 -u myDbUser1 -p myDbPasword1 --collection myCollection1 --out myfile.csv --type=csv
在 csv 文件 (name1.decimal(),name1.string()..) 中添加 clolumn 类型,然后:
mongoimport --host myHost2.com --db myDb2 -u myDbUser2 -p myDbPasword2 --collection myCollection2 --file myfile.csv --type csv --headerline --columnsHaveTypes
这可以使用 Mongo 的 db.copyDatabase
方法完成:
db.copyDatabase(fromdb, todb, fromhost, username, password)
参考:http://docs.mongodb.org/manual/reference/method/db.copyDatabase/