PrimeFaces p:fileUpload无法获取CSV全路径，LOAD DATA LOCAL导入失败

首先要明确一个关键事实：现代浏览器出于安全考虑，不会向服务器暴露客户端文件的完整路径，你拿到的fichierUpload.getFileName()只有文件名是正常行为，不可能直接获取到客户端的C:\\Users\\helyoubi\\Desktop\\Japon 2\\xxx.csv这类路径。

你的核心问题是想用MySQL的LOAD DATA LOCAL INFILE读取上传的文件，但这个语句需要的是服务器端的文件路径，而不是客户端的。下面提供两种可行的解决方案：

方案1：将上传文件保存到服务器，再用LOAD DATA LOCAL导入 #

先把用户上传的文件写入服务器的临时目录或指定目录，然后用服务器上的完整路径执行SQL语句。

修改ManagedBean的importation方法 #

public void importation() {
    if(fichierUpload != null && fichierUpload.getFileName() != null) {
        try {
            // 选择服务器存储路径：这里用系统临时目录，也可以自定义固定目录
            String tempDir = System.getProperty("java.io.tmpdir");
            String serverFilePath = tempDir + File.separator + fichierUpload.getFileName();
            File serverFile = new File(serverFilePath);

            // 将上传的文件内容写入服务器文件
            try (OutputStream out = new FileOutputStream(serverFile)) {
                out.write(fichierUpload.getContents());
            }

            // 传入服务器端完整路径执行导入
            prelevServ.importToDB(serverFilePath);

            FacesMessage message = new FacesMessage("Succès", fichierUpload.getFileName() + " 已成功导入数据库！");
            FacesContext.getCurrentInstance().addMessage(null, message);

            // 可选：导入完成后删除临时文件（避免占用空间）
            // serverFile.deleteOnExit();
        } catch (IOException e) {
            FacesMessage message = new FacesMessage("Erreur", "保存文件失败：" + e.getMessage());
            FacesContext.getCurrentInstance().addMessage(null, message);
            e.printStackTrace();
        }
    } else {
        FacesMessage message = new FacesMessage("Erreur", "未选择有效文件！");
        FacesContext.getCurrentInstance().addMessage(null, message);
    }
}

关键配置注意事项 #

1. MySQL开启本地文件导入：在MySQL配置文件（my.cnf/my.ini）中添加：

   local_infile=ON
   

   或者在连接MySQL时执行SET GLOBAL local_infile = 1;（需要管理员权限）。

2. JDBC URL配置：MySQL 8.0.23+默认禁用本地文件导入，需要在JDBC URL中显式开启：

   jdbc:mysql://localhost:3306/your_database?allowLoadLocalInfile=true
   

方案2：直接解析上传文件内容，批量插入数据库（更安全灵活） #

不需要依赖服务器文件系统，直接读取上传文件的字节流，解析CSV后批量插入，避免文件权限和MySQL配置问题。

修改ManagedBean的importation方法 #

public void importation() {
    if(fichierUpload != null && fichierUpload.getFileName() != null) {
        try {
            // 直接传入文件字节流给导入方法
            prelevServ.importToDB(fichierUpload.getContents());
            FacesMessage message = new FacesMessage("Succès", fichierUpload.getFileName() + " 已成功导入数据库！");
            FacesContext.getCurrentInstance().addMessage(null, message);
        } catch (IOException e) {
            FacesMessage message = new FacesMessage("Erreur", "读取文件失败：" + e.getMessage());
            FacesContext.getCurrentInstance().addMessage(null, message);
            e.printStackTrace();
        }
    } else {
        FacesMessage message = new FacesMessage("Erreur", "未选择有效文件！");
        FacesContext.getCurrentInstance().addMessage(null, message);
    }
}

修改importToDB方法（解析CSV批量插入） #

假设你有对应的实体类PrelevementSaisons：

@Override
public void importToDB(byte[] fileContent) throws IOException {
    session.beginTransaction();
    
    try (BufferedReader reader = new BufferedReader(
            new InputStreamReader(new ByteArrayInputStream(fileContent), StandardCharsets.UTF_8))) {
        String line;
        // 如果CSV有表头，先跳过第一行
        // reader.readLine();
        
        while ((line = reader.readLine()) != null) {
            // 智能分割CSV字段：处理引号包裹的逗号（比如"abc,def"不会被分割）
            String[] fields = line.split(",(?=(?:[^\"]*\"[^\"]*\")*[^\"]*$)", -1);
            
            // 去除字段前后的引号
            for (int i = 0; i < fields.length; i++) {
                fields[i] = fields[i].replaceAll("^\"|\"$", "").trim();
            }
            
            // 构造实体对象
            PrelevementSaisons prelevement = new PrelevementSaisons();
            prelevement.setEspece(fields[0]);
            prelevement.setSaison(fields[1]);
            prelevement.setDepartement(fields[2]);
            prelevement.setCommune(fields[3]);
            prelevement.setCode(fields[4]);
            prelevement.setAttributions(Integer.parseInt(fields[5]));
            prelevement.setRealisations(Integer.parseInt(fields[6]));
            
            session.save(prelevement);
        }
    } catch (NumberFormatException e) {
        session.getTransaction().rollback();
        throw new RuntimeException("CSV格式错误：数字字段解析失败", e);
    }
    
    session.getTransaction().commit();
}

两种方案对比 #

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