nodejs操作mongodbデータベース教程

  npm install mongodb -D

const MongoClient = require('mongodb').MongoClient;
const DB_URL = 'mongodb://192.168.1.153:27017';

MongoClient.connect(DB_URL,(err,db)=>{
  if(err){
      console.log('    ',err);
  }else {
      console.log('    ！');
  }
});

/**
 * insert     
 * @param {*} db
 * @param {*} callback
 */
exports.insert = (db,callback)=>{
    let data = {
        name:'nodejs handle mongodb',
        age:34,
        addTime: new Date()
    }

    db.collection('node_mongo').insert(data,(err,result)=>{
        if(err){
            console.log('       ');
        }else {
            console.log('      ');
            callback(result);
        }
    });
}

/**
 * findAll       
 * @param {*} db
 * @param {*} callback
 */
exports.findAll = (db,callback)=>{
    db.collection('node_mongo').find({}).toArray((err,docs)=>{
        if(err){
            console.log('    ',err);
        }else {
            callback(docs);
        }
    });
}

/**
 * findQuery       
 * @param {*} db
 * @param {*} callback
 */
exports.findQuery = (db,callback)=>{
    db.collection('node_mongo').find({age:34}).toArray((err,docs)=>{
        if(err){
            console.log('    ',err);
        }else {
            callback(docs);
        }
    });
}

/**
 *
 * updateOne      
 * @param {*} db
 * @param {*} callback
 */
exports.updateOne = (db,callback)=>{
    db.collection('node_mongo').updateOne({age:34},{$set:{age:88}},(err,result)=>{
        callback(result);
    });
}

/**
 *
 * deleteOne   1   
 * @param {*} db
 * @param {*} callback
 */
exports.deleteOne = (db,callback)=>{
    db.collection('node_mongo').deleteOne({age:88},(err,result)=>{
        callback(result);
    });
}

const MongoClient = require('mongodb').MongoClient;
const DB_URL = 'mongodb://192.168.1.153:27017';
const Model = require('./model');

const dbName = 'mProject';

MongoClient.connect(DB_URL,(err,client)=>{
    if(err){
        console.log('    ',err);
    }else {
        console.log('    ！');

        const db = client.db(dbName);

        /**
         * insert     
         */
        // Model.insert(db,result=>{
        //     console.log(result.result);
        //     client.close();
        // });

        /**
         * findAll        
         *
         */
        // Model.findAll(db,docs=>{
        //     console.log(docs);
        //     client.close();
        // })

        /**
         * findQuery       
         *
         */
        // Model.findQuery(db,docs=>{
        //     console.log(docs);
        //     client.close();
        // });

        /**
         * updateOne   1   
         */
        // Model.updateOne(db,result=>{
        //     console.log(result.result);
        //     client.close();
        // });

        /**
         * deleteOne   1   
         */
        // Model.deleteOne(db,result=>{
        //     console.log(result.result);
        //     client.close();
        // });

    }
});