怎么在Go语言中操作MongoDB的GridFS-MongoDB-PHP中文网

mongodb go驱动需显式引入x/exp/gridfs包，上传用openuploadstream+io.copy避免oom，下载用opendownloadstream+io.copy流式响应，删除仅清files文档需手动清理孤儿chunks，查询须用bucket.find而非直查集合。

怎么在go语言中操作mongodb的gridfs

用 `mongo-go-driver` 的 `gridfs` 包上传文件

Go 官方驱动不内置 GridFS，得显式引入 go.mongodb.org/mongo-driver/x/exp/gridfs（注意是 x/exp/，非稳定版）。上传前必须先有有效的 *mongo.Database 实例和可写的 bucket。

别漏掉 import "go.mongodb.org/mongo-driver/x/exp/gridfs"，否则编译报 undefined: gridfs
bucket 名默认是 fs，但实际集合名是 fs.files 和 fs.chunks；改名需传 gridfs.WithBucketName("mybucket")
上传大文件时，UploadFromStream 接收 io.Reader，别直接传 []byte——容易 OOM；用 bytes.NewReader 或文件句柄更安全

示例：

b, _ := gridfs.NewBucket(db)
uploadStream, _ := b.OpenUploadStream("report.pdf")
io.Copy(uploadStream, fileReader)
uploadStream.Close()

从 GridFS 读取文件内容并写入响应流

常见于 Web 服务返回图片或 PDF，核心是避免把整个文件加载进内存。用 OpenDownloadStream 拿到 gridfs.File，它实现了 io.ReadCloser。

调用 File.Size() 前务必检查 err == nil，否则可能 panic（比如文件不存在时 Size() 返回 0 且无错误，但后续读取会失败）
HTTP 响应头要设 Content-Length 和 Content-Type，否则浏览器可能无法正确解析；Content-Type 得从 File.ContentType 取，不是猜
别用 io.ReadAll 读取整个文件再写——100MB 文件就崩了；用 io.Copy(w, file) 直接流式转发

示例：

file, err := b.OpenDownloadStream(id)
if err != nil { /* 404 */ }
defer file.Close()
w.Header().Set("Content-Length", strconv.FormatInt(file.Size(), 10))
w.Header().Set("Content-Type", file.ContentType())
io.Copy(w, file)

删除文件时为什么 `Delete` 不报错但文件还在

gridfs.Bucket.Delete 只删 files 集合文档，不自动清理关联的 chunks 数据——这是设计行为，不是 bug。MongoDB 官方驱动不会做级联删除。

确认是否真删了：查 fs.files 集合，该文档应已消失；再查 fs.chunks，对应 files_id 的 chunk 还在
手动清理 chunks 很危险：必须用和 Delete 同一事务或同一时间点的 files_id，否则可能误删其他文件的块
稳妥做法是定期跑后台任务，用 fs.chunks 的 files_id 去反查 fs.files 是否还存在，只删“孤儿 chunk”
如果业务要求强一致性，建议换用普通集合存文件元数据 + 对象存储（如 S3），GridFS 的维护成本其实高于预期

查询 GridFS 文件元信息的坑：不能直接用 `Find` 查 `fs.files`

fs.files 是普通集合，但它的 _id 字段类型可能是 ObjectID、string 或自定义类型，取决于上传时传的 options.FileID。直接 collection.Find 容易因类型不匹配查不到。

想按文件名查，用 b.Find（gridfs.Bucket 提供的方法），它内部处理了字段映射和类型转换

想按自定义字段（如 user_id）查，得先确保上传时写了该字段：

b.UploadFromStream("a.pdf", r, options.GridFSUpload().SetMetadata(bson.M{"user_id": 123}))

Find 返回的是 *gridfs.File 切片，不是原始 BSON 文档；要拿原始数据，得用 file.FileID、file.UploadDate 等导出字段，别试图 file.Decode
注意 Find 不支持 sort / limit 的链式调用，得用 options.GridFSFind().SetSort(...)