PocketBase中定时任务删除记录时关联文件未被清理的问题解析

在使用PocketBase开发应用时，开发者rommyarb遇到了一个典型问题：通过cron定时任务删除wa_chat集合中超过7天的记录时，虽然数据库记录被成功删除，但关联的文件却仍然保留在存储系统中，导致存储空间不断增长。

问题本质分析

该问题的核心在于直接使用原始SQL查询删除记录时，绕过了PocketBase的模型层处理逻辑。PocketBase的设计架构中，数据库操作分为两个层级：

1. 底层数据库操作：直接执行SQL语句，仅影响数据库表数据
2. 模型层操作：通过Record模型进行CRUD，会触发完整的业务逻辑处理链

当开发者使用app.Dao().DB().NewQuery(del_query).Execute()这样的原始SQL删除数据时，实际上只执行了最底层的数据库删除操作，而PocketBase的文件管理、钩子函数等高级功能都没有被触发。

解决方案实现

正确的做法是使用PocketBase提供的Record模型API来删除记录。以下是改进后的实现方案：

// 获取当前时间7天前的时间戳
cutoffTime := time.Now().AddDate(0, 0, -7).Format(types.DefaultDateLayout)

// 查询符合条件的记录
var records []*models.Record
err := app.Dao().RecordQuery("wa_chat").
    AndWhere(dbx.NewExp("created < {:created}"), dbx.Params{"created": cutoffTime}).
    All(&records)

if err != nil {
    app.Logger().Error("查询待删除记录失败", "error", err)
    return
}

// 逐个删除记录
for _, record := range records {
    if err := app.Dao().DeleteRecord(record); err != nil {
        app.Logger().Error("删除记录失败", 
            "recordId", record.Id, 
            "error", err)
    }
}

技术要点解析

1. 时间处理：使用Go标准库的time.Now().AddDate()方法计算7天前的时间点，并格式化为PocketBase使用的日期字符串格式。

2. 批量查询：通过RecordQuery构建查询条件，使用All()方法获取所有符合条件的记录集合。

3. 安全删除：遍历记录集合并使用DeleteRecord()方法逐个删除，这会触发PocketBase的完整删除流程，包括：

   • 文件系统清理
   • 关联数据维护
   • 事件钩子触发

4. 错误处理：对每个删除操作进行错误捕获和日志记录，确保问题可追溯。

性能优化建议

对于数据量较大的场景，可以考虑以下优化措施：

1. 分批次处理：在查询时添加Limit(1000)限制，分多次处理大量数据
2. 并行删除：使用goroutine并发处理删除操作（需注意线程安全）
3. 事务管理：对批量删除操作使用数据库事务保证一致性

总结

在PocketBase开发中，直接操作数据库虽然简单高效，但会绕过框架提供的许多重要功能。特别是在涉及文件管理、关联数据等复杂场景时，务必使用框架提供的模型层API进行操作，才能确保数据完整性和系统稳定性。本文提供的解决方案不仅解决了原始问题，也为类似的数据清理需求提供了可复用的模式。