当前位置：首页 > article >正文

不同的数据库操作方式：MongoDB（NoSQL）和 MySQL/SQL

article 2025/9/12 2:42:59

这两种写法分别使用了不同的数据库操作方式：第一种是 MongoDB（NoSQL） 的写法，第二种是 MySQL/SQL 的写法。我们来对比它们的区别，并给出优化建议。

1. MongoDB（NoSQL）写法

const user = await db.collection('users').findOne({ email });
if (!user) {return res.status(404).json({ status: 'fail', message: '用户不存在' });
}
await db.collection('users').updateOne({ email }, { $set: { emailVerified: true } });

特点

异步 await 语法：使用 Promise 风格，代码更清晰。
MongoDB 查询方式：
- findOne({ email })：查询单个用户（基于 email 字段）。
- updateOne({ email }, { $set: { emailVerified: true } })：更新 emailVerified 字段。
返回 JSON 响应：如果用户不存在，返回 404 状态码和错误信息。

优化建议

增加错误处理：

try {const user = await db.collection('users').findOne({ email });if (!user) {return res.status(404).json({ status: 'fail', message: '用户不存在' });}await db.collection('users').updateOne({ email }, { $set: { emailVerified: true } });res.json({ status: 'success', message: '邮箱验证成功' });
} catch (err) {res.status(500).json({ status: 'error', message: '服务器错误' });
}

使用 $exists 检查字段（如果需要）：

const user = await db.collection('users').findOne({ email, emailVerified: { $exists: true } });

2. MySQL/SQL 写法

db.query(`SELECT * FROM users WHERE openid = ?`, [openid], (err, results) => {if (err) throw err;if (results.length === 0) {return res.status(404).json({ status: 'fail', message: '用户不存在' });}db.query(`UPDATE users SET emailVerified = 1 WHERE openid = ?`, [openid], (err) => {if (err) throw err;res.json({ status: 'success', message: '邮箱验证成功' });});
});

特点

回调函数风格：db.query(sql, [params], callback)，容易形成“回调地狱”。
SQL 语句：
- SELECT * FROM users WHERE openid = ?：查询用户（? 是参数占位符）。
- UPDATE users SET emailVerified = 1 WHERE openid = ?：更新 emailVerified 字段（1 表示 true）。
错误处理：if (err) throw err; 直接抛出错误（不够友好）。

优化建议

改用 async/await（推荐）：

try {const [rows] = await db.query(`SELECT * FROM users WHERE openid = ?`, [openid]);if (rows.length === 0) {return res.status(404).json({ status: 'fail', message: '用户不存在' });}await db.query(`UPDATE users SET emailVerified = 1 WHERE openid = ?`, [openid]);res.json({ status: 'success', message: '邮箱验证成功' });
} catch (err) {res.status(500).json({ status: 'error', message: '服务器错误' });
}

使用 mysql2/promise 或 knex.js 等库，避免回调写法：

import mysql from 'mysql2/promise';
const db = await mysql.createConnection({ ... });

3. 主要区别对比

特性	MongoDB（NoSQL）	MySQL（SQL）
查询方式	`findOne({ email })`	`SELECT * FROM users WHERE email = ?`
更新方式	`updateOne({ email }, { $set: { ... } })`	`UPDATE users SET emailVerified = 1 WHERE email = ?`
错误处理	`try/catch`	回调或 `try/catch`（推荐）
异步风格	`Promise`（`await`）	回调或 `Promise`（推荐 `mysql2/promise`）
适用场景	非结构化数据（JSON）	结构化数据（关系型数据库）

4. 最终推荐写法

MongoDB（推荐）

try {const user = await db.collection('users').findOne({ email });if (!user) {return res.status(404).json({ status: 'fail', message: '用户不存在' });}await db.collection('users').updateOne({ email }, { $set: { emailVerified: true } });res.json({ status: 'success', message: '邮箱验证成功' });
} catch (err) {res.status(500).json({ status: 'error', message: '服务器错误' });
}

MySQL（推荐 `async/await`）

try {const [rows] = await db.query(`SELECT * FROM users WHERE email = ?`, [email]);if (rows.length === 0) {return res.status(404).json({ status: 'fail', message: '用户不存在' });}await db.query(`UPDATE users SET emailVerified = 1 WHERE email = ?`, [email]);res.json({ status: 'success', message: '邮箱验证成功' });
} catch (err) {res.status(500).json({ status: 'error', message: '服务器错误' });
}