Node.js对MongoDB进行增删改查操作
发布日期:2021-10-24 12:41:45 浏览次数:2 分类:技术文章

本文共 4087 字,大约阅读时间需要 13 分钟。

MongoDB简介

是一个开源的、文档型的NoSQL数据库程序。MongoDB将数据存储在类似JSON的文档中,操作起来更灵活方便。NoSQL数据库中的文档(documents)对应于SQL数据库中的一行。将一组文档组合在一起称为集合(collections),它大致相当于关系数据库中的表。

除了作为一个NoSQL数据库,MongoDB还有一些自己的特性:

  • 易于安装和设置
  • 使用BSON(类似于JSON的格式)来存储数据
  • 将文档对象映射到应用程序代码很容易
  • 具有高度可伸缩性和可用性,并支持开箱即用,无需事先定义结构
  • 支持MapReduce操作,将大量数据压缩为有用的聚合结果
  • 免费且开源
  • ......

连接MongoDB

在Node.js中,通常使用库对MongoDB进行操作。Mongoose是一个MongoDB对象建模工具,设计用于在异步环境中工作。

const mongoose = require('mongoose');mongoose.connect('mongodb://localhost/playground')    .then(() => console.log('Connected to MongoDB...'))    .catch( err => console.error('Could not connect to MongoDB... ', err));

Schema

Mongoose中的一切都始于一个模式。每个模式都映射到一个MongoDB集合,并定义该集合中文档的形状。

Schema类型

const courseSchema = new mongoose.Schema({    name: String,    author: String,    tags: [String],    date: {type: Date, default: Date.now},    isPublished: Boolean});

Model

模型是根据模式定义编译的构造函数,模型的实例称为文档,模型负责从底层MongoDB数据库创建和读取文档。

const Course = mongoose.model('Course', courseSchema);const course = new Course({    name: 'Nodejs Course',    author: 'Hiram',    tags: ['node', 'backend'],    isPublished: true});

新增(保存)一个文档

async function createCourse(){    const course = new Course({        name: 'Nodejs Course',        author: 'Hiram',        tags: ['node', 'backend'],        isPublished: true    });        const result = await course.save();    console.log(result);}createCourse();

查找文档

async function getCourses(){    const courses = await Course        .find({author: 'Hiram', isPublished: true})        .limit(10)        .sort({name: 1})        .select({name: 1, tags:1});    console.log(courses);}getCourses();

使用比较操作符

比较操作符

async function getCourses(){    const courses = await Course        // .find({author: 'Hiram', isPublished: true})        // .find({ price: {$gt: 10, $lte: 20} })        .find({price: {$in: [10, 15, 20]} })        .limit(10)        .sort({name: 1})        .select({name: 1, tags:1});    console.log(courses);}getCourses();

使用逻辑操作符

  • or (或) 只要满足任意条件
  • and (与) 所有条件均需满足
async function getCourses(){    const courses = await Course        // .find({author: 'Hiram', isPublished: true})        .find()        // .or([{author: 'Hiram'}, {isPublished: true}])        .and([{author: 'Hiram', isPublished: true}])        .limit(10)        .sort({name: 1})        .select({name: 1, tags:1});    console.log(courses);}getCourses();

使用正则表达式

async function getCourses(){    const courses = await Course        // .find({author: 'Hiram', isPublished: true})        //author字段以“Hiram”开头        // .find({author: /^Hiram/})        //author字段以“Pierce”结尾        // .find({author: /Pierce$/i })        //author字段包含“Hiram”        .find({author: /.*Hiram.*/i })        .limit(10)        .sort({name: 1})        .select({name: 1, tags:1});    console.log(courses);}getCourses();

使用count()计数

async function getCourses(){    const courses = await Course        .find({author: 'Hiram', isPublished: true})        .count();    console.log(courses);}getCourses();

使用分页技术

通过结合使用 skip()limit() 可以做到分页查询的效果

async function getCourses(){    const pageNumber = 2;    const pageSize = 10;    const courses = await Course        .find({author: 'Hiram', isPublished: true})        .skip((pageNumber - 1) * pageSize)        .limit(pageSize)        .sort({name: 1})        .select({name: 1, tags: 1});    console.log(courses);}getCourses();

更新文档

先查找后更新

async function updateCourse(id){    const course = await Course.findById(id);    if(!course) return;    course.isPublished = true;    course.author = 'Another Author';    const result = await course.save();    console.log(result);}

直接更新

async function updateCourse(id){    const course = await Course.findByIdAndUpdate(id, {        $set: {            author: 'Jack',            isPublished: false        }    }, {new: true}); //true返回修改后的文档,false返回修改前的文档    console.log(course);}

MongoDB更新操作符,请参考:

删除文档

  • deleteOne 删除一个
  • deleteMany 删除多个
  • findByIdAndRemove 根据ObjectID删除指定文档
async function removeCourse(id){    // const result = await Course.deleteMany({ _id: id});    const course = await Course.findByIdAndRemove(id);    console.log(course)}

转载于:https://www.cnblogs.com/hiramP/p/10724945.html

转载地址:https://blog.csdn.net/weixin_30784141/article/details/98396407 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:oracle instr函数
下一篇:嵌入式系统之操作系统篇

发表评论

最新留言

第一次来,支持一个
[***.219.124.196]2024年03月28日 05时53分05秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

推荐文章