导出 mongodb 集合数据并使用 node js 将其导入回来
Export mongodb collection data and import it back using node js
我是 mongodb 的新手,所以需要一些关于导出和导入 mongodb 数据的帮助 nodejs.I 我有一个 mongodb 数据库和一些集合(例如产品集合,公式集合和规则集合,其中包含产品 ID 的引用),我想根据 api 请求的参数从不同集合中导出数据,并生成包含相应数据的文件,该文件将在客户端浏览器上下载.用户可以使用导出的文件将导出的数据导入另一个数据库 instance.Have 已经搜索过这个主题并且得到了 acros this answer 不确定我是否可以使用 mongoexport 来完成我的任务。任何想法我可以做 that.Any 帮助或想法都非常感谢。提前致谢。
此代码将从 MongoDB 集合中读取文档(导出功能),然后写入文件 JSON。该文件用于读取(导入功能)并将 JSON 插入到另一个集合中。该代码使用 MongoDB NodeJS 驱动程序。
出口:
根据提供的查询从集合 inCollection
中读取,并写入文件 JSON "out_file.json".
const MongoClient = require('mongodb').MongoClient;
const fs = require('fs');
const dbName = 'testDB';
const client = new MongoClient('mongodb://localhost:27017', { useUnifiedTopology:true });
client.connect(function(err) {
//assert.equal(null, err);
console.log('Connected successfully to server');
const db = client.db(dbName);
getDocuments(db, function(docs) {
console.log('Closing connection.');
client.close();
// Write to file
try {
fs.writeFileSync('out_file.json', JSON.stringify(docs));
console.log('Done writing to file.');
}
catch(err) {
console.log('Error writing to file', err)
}
});
}
const getDocuments = function(db, callback) {
const query = { }; // this is your query criteria
db.collection("inCollection")
.find(query)
.toArray(function(err, result) {
if (err) throw err;
callback(result);
});
};
导入:
读取导出的“out_file.json”文件并将JSON数据插入outCollection
。
client.connect(function(err) {
const db = client.db(dbName);
const data = fs.readFileSync('out_file.json');
const docs = JSON.parse(data.toString());
db.collection('outCollection')
.insertMany(docs, function(err, result) {
if (err) throw err;
console.log('Inserted docs:', result.insertedCount);
client.close();
});
});
我是 mongodb 的新手,所以需要一些关于导出和导入 mongodb 数据的帮助 nodejs.I 我有一个 mongodb 数据库和一些集合(例如产品集合,公式集合和规则集合,其中包含产品 ID 的引用),我想根据 api 请求的参数从不同集合中导出数据,并生成包含相应数据的文件,该文件将在客户端浏览器上下载.用户可以使用导出的文件将导出的数据导入另一个数据库 instance.Have 已经搜索过这个主题并且得到了 acros this answer 不确定我是否可以使用 mongoexport 来完成我的任务。任何想法我可以做 that.Any 帮助或想法都非常感谢。提前致谢。
此代码将从 MongoDB 集合中读取文档(导出功能),然后写入文件 JSON。该文件用于读取(导入功能)并将 JSON 插入到另一个集合中。该代码使用 MongoDB NodeJS 驱动程序。
出口:
根据提供的查询从集合 inCollection
中读取,并写入文件 JSON "out_file.json".
const MongoClient = require('mongodb').MongoClient;
const fs = require('fs');
const dbName = 'testDB';
const client = new MongoClient('mongodb://localhost:27017', { useUnifiedTopology:true });
client.connect(function(err) {
//assert.equal(null, err);
console.log('Connected successfully to server');
const db = client.db(dbName);
getDocuments(db, function(docs) {
console.log('Closing connection.');
client.close();
// Write to file
try {
fs.writeFileSync('out_file.json', JSON.stringify(docs));
console.log('Done writing to file.');
}
catch(err) {
console.log('Error writing to file', err)
}
});
}
const getDocuments = function(db, callback) {
const query = { }; // this is your query criteria
db.collection("inCollection")
.find(query)
.toArray(function(err, result) {
if (err) throw err;
callback(result);
});
};
导入:
读取导出的“out_file.json”文件并将JSON数据插入outCollection
。
client.connect(function(err) {
const db = client.db(dbName);
const data = fs.readFileSync('out_file.json');
const docs = JSON.parse(data.toString());
db.collection('outCollection')
.insertMany(docs, function(err, result) {
if (err) throw err;
console.log('Inserted docs:', result.insertedCount);
client.close();
});
});