MySQL批量插入报错：Named parameter name is empty等问题排查

错误原因分析 #

• 第一个错误Named parameter name is empty：你的数据库客户端开启了命名参数模式，它将SQL中的?识别为命名参数占位符，但你未提供对应的参数名，导致报错。
• 第二个错误Unexpected key '0' found in params.parameterSets[0][0]：传入[[values]]后参数变为三维数组，客户端无法解析这种嵌套结构，引发错误。

针对性解决方案 #

场景1：使用mysql2库连接RDS #

如果你的RDS是mysql2的连接实例，优先关闭命名参数模式，或者调整参数写法：

方案A：关闭命名参数模式

在创建数据库连接时，确保namedPlaceholders设为false（默认值即为false，若之前手动开启则关闭）：

const mysql = require('mysql2/promise');
const RDS = await mysql.createConnection({
  host: 'your-rds-host',
  user: 'db-user',
  password: 'db-password',
  database: 'db-name',
  namedPlaceholders: false // 关键配置
});

之后使用你原本的代码即可正常执行：

const values = workouts.map((workout) => [
  nanoid(),
  programEnrollmentId,
  workout.workout_id,
  userId, 
]);

await RDS.query(
  `INSERT INTO user_workouts (nano_id, program_enrolment_id, workout_id, user_id) VALUES ?`,
  [values]
);

方案B：改用命名参数写法（若必须开启命名参数）

生成带命名占位符的SQL语句，同时构造对应的参数对象：

// 生成每个行的命名占位符组
const placeholders = workouts.map((_, index) => 
  `(:nano_id_${index}, :program_enrolment_id_${index}, :workout_id_${index}, :user_id_${index})`
).join(', ');

// 构造命名参数对象
const params = {};
workouts.forEach((workout, index) => {
  params[`nano_id_${index}`] = nanoid();
  params[`program_enrolment_id_${index}`] = programEnrollmentId;
  params[`workout_id_${index}`] = workout.workout_id;
  params[`user_id_${index}`] = userId;
});

// 执行插入
await RDS.query(
  `INSERT INTO user_workouts (nano_id, program_enrolment_id, workout_id, user_id) VALUES ${placeholders}`,
  params
);

场景2：使用AWS RDS Data Service（@aws-sdk/client-rds-data） #

该服务不支持VALUES ?的批量插入语法，需手动生成占位符并平铺参数数组：

const { RDSDataClient, ExecuteStatementCommand } = require("@aws-sdk/client-rds-data");

const client = new RDSDataClient({ region: 'your-region' });

// 生成每个行的占位符组
const placeholders = workouts.map(() => '(?, ?, ?, ?)').join(', ');
// 平铺所有参数为一维数组
const flatValues = workouts.flatMap(workout => [
  nanoid(),
  programEnrollmentId,
  workout.workout_id,
  userId,
]);

// 构造执行参数（注意值类型需匹配字段类型，这里以字符串为例）
const command = new ExecuteStatementCommand({
  resourceArn: 'your-db-resource-arn',
  secretArn: 'your-db-secret-arn',
  database: 'your-db-name',
  sql: `INSERT INTO user_workouts (nano_id, program_enrolment_id, workout_id, user_id) VALUES ${placeholders}`,
  parameters: flatValues.map(val => ({
    value: { stringValue: val }
  }))
});

await client.send(command);

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