MySQL批量执行LOAD DATA LOCAL INFILE遇参数绑定错误，求解决方案

首先得明确：MySQL的LOAD DATA LOCAL INFILE语句里的文件名位置不支持使用?参数占位符——这是因为这个部分不属于SQL标准定义的参数绑定范围，JDBC驱动不会解析这里的占位符，所以你才会遇到"参数索引越界"的错误。

下面给你几个可行的解决方案，按需选择：

方案1：动态拼接SQL语句（最直接） #

既然不能用占位符，那可以直接把文件名拼接进SQL语句里。但要注意必须保证文件名是安全可信的（比如是你自己生成的绝对路径，而非用户输入的内容），避免SQL注入风险。同时要转义文件名里的单引号，防止SQL语法错误：

con.setAutoCommit(false); // 开启手动事务，确保批量操作的原子性
try {
    for (String filename : filenames) {
        // 转义文件名中的单引号，避免破坏SQL语法
        String escapedFilename = filename.replace("'", "\\'");
        String sql = String.format("LOAD DATA LOCAL INFILE '%s' INTO TABLE mytable", escapedFilename);
        
        PreparedStatement ps = con.prepareStatement(sql);
        ps.executeUpdate();
        ps.close();
    }
    con.commit(); // 所有文件插入完成后提交事务
} catch (SQLException e) {
    con.rollback(); // 出错时回滚
    throw new RuntimeException("批量插入失败", e);
}

方案2：使用MySQL用户变量（更安全的拼接替代） #

如果担心直接拼接的安全问题，可以先把文件名赋值给MySQL的用户变量，再在LOAD DATA语句中引用这个变量。这样既避免了直接拼接SQL，又能动态传入文件名：

con.setAutoCommit(false);
try {
    // 先准备设置用户变量的PreparedStatement
    PreparedStatement setVarStmt = con.prepareStatement("SET @filename = ?");
    
    for (String filename : filenames) {
        // 设置用户变量为当前文件名
        setVarStmt.setString(1, filename);
        setVarStmt.executeUpdate();
        
        // 执行LOAD语句，引用用户变量
        PreparedStatement loadStmt = con.prepareStatement("LOAD DATA LOCAL INFILE @filename INTO TABLE mytable");
        loadStmt.executeUpdate();
        loadStmt.close();
    }
    
    setVarStmt.close();
    con.commit();
} catch (SQLException e) {
    con.rollback();
    throw new RuntimeException("批量插入失败", e);
}

注意：部分MySQL驱动版本对这种方式的支持可能有差异，建议先测试验证。

方案3：使用Statement的批量处理（减少对象创建开销） #

如果你的批量操作文件数量较多，可以用Statement的addBatch方法批量添加SQL语句，减少重复创建PreparedStatement的开销：

con.setAutoCommit(false);
Statement stmt = con.createStatement();
try {
    for (String filename : filenames) {
        String escapedFilename = filename.replace("'", "\\'");
        String sql = String.format("LOAD DATA LOCAL INFILE '%s' INTO TABLE mytable", escapedFilename);
        stmt.addBatch(sql);
    }
    
    stmt.executeBatch(); // 执行所有批量SQL
    con.commit();
} catch (SQLException e) {
    con.rollback();
    throw new RuntimeException("批量插入失败", e);
} finally {
    stmt.close();
}

关键注意事项 #

• 开启本地加载权限：MySQL JDBC连接URL需要添加allowLoadLocalInfile=true参数（部分驱动版本参数名为allowLoadLocalInfiles），否则会禁止本地文件加载。
• 权限验证：数据库用户需要拥有FILE权限，同时本地文件的权限要确保能被读取（如果是客户端本地文件，JDBC驱动会负责上传，但要确保客户端允许本地加载操作）。
• 安全防护：如果文件名来自外部输入，一定要严格校验（比如限制文件路径在指定目录、过滤特殊字符），绝对不能直接拼接进SQL，避免SQL注入攻击。

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