あなたは以下のコード試すことができます -
mongoose.connect(<mongodbUri>);
var lineList = fs.readFileSync(<filepath>).toString().split('\n');
lineList.shift();
//creating schema for database. As an example you can see below -
var schemaKeyList = ['EmployeeID', 'Designation', 'Address'];
var EmployeeSchema = new mongoose.Schema({
EmployeeID: String,
Designation: String,
Address: String
});
//create model for schema
var EmpDoc = mongoose.model('Employees', EmployeeSchema);
function queryAllEntries() {
EmpDoc .aggregate(
{$group: {_id: '$EmployeeID', oppArray: {$push: {
Designation: '$Designation',
Address: '$Address'
}}
}}, function(err, qDocList) {
//console.log(util.inspect(qDocList, false, 10));
process.exit(0);
});
}
function createDocRecurse (err) {
if (err) {
console.log(err);
process.exit(1);
}
if (lineList.length) {
var line = lineList.shift();
var doc = new EmpDoc();
line.split(',').forEach(function (entry, i) {
doc[schemaKeyList[i]] = entry;
});
doc.save(createDocRecurse);
} else {
queryAllEntries();
}
}
createDocRecurse(null);
を