Node.js中MySQL事件Prepared Statement的SQL函数/子查询引号问题

问题根源是参数化查询会自动给所有传入的字符串值添加单引号，导致NOW()和子查询被当作普通字符串处理，无法作为SQL表达式执行。以下是两种直接的修复方式：

方式一：拆分静态SQL表达式与动态参数（推荐） #

把NOW()和子查询这类SQL表达式直接写入INSERT语句结构中，仅对动态生成的字段值进行参数化，从根源避免被加单引号。

步骤1：调整参数数组的构建逻辑 #

只保留需要动态传入的字段值，去掉NOW()和子查询：

payload.TierKeys.forEach(t => {
    queryArrays.push([
        CREATE_KEY(),
        t,
        payload.PageKey,
        payload.StoryKey
    ]);
});

步骤2：修改CREATE EVENT的SQL语句 #

将NOW()和子查询直接嵌入VALUES子句，同时把原硬编码的StoryKey改为参数化形式（避免SQL注入）：

// 生成批量插入的行模板，每行对应一组动态参数+静态SQL表达式
const insertRows = queryArrays.map(() => '(?, ?, ?, ?, NOW(), (SELECT Chapters.ChapterKey FROM Chapters INNER JOIN PublishingQueue ON Chapters.ChapterKey = PublishingQueue.ChapterKey WHERE Chapters.StoryKey = ? ORDER BY Chapters.ChapterOrder ASC LIMIT 1))').join(',');

pool.query(`
    CREATE EVENT ${queryData.ScheduleKey + i}
        ON SCHEDULE EVERY 1 WEEK STARTS ?
        DO
            INSERT INTO PublishRecord (PublishRecordKey, TierKey, PageKey, StoryKey, PublishDate, ChapterKey) VALUES ${insertRows}
`, 
// 拼接参数：起始日期 + 所有动态字段值 + 重复传入StoryKey（对应每行子查询的参数）
[dateISO, ...queryArrays.flat(), ...Array(queryArrays.length).fill(payload.StoryKey)], 
(err, rows, fields) => {
    // 你的回调逻辑
});

方式二：在事件内部使用预处理语句 #

如果需要保留原参数数组的结构，可以在事件的DO子句中使用PREPARE和EXECUTE来区分字符串值与SQL表达式：

// 原参数数组保留字段位置，子查询改用占位符
payload.TierKeys.forEach(t => {
    queryArrays.push([
        CREATE_KEY(),
        t,
        payload.PageKey,
        payload.StoryKey,
        'NOW()',
        '(SELECT Chapters.ChapterKey FROM Chapters INNER JOIN PublishingQueue ON Chapters.ChapterKey = PublishingQueue.ChapterKey WHERE Chapters.StoryKey = ? ORDER BY Chapters.ChapterOrder ASC LIMIT 1)'
    ]);
});

// 拼接批量插入的VALUES模板
const valuesTemplate = queryArrays.map(() => '(?, ?, ?, ?, ?, ?)').join(',');

pool.query(`
    CREATE EVENT ${queryData.ScheduleKey + i}
        ON SCHEDULE EVERY 1 WEEK STARTS ?
        DO
            BEGIN
                SET @storyKey = ?;
                PREPARE stmt FROM 'INSERT INTO PublishRecord (PublishRecordKey, TierKey, PageKey, StoryKey, PublishDate, ChapterKey) VALUES ${valuesTemplate}';
                EXECUTE stmt USING ${Array(queryArrays.length * 6).fill('?').join(',')};
                DEALLOCATE PREPARE stmt;
            END
`, 
// 拼接参数：起始日期 + StoryKey + 所有动态字段值 + 重复传入StoryKey对应子查询参数
[dateISO, payload.StoryKey, ...queryArrays.flat(), ...Array(queryArrays.length).fill(payload.StoryKey)], 
(err, rows, fields) => {
    // 你的回调逻辑
});

这种方式复杂度较高，仅在特殊场景下使用，推荐优先使用方式一。

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