插入数据库通常情况下针对每个表创建一个结构体,但是mongodb是schemaless,文档数据库,对字段没有严格要求
package mainimport ( "fmt" "gopkg.in/mgo.v2" "io/ioutil" "net/http" "encoding/json" //"time")type Count struct { I int}var session *mgo.Sessionvar err errorfunc main() { session, err = mgo.Dial("127.0.0.1:27017") if err != nil { fmt.Print(err) } defer session.Close() http.HandleFunc("/insert",insert) http.ListenAndServe(":9999",nil) b := session.DB("testdb").C("test1").Bulk() // 第二种 //c := session.DB("testdb").C("test1") //第一种 //start := time.Now() //for i := 0; i < 100000; i++ { // //b.Insert(&Count{i}) //第二种 // c.Insert(&Count{i}) //第一种 //} b.Run() // 第二种 //duration := time.Since(start) //fmt.Printf("insert 10w: %v", duration.Seconds()*1e6/float64(1000))}func insert(w http.ResponseWriter,r *http.Request){ s, _ := ioutil.ReadAll(r.Body) var p []interface{} err := json.Unmarshal([]byte(s), &p) if err!=nil{ fmt.Fprint(w,"json格式错误") fmt.Println(err) return } c := session.DB("testdb").C("test1") //第一种 //start := time.Now() for _,mp :=range p{ //mp["time"]=start err=c.Insert(&mp) //第一种 if err != nil { fmt.Println(mp) panic(err) } fmt.Println(err) } fmt.Println( p )}func test() { //Create the Json string var data = ` { "id": 12423434, "Name": "Fernando" } ` //Marshal the json to a map var result map[string]interface{} err := json.Unmarshal([]byte(data), &result) if err != nil { fmt.Println(err.Error()) return } fmt.Println(result)}