使用PreparedStatement批量插入MySQL后如何获取插入行指定name列的返回值

你遇到的困境核心来自两方面的认知和实现限制：

• JDBC规范中Connection.prepareStatement(sql, columnNames)方法的第二个参数，设计初衷是指定需要随插入操作返回的自动生成列，但这个能力的落地完全依赖数据库服务端、JDBC驱动的实际实现
• MySQL 8.0.20版本之前没有内置INSERT ... RETURNING语法，对应的Connector/J驱动就算你传入new String[]{"name"}作为返回列参数，也只会自动返回表的自增主键，完全不会读取你指定的普通列的值，因此你调用getGeneratedKeys()永远拿不到目标的name列数据。

方案1：适配MySQL 8.0.20及以上版本，用原生RETURNING语法 #

这是性能最优、不需要额外查询的实现方式，只需要在原有插入SQL末尾追加RETURNING子句指定要返回的列即可：

1. 修改插入SQL，把需要返回的列写在RETURNING后面
2. 正常执行批量插入，直接通过getGeneratedKeys()拿到返回结果即可，不需要再给prepareStatement传入列名数组参数

代码示例（适配addBatch批量插入模式） #

String insertSql = "INSERT INTO x (id, name) VALUES (?, ?) RETURNING name";
PreparedStatement pstmt = connection.prepareStatement(insertSql);

// 循环攒批量
for (Record record : insertRecordList) {
    pstmt.setLong(1, record.getId());
    pstmt.setString(2, record.getName());
    pstmt.addBatch();
}
// 执行批量插入
pstmt.executeBatch();

// 直接获取返回的name值
ResultSet generatedRs = pstmt.getGeneratedKeys();
List<String> successInsertNames = new ArrayList<>();
while (generatedRs.next()) {
    successInsertNames.add(generatedRs.getString(1));
}

注意：该能力需要同时满足两个版本要求：MySQL服务端版本≥8.0.20，配套的Connector/J驱动版本≥8.0.20，任意一个版本过低都会导致RETURNING子句无法被识别。

方案2：低版本MySQL兼容实现 #

如果你的MySQL版本低于8.0.20，不支持原生RETURNING语法，就没法在插入操作里直接返回普通列值，只能通过插入后二次查询的方式拿到目标列值，根据你的id列生成逻辑分两种情况处理：

• 插入时id是你手动传入的、全局唯一的值：直接把所有传入的id拼到IN查询条件里，查对应行的name列即可，查询出来的结果天然就是实际成功插入的行
• 插入时id是数据库自增生成的：先通过getGeneratedKeys()拿到所有插入行的自增id，再用这批id拼IN查询条件，查对应的name列即可

代码示例（自增id场景） #

String insertSql = "INSERT INTO x (name) VALUES (?)"; // id为自增列
PreparedStatement pstmt = connection.prepareStatement(insertSql, new String[]{"id"});

// 攒批量
for (String name : nameList) {
    pstmt.setString(1, name);
    pstmt.addBatch();
}
pstmt.executeBatch();

// 先拿到所有插入行的自增id
ResultSet idRs = pstmt.getGeneratedKeys();
List<Long> insertIds = new ArrayList<>();
while (idRs.next()) {
    insertIds.add(idRs.getLong(1));
}

// 用id查询对应的name列
String querySql = "SELECT name FROM x WHERE id IN (" +
    String.join(",", Collections.nCopies(insertIds.size(), "?")) + ")";
PreparedStatement queryPstmt = connection.prepareStatement(querySql);
for (int i = 0; i < insertIds.size(); i++) {
    queryPstmt.setLong(i + 1, insertIds.get(i));
}
ResultSet queryRs = queryPstmt.executeQuery();
List<String> successInsertNames = new ArrayList<>();
while (queryRs.next()) {
    successInsertNames.add(queryRs.getString(1));
}

你之前使用的prepareStatement("INSERT INTO x (id,name) VALUES (?,?)", new String[]{"name"})写法，在低版本MySQL驱动环境下：

• 驱动会直接忽略你传入的普通列名参数，默认只返回自增主键列
• 部分老版本驱动甚至会因为检测到你指定的列不是自增生成列，直接抛出参数错误，根本不会正常执行插入逻辑

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