When to close MongoDB database connection in Nodejs

by

Here’s a potential solution based on the counting approach (I haven’t tested it and there’s no error trapping, but it should convey the idea).

The basic strategy is: Acquire the count of how many records need to be updated, save each record asynchronously and a callback on success, which will decrement the count and close the DB if the count reaches 0 (when the last update finishes). By using {safe:true} we can ensure that each update is successful.

The mongo server will use one thread per connection, so it’s good to either a) close unused connections, or b) pool/reuse them.

db.open(function (err, db) {
  db.collection('foo', function (err, collection) {
    var cursor = collection.find({});
    cursor.count(function(err,count)){
      var savesPending = count;

      if(count == 0){
        db.close();
        return;
      }

      var saveFinished = function(){
        savesPending--;
        if(savesPending == 0){
          db.close();
        }
      }

      cursor.each(function (err, doc) {
        if (doc != null) {
          doc.newkey = 'foo'; // Make some changes
          db.save(doc, {safe:true}, saveFinished);
        }
      });
    })
  });
});

More Related Contents:

  1. Callback after all asynchronous forEach callbacks are completed
  2. Are all javascript callbacks asynchronous? If not, how do I know which are?
  3. Asynchronous exception handling with bluebird promises
  4. Render basic HTML view?
  5. How to return values from async functions using async-await from function? [duplicate]
  6. nodeJs callbacks simple example
  7. Best way to call an asynchronous function within map?
  8. How to avoid long nesting of asynchronous functions in Node.js
  9. Understanding Asynchronous Code in Layman’s terms
  10. How do I remove documents using Node.js Mongoose?
  11. How to wrap async function calls into a sync function in Node.js or Javascript?
  12. SyntaxError: Unexpected token function – Async Await Nodejs
  13. Are all Node.js callback functions asynchronous?
  14. using async await and .then together
  15. Node js socket explanation
  16. Mongoose subdocuments vs nested schema
  17. Formatting ISODate from Mongodb
  18. How to get updated document back from the findOneAndUpdate method?
  19. javascript – Why is there a spec for sync and async modules?
  20. Can I determine if a string is a MongoDB ObjectID?
  21. How do you create custom asynchronous functions in node.js?
  22. How to use MongoDB with promises in Node.js?
  23. Why is node.js asynchronous?
  24. Create an ISO date object in javascript
  25. Javascript Asynchronous Exception Handling with node.js
  26. How to use the ‘main’ parameter in package.json?
  27. Storing data stream from POST request in GridFS, express, mongoDB, node.js
  28. Does an async function always need to be called with await?
  29. Properly batch nested promises in Node
  30. How to convert a string to ObjectId in nodejs mongodb native driver?

Leave a Comment