Golang – MongoDB(mgo)检索已插入的文件(BSON而不是GridFS)

huangapple go评论89阅读模式
英文:

Golang - MongoDB (mgo) retrieve inserted file (BSON not GridFS)

问题

我是一个Golang的新手。
我正在尝试检索我插入的PDF文件对象。由于存储的文件大小不超过16 MB,我不使用GridFS。
对象已经被插入(使用load_file函数),我在MongoDB可视化客户端中看到的对象ID是ObjectId("554f98a400afc2dd3cbfb21b")。

不幸的是,磁盘上创建的文件大小为0 kb。
请指导如何正确检索插入的PDF对象。

谢谢

package main

import (
	"fmt"
	"io/ioutil"

	"gopkg.in/mgo.v2"
)

type Raw struct {
	Kind byte
	Data []byte
}

type RawDocElem struct {
	Name  string
	Value Raw
}

func check(err error) {
	if err != nil {
		panic(err.Error())
	}
}

func read_file_content(AFileName string) []byte {

	file_contents, err := ioutil.ReadFile(AFileName)
	check(err)
	return file_contents
}

func save_fetched_file(AFileName RawDocElem) {
	ioutil.WriteFile("fisier.pdf", AFileName.Value.Data, 0644)
	fmt.Println("FileName:", AFileName.Name)
}

func load_file(AFileName string, ADatabaseName string, ACollection string) {
	session, err := mgo.Dial("127.0.0.1,127.0.0.1")

	if err != nil {
		panic(err)
	}
	defer session.Close()

	session.SetMode(mgo.Monotonic, true)

	c := session.DB(ADatabaseName).C(ACollection)

	the_obj_to_insert := Raw{Kind: 0x00, Data: read_file_content(AFileName)}

	err = c.Database.C(ACollection).Insert(&the_obj_to_insert)
	check(err)

}

func get_file(ADatabaseName string, ACollection string, The_ID string) RawDocElem {
	session, err := mgo.Dial("127.0.0.1,127.0.0.1")

	if err != nil {
		panic(err)
	}
	defer session.Close()

	session.SetMode(mgo.Monotonic, true)
	c := session.DB(ADatabaseName).C(ACollection)

	result := RawDocElem{}
	err = c.FindId(The_ID).One(&result)
	return result
}

func main() {
	//f_name := "Shortcuts.pdf"
	db_name := "teste"
	the_collection := "ColectiaDeFisiere"
	//load_file(f_name, db_name, the_collection)
	fmt.Sprintf(`ObjectIdHex("%x")`, string("554f98a400afc2dd3cbfb21b"))
	save_fetched_file(get_file(db_name, the_collection, fmt.Sprintf(`ObjectIdHex("%x")`, string("554f98a400afc2dd3cbfb21b"))))
}
英文:

I am a newbie in Golang.
I am trying to retrieve a PDF file object I have inserted. I am not using GridFS, as the files that I would be storing are under 16 MB.
The object has been inserted (using load_file function) and the object ID I am seeing with the MongoDB visual client is ObjectId("554f98a400afc2dd3cbfb21b").

Unfortunately the file created on disk is of 0 kb.
Please advise how to correctly retrieve the inserted PDF object.

Thank you

package main
import (
"fmt"
"io/ioutil"
"gopkg.in/mgo.v2"
)
type Raw struct {
Kind byte
Data []byte
}
type RawDocElem struct {
Name  string
Value Raw
}
func check(err error) {
if err != nil {
panic(err.Error())
}
}
func read_file_content(AFileName string) []byte {
file_contents, err := ioutil.ReadFile(AFileName)
check(err)
return file_contents
}
func save_fetched_file(AFileName RawDocElem) {
ioutil.WriteFile("fisier.pdf", AFileName.Value.Data, 0644)
fmt.Println("FileName:", AFileName.Name)
}
func load_file(AFileName string, ADatabaseName string, ACollection string) {
session, err := mgo.Dial("127.0.0.1,127.0.0.1")
if err != nil {
panic(err)
}
defer session.Close()
session.SetMode(mgo.Monotonic, true)
c := session.DB(ADatabaseName).C(ACollection)
the_obj_to_insert := Raw{Kind: 0x00, Data: read_file_content(AFileName)}
err = c.Database.C(ACollection).Insert(&the_obj_to_insert)
check(err)
}
func get_file(ADatabaseName string, ACollection string, The_ID string) RawDocElem {
session, err := mgo.Dial("127.0.0.1,127.0.0.1")
if err != nil {
panic(err)
}
defer session.Close()
session.SetMode(mgo.Monotonic, true)
c := session.DB(ADatabaseName).C(ACollection)
result := RawDocElem{}
err = c.FindId(The_ID).One(&result)
return result
}
func main() {
//f_name := "Shortcuts.pdf"
db_name := "teste"
the_collection := "ColectiaDeFisiere"
//load_file(f_name, db_name, the_collection)
fmt.Sprintf(`ObjectIdHex("%x")`, string("554f98a400afc2dd3cbfb21b"))
save_fetched_file(get_file(db_name, the_collection, fmt.Sprintf(`ObjectIdHex("%x")`, string("554f98a400afc2dd3cbfb21b"))))
}

答案1

得分: 0

我认为你构建对象ID的方式是错误的。此外,你忘记测试FindId调用后的错误。

我建议尝试导入bson包,并使用以下方式构建对象ID:

hexString := "554f98a400afc2dd3cbfb21b" //24位十六进制字符串
objid := bson.ObjectIdHex(hexString)
...
err = c.FindId(objid).One(&result)
if err == nil {
// 处理result
...
} else {
// 错误处理
...
}
英文:

I think your way to build the object ID is wrong. Furthermore, you forgot to test the error following the FindId call.

I would try to import the bson package, and build the object ID using something like:

hexString := "554f98a400afc2dd3cbfb21b" //24 digits hexadecimal string
objid := bson.ObjectIdHex(hexString)
...
err = c.FindId(objid).One(&result)
if err == nil {
// Do something with result
...
} else {
// Error
...
}

huangapple
  • 本文由 发表于 2015年5月11日 02:55:06
  • 转载请务必保留本文链接:https://go.coder-hub.com/30155409.html
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定