欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

MongoDB数据库操作增删查改函数包装

程序员文章站 2024-03-06 11:06:19
...

mongodb数据库操作模块

MongoDB数据库操作增删查改函数包装

简单的说就是通过构造器将mongodb复杂的中间操作省去,而直接对数据进行操作

  1. 引入mongodb模块
const mongodb = require('mongodb') 
  1. 定义mongo客户端、mongo ObjectIdMongoClient服务器ip地址
const mongoclient = mongodb.MongoClient
const objectid = mongodb.ObjectId
const mongodbUrl = 'mongodb://127.0.0.1:27017'
  1. 构建一个MongoControl构造器 变量 dbName数据库名称/tableName集合变量

mongo客户端连接基本步骤

  1. MongoClient连接mongodbUrl
    mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) = {     }    
    
    服务器,返回连接成功后的客户端
  2. 连接数据库,定义为db
    var db = client.db(this.dbName) 
    
  3. 选择当前数据库中集合
    db.collection(this.tableName)     
    
  4. 再对数据库进行各种数据操作,如insert(插入)、update(更新)、remove(移除)、find(查找)等操作

全部代码如下

const mongodb = require('mongodb')
const mongoclient = mongodb.MongoClient
const objectid = mongodb.ObjectId
const mongodbUrl = 'mongodb://127.0.0.1:27017'
var MongoControl = function (dbName, tableName) {
    this.tableName = tableName
    this.dbName = dbName
    this.insert = function (data, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                console.log(err)
                return
            }
            var db = client.db(this.dbName)
            db.collection(this.tableName).insert(data, function (err, res) {
                callback(err, res)
                client.close()
            })
        })
    }
    this.find = function (findQuery, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                console.log(err)
                return
            }
            var db = client.db(this.dbName)
            db.collection(this.tableName).find(findQuery).toArray(function (err, res) {
                callback(err, res)
                client.close()
            })
        })
    }
    this.findById = function (_id, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                callback(err)
                 return
            }
            var db = client.db(this.dbName)
            db.collection(this.tableName).find({ _id: objectid(_id) }).toArray(function (err, res) {
                callback(err, res)
                client.close()
            })
        })
    }
    this.removeByid = function (_id, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                return console.log(err)
            }
            var db = client.db(this.dbName)
            db.collection(this.tableName).remove({ _id: objectid(_id) }, function (err, res) {
                callback(err, res.result)
                client.close()
            })
        })
    }
    this.update = function (jName, xName, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                console.log(err)
                return 
            }
            var db = client.db(dbName)
            db.collection(tableName).update(jName, { $set: xName }, function (err, res) {
                callback(err, res.result)
                client.close()
            })
        })
    }
    this.updateById = function (_id, newdos, callback) {
        mongoclient.connect(mongodbUrl, { useNewUrlParser: true }, (err, client) => {
            if (err) {
                return console.log(err)
            }
            var db = client.db(dbName)
            db.collection(tableName).update({ _id: objectid(_id) }, { $set: newdos }, function (err, res) {
                callback(err, res.result)
                client.close()
            }) 
        })
    }
} // 引出mongocontrol模块
exports.MongoControl = MongoControl                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                                

在处理数据时会存在的一些问题:

  1. 插入数据时需用toArray()方法,将集合转化为数组。
  2. mongodb id处理必须用其自身所带的属性ObjectId进行操作。
  3. 在对数据进行update方法更新时必须使用{$set:nowdate}的方式进行更新,否则会覆盖当前数据
  4. 通过callback回调函数处理结果。\r\n\u003e5. 处理完结果需关闭客户端,否则服务器会一直处于等待状态。
相关标签: MongoDB包装