Query Objects: Example

queryObjects3.js

var _ = require('underscore')
var async = require('async')
var MongoClient = require('mongodb').MongoClient

var CreateStudentQuery = function(student) {
  this.student = student
}

CreateStudentQuery.prototype = _.extend(CreateStudentQuery, {

  run: function(callback) {
    async.waterfall([
      _.bind(this.connectToDatabase, this),
      _.bind(this.getStudentsCollection, this),
      _.bind(this.insertStudent, this),
      _.bind(this.closeConnection, this)
    ], callback)
  },

  connectToDatabase: function(callback) {
    MongoClient.connect(CreateStudentQuery.DATABASE_URL, callback)
  },

  getStudentsCollection: function(db, callback) {
    this.db = db
    callback(null, db.collection(CreateStudentQuery.COLLECTION_NAME))
  },

  insertStudent: function(collection, callback) {
    collection.insert(this.student, callback)
  },

  closeConnection: function(result, callback) {
    this.db.close()
    callback(null, result)
  }

})

CreateStudentQuery.DATABASE_URL = 'mongodb://127.0.0.1:27017/test'
CreateStudentQuery.COLLECTION_NAME = 'students'