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

小鱼儿 2021-09-17 01:38 280阅读 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 条评论，280人围观）

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

相关阅读

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

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

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

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

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

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

相关 MongoDB 增删改查（三）

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

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

相关 MongoDB 简单的增删改查

备注: MongoDB 4.2 版本文章目录一.创建二.读取三.更新四.删除一.创建语法: db.COLLE

电玩女神/ 2022年12月22日 09:17/ 0 赞/ 274 阅读

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

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

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

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

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

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

相关 mongodb基本的增删改查

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

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

相关 mongodb 增删查改

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

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

相关 Mongodb数据库常用操作（增删改查）

mongodb也是近几年比较火的一个数据库，相比其他诸如mysql这些关系型数据库来说，它是一种非关系型数据库。那么让我们来看看一些常用的操作命令 / 创建/切换

矫情吗；*/ 2021年09月18日 12:48/ 0 赞/ 480 阅读

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

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

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