more mongodb demos

Author: Ryan Kotzen

.idea/inspectionProfiles/Project_Default.xml

@@ -13,14 +13,11 @@ A repository for my Beer & Technology talk on MongoDB and Node.js
 * https://www.youtube.com/watch?v=bzkRVzciAZg
 * http://www.mongodb-is-web-scale.com/
 
-#TODO
+# Possible addons
 
 * eslint
 * testing (mocking, async vs sync)
 
-* MongoDB
-* MongoChef
-
 * How to deal with async callback hell (Promise, Async.js, async/await co/generator functions)
 
 * Express

.idea/workspace.xml

@@ -0,0 +1,24 @@
+# Installation
+
+https://www.mongodb.com/download-center?jmp=nav
+
+Running as a service: https://docs.mongodb.com/manual/tutorial/install-mongodb-on-windows/#configure-a-windows-service-for-mongodb-community-edition
+
+# Api Reference
+
+To see all the possible methods and what they accept/return, see [the api docs.](http://mongodb.github.io/node-mongodb-native/2.0/api/Collection.html)
+
+# Using the shell
+
+Ensure that mongo is running and is in your path variable (e.g. `C:\Program Files\MongoDB\Server\3.2\bin`). Open up a terminal and type `mongo`
+
+> `use <nameOfDb>`
+> `db.test.insertOne({asd:true})`
+
+Simple as that!
+
+# Using some more advanced tools
+
+Download and install [MongoChef](https://studio3t.com/download/) it's like the sql management studio of the mongo world.
+[RoboMongo](https://robomongo.org/) is a great alternative if you aren't working with a replica set.
+

README.md

@@ -0,0 +1,5 @@
+'use strict';
+
+module.exports = {
+    example: "example"
+};

node/mongodb/README.md

@@ -1,12 +1,31 @@
 'use strict';
 const mongo = require('./mongo');
-
+const mongodb = require('mongodb');
+const collectionNames = require('./collection-names');
 mongo.connect(connected);
+
 function connected(err, db) {
     if (err) {
         throw err;
     }
-    db.collection('example').insertOne({value: 1});
+    const exampleDocument = {
+        naturalKey: "bob",
+        value: 1,
+        dateCreated: new Date(),
+        owner: new mongodb.ObjectId(),
+        someCoolSubObject: {
+            isCool: true
+        }
+    };
+    db.collection(collectionNames.example).insertOne(exampleDocument, inserted);
+}
+
+function inserted(err, result) {
+    if (err) {
+        mongo.close(disconnected);
+        throw err;
+    }
+    console.log(result);
     mongo.close(disconnected);
 }
 

node/mongodb/collection-names.js

@@ -0,0 +1,28 @@
+'use strict';
+const mongo = require('./mongo');
+const collectionNames = require('./collection-names');
+mongo.connect(connected);
+
+function connected(err, db) {
+    if (err) {
+        throw err;
+    }
+    const filter = {naturalKey: "bob"};
+    db.collection(collectionNames.example).findOneAndDelete(filter, deleted);
+}
+
+function deleted(err, result) {
+    if (err) {
+        mongo.close(disconnected);
+        throw err;
+    }
+    console.log(result);
+    mongo.close(disconnected);
+}
+
+function disconnected(err) {
+    if (err) {
+        throw err;
+    }
+    console.log("Exiting");
+}

node/mongodb/create.js

@@ -1,17 +1,6 @@
 'use strict';
 const mongo = require('mongodb');
 const connectionString = "mongodb://localhost:27017/beer-and-tech";
-const opts = {
-    socketOptions: {
-        keepAlive: 1,
-        autoReconnect: true
-    },
-    sslValidate: false
-};
-const mongoConnectionOptions = {
-    server: opts,
-    replSet: opts
-};
 let state = {
     connect: connectToDb,
     db: null,
@@ -43,7 +32,7 @@ function connectToDb(callback) {
             callback(null, state.db);
         });
     }
-    mongo.MongoClient.connect(connectionString, mongoConnectionOptions, connected);
+    mongo.MongoClient.connect(connectionString, connected);
     function connected(err, db) {
         if (err) {
             return callback(err);

node/mongodb/delete.js

@@ -0,0 +1,27 @@
+'use strict';
+const mongo = require('./mongo');
+const collectionNames = require('./collection-names');
+mongo.connect(connected);
+
+function connected(err, db) {
+    if (err) {
+        throw err;
+    }
+    db.collection(collectionNames.example).findOne({naturalKey: "bob"}, retrieved);
+}
+
+function retrieved(err, result) {
+    if (err) {
+        mongo.close(disconnected);
+        throw err;
+    }
+    console.log(result);
+    mongo.close(disconnected);
+}
+
+function disconnected(err) {
+    if (err) {
+        throw err;
+    }
+    console.log("Exiting");
+}

node/mongodb/mongo.js

@@ -0,0 +1,32 @@
+'use strict';
+const mongo = require('./mongo');
+const collectionNames = require('./collection-names');
+mongo.connect(connected);
+
+function connected(err, db) {
+    if (err) {
+        throw err;
+    }
+    const filter = {naturalKey: "bob"};
+    const replacement = {
+        naturalKey: "bob",
+        updated: true
+    };
+    db.collection(collectionNames.example).findOneAndReplace(filter, replacement, replaced);
+}
+
+function replaced(err, result) {
+    if (err) {
+        mongo.close(disconnected);
+        throw err;
+    }
+    console.log(result);
+    mongo.close(disconnected);
+}
+
+function disconnected(err) {
+    if (err) {
+        throw err;
+    }
+    console.log("Exiting");
+}