如何将Node.js中的PostgreSQL查询转换为存储过程？

1. 创建PostgreSQL存储函数 #

先在PostgreSQL中创建处理学生插入的存储函数，接收姓名、邮箱、爱好参数，执行插入并返回新增的学生记录：

-- PL/pgSQL版本（支持更复杂逻辑扩展）
CREATE OR REPLACE FUNCTION add_student(p_name VARCHAR, p_email VARCHAR, p_hobby VARCHAR)
RETURNS student AS $$
BEGIN
    INSERT INTO student (name, email, hobby)
    VALUES (p_name, p_email, p_hobby)
    RETURNING * INTO FUNCTION;
END;
$$ LANGUAGE plpgsql;

或者用更简洁的SQL函数版本：

CREATE OR REPLACE FUNCTION add_student(p_name VARCHAR, p_email VARCHAR, p_hobby VARCHAR)
RETURNS SETOF student AS $$
    INSERT INTO student (name, email, hobby)
    VALUES ($1, $2, $3)
    RETURNING *;
$$ LANGUAGE sql;

2. 修改Express接口代码 #

更新你的Express POST接口，调用存储函数完成插入操作：

app.post("/add", async(req, res) => {
    try {
        const { name, email, hobby } = req.body;
        // 调用存储函数获取新增学生记录
        const newStudent = await pool.query(
            "SELECT * FROM add_student($1, $2, $3)", 
            [name, email, hobby]
        );
        res.json(newStudent.rows);
    } catch (err) {
        console.error(err.message);
        res.status(500).json({ error: err.message }); // 建议给客户端返回错误响应
    }
});

注意事项 #

• 确保student表结构与函数返回类型匹配，表结构变更时需同步更新存储函数。
• 存储函数的参数类型要和表字段类型一致，避免类型转换错误。
• 继续使用参数化查询方式，$1/$2/$3是安全的占位符，可防范SQL注入。

内容的提问来源于stack exchange，提问作者Ashley Ferns