//引入mongodb模組，獲得客戶端物件
var MongoClient = require('mongodb').MongoClient;
//連線字串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定義函式表示式，用於操作資料庫並返回結果
var updateData = function(db, callback) {  
    //獲得指定的集合 
    var collection = db.collection('users');
    //要修改資料的條件，>=10歲的使用者
    var  where={age:{"$gte":10}};
    //要修改的結果
    var set={$set:{age:95}};
    collection.updateMany(where,set, function(err, result) { 
        //如果存在錯誤
        if(err)
        {
            console.log('Error:'+ err);
            return;
        } 
        //呼叫傳入的回撥方法，將操作結果返回
        callback(result);
    });
}

//使用客戶端連線資料，並指定完成時的回撥方法
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("連線成功！");
    //執行插入資料操作，呼叫自定義方法
    updateData(db, function(result) {
        //顯示結果
        console.log(result);
        //關閉資料庫
        db.close();
    });
});
 

//引入mongodb模組，獲得客戶端物件
var MongoClient = require('mongodb').MongoClient;
//連線字串
var DB_CONN_STR = 'mongodb://localhost:27017/gomall';    

//定義函式表示式，用於操作資料庫並返回結果
var findData = function(db, callback) {  
    //獲得指定的集合 
    var collection = db.collection('users');
    //要查詢資料的條件，<=10歲的使用者
    var  where={age:{"$lte":10}};
    //要顯示的欄位
    var set={name:1,age:1};
    collection.find(where,set).toArray(function(err, result) { 
        //如果存在錯誤
        if(err)
        {
            console.log('Error:'+ err);
            return;
        } 
        //呼叫傳入的回撥方法，將操作結果返回
        callback(result);
    });
}

//使用客戶端連線資料，並指定完成時的回撥方法
MongoClient.connect(DB_CONN_STR, function(err, db) {
    console.log("連線成功！");
    //執行插入資料操作，呼叫自定義方法
    findData(db, function(result) {
        //顯示結果
        console.log(result);
        //關閉資料庫
        db.close();
    });
});