node.js - MongoDB save() 每次创建新文档而不是更新现有文档
问题描述
我正在使用此功能保存到 mongodb:
create(req, res, next) {
let data = req.body;
if(data) {
let newIssue = this.lib.db.model('Issues')('data');
console.log(newIssue);
newIssue.save((err, emp) => {
if(err) return next(this.RESTError('InternalServerError', err));
this.writeHAL(res, emp);
});
} else {
next(this.RESTError('InvalidArgumentError', 'No data received'));
}
}
这是我的架构:
module.exports = {
"id": "Issues",
"properties": {
"issue_title": {
"type": "string",
"description": "The title of the issue"
},
"issue_number": {
"type": "string",
"description": "The issue number"
},
"issue_url": {
"type": "string",
"description": "URL of the issue"
}
}
}
我的理解save()
是,如果文档已经存在于 mongodb 中,它会被更新,但如果它不存在,则会创建一个新文档。但是,每次我发布同一个文档时,都会插入一个新文档,而不是更新现有文档。我怀疑这是因为在保存时,_id
包含唯一 ID 的密钥被添加到我的架构中,从而使文档唯一。这是正确的,如果是,我该如何解决?
附加信息
我现在添加了一个 PUT。这个想法是我会用{upsert:true}
. 我已经部分工作了,我可以 PUT 到issue/{id} where
{id} is the mongodb
_id` 并更新现有文档。
这是我的 PUT:
update(req, res, next) {
let data = req.body;
let id = req.params.id;
if(id) {
this.lib.db.model('Issues')
.findOne({_id: id})
.exec((err, updateIssue) => {
if(err) return next(this.RESTError('InternalServerError', err));
updateIssue = Object.assign(updateIssue, data);
updateIssue.update((err, issue) => {
if(err) return next(this.RESTError('InternalServerError', err));
this.writeHAL(res, issue);
});
});
}
}
这是路由:
controller.addAction({
'path': '/issues/{id}',
'method': 'PUT',
'summary': "UPDATES the issues's information",
'params': [swagger.pathParam('id', 'The id of the issue', 'string'),
swagger.bodyParam('issue', 'the new information to update', 'string')],
'responseClass': 'Issues',
'nickname': 'updateIssue'
}, controller.update);
我不认为我可以将它用于 upsert,因为我没有_id
开始,所以不能创建路径。我的另一个选择是使用github_id
. 但是,每当我尝试更改我的路由路径/issues/{github_id}
或更新我的功能时,.findOne({github_id: id})
我都会遇到错误。我需要能够使用/issues/{github_id}
并检查是否github_id
已经存在。如果是,则更新文档,如果不是,则创建一个新文档。
更多信息。
我已将更新功能更改为:
update(req, res, next) {
let data = req.body;
let id = req.params.id;
if(id) {
this.lib.db.model('Issues')
.findOne({_id: id})
.exec((err, updateIssue) => {
if(err) return next(this.RESTError('InternalServerError', err));
updateIssue = Object.assign(updateIssue, data);
updateIssue.update({_id: id}, data, (err, issue) => {
if(err) return next(this.RESTError('InternalServerError', err));
this.writeHAL(res, issue);
});
});
}
}
如果我console.log
在行后添加以下内容updateIssue.update({_id: id}, data, (err, issue) => {
:
console.log('id: ', id);
console.log('data: ', data);
console.log('err: ', err);
console.log('issue: ', issue);
我得到这个输出:
id: 5b80307403eea4f14b06fe8c
data: { _id: '5b80307403eea4f14b06fe8c',
github_id: '347593262',
issue_title: 'test issue XY',
issue_number: '2',
issue_url: 'https://api.github.com/repos/PCTestOrg/test1/issues/2a',
__v: 0 }
err: null
issue: { n: 1, nModified: 0, ok: 1 }
我希望issue_title
从 更新test issue X
到test issue XY
,但是更新不会发生。我在这里做错了什么?
解决方案
如果要创建或更新,请使用带有upsert的更新
Model.update({_id: id}, obj, {upsert: true}, function (err) {...});
推荐阅读
- node.js - Knex 和 Postgress 连接
- python - 当我已经拥有数据时,为什么我的列表分配索引超出范围?
- c - 在 c 编程中搜索文本文件中的项目
- java - 没有关闭插座的断管
- node.js - 如何向每个套接字连接发送消息(来自服务器)
- php - PHP 未从 Swift 接收 POST 数据
- hybris - 创建新扩展
- angular - Angular Instant Search - 基于 URL 参数更新 HTML 配置
- c# - 在 Telerik datepicker selecteddate 事件的 gridview 单元格中使用 jquery 进行访问控制
- c# - Cannot bind from CreateMessageOptions to TwilioSms Azure Functions