Node.js MariaDB：SELECT正常但INSERT报参数错误或语法错误

问题描述 #

使用Express和mariadb连接器构建REST API时，GET路由可正常返回数据库数据，但POST路由在保存新记录时始终报错，数据库返回语法错误或失败信息，怀疑是连接池处理或INSERT语句参数绑定存在问题。

代码示例 #

const express = require('express');
const mariadb = require('mariadb');
const bodyParser = require('body-parser');
const cors = require('cors');
const app = express();
const port = 3000;

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

const pool = mariadb.createPool({
  host: 'localhost',
  user: 'root',
  password: 'admin',
  database: 'gyak0416',
  port: 8888,
  connectionLimit: 5
});

// GET路由正常工作
app.get('/alkalmazottak', async (req, res) => {
    let conn;
    try {
        conn = await pool.getConnection();
        const rows = await conn.query('SELECT * FROM alkalmazottak');
        res.json(rows);
    } catch(err) {
        console.error(err);
        res.status(500).send('Internal Server Error');
    } finally {
        if(conn) conn.end();
    }
});

// POST路由持续报错
app.post('/mentesek', async (req, res) => {
    let conn;
    try {
        conn = await pool.getConnection();
        const {vezeteknev, keresztnev, kor, jelszo} = req.body;
        
        // 报错发生在此行
        const result = await conn.query(
            "INSERT INTO alkalmazottak (vezeteknev, keresztnev, kor, password_hash, belepes_datuma) VALUES (?, ?, ?, ?, ?,)" , 
            [vezeteknev, keresztnev, kor, jelszo]
        );
        res.json({message: 'Sikeres mentés'});
    } catch(err) {
        console.error(err); // 通常记录通用SQL错误
        res.status(500).send('Sikertelen mentés');
    } finally {
        if(conn) conn.end();
    }
});

app.listen(port, () => {
    console.log(`Server running on port ${port}`);
});

已做排查 #

• 验证数据库连接参数（端口8888、主机）正确；
• 确认req.body包含所需数据；
• package.json中引入了bcrypt但尚未实现哈希功能，怀疑原始字符串是否会影响MariaDB驱动的参数绑定。

核心问题 #

INSERT语句是否存在遗漏的语法错误？或是POST路由中pool.getConnection()的生命周期处理有误？

解决方案 #

1. 修复INSERT语句的语法错误 #

你的POST路由报错根源是INSERT语句存在两处明显问题：

• VALUES子句多余逗号：VALUES (?, ?, ?, ?, ?,) 最后一个问号后的逗号属于无效语法，直接触发SQL解析错误；
• 字段与参数数量不匹配：INSERT指定了5个字段（vezeteknev, keresztnev, kor, password_hash, belepes_datuma），但参数数组只传了4个值，缺少belepes_datuma对应的参数。

根据字段的默认值规则，修改方式分为两种：

情况1：belepes_datuma字段有默认值（比如当前时间）

const result = await conn.query(
    "INSERT INTO alkalmazottak (vezeteknev, keresztnev, kor, password_hash, belepes_datuma) VALUES (?, ?, ?, ?, NOW())" , 
    [vezeteknev, keresztnev, kor, jelszo]
);

情况2：需要前端传入belepes_datuma值

const {vezeteknev, keresztnev, kor, jelszo, belepes_datuma} = req.body;
const result = await conn.query(
    "INSERT INTO alkalmazottak (vezeteknev, keresztnev, kor, password_hash, belepes_datuma) VALUES (?, ?, ?, ?, ?)" , 
    [vezeteknev, keresztnev, kor, jelszo, belepes_datuma]
);

2. 连接池使用优化（非报错原因，但推荐改进） #

当前用conn.end()关闭连接的方式是正确的，但Mariadb连接池更推荐用conn.release()将连接放回池复用，而非直接关闭，这样能提升连接池的资源利用率：

finally {
    if(conn) conn.release(); // 替换conn.end()为conn.release()
}

3. 密码哈希补充建议 #

虽然当前报错与明文密码无关，但后续必须实现bcrypt哈希避免明文存储：

const bcrypt = require('bcrypt');

// 在插入前哈希密码
const hashedPassword = await bcrypt.hash(jelszo, 10);
// 用哈希后的值替换原始密码传入参数数组
const result = await conn.query(
    "INSERT INTO alkalmazottak (vezeteknev, keresztnev, kor, password_hash, belepes_datuma) VALUES (?, ?, ?, ?, NOW())" , 
    [vezeteknev, keresztnev, kor, hashedPassword]
);

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