GridFS

Crie um intervalo GridFS

Para armazenar ou recuperar arquivos do GridFS, crie um contêiner ou obtenha uma referência a um contêiner existente em um banco de dados MongoDB. Para criar uma instância GridFSBucket , chame o método NewBucket() com um parâmetro de banco de dados:

db := client.Database("db")
bucket, err := gridfs.NewBucket(db)
if err != nil {
   panic(err)
}

Por padrão, o novo bucket é denominado fs. Para instanciar um bucket com um nome personalizado, chame o método SetName() em uma instância BucketOptions da seguinte forma:

db := client.Database("db")
opts := options.GridFSBucket().SetName("custom name")
bucket, err := gridfs.NewBucket(db, opts)
if err != nil {
   panic(err)
}

Fazer upload de arquivos

Você pode carregar um arquivo em um contêiner GridFS de uma das seguintes maneiras:

• Utilize o método UploadFromStream(), que lê a partir de um fluxo de entrada.

• Use o método OpenUploadStream(), que grava em um fluxo de saída.

Para qualquer processo de carregamento, você pode especificar informações de configuração em uma instância do UploadOptions. Para ver uma lista completa dos UploadOptions campos , acesse a documentação da API.

file, err := os.Open("path/to/file.txt")
uploadOpts := options.GridFSUpload().SetMetadata(bson.D{{"metadata tag", "first"}})
objectID, err := bucket.UploadFromStream("file.txt", io.Reader(file),
   uploadOpts)
if err != nil {
   panic(err)
}
fmt.Printf("New file uploaded with ID %s", objectID)

file, err := os.Open("path/to/file.txt")
if err != nil {
	panic(err)
}
uploadOpts := options.GridFSUpload().SetChunkSizeBytes(200000)
uploadStream, err := bucket.OpenUploadStream("file.txt", uploadOpts)
if err != nil {
	panic(err)
}
fileContent, err := io.ReadAll(file)
if err != nil {
	panic(err)
}
var bytes int
if bytes, err = uploadStream.Write(fileContent); err != nil {
	panic(err)
}
fmt.Printf("New file uploaded with %d bytes written", bytes)

Recuperar informações do arquivo

Você pode recuperar metadados de arquivo armazenados na coleção files do contêiner GridFS. Cada documento na coleção files contém as seguintes informações:

• O ID do arquivo

• O comprimento do arquivo

• O tamanho máximo do chunk

• A data e a hora do carregamento

• O nome do arquivo

• Um documento metadata no qual você pode armazenar qualquer outra informação

Para recuperar dados do arquivo, chame o método Find() em uma instância GridFSBucket. Você pode passar um filtro de query como argumento para Find() para corresponder somente a determinados documentos de arquivo.

O exemplo a seguir recupera o nome do arquivo e o tamanho dos documentos na coleção files com valores length maiores que 1500:

filter := bson.D{{"length", bson.D{{"$gt", 1500}}}}
cursor, err := bucket.Find(filter)
if err != nil {
   panic(err)
}
type gridfsFile struct {
   Name   string `bson:"filename"`
   Length int64  `bson:"length"`
}
var foundFiles []gridfsFile
if err = cursor.All(context.TODO(), &foundFiles); err != nil {
   panic(err)
}
for _, file := range foundFiles {
   fmt.Printf("filename: %s, length: %d\n", file.Name, file.Length)
}

Baixar arquivos

Você pode baixar um arquivo GridFS de uma das seguintes maneiras:

• Utilize o método DownloadToStream() para baixar um arquivo para um fluxo de saída.

• Utilize o método OpenDownloadStream() para abrir um fluxo de entrada.

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
fileBuffer := bytes.NewBuffer(nil)
if _, err := bucket.DownloadToStream(id, fileBuffer); err != nil {
   panic(err)
}

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
downloadStream, err := bucket.OpenDownloadStream(id)
if err != nil {
   panic(err)
}
fileBytes := make([]byte, 1024)
if _, err := downloadStream.Read(fileBytes); err != nil {
   panic(err)
}

Renomear arquivos

Você pode atualizar o nome de um arquivo GridFS em seu bucket utilizando o método Rename(). Passe um valor de ID de arquivo e um novo valor de filename como argumentos para Rename().

O exemplo a seguir renomeia um arquivo para "mongodbTutorial.zip":

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
if err := bucket.Rename(id, "mongodbTutorial.zip"); err != nil {
    panic(err)
}

Excluir arquivos

Você pode remover um arquivo do bucket GridFS usando o método Delete(). Passe um valor de ID de arquivo como argumento para Delete().

O exemplo a seguir exclui um arquivo:

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
if err := bucket.Delete(id); err != nil {
   panic(err)
}

Excluir um bucket do GridFS

Você pode excluir um bucket GridFS usando o método Drop().

O seguinte exemplo de código exclui um bucket GridFS:

if err := bucket.Drop(); err != nil {
   panic(err)
}

Documentação da API

Para saber mais sobre os métodos ou tipos discutidos neste guia, consulte a seguinte documentação da API:

• NewBucket()

• OpenUploadStream()

• UploadFromStream()

• Find()

• OpenDownloadStream()

• DownloadToStream()

• Rename()

• Delete()

• Drop()