Java Stream读取txt文件后执行save无SQL生成问题排查

你的代码存在两个核心问题，导致数据库写入逻辑完全没执行：

• Stream流只能消费一次：Files.lines()返回的Stream<String>是单次使用的，执行完stream.forEach(System.out::println)之后，流已经被完全消费并关闭了。后续再调用stream.collect(Collectors.toList())时，会抛出IllegalStateException: stream has already been operated upon or closed异常——如果你的代码外层有统一异常捕获把错误吞了，你就看不到这个报错，此时拿到的result是空列表，后面的for循环根本不会进入，自然不会触发save操作、不会生成SQL。这也是你能看到控制台打印所有文件行，但没有数据库操作的最核心原因。
• Windows路径转义错误：Java字符串里反斜杠是转义字符，你写的"C:\in_progress\test.txt"不是合法路径，其中\t会被解析为制表符，实际指向的文件路径和你预期的完全不一致。你能看到打印内容，大概率是调试时临时改对过路径，正式运行时路径解析异常也会导致读取不到有效内容。
• 额外隐患：你没有显式关闭Files.lines()打开的文件流，会造成文件句柄泄漏，服务长时间运行会耗尽系统资源。

// 用try-with-resources语法自动关闭文件流，避免资源泄漏
try (Stream<String> stream = Files.lines(Paths.get("C:\\in_progress\\test.txt"), StandardCharsets.UTF_8)) {
    // 先一次性把所有行读取到列表，只消费一次流
    List<String> lineList = stream.collect(Collectors.toList());
    // 打印所有读取到的行
    lineList.forEach(System.out::println);

    for (String line : lineList) {
        Thread.sleep(1000);
        ProcessedWords obj = ProcessedWords.builder()
                .keyword(line)
                .createdAt(LocalDateTime.now())
                .build();
        processedWordsService.save(obj);
    }
} catch (IOException | InterruptedException e) {
    // 不要吞异常，打印完整错误栈方便定位问题
    e.printStackTrace();
}

路径也可以写成"C:/in_progress/test.txt"，Java在Windows系统下可以识别正斜杠路径，不需要额外转义，写起来更方便。

如果改完上述代码还是看不到SQL、数据写不入库，再检查两个配置：

• 确认你用的持久层框架（MyBatis/JPA/MyBatis-Plus等）开启了SQL日志打印，没开的话控制台默认不会输出SQL语句
• 确认processedWordsService.save()方法被Spring事务托管，如果没有正常提交事务，数据不会真正写入数据库

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