Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var csv = require('csv');
- var server = new Server('localhost', 27017, {auto_reconnect: true, poolSize: 1});
- var db = new Db('test', server);
- db.open(function(err, db, onemore) {
- if(!err) {
- //Database connection is established.
- db.collection('teststocks', function(err, collection) {
- if(!err) {
- // Stocks collection is connected, open the file and insert the doc
- console.log("Trying to load from " + process.argv[2]);
- csv()
- .fromPath(process.argv[2], {
- columns: true
- })
- .on('data', function(data, index) {
- //data.stock = process.argv[2].substring(process.argv[2].lastIndexOf('/') + 1, process.argv[2].lastIndexOf('.'));
- collection.insert(data, {safe: true}, function(error, collection){
- if ( error ) { console.log("Error inserting record : " + error); }
- });
- console.log("Inserted data for " + index);
- })
- .on('error', function(error) {
- db.close();
- console.log("Error: " + error);
- })
- .on('end', function(count) {
- console.log("Finished all writing.");
- db.close();
- });
- }
- });
- }
- });
- var docs = [];
- csv()
- // ...
- .on('data', function (data, index) {
- docs.push(data); // or possibly: docs[index] = data;
- })
- // ...
- .on('end', function () {
- console.log("Finished reading CSV.");
- collection.insert(docs, { safe: true }, function (error, inserted) {
- console.log("Finished all writing.");
- db.close();
- });
- });
Add Comment
Please, Sign In to add comment