如何用JavaScript和SQL从对象数组向PostgreSQL动态插入数据

我正在开发一个供客户填写的动态表单，提交数据到PostgreSQL数据库。前端基于React构建，后端使用Node.js，目前问题聚焦在服务端代码上。

客户填写表单后，输入内容会整理为对象数组，示例如下：

const array = [{name: 'Jack', age: 30}, {name:'Sally', age: 28}, {name: 'Zero', age: 0}]

用户可从表单添加任意数量的对象到该数组，数组内对象数量无限制。我需要遍历此对象数组，将每个对象对应的name和age值正确POST至数据库，但提交后浏览器控制台返回400 BAD REQUEST错误响应，以下是当前无法正常运行的代码片段：

app.post('/test-url', (req, res) => {

  const { array } = req.body;

  const insertDetailsSQL = '
    insert into "details" ("name", "age")
    values ($1, $2)
  ';

  array.map(event => {

    const insertDetailsParams = [event.name, event.age] 
    db.query (insertDetailsSQL, insertDetailsParams)
    .then(result => {
      const [newResult] = result.rows
  }

 const newDetails = { newResult };
 res.status(201).json(newDetails);

}

你的代码存在语法、逻辑、异步处理三类核心问题，直接导致了400错误和功能失效，修复后的代码及问题解析如下：

核心问题点 #

1. SQL字符串语法错误：多行字符串用单引号包裹会触发语法报错，需改用反引号`
2. 异步逻辑顺序错误：db.query是异步操作，原代码在遍历后直接返回响应，此时数据库操作尚未完成，会导致数据插入不完整或请求异常
3. 变量作用域问题：newResult定义在then回调内部，外部无法访问，直接赋值会触发未定义错误
4. 语法闭合缺失：then回调、map函数均未正确闭合括号，直接导致服务端语法报错
5. 无错误捕获机制：未处理数据库查询异常，一旦出错会导致请求挂起或返回模糊错误

修复后的完整代码 #

app.post('/test-url', async (req, res) => {
  try {
    // 前置校验：确保请求体中的array合法
    if (!req.body.array || !Array.isArray(req.body.array)) {
      return res.status(400).json({ error: '请求数据格式错误，array必须为有效数组' });
    }

    const { array } = req.body;
    // 用反引号包裹多行SQL，添加RETURNING返回插入后的记录
    const insertDetailsSQL = `
      INSERT INTO "details" ("name", "age")
      VALUES ($1, $2)
      RETURNING *;
    `;

    // 用Promise.all批量处理异步插入，确保所有操作完成后再响应
    const insertedRecords = await Promise.all(
      array.map(event => {
        // 校验单个对象的字段合法性
        if (!event.name || typeof event.age !== 'number') {
          throw new Error(`无效数据项：${JSON.stringify(event)}`);
        }
        const params = [event.name, event.age];
        return db.query(insertDetailsSQL, params).then(result => result.rows[0]);
      })
    );

    res.status(201).json({ data: insertedRecords });
  } catch (error) {
    console.error('数据插入失败:', error);
    res.status(500).json({ error: '服务器内部错误', details: error.message });
  }
});

• 异步处理优化：使用async/await配合Promise.all，确保所有数据库插入操作完成后再返回响应，避免异步竞态问题
• 请求合法性校验：提前校验请求体格式，快速返回400错误，避免无效逻辑执行
• SQL语法修正：用反引号包裹多行SQL，同时添加RETURNING *获取插入后的完整记录，方便前端确认结果
• 错误捕获机制：用try/catch覆盖所有异常场景，返回清晰的错误信息，便于问题排查

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