如何用Node.js更新MySQL数据？解决更新失败及connection未定义错误

看起来你遇到了两个核心问题——数据库连接的ReferenceError，以及预测结果无法成功保存到MySQL的问题。我来一步步帮你搞定：

1. 修复「connection is not defined」错误 #

你代码里用了db.query()，但报错提示connection未定义，本质是你的db对象没有正确初始化——也就是数据库连接根本没建立起来。

不管你用的是mysql还是mysql2模块，都得先创建合法的连接对象或者连接池：

推荐方案：用连接池初始化（适合生产环境） #

const mysql = require('mysql2'); // 或者 require('mysql')

// 替换成你的真实数据库配置
const db = mysql.createPool({
  host: 'localhost', // 你的数据库地址
  user: 'your_db_username', // 数据库用户名
  password: 'your_db_password', // 数据库密码
  database: 'your_database_name', // 要操作的目标数据库
  connectionLimit: 10, // 连接池最大连接数
  waitForConnections: true
});

// 可选：测试连接是否正常
db.getConnection((err, connection) => {
  if (err) {
    console.error('数据库连接失败:', err);
    return;
  }
  console.log('已成功连接到MySQL数据库');
  connection.release(); // 用完记得释放连接回池
});

如果你之前用的是单连接而非连接池，要确保调用了connect()方法，并且变量名和代码里的db保持一致（别把connection写成db，或者反过来）。

2. 修复SQL语句，解决数据无法保存问题 #

你的原始SQL直接拼接变量，不仅有SQL注入风险，还会因为日期格式不匹配导致WHERE条件找不到对应行，最终数据无法更新。咱们改成参数化查询：

const periode = _.get(row, "periode", new Date());
// 将Date对象转换为MySQL支持的DATETIME格式（YYYY-MM-DD HH:MM:SS）
const formattedPeriode = periode.toISOString().slice(0, 19).replace('T', ' ');
const prediction = b0 + b1 * Number.parseFloat(_.get(row, "x1", 0)) + b2 * Number.parseFloat(_.get(row, "x2", 0));

// 使用?作为占位符，让数据库自动处理数据类型转换
const sql = 'UPDATE performance SET prediction_result = ? WHERE periode = ?';
db.query(sql, [prediction, formattedPeriode], (error, results, fields) => {
  if (error) {
    console.error('执行更新查询时出错:', error);
    throw error;
  }

  // 检查是否有行被实际更新，快速排查数据没保存的原因
  if (results.affectedRows === 0) {
    console.warn('⚠️ 没有找到匹配periode的记录，未更新任何数据');
    // 可以在这里打印formattedPeriode，和数据库里的periode值对比验证
    console.log('当前查询的periode值:', formattedPeriode);
  } else {
    console.log(`✅ 成功更新了${results.affectedRows}条数据`);
  }
});

为什么要这么改？ #

• 彻底避免SQL注入：直接拼接变量会让恶意用户篡改你的SQL语句，参数化查询能从根源解决这个安全问题。
• 日期格式兼容：MySQL的DATE/DATETIME类型只认特定格式的字符串，转换后的格式能确保WHERE条件精准匹配。
• 明确更新结果：通过results.affectedRows可以直接知道是否有数据被修改，方便快速定位问题。

3. 其他可能导致数据无法保存的排查点 #

如果以上两步做完还是没解决，你可以检查这几个地方：

• 确认数据库里periode字段的类型：如果是DATE类型，只需YYYY-MM-DD格式，把formattedPeriode改成periode.toISOString().slice(0, 10)即可。
• 检查数据库用户权限：确保你用的账号有UPDATE表performance的权限。
• 查看MySQL日志：如果有隐性错误，数据库日志会给出更详细的报错信息。

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