如何在Sequelize项目中调用已编写的MySQL存储过程sp_agregarAlumno

1. 分层逻辑说明 #

你的项目采用标准的MVC目录结构，存储过程调用逻辑放在controller层处理，routes层负责接收前端请求转发到对应处理方法，无需修改现有models层的表定义。

2. Controller 层代码实现 #

在controller目录下新建alumnoController.js，写入如下逻辑：

// 引入项目中已配置好的sequelize实例，一般从models/index.js导出
const { sequelize } = require('../models');

exports.agregarAlumno = async (req, res) => {
  try {
    // 从请求体提取所有入参
    const { nombre, sexo, telefono, email, clave, noControl, anioEgreso, promedio, idCarrera } = req.body;

    // 执行存储过程，同时获取输出参数msg
    const [results] = await sequelize.query(
      `CALL sp_agregarAlumno(:nombre, :sexo, :telefono, :email, :clave, :noControl, :anioEgreso, :promedio, :idCarrera, @msg);
       SELECT @msg as msg;`,
      {
        replacements: {
          nombre,
          sexo,
          telefono,
          email,
          clave,
          noControl,
          anioEgreso,
          promedio,
          idCarrera
        },
        type: sequelize.QueryTypes.RAW
      }
    );

    const mensaje = results[0]?.msg || '操作完成';
    res.json({
      success: mensaje.includes('exito'),
      message: mensaje
    });
  } catch (error) {
    res.status(500).json({
      success: false,
      message: '服务器内部错误'
    });
  }
};

3. 路由层配置 #

在routes目录下新建alumnos.js，配置接口路由：

const express = require('express');
const router = express.Router();
const alumnoController = require('../controller/alumnoController');

// 新增学生接口
router.post('/agregar', alumnoController.agregarAlumno);

module.exports = router;

之后在项目入口文件（通常为app.js或index.js）中挂载路由：

app.use('/api/alumnos', require('./routes/alumnos'));

4. 注意事项 #

• 提前确认数据库中sp_agregarAlumno存储过程以及依赖的registrarUsuario函数已正常创建，数据库用户拥有存储过程的执行权限
• 前端传递的参数类型需要和存储过程定义的参数类型匹配，比如anioEgreso为整型、promedio为浮点型，避免类型不匹配导致执行报错
• 生产环境不要返回原始数据库错误信息到前端，避免泄露敏感信息

内容的提问来源于stack exchange，提问作者Jaime Alejandro