node.js mongoose middleware

目录

官方文档

简介

定义模型

注册中间件

创建doc实例,并进行增删改查

方法名和注册的中间件名相匹配

执行结果

分析

错误处理中间件 

手动抛出错误

注意点


官方文档

Mongoose v8.0.3: Middleware

简介

在mongoose中,中间件是一种允许在执行数据库操作前(pre)或后(post)执行自定义逻辑的机制。

定义模型

const mongoose = require('mongoose');
const schema = new mongoose.Schema({name: {type: String,required: true}},
);

注册中间件

pre为前置中间件,post为后置中间件,允许正则匹配

schema.pre('validate', function(next){  
// this指向正在验证的docconsole.log('doc validate before')next()
})
schema.post('validate', function(doc) { 
//this == doc   trueconsole.log('doc validated')
})schema.pre('save', function(next){  
// this指向正在验证的docconsole.log('doc save brfore')next()
})
schema.post('save', function(doc) {  
//this == doc   trueconsole.log('doc saved')
})schema.pre('init', function(doc) { 
// doc是查询的文档console.log('doc init before')
})schema.post('init', function(doc) {  
// this == doc   trueconsole.log('doc inited')
})schema.pre(/find/, function() {   
//this指向Query实例 console.log('doc find')
})schema.post(/find/, function(doc) { 
// doc是查询的文档console.log('doc finded')
})schema.pre('updateOne', function(next){ 
//this指向Query实例  _conditions: { _id: new ObjectId('658147685eca07e7b0c52259') }console.log('doc update before')next()
})schema.post('updateOne', function(res) { 
// res更新结果console.log('doc updated') 
})schema.pre('deleteOne', function(next){  
//this指向Query实例  _conditions: { _id: new ObjectId('658147685eca07e7b0c52259') }console.log('doc remove before')next()
})schema.post('deleteOne', function() {  
// res删除结果console.log('doc removed')
})schema.pre('aggregate', function() {  
// this指向正在处理的aggregate
})schema.pre('aggregate', function() {  
// this指向正在处理的aggregate
})const Model = mongoose.model('SchemaIdentify', schema)

创建doc实例,并进行增删改查

app.post('/', async (req, res) => {const doc = new Model({name: 'saaaaaaaaaa',})await doc.save()await Model.findById(doc._id)await Model.updateOne({_id: doc._id}, {name: 'hahahahah'})await Model.deleteOne({_id: doc._id})  res.status(200).json()
})

方法名和注册的中间件名相匹配

执行结果

分析

Mongoose 内部有一个内置的 pre('save') 钩子,它会调用 validate() 方法,从而触发中间件。因此,在执行 save() 之前,所有注册的 pre('validate') 和 post('validate') 钩子都会被调用

schema.pre('save', async function(next){ // 模拟内置await this.validate() // this指向正在处理的docnext()
})

注册validate、save、/find/ 、/update/、/delete/等前置中间件接收一个next函数,可以控制next决定是否继续执行注册的中间件, 回调函数中的this有不同的指向,validate、save中间件指向正在处理的文档, /find/ 、/update/、/delete/等中间件中的this指向Query实例。后置中间件validate、save接收一个参数表示处理过的doc,/find/接收一个参数表示查询结果doc或docs、/update/、/delete/等中间件接收一个参数表示处理的结果, 第二个参数为next。

/find/ :

/update/:

/delete/:

错误处理中间件 

当执行某操作的时候如果发生错误,后置中间件会接收一个error参数,并且不会继续执行后续的中间件,规定定义三个参数

不传入更新的内容

schema.post('updateOne', function(error, res, next) { // res更新结果console.log('doc updated', error)next()
})


手动抛出错误

不管是前置、后置,任何中间件中手动抛出一个错误也不会继续往下执行中间件

schema.post(/find/, function(doc) {throw new Error('eeeerrror')
})

注意点

1、中间件如果不声明next参数,执行完则默认继续执行下一个中间件,如果中间件声明了next不调用则卡在这个中间件(声明必调用,要不就不声明)

2、在const Model = mongoose.model('SchemaIdentify', schema) 编译之前声明中间件,否则中间件不会执行

3、/update/ 中间件并不会触发save中间件,也就不会调用validate(),即也不会执行validate中间件。可以调用Model.findOneAndUpdate或findByIdAndUpdat,设置第三个参数options { runValidators: true },允许monggose进行数据校验。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/234473.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

DDD领域驱动设计(二)

软件系统复杂性的应对 解决复杂和大规模软件的武器可以粗略的归位三种:抽象 分治和知识 抽象: 使用抽象能够精简问题空间,而且问题越小越容易理解。比如你去一个地方 一开始的时候并不需要确定用什么方式到达。分治: 类似算法里面的dp用的就是分治的想法。分割后的…

JDK+Maven环境变量配置

JDK环境变量配置 首先,找到 JDK 的安装目录,之前复制的以备后用。 然后,通过“控制面板”进入“系统”属性: 然后,点击“高级系统设置”,选择“高级” 再点击“环境变量(N)...”…

破局新渠道|2023年热度全域达人分销生态大会回顾

12月7日,由热度电商、热度云、集脉新电商联合举办的「破局新渠道」热度全域达人分销生态大会暨热度云3.0发布会在杭州国际博览中心圆满收官。大会邀请了平台官方、电商协会、品牌方、业务操盘手、数据专家、团长机构、达人等达人分销生态中的多个角色,从…

Python办公—pandas读取Excel表格增加列、两列保持一致、依条件修改单元格内容(附代码)

目录 专栏导读背景插入一列插入多列依条件修改单元格内容(2个条件以内)依条件修改单元格内容(3个条件以上)两列保持一致结尾 专栏导读 🌸 欢迎来到Python办公自动化专栏—Python处理办公问题,解放您的双手 🏳️‍🌈 博客主页&am…

快速排序

描述 著名的快速排序算法里有一个经典的划分过程:我们通常采用某种方法取一个元素作为主元,通过交换,把比主元小的元素放到它的左边,比主元大的元素放到它的右边。 给定划分后的 N 个互不相同的正整数的排列,请问有多少…

Flink系列之:Upsert Kafka SQL 连接器

Flink系列之:Upsert Kafka SQL 连接器 一、Upsert Kafka SQL 连接器二、依赖三、完整示例四、可用元数据五、键和值格式六、主键约束七、一致性保证八、为每个分区生成相应的watermark九、数据类型映射 一、Upsert Kafka SQL 连接器 Scan Source: Unbounded 、Sink…

2023年中国数据智能管理峰会(DAMS上海站2023)-核心PPT资料下载

一、峰会简介 数据已经成为企业的核心竞争力!谁掌控数据、更好的利用数据、实现资产化,谁就会真正率先进入大数据时代。 1、数据智能管理趋势和挑战 在峰会上,与会者讨论了数据智能管理的最新趋势和挑战。随着数据量的不断增加&#xff0c…

JNI逆向

IDA:JNI类型转换 1.IDA高版本(IDA 高版本内置了定义的JNI结构体; 如果没有的话,在Views->Open subviews -> Type Libraries 中添加Android ARM的lib即可) 解决方法: 只需要对JNIEnv 指针(JNIEnv * &#xff09…

【影像组学入门百问】#32—#34

#32-影像组学研究过程中,图像重采样参 数怎么选择? 在影像组学研究过程中,选择合适的图像重采样参数对于保证分析质量和准确性至关重要。以下是在选择图像重采样参数时需要考虑的一些建议: 1.目标分辨率:首先&#…

力扣 | 347. 前 K 个高频元素

leetcode 347 号算法题&#xff1a;前 K 个高频元素 给你一个整数数组 nums 和一个整数 k &#xff0c;请你返回其中出现频率前 k 高的元素。 你可以按 任意顺序 返回答案。输入: nums [1,1,1,2,2,3], k 2 输出: [2, 1]输入: nums [1], k 1 输出: [1]1 < nums.length &…

使用postman时,报错SSL Error: Unable to verify the first certificate

开发中使用postman调用接口&#xff0c;出现以下问题&#xff0c;在确认路径、参数、请求方式均为正确的情况下 解决方法 File - Settings -> SSL certification verification 关闭 找到图中配置&#xff0c;这里默认是打开状态&#xff0c;把它关闭即可&#xff1a;ON …

虾皮测评选品:如何在虾皮平台上进行有效的产品测评和选品

在如今的电商市场中&#xff0c;虾皮&#xff08;Shopee&#xff09;平台已经成为了卖家们最为重要的销售渠道之一。而在虾皮平台上进行产品测评和选品对于卖家来说至关重要&#xff0c;它直接影响到店铺的销售额和利润。本文将为您提供一些关于如何在虾皮平台上进行有效的产品…

如何通过ETLCloud的API对接功能实现各种SaaS平台数据对接

前言 当前使用SaaS系统的企业越来越多&#xff0c;当我们需要对SaaS系统中产生的数据进行分析和对接时就需要与SaaS系统提供的API进行对接&#xff0c;因为SaaS一般是不会提供数据库表给企业&#xff0c;这时就应该使用ETL&#xff08;Extract, Transform, Load&#xff09;的…

Tenda账号密码泄露漏洞复现 [附POC]

文章目录 Tenda账号密码泄露漏洞复现 [附POC]0x01 前言0x02 漏洞描述0x03 影响版本0x04 漏洞环境0x05 漏洞复现1.访问漏洞环境2.构造POC3.复现Tenda账号密码泄露漏洞复现 [附POC] 0x01 前言 免责声明:请勿利用文章内的相关技术从事非法测试,由于传播、利用此文所提供的信息…

复杂 SQL 实现分组分情况分页查询

其他系列文章导航 Java基础合集数据结构与算法合集 设计模式合集 多线程合集 分布式合集 ES合集 文章目录 其他系列文章导航 文章目录 前言 一、根据 camp_status 字段分为 6 种情况 1.1 SQL语句 1.2 SQL解释 二、分页 SQL 实现 2.1 SQL语句 2.2 根据 camp_type 区分返…

Unity中Shader测试常用的UGUI功能简介

文章目录 前言一、锚点1、锚点快捷修改位置2、使用Anchor Presets快捷修改3、Anchor Presets界面按下 Shift 可以快捷修改锚点和中心点位置4、Anchor Presets界面按下 Alt 可以快捷修改锚点位置、UI对象位置 和 长宽大小 二、Canvas画布1、UGUI中 Transform 变成了 Rect Transf…

openssl数据压缩

介绍 数据压缩是将原有数据通过某种压缩算法计算得到相对数据量小的过程。这种过程是可逆的&#xff0c;即能通过压缩后的数据恢复出原数据。数据压缩能够节省存储空间&#xff0c;减轻网络负载。 在即需要加密又需要压缩的情况下&#xff0c;必须先压缩再加密&#xff0c;次…

Linux 操作系统(查看文件内容)

cat 格式&#xff1a;cat [选项]...[文件]... 说明&#xff1a;把多个文件连接后输出到标准输出&#xff08;屏幕&#xff09;或者加”> 文件名” 输出到另一个文件中 常用选项&#xff1a; -b或—number-noblank: 从1开始对所有非空输出行进行编号 -n或—number: 从1开始所…

网络协议小记

一、TCP/IP协议 作为一个小萌新&#xff0c;当然我无法将tcp/ip协议的大部分江山和盘托出&#xff0c;但是其中很多面试可能问到的知识&#xff0c;我觉得有必要总结一下&#xff01; 首先&#xff0c;在学习tcp/ip协议之前&#xff0c;我们必须搞明白什么是tcp/ip协议。 1、…

6. 3 lambda表达式

6.3 lambda表达式 指定时间间隔完成工作&#xff0c;该工作放在了ActionListener中的action performed 方法中&#xff1b;work类继承上述类&#xff0c;构造work类实例 定制比较器完成排序&#xff0c;定义一个长度比较类&#xff0c;再传给sort&#xff1b;实现基于长度排…