Node.js中如何检查邮箱是否已存在于MySQL数据库

你当前的实现存在几个明显问题，会导致功能不符合预期：

• 路由逻辑直接执行INSERT写入，没有做邮箱存在性校验，会写入重复邮箱数据；就算给email字段加了唯一约束，也会直接抛出未处理的数据库错误
• 路由内先调用res.sendFile()提交响应，后续的数据库操作结果无法正常返回给前端
• 用GET请求做数据写入不符合接口规范，写入类操作应该使用POST方法
• 异步数据库回调里直接throw err会触发进程崩溃，没有做错误兜底处理

首先要给数据库users表的email字段加唯一索引作为最后兜底，避免并发场景下的重复数据写入，执行以下SQL即可：

ALTER TABLE users ADD UNIQUE INDEX idx_email (email);

代码层推荐两种实现方式，优先选第二种，并发场景下更可靠、性能更好。

方式1：先查询后插入（逻辑直观） #

逻辑为先根据传入邮箱查询库中是否已有对应记录，不存在再执行插入：

const express = require('express');
const path = require('path');
const router = express.Router();

app.use(express.static(path.join(__dirname, 'public')));
// 静态页面路由单独编写，不要混入数据操作逻辑
router.get('/',function(req,res) {
    res.sendFile(path.join(__dirname, 'public/html/index.html'));
});

// 邮箱录入接口改用POST方法
router.post('/addEmail', express.json(), async (req, res) => {
    try {
        const email = req.body.email?.trim();
        // 前置校验邮箱格式
        const emailValid = /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(email);
        if (!email || !emailValid) {
            return res.status(400).json({msg: '邮箱格式不合法'});
        }
        // 查询邮箱是否已存在
        const [existList] = await conn.promise().query(
            'SELECT id FROM users WHERE email = ? LIMIT 1',
            [email]
        );
        if (existList.length > 0) {
            return res.status(409).json({msg: '邮箱已存在'});
        }
        // 邮箱不存在则插入
        const [result] = await conn.promise().query(
            'INSERT INTO users (email) VALUES (?)',
            [email]
        );
        return res.status(200).json({msg: '录入成功', userId: result.insertId});
    } catch (err) {
        console.error('接口处理错误：', err);
        return res.status(500).json({msg: '服务内部错误'});
    }
})

如果你使用的是不支持promise的mysql驱动，把await写法换成对应回调写法即可，核心逻辑不变

方式2：依赖唯一索引判断（推荐，高并发安全） #

高并发场景下，方式1可能出现两个请求同时查询到邮箱不存在、随后都执行插入的竞态问题。给email加了唯一索引后，可以直接执行插入，通过捕获MySQL的唯一约束冲突错误判断邮箱是否存在，少一次数据库查询，性能更好，也不会出现并发重复问题：

router.post('/addEmail', express.json(), async (req, res) => {
    try {
        const email = req.body.email?.trim();
        const emailValid = /^[^\s@]+@[^\s@]+\.[^\s@]+$/.test(email);
        if (!email || !emailValid) {
            return res.status(400).json({msg: '邮箱格式不合法'});
        }
        const [result] = await conn.promise().query(
            'INSERT INTO users (email) VALUES (?)',
            [email]
        );
        return res.status(200).json({msg: '录入成功', userId: result.insertId});
    } catch (err) {
        // ER_DUP_ENTRY 是MySQL唯一约束冲突的固定错误码
        if (err.code === 'ER_DUP_ENTRY') {
            return res.status(409).json({msg: '邮箱已存在'});
        }
        console.error('接口处理错误：', err);
        return res.status(500).json({msg: '服务内部错误'});
    }
})

• 所有数据库查询都要用?做参数占位，不要手动拼接SQL字符串，避免SQL注入风险
• 不要在异步回调中直接throw err，这类错误不会被Express默认错误处理逻辑捕获，会直接导致服务进程退出
• 接口严格遵循请求方法语义：GET只做数据查询，写入、修改、删除操作分别用POST、PUT、DELETE方法
• 不要在同一个路由里混合静态资源返回和数据操作逻辑，两类路由分开编写

内容的提问来源于stack exchange，提问作者Daniel Dinca