EJS表单提交批量成绩转换为PostgreSQL更新查询方案

表单优化建议 #

你当前的表单命名方式可以正常工作，但存在两个可优化点：

• 输入框用type="number"替代type="text"，自带前端数值校验，可直接通过min/max属性限制分数范围，减少非法输入
• 表单字段名改用Express原生支持的嵌套对象格式，无需手动正则解析键名，后端处理逻辑更简洁

优化后的EJS单元格代码如下：

<td class="score-cell center">
  <input 
    type="number" 
    min="0" 
    max="100" 
    class="score-input" 
    name="scores[<%= student.id %>][<%= topic.id %>]"
    value="<%= existingScore?.points ?? '' %>"
  >
</td>

注意需要提前给Express配置urlencoded中间件开启扩展模式，否则嵌套结构无法正常解析：

app.use(express.urlencoded({ extended: true }));

该写法提交后，req.body.scores会被自动解析为嵌套对象，结构如下，比你当前平铺的键值对更易处理：

{
  1: {2: '75', 3: '92', 4: '100', 5: '100', 6: ''},
  2: {1: '65', 2: '60', 3: '50', 4: '35'}
}

后端数据处理与批量更新 #

无论你保留原有平铺键名的写法，还是改用优化后的嵌套格式，核心逻辑都是先将提交数据整理为[student_id, topic_id, points]格式的有效条目数组，再通过PostgreSQL的批量更新语法一次性写入，禁止循环执行单条UPDATE语句，性能差且容易出现数据不一致问题。

第一步：解析提交数据 #

如果保留原有scores_<sid>_<tid>的命名格式，用正则提取字段中的ID即可：

const scoreUpdates = [];
for (const [key, rawValue] of Object.entries(req.body)) {
  const match = key.match(/^scores_(\d+)_(\d+)$/);
  if (!match) continue; // 过滤非成绩字段
  const studentId = Number(match[1]);
  const topicId = Number(match[2]);
  const points = rawValue.trim();
  if (!points) continue; // 空值跳过，不需要更新
  scoreUpdates.push([studentId, topicId, Number(points)]);
}

如果使用优化后的嵌套表单格式，解析逻辑更简单：

const scoreUpdates = [];
for (const [sid, topicMap] of Object.entries(req.body.scores || {})) {
  const studentId = Number(sid);
  for (const [tid, rawValue] of Object.entries(topicMap)) {
    const topicId = Number(tid);
    const points = rawValue.trim();
    if (!points) continue;
    scoreUpdates.push([studentId, topicId, Number(points)]);
  }
}

如果业务需要支持清空已录入成绩，把空值判断逻辑改为points === '' ? null : Number(points)，将空值转为null存入数组即可，后续更新逻辑无需修改。

第二步：执行参数化批量更新 #

使用node-postgres执行批量更新时，全程用参数化查询避免SQL注入，同时用事务包裹保证数据一致性，代码如下：

// 无有效成绩时直接返回
if (scoreUpdates.length === 0) {
  return res.redirect('/scoresheet?msg=没有需要更新的成绩');
}

// 构造VALUES占位符
const placeholders = scoreUpdates.map((_, idx) => {
  const base = idx * 3;
  return `($${base+1}, $${base+2}, $${base+3})`;
}).join(',');
// 拍平参数为一维数组
const queryParams = scoreUpdates.flat();

const updateSql = `
  UPDATE scores s
  SET points = v.points
  FROM (VALUES ${placeholders}) AS v(student_id, topic_id, points)
  WHERE s.student_id = v.student_id AND s.topic_id = v.topic_id
`;

const client = await pool.connect();
try {
  await client.query('BEGIN');
  await client.query(updateSql, queryParams);
  await client.query('COMMIT');
  res.redirect('/scoresheet?success=成绩更新成功');
} catch (err) {
  await client.query('ROLLBACK');
  console.error('成绩更新失败:', err);
  res.status(500).send('成绩更新失败，请重试');
} finally {
  client.release();
}

该方案生成的单条UPDATE语句会一次性完成所有成绩写入，相比循环单条更新性能提升10~100倍，事务机制可以保证要么所有成绩更新成功，要么全部回滚，不会出现部分数据写入的脏数据问题。

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