使用JDBC连接MySQL执行load data语句可以快速完成批量数据导入，比逐条插入效率高出很多，但实际使用中经常会遇到执行失败的情况，需要结合具体原因针对性解决。
常见失败原因及解决方法
1. 权限不足导致失败
MySQL的用户需要有FILE权限才能执行load data语句，如果当前连接MySQL的用户没有这个权限，就会直接返回权限错误。
解决方法是通过root用户给当前使用的数据库用户授予FILE权限，执行如下SQL语句：
-- 授予指定用户的FILE权限，替换用户名和主机地址 GRANT FILE ON *.* TO 'your_username'@'your_host'; -- 刷新权限使配置生效 FLUSH PRIVILEGES;
2. 本地文件读取限制
MySQL默认可能禁止从客户端本地读取文件，尤其是高版本MySQL默认关闭了local_infile参数，此时执行load data local infile就会失败。
首先可以检查MySQL的local_infile参数状态：
SHOW VARIABLES LIKE 'local_infile';
如果返回值是OFF，需要先开启这个参数：
SET GLOBAL local_infile = ON;
同时JDBC连接URL中需要添加开启本地文件读取的参数，示例连接URL如下：
// 在JDBC URL后添加allowLoadLocalInfile=true参数 String jdbcUrl = "jdbc:mysql://127.0.0.1:3306/test_db?useSSL=false&allowLoadLocalInfile=true";
3. SQL语句格式错误
load data语句的格式不符合要求也会导致执行失败，比如文件路径不正确、字段分隔符和数据文件不匹配、目标表不存在等。
正确的load data语句示例：
-- 从本地文件导入数据到user表，字段以逗号分隔，行以换行分隔 LOAD DATA LOCAL INFILE '/tmp/user_data.csv' INTO TABLE user FIELDS TERMINATED BY ',' LINES TERMINATED BY 'n' IGNORE 1 ROWS; -- 忽略表头行
需要注意文件路径必须是JDBC客户端所在机器的绝对路径，字段分隔符、行分隔符要和实际数据文件完全匹配，目标表必须已经存在且字段对应。
4. 字符集不匹配
如果数据文件的字符集和MySQL表的字符集不一致，可能会出现乱码或者导入失败的情况。
可以在load data语句中指定字符集，示例如下：
LOAD DATA LOCAL INFILE '/tmp/user_data.csv' INTO TABLE user CHARACTER SET utf8mb4 FIELDS TERMINATED BY ',' LINES TERMINATED BY 'n';
5. 文件路径或权限问题
如果数据文件所在的路径JDBC进程没有读取权限，或者文件路径不存在，也会导致load data失败。
可以先确认数据文件是否存在，并且当前运行JDBC程序的用户有读取该文件的权限，Windows系统下路径需要写双反斜杠，比如C:\data\user.csv。
完整JDBC执行示例
以下是完整的JDBC执行load data语句的代码示例：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class JdbcLoadDataDemo {
public static void main(String[] args) {
String jdbcUrl = "jdbc:mysql://127.0.0.1:3306/test_db?useSSL=false&allowLoadLocalInfile=true";
String username = "root";
String password = "your_password";
Connection conn = null;
Statement stmt = null;
try {
// 加载驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 建立连接
conn = DriverManager.getConnection(jdbcUrl, username, password);
stmt = conn.createStatement();
// 执行load data语句
String sql = "LOAD DATA LOCAL INFILE '/tmp/user_data.csv' " +
"INTO TABLE user " +
"CHARACTER SET utf8mb4 " +
"FIELDS TERMINATED BY ',' " +
"LINES TERMINATED BY 'n' " +
"IGNORE 1 ROWS";
int rows = stmt.executeUpdate(sql);
System.out.println("成功导入" + rows + "条数据");
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) stmt.close();
if (conn != null) conn.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
排查思路总结
遇到load data失败时，可以按照以下顺序排查：
- 先查看错误提示信息，根据错误信息定位大致方向
- 检查MySQL用户是否有FILE权限，local_infile参数是否开启
- 检查JDBC连接URL是否添加了allowLoadLocalInfile参数
- 检查load data语句格式、文件路径、字符集配置是否正确
- 检查数据文件是否存在且有权限读取