Skip to content

Commit e239968

Browse files
committed
Added MongoDB demo.
1 parent 2eda309 commit e239968

File tree

2 files changed

+84
-0
lines changed

2 files changed

+84
-0
lines changed

13_MongoDB/app.js

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
// import the language driver
2+
var MongoClient = require('mongodb').MongoClient
3+
, assert = require('assert');
4+
var ObjectID = require('mongodb').ObjectID;
5+
6+
// Connection URL for local mongodb server
7+
var url = 'mongodb://127.0.0.1:27017/test';
8+
9+
// Use connect method to connect to the Server
10+
MongoClient.connect(url, function (err, db) {
11+
//ensure we've connected
12+
assert.equal(null, err);
13+
14+
var bankData = db.collection('bank_data');
15+
16+
bankData.insertOne({
17+
first_name: "Rami",
18+
last_name: "Sayar",
19+
accounts: [
20+
{
21+
account_balance: "50000000",
22+
account_type: "Investment",
23+
currency: "USD"
24+
}]
25+
}, function (err, op_result) {
26+
27+
if (err) {
28+
return console.error(err);
29+
}
30+
31+
console.log('inserted:');
32+
console.log(op_result.ops[0]);
33+
34+
var updatedPerson = op_result.ops[0];
35+
updatedPerson.accounts[0].account_balance += 100000;
36+
37+
bankData.updateOne({ _id: updatedPerson._id }, updatedPerson, { w: 1 }, function (err, op_result) {
38+
39+
if (err) {
40+
return console.error(err);
41+
}
42+
43+
console.log('sucessfully updated ' + op_result.result.n + ' person document');
44+
45+
//retrieve the inserted collection from mongodb
46+
//should be the exact same object we just updated
47+
bankData.findOne({ _id: updatedPerson._id }, function (err, doc) {
48+
49+
if (err) {
50+
return console.error(err);
51+
}
52+
53+
console.log('retrieved person: ' + doc.first_name + ' ' + doc.last_name);
54+
console.log('accounts: ');
55+
for (var i in doc.accounts) {
56+
console.log('Type: ' + doc.accounts[i].account_type);
57+
console.log('Balance: ' + doc.accounts[i].account_balance);
58+
}
59+
60+
//now delete the document we just inserted
61+
62+
bankData.remove({ _id: updatedPerson._id }, function (err, count) {
63+
64+
if (err) {
65+
db.close();
66+
return console.error(err);
67+
}
68+
console.log('sucessfully deleted documents');
69+
70+
return db.close();
71+
});
72+
});
73+
});
74+
return;
75+
});
76+
return console.log("Connected correctly to server");
77+
});

13_MongoDB/package.json

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"name": "13_MongoDB",
3+
"version": "0.0.0",
4+
"dependencies": {
5+
"mongodb": "^2.0.39"
6+
}
7+
}

0 commit comments

Comments
 (0)