golang mongodb插入insert数据demo

插入数据库通常情况下针对每个表创建一个结构体，但是mongodb是schemaless，文档数据库，对字段没有严格要求

 

package main

import (
	"fmt"
	"gopkg.in/mgo.v2"
	"io/ioutil"
	"net/http"
	"encoding/json"
	//"time"
)

type Count struct {
	I int
}
var session *mgo.Session
var err error

func 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)
}

 

---