DAO封装

• 新建数据库配置文件config.js

// config.js
module.exports = {
    dburl: 'mongodb://localhost:27017/',      // 数据库链接地址
    dbname: 'test'                        // 要链接的数据库名
}

• 不管数据库什么操作，都要先连接数据库

// dao.js
// 引入mongodb库
let MongoClient = require('mongodb').MongoClient;
// 引入上一步的数据库配置文件
let config = require('../config.js');
let url = config.dburl;
let dbname = config.dbname;


// 方法一：链接数据库，这个方法不用抛出，把增删改查抛出就可以了
function _connectDB(callback){
    MongoCLient.connect(url,function(err,client){
        // let db = client.db(dbname);    
        // 这里不配置数据库名，在增删改查的方法中配置
        if(err){
            callback(err,null);
            return;
        }
        callback(err,client);

    })
}
 

// 方法二：插入数据，需要抛出
exports.insertOne = function(collectionName,jsonData,callback){
    // 调用上面封装的链接数据库方法_connectDb()
    _connectDB(function(err,client){
        let db = client.db(dbname);   // 选择数据库，dbname在配置文件中配置
        if(err){  //数据库链接失败
            
        }
        //  插入传递过来的数据jsonData
        db.collection('users').insertOne(jsonData,function(err,result){
            callback(err,result);  //把查询结果通过回调函数传给方法调用者
            client.close(); // 关闭数据库
        })
    })
}