//mongodb_demo.js

/**
cnpm install mongodb
 */

var MongoClient = require('mongodb').MongoClient;
var DB_CONN_STR = 'mongodb://test:[email protected]:27017/test'; // 資料庫為 test

var insertData = function (db, callback) {
    //連線到表 site
    var collection = db.collection('site');
    //插入資料
    var data = [{ "name"
 
: "網站1", "url": "www.test1.com" }, { "name": "網站2", "url": "www.test2.com" }];
    collection.insert(data, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var selectData = function (db, callback) {
 

    //連線到表  
    var collection = db.collection('site');
    //查詢資料
    var whereStr = { "name": '網站1' };
    collection.find(whereStr).toArray(function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var updateData = function
 
 (db, callback) {
    //連線到表  
    var collection = db.collection('site');
    //更新資料
    var whereStr = { "name": '網站1' };
    var updateStr = { $set: { "url": "https://www.test1.com" } };
    collection.update(whereStr, updateStr, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}
var delData = function (db, callback) {
    //連線到表  
    var collection = db.collection('site');
    //刪除資料
    var whereStr = { "name": '網站1' };
    collection.remove(whereStr, function (err, result) {
        if (err) {
            console.log('Error:' + err);
            return;
        }
        callback(result);
    });
}

MongoClient.connect(DB_CONN_STR, function (err, db) {
    if (err) {
        console.log(err);
        return;
    }
    console.log("連線成功！");
    //1、插入
    insertData(db, function (result) {
        console.log(result);
        db.close();
    });
    //2、查詢資料
    selectData(db, function (result) {
        console.log(result);
        db.close();
    });
    //3、更新資料
    updateData(db, function (result) {
        console.log(result);
        db.close();
    });
    //4、刪除資料
    delData(db, function (result) {
        console.log(result);
        db.close();
    });

});

執行：node mongodb_demo.js