当将重复数据插入mongodb时，节点崩溃

Question

所以我试图测试我的节点服务器是否可以处理向mongodb插入重复数据，但显然不能。

这是代码：

app.post('/register', async (req, res) => {
const { email, password, firstName, lastName} = req.body
console.log(lastName)
console.log(typeof(lastName))
pword = await bcrypt.hash(password, 10)
try {
const response = user.create({
email: email,
password: pword,
firstName: firstName,
lastName: lastName
})
console.log("User created successfully: " + response)
} catch (error) {
return res.json({ status: 'error'})
}
})

错误是：

MongoServerError: E11000 duplicate key error collection: ApartmentDB.UserData index: email_1 dup key: { email: "asdasa" }
at C:UsersHansDesktopMobDev Final Projectnode_modulesmongodbliboperationsinsert.js:51:33
at C:UsersHansDesktopMobDev Final Projectnode_modulesmongodblibcmapconnection_pool.js:272:25
at handleOperationResult (C:UsersHansDesktopMobDev Final Projectnode_modulesmongodblibsdamserver.js:370:9)
at MessageStream.messageHandler (C:UsersHansDesktopMobDev Final Projectnode_modulesmongodblibcmapconnection.js:479:9)
at MessageStream.emit (node:events:390:28)
at processIncomingData (C:UsersHansDesktopMobDev Final Projectnode_modulesmongodblibcmapmessage_stream.js:108:16)
at MessageStream._write (C:UsersHansDesktopMobDev Final Projectnode_modulesmongodblibcmapmessage_stream.js:28:9)
at writeOrBuffer (node:internal/streams/writable:389:12)
at _write (node:internal/streams/writable:330:10)
at MessageStream.Writable.write (node:internal/streams/writable:334:10) {
index: 0,
code: 11000,
keyPattern: { email: 1 },
keyValue: { email: 'asdasa' }
}
[nodemon] app crashed - waiting for file changes before starting...

我看到了一个类似于我的帖子，说他发送了两个回复，但我看不出

Answer 1

我认为您没有使用await user.create。

在完成DB插入操作之前，您将返回响应，稍后DB将抛出错误。

app.post("/register", async (req, res) => {
const { email, password, firstName, lastName } = req.body;
console.log(lastName);
console.log(typeof lastName);
pword = await bcrypt.hash(password, 10);
try {
const response = await user.create({
email: email,
password: pword,
firstName: firstName,
lastName: lastName,
});
console.log("User created successfully: " + response);
} catch (error) {
if (error.status === "E11000") { // it could be .status, .code etc.. not sure
return res.json({ status: "error", msg: "User already exist." });
}
return res.json({ status: "error" });
}
});

Answer 2

解决方案只是在处理程序中添加一个检查，如下所示：

app.post("/register", async (req, res) => {
const { email, password, firstName, lastName } = req.body;
console.log(lastName);
console.log(typeof lastName);
pword = await bcrypt.hash(password, 10);
const existingUser = user.findOne({ email });
if (existingUser) return res.send("User already exists");
try {
const response = await user.create({
email: email,
password: pword,
firstName: firstName,
lastName: lastName,
});
console.log("User created successfully: " + response);
} catch (error) {
return res.json({ status: "error" });
}
});

还要注意，一旦添加了用户，您只会console.log()处理数据，而不会发送任何响应，这只会导致客户端超时。

Answer 3

只需在检查用户是否已经存在后返回一个状态代码和一条消息。这将确保流程不会向前推进，也不会试图创建具有以下现有详细信息的新用户：如果(existingUser(返回res.send("用户已经存在"(；