1. MongoDB介绍
2. MongoDB本地安装
3. MongoDB本地操作
    3.1 库操作
    3.2 表操作
4. node-mongodb安装
5. node-mongodb连接
6. node-mongodb语法和执行
    - 插入
    - 查询
    - 修改
    - 删除
    - 存储过程
7. node-mongoose介绍和使用
    7.1 mongoose名词介绍
    7.2 node-mongoose安装
    7.3 node-mongoose安装
    7.4 node-mongoose语法和执行
        7.4.1 Schema，Modal创建
            - 索引和默认值
            - 验证器
        7.4.2 数据库操作
            - 插入
            - 删除
            - 修改
                - 修改器和更新器
            - 查询
                - 条件查询
                - 数量查询
                - 根据id查询
                - 分页查询
            - aggregate
8. 其他

// 创建存储过程：
db.system.js.save({_id:"存储过程ID", 
value:function(参数){  
        -- 逻辑主体; 
        return 返回; 
}});                
// 调用存储过程
db.eval("存储过程ID()");

const mongodbClient = require('mongodb').MongoClient;
    const url = 'mongodb://locolhost:27017';
    const dbName = 'test'; // 数据库名称

    mongodbClient.connect(url, function(err, client){
      console.log('连接成功!');
      const db = client.db(dbName);
      const collection = db.collection('test'); // 连接到表
      // 执行mongo语句
      ......        
      client.close(); // 关闭连接  
    })

const insertData = function(collection, callback) {   
  //插入数据
  const data = [{"name":'zhangsan',"age":21},{"name":'lisi',"age":22}];
  collection.insert(data, function(err, result) { 
      if(err){
          console.log('Error:'+ err);
          return;
      }     
      callback(result);
  });
}
mongodbClient.connect(url, function(err, client){
  console.log('连接成功!');
  const db = client.db(dbName);
  const collection = db.collection('test');
  insertData(collection, function(result){
    console.log(result);
  });
})

const selectData = function(collection, callback) {  
  // 查询所有
  let whereStr = {"name":"张三"};
  collection.find(whereStr).toArray(function(err, result) {
    if(err){
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
  // 条件查询 查询参数很多，自行查阅
  collection.find({"age":{$gt:30}}).toArray(function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}
......

const updateData = function(collection, callback) {  
    const whereStr = {"name":'zhangsan'};
    const updateStr = {$set: { "age" : 100 }};
    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('tb2');
  //删除数据
  var whereStr = {"name":'wilson001'};
  collection.remove(whereStr, function(err, result) {
    if(err)
    {
      console.log('Error:'+ err);
      return;
    }     
    callback(result);
  });
}

const invokeProcData = function(db, callback) {  
    db.eval('get_tb2_count()', function(err, result) { 
        if(err)
        {
            console.log('Error:'+ err);
            return;
        }             
        callback(result);
    });
}

const mongoose = require('mongoose'),
      DB_URL = 'mongodb://localhost:27017/test';
// 若有密码，则url：mongodb://username:password@host:port/database?options...'
// 连接
mongoose.connect(DB_URL);

// 连接成功
mongoose.connection.on('connected', function () {    
    console.log('Mongoose connection open to ' + DB_URL);  
});

// 连接异常
mongoose.connection.on('error',function (err) {    
    console.log('Mongoose connection error: ' + err);  
});

// 连接断开
mongoose.connection.on('disconnected', function () {    
    console.log('Mongoose connection disconnected');  
});

module.exports = mongoose;

const mongoose = require('./db.js'),
            Schema = mongoose.Schema;

    const UserSchema = new Schema({
        username : { type: String, index: true },                //用户账号
        userpwd: { type: String, required: true },               //密码
        userage: {type: Number, min: 18, max 80 },               //年龄
        logindate : { type: Date, default: new Date()},          //最近登录时间
        city:{ type:'String', enum:['北京','上海'] },             // 城市
        other:{
            type:'String',
            validate:[validator,err]  //validator是一个验证函数，err是验证失败的错误信息
        }
    });
    module.exports = mongoose.model('User',UserSchema);

const User = require("./user.js");
function insert() {
    const user = new User({
        username : 'zhangsan',
        userpwd: 'abcd',
        userage: 37,
        logindate : new Date()
    });

    user.save(function (err, res) {
        if (err) {
            console.log("Error:" + err);
        }
        else {
            console.log("Res:" + res);
        }
    });
}
insert();

const User = require("./user.js");
function update(){
    const wherestr = {'username' : 'zhangsan McGrady'};
    const updatestr = {'userpwd': 'zzzz'};

User.update(wherestr, updatestr, function(err, res){
    if (err) {
        console.log("Error:" + err);
    }
    else {
        console.log("Res:" + res);
    }
})

}
update();

    $inc增减修改器,只对数字有效.下面的实例: 找到 age=22的文档,修改文档的age值自增1
    Model.update({‘age’:22}, {‘$inc’:{‘age’:1} } );
    执行后: age=23

    $set指定一个键的值,这个键不存在就创建它.可以是任何MondoDB支持的类型
    Model.update({‘age’:22}, {‘$set’:{‘age’:’haha’} } );
    执行后: age=’haha’

    $unset同上取反,删除一个键
    Model.update({‘age’:22}, {‘$unset’:{‘age’:’haha’} } );
    执行后: age键不存在

    $push给一个键push一个数组成员,键不存在会创建
    Model.update({‘age’:22}, {‘$push’:{‘array’:10} } );
    执行后: 增加一个 array 键,类型为数组, 有一个成员 10

    $addToSet向数组中添加一个元素,如果存在就不添加
    Model.update({‘age’:22}, {‘$addToSet’:{‘array’:10} } );
    执行后: array中有10所以不会添加

    $each遍历数组, 和 $push 修改器配合可以插入多个值
    Model.update({‘age’:22}, {‘$push’:{‘array’:{‘$each’: [1,2,3,4,5]}} } );
    执行后: array : [10,1,2,3,4,5]

    $pop向数组中尾部删除一个元素
    Model.update({‘age’:22}, {‘$pop’:{‘array’:1} } );
    执行后: array : [10,1,2,3,4] tips: 将1改成-1可以删除数组首部元素

    $pull向数组中删除指定元素
    Model.update({‘age’:22}, {‘$pull’:{‘array’:10} } );
    执行后: array : [1,2,3,4] 匹配到array中的10后将其删除

const User = require("./user.js");
function del(){
    const wherestr = {'username' : 'zhangsan'};

    User.remove(wherestr, function(err, res){
        if (err) {
            console.log("Error:" + err);
        }
        else {
            console.log("Res:" + res);
        }
    })
}
del();

const User = require("./user.js");
    function findByIdAndUpdate(){
        const id = '56f2558b2dd74855a345edb2';
        cibst updatestr = {'userpwd': 'abcd'};
        User.findByIdAndUpdate(id, updatestr, function(err, res){
            if (err) {
                console.log("Error:" + err);
            }
            else {
                console.log("Res:" + res);
            }
        })
    }
    findByIdAndUpdate();

const User = require("./user.js");
function getByPager(){           
    const pageSize = 5;                   //一页多少条
    const currentPage = 1;                //当前第几页
    const sort = {'logindate':-1};        //排序（按登录时间倒序）
    const condition = {};                 //条件
    const skipnum = (currentPage - 1) * pageSize;   //跳过数

    User.find(condition).skip(skipnum).limit(pageSize).sort(sort).exec(function (err, res) {
        if (err) {
            console.log("Error:" + err);
        }
        else {
            console.log("Res:" + res);
        }
    })
}
getByPager();