使用encoding/csv向CSV文件添加新行无报错但文件未更新问题

核心问题排查 #

• 重复关闭文件：代码中存在两次defer file.Close()，第一次已确保函数退出时自动关闭文件，第二次属于冗余操作，可能引发文件状态异常，需删除第二个defer file.Close()。
• 未处理Flush()错误：csv.Writer.Flush()负责将缓冲区内容写入文件，此操作可能失败，但当前代码未检查其返回的错误。即便Write()成功，缓冲区内容也可能因Flush()失败未写入文件。
• 路径有效性验证：确认r.csvPath是否为项目根目录下的相对路径./data/data.csv。若使用绝对路径/data/data.csv，文件会被写入系统根目录而非项目目录，导致看起来“无变化”。
• 目录存在性检查：若data目录不存在，os.O_CREATE仅能创建文件无法自动生成上级目录，此时os.OpenFile会报错，但代码用panic(err)处理，若未触发panic则说明目录存在，建议提前添加目录创建逻辑避免后续问题。

修复后的完整代码 #

import (
    "encoding/csv"
    "os"
    "strconv"
    "time"
    "path/filepath"
)

func (r *CSVRepository) Add(quantity int) error {
    // 确保目标目录存在
    dir := filepath.Dir(r.csvPath)
    if err := os.MkdirAll(dir, 0755); err != nil {
        return err
    }

    // 打开CSV文件
    file, err := os.OpenFile(r.csvPath, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
    if err != nil {
        return err // 替换panic为返回错误，符合Go错误处理规范
    }
    defer file.Close()

    writer := csv.NewWriter(file)
    defer func() {
        writer.Flush()
        // 捕获Flush过程中的错误
        if flushErr := writer.Error(); flushErr != nil && err == nil {
            err = flushErr
        }
    }()

    timestamp := time.Now().String()
    value := strconv.Itoa(quantity)

    err = writer.Write([]string{"1", timestamp, value})
    if err != nil {
        return err
    }

    return err
}

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