_node-js-driver-basic-crud-operations.md

Code Examples for my Blog Post: Getting Started With the MongoDB Node.JS Driver – Basic CRUD Operations

example-1.js

var mongoDbClient = require('mongodb').MongoClient,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names';

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
  console.log("Connected successfully to MongoDB database");
});

example-2.js

var mongoDbClient = require('mongodb').MongoClient,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names',
  dbDocument = {name : 'Don Draper'};

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
  console.log("Connected successfully to MongoDB database");

  //set the database and collection references
  var db = database.db(dbName),
    collection = db.collection(collectionName);

    //insert one document into the collection
    collection.insert(dbDocument, function(err, result) {
      console.log("Inserted 1 document into the collection:");
      console.log(result);

      //close the database
      database.close();
    });
});

example-3.js

var mongoDbClient = require('mongodb').MongoClient,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names',
  dbDocuments = [
    {name : 'Don Draper'},
    {name : 'Pete Campbell'},
    {name : 'Joan Harris'}
  ];

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
  console.log("Connected successfully to MongoDB database");

  //set the database and collection references
  var db = database.db(dbName),
    collection = db.collection(collectionName);

    //insert one document into the collection
    collection.insertMany(dbDocuments, function(err, result) {
      console.log('Inserted ' + dbDocuments.length +  ' documents into the collection:');
      console.log(result);

      //close the database
      database.close();
    });
});

example-4.js

var mongoDbClient = require('mongodb').MongoClient,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names';

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
    database
      .db(dbName)
      .collection(collectionName)
      .find()
      .each(function (err, document) {
        //if the document is null
        if (document == null) {
          //close the database and return
          database.close();
          return;
        }

        //show the next document
        console.log(document);
      });
});

example-5.js

var mongoDbClient = require('mongodb').MongoClient,
  ObjectID = require('mongodb').ObjectID,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names',
  documentToDelete = {_id:  new ObjectID('XXXXX')};

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
    database
    database
    .db(dbName)
    .collection(collectionName)
    .deleteOne(documentToDelete)
    .then(function(result) {
      console.log('Database record deleted');

      //close the database and return
      database.close();
    })
});

example-6.js

var mongoDbClient = require('mongodb').MongoClient,
  dbUrl = 'mongodb://localhost:27017',
  dbName = 'madMen',
  collectionName = 'names';

//connect to the madMen database
mongoDbClient.connect(dbUrl, function(err, database) {
    database
    database
    .db(dbName)
    .collection(collectionName)
    .deleteMany({})
    .then(function(result) {
      console.log('All database records deleted');

      //close the database and return
      database.close();
    })
});