var fs= require('fs');
var csv = require('fast-csv');
var mongodb = require('mongodb');
var url = 'mongodb://localhost:27017/CSVDATA';
var MongoClient = mongodb.MongoClient;
var data;
MongoClient.connect(url, function (err, db) {
if (err) {
console.log('Unable to connect to the mongoDB server. Error:', err);
} else {
console.log('Connection established to', url);
var collection = db.collection('INFORMATION');
readData=fs.createReadStream('data.csv').pipe(csv())
.on('data',function(data){
collection.insert({'data':data})
})
.on('end',function(data){
console.log('Read finished');
})
}
});