mongodb + node.js封装的数据库增删改查

小鱼儿 2021-09-17 01:38 342阅读 0赞

var MongoClient = require('mongodb').MongoClient;
    var dburl = 'mongodb://localhost:27017/zhihu';
    //不管数据库什么操作，都是先连接数据库，所以我们可以把连接数据库
    //封装成为内部函数
    function _connectDB(callback) {
        var url = dburl;   //从settings文件中，都数据库地址
        //连接数据库
        MongoClient.connect(url, function (err, db) {
            if (err) {
                callback(err, null);
                return;
            }
            callback(err, db);
        });
    }
    
    //插入数据
    exports.insertOne = function (collectionName, json, callback) {
        _connectDB(function (err, db) {
            db.collection(collectionName).insertOne(json, function (err, result) {
                callback(err, result);
                db.close(); //关闭数据库
            })
        })
    };
    
    //查找数据，找到所有数据。args是个对象{"pageamount":10,"page":10}
    exports.find = function (collectionName, json, C, D) {
        var result = [];    //结果数组
        if (arguments.length == 3) {
            //那么参数C就是callback，参数D没有传。
            var callback = C;
            var skipnumber = 0;
            //数目限制
            var limit = 0;
        } else if (arguments.length == 4) {
            var callback = D;
            var args = C;
            //应该省略的条数
            var skipnumber = args.pageamount * args.page || 0;
            //数目限制
            var limit = args.pageamount || 0;
            //排序方式
            var sort = args.sort || {};
        } else {
            throw new Error("find函数的参数个数，必须是3个，或者4个。");
            return;
        }
    
        //连接数据库，连接之后查找所有
        _connectDB(function (err, db) {
            var cursor = db.collection(collectionName).find(json).skip(skipnumber).limit(limit).sort(sort);
            cursor.each(function (err, doc) {
                if (err) {
                    callback(err, null);
                    db.close(); //关闭数据库
                    return;
                }
                if (doc != null) {
                    result.push(doc);   //放入结果数组
                } else {
                    //遍历结束，没有更多的文档了
                    callback(null, result);
                    db.close(); //关闭数据库
                }
            });
        });
    }
    
    //删除
    exports.deleteMany = function (collectionName, json, callback) {
        _connectDB(function (err, db) {
            //删除
            db.collection(collectionName).deleteMany(
                json,
                function (err, results) {
                    callback(err, results);
                    db.close(); //关闭数据库
                }
            );
        });
    }
    
    //修改
    exports.updateMany = function (collectionName, json1, json2, callback) {
        _connectDB(function (err, db) {
            db.collection(collectionName).updateMany(
                json1,
                json2,
                function (err, results) {
                    callback(err, results);
                    db.close();
                });
        })
    }
    
    exports.getAllCount = function (collectionName,callback) {
        _connectDB(function (err, db) {
            db.collection(collectionName).count({}).then(function(count) {
                callback(count);
                db.close();
            });
        })
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，342人围观）

还没有评论，来说两句吧...

相关阅读

相关 MongoDB数据库实现基础的增删改查数据库的信息----MongoDB

> db.createCollection("my") > > db.createCollection("my") > > show collections

╰半橙微兮°/ 2024年03月24日 23:44/ 0 赞/ 194 阅读

相关 MongoDB学习【三】—MongoDB数据库增删改查

一、数据库的增删查增加 use db 有则切换，无则新增查看 show dbs 查看所有数据库 db

喜欢ヅ旅行/ 2023年08月17日 17:45/ 0 赞/ 289 阅读

相关 MongoDB 增删改查（三）

MongoDB 增删改查（三）聚合查询 mongodb自带了一个聚合功能，使用聚合功能，可以直接让mongodb来处理数据。聚合功能可以把数据像放入传送带上一样，先把

比眉伴天荒/ 2023年06月23日 14:22/ 0 赞/ 121 阅读

相关 MongoDB 增删改查（二）

MongoDB 增删改查（二）上一篇写了一些基础的增删改查。这篇写点功能类函数 1、排序 sort为排序函数，-1代表从大到小，1代表从小到大 db.

叁歲伎倆/ 2023年06月23日 13:11/ 0 赞/ 74 阅读

相关 MongoDB 增删改查（一）

MongoDB 增删改查（一）主要特点 MongoDB 是一个面向文档存储的数据库，操作起来比较简单和容易。你可以在MongoDB记录中设置任何属性的索引 (

Dear 丶/ 2023年06月23日 09:57/ 0 赞/ 74 阅读

相关 MongoDB数据库、集合操作（增删改查）

数据库操作选择和创建数据库 use articledb 都是用的是use，在这里进行创建数据库之后，再进行show dbs 查看数据库，会发现articl

我会带着你远行/ 2022年12月15日 03:45/ 0 赞/ 300 阅读

相关【MongoDB】基本的增删改查

强烈推荐一个大神的人工智能的教程：[http://www.captainbed.net/zhanghan][http_www.captainbed.net_zhanghan]

太过爱你忘了你带给我的痛/ 2022年06月16日 06:55/ 0 赞/ 437 阅读

相关 mongodb基本的增删改查

一、基本的增删改查： 1、pom: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="ht

ゝ一世哀愁。/ 2022年02月16日 12:53/ 0 赞/ 524 阅读

相关 mongodb 增删查改

安装模块 pip install pymongo MongoClient对象：用于与MongoDB服务器建立连接 client=MongoClient('主机ip',

淡淡的烟草味﹌/ 2022年01月11日 11:17/ 0 赞/ 648 阅读

相关 mongodb + node.js封装的数据库增删改查

var MongoClient = require('mongodb').MongoClient; var dburl = 'mongodb://localho

小鱼儿/ 2021年09月17日 01:38/ 0 赞/ 343 阅读