How to use New method of mgo Package

...22	questions = make([]*st.V2QuestionInfo, 0)23	//都是Clone出来的, 要及时Close24	session := mymgo.GetSession(constant.ENUM_MGO_INST_YPLAY)25	if session == nil {26		err = rest.NewAPIError(constant.E_MGO_INST_NIL, "mgo clone session nil")27		log.Error(err.Error())28		return29	}30	defer session.Close()31	db := session.DB("yplay")32	if db == nil {33		err = rest.NewAPIError(constant.E_MGO_DB_NIL, "mgo database nil")34		log.Error(err.Error())35		return36	}37	c := db.C("questions")38	if c == nil {39		err = rest.NewAPIError(constant.E_MGO_COLLECTION_NIL, "mgo collection nil")40		log.Error(err.Error())41		return42	}43	questionMgoMap := make([]MgoQuestionInfo, 0)44	err = c.Find(bson.M{45		"loc": bson.M{46			"$near": bson.M{47				"type":        "Point",48				"coordinates": []float64{longitude, latitude}}},49	}).Limit(1000).All(&questionMgoMap)50	if err != nil {51		err = rest.NewAPIError(constant.E_MGO_QUERY, err.Error())52		log.Error(err.Error())53		return54	}55	qidList := make([]int, 0)56	//TODO 获取未读的qid57	for _, mgoQst := range questionMgoMap {58		qidList = append(qidList, mgoQst.Qid)59	}60	return61}62func GetPoiTagQuestions(uin int64, boardId int, latitude, longitude float64, poiTag string, version int) (questions []*st.V2QuestionInfo, err error) {63	questions = make([]*st.V2QuestionInfo, 0)64	//都是Clone出来的, 要及时Close65	session := mymgo.GetSession(constant.ENUM_MGO_INST_YPLAY)66	if session == nil {67		err = rest.NewAPIError(constant.E_MGO_INST_NIL, "mgo clone session nil")68		log.Error(err.Error())69		return70	}71	defer session.Close()72	db := session.DB("yplay")73	if db == nil {74		err = rest.NewAPIError(constant.E_MGO_DB_NIL, "mgo database nil")75		log.Error(err.Error())76		return77	}78	c := db.C("questions")79	if c == nil {80		err = rest.NewAPIError(constant.E_MGO_COLLECTION_NIL, "mgo collection nil")81		log.Error(err.Error())82		return83	}84	questionMgoMap := make([]MgoQuestionInfo, 0)85	err = c.Find(bson.M{86		"loc": bson.M{87			"$near": bson.M{88				"type":        "Point",89				"coordinates": []float64{longitude, latitude}}},90		"poiTag": poiTag}).Limit(1000).All(&questionMgoMap)91	if err != nil {92		err = rest.NewAPIError(constant.E_MGO_QUERY, err.Error())93		log.Error(err.Error())94		return95	}96	qidList := make([]int, 0)97	qidStr := ""98	for _, mgoQst := range questionMgoMap {99		qidList = append(qidList, mgoQst.Qid)100		qidStr += fmt.Sprintf("%d,", mgoQst.Qid)101	}102	questions, err3 := common.GetQuestionsByQidStr(qidStr, version)103	if err3 != nil {104		return105	}106	return107}108func AddQuestionToMgo(uin int64, qid int, latitude, longitude float64, poiTag string, createTs int64) (err error) {109	//将学校信息存储到mgo中110	session := mymgo.GetSession(constant.ENUM_MGO_INST_YPLAY)111	if session == nil {112		err = rest.NewAPIError(constant.E_MGO_INST_NIL, "mgo clone session nil")113		log.Error(err.Error())114		return115	}116	defer session.Close()117	db := session.DB("yplay")118	if db == nil {119		err = rest.NewAPIError(constant.E_MGO_DB_NIL, "mgo database nil")120		log.Error(err.Error())121		return122	}123	c := db.C("questions")124	if c == nil {125		err = rest.NewAPIError(constant.E_MGO_COLLECTION_NIL, "mgo collection nil")126		log.Error(err.Error())127		return128	}129	questionMgoMap := make(map[string]interface{})130	mgoLocalINfoMap := make(map[string]interface{})131	mgoLocalINfoMap["type"] = "Point"132	mgoLocalINfoMap["coordinates"] = []float64{longitude, latitude}133	questionMgoMap["_id"] = qid134	questionMgoMap["poiTag"] = poiTag135	questionMgoMap["loc"] = mgoLocalINfoMap136	questionMgoMap["createTs"] = createTs137	log.Debugf("questionMgoMap %+v", questionMgoMap)138	err = c.Insert(&questionMgoMap)139	if err != nil {...

1package tweet_words2import (3		"gopkg.in/mgo.v2"4		"gopkg.in/mgo.v2/bson"5		"fmt"6		"log"7		)8type User struct {9        Token string10        Secret string11        Keywords []string12}13var GUser User14//var KeywordsArray = []string{"test"}15var KeywordsArray = make(map[string][]string)16func StoreUser(user User) (ret bool) {17		mgoSession, err := mgo.Dial("mongodb://54.188.201.254")18		if err != nil {19			panic(err)20		}21		mgoSession.SetMode(mgo.Monotonic, true)22		defer mgoSession.Close()23		newSes := mgoSession.Copy()24		defer newSes.Close()25		db := newSes.DB("test")26		r, _ := db.CollectionNames()27		fmt.Println(r)28		col := db.C("User")29		if col == nil {30			panic("unable to get collection")31		}32		result := User{}33		fmt.Println(bson.M{"token": user.Token})34		err = col.Find(bson.M{"token": user.Token}).One(&result)35		if result.Token == "" {36			dummy := []string{"bjp"}37			err = col.Insert(&User{user.Token, user.Secret, dummy})38			if err != nil {39				panic(err)40			}41		}42		err = col.Find(bson.M{"token": user.Token}).One(&result)43		if err != nil {44            log.Fatal(err)45        }46	return47}48func StoreKeywords(data string) (ret bool) {49	mgoSession, err := mgo.Dial("mongodb://54.188.201.254")50	if err != nil {51		panic(err)52	}53	mgoSession.SetMode(mgo.Monotonic, true)54	defer mgoSession.Close()55	newSes := mgoSession.Copy()56	defer newSes.Close()57	col := newSes.DB("test").C("User")58	if col == nil {59		panic("unable to get collection")60	}61	result := User{}62	err = col.Find(bson.M{"token": GUser.Token}).One(&result)63	if err != nil {64        log.Fatal(err)65    }66    n := len(result.Keywords)67    words := make([]string, n+1);68    copy(words, result.Keywords[0:])69    words[n] = data70    _, err = col.Upsert(bson.M{"token": GUser.Token, "secret" : GUser.Secret}, bson.M{"$set" : bson.M{"keywords": words}})71    if err != nil {72    	fmt.Println(err)73    }74    result1 := User{}75	err = col.Find(bson.M{"token": GUser.Token}).One(&result1)76	if err != nil {77        log.Fatal(err)78    }79	return80}81func GetKeywords() (ret []string) {82	mgoSession, err := mgo.Dial("mongodb://54.188.201.254")83	if err != nil {84		panic(err)85	}86	mgoSession.SetMode(mgo.Monotonic, true)87	defer mgoSession.Close()88	newSes := mgoSession.Copy()89	defer newSes.Close()90	col := newSes.DB("test").C("User")91	if col == nil {92		panic("unable to get collection")93	}94	result := User{}95	err = col.Find(bson.M{"token": GUser.Token}).One(&result)96	if err != nil {97        log.Fatal(err)98    }99    return result.Keywords100}101func GetTweets(keyValue string) (retValue []TweetStore){102		mgoSession, err := mgo.Dial("mongodb://54.188.201.254")103	if err != nil {104		panic(err)105	}106	mgoSession.SetMode(mgo.Monotonic, true)107	defer mgoSession.Close()108	newSes := mgoSession.Copy()109	defer newSes.Close()110	col := newSes.DB("test").C(keyValue)111	if col == nil {112		panic("unable to get collection")113	}114	result := []TweetStore{}115	err = col.Find(bson.M{}).All(&result)116	if err != nil {117        log.Fatal(err)118    }119    return result120}...

...5	"go.mongodb.org/mongo-driver/bson/primitive"6)7func TestMgo_UserInsertOne(t *testing.T) {8	user := &User{9		Id: primitive.NewObjectID(),10		Name: "laixhe",11		Age:  18,12		As:   []string{"aa", "dd"},13	}14	result, err := NewMgo().UserInsertOne(user)15	fmt.Printf("result=%s err=%v\n", result.InsertedID, err)16}17func TestMgo_UserFindOne(t *testing.T) {18	user, err := NewMgo().UserFindOne("laixhe", 18)19	fmt.Printf("user=%v err=%v\n", user, err)20}21func TestMgo_UserFind(t *testing.T) {22	users, err := NewMgo().UserFind(19, 1)23	fmt.Printf("users=%v err=%v\n", users, err)24}25func TestMgo_UserFindLike(t *testing.T) {26	users, err := NewMgo().UserFindLike("laixhe")27	fmt.Printf("users=%v err=%v\n", users, err)28}29func TestMgo_UserFindOneAndDelete(t *testing.T) {30	user, err := NewMgo().UserFindOneAndDelete("laiki")31	fmt.Printf("user=%v err=%v\n", user, err)32}33func TestMgo_UserFindOneAndUpdate(t *testing.T) {34	user, err := NewMgo().UserFindOneAndUpdate("laiki", "laixhe000")35	fmt.Printf("user=%v err=%v\n", user, err)36}37func TestMgo_UserCount(t *testing.T) {38	count, err := NewMgo().UserCount()39	fmt.Printf("count=%v err=%v\n", count, err)40}41func TestMgo_UserWhereCount(t *testing.T) {42	count, err := NewMgo().UserWhereCount(19)43	fmt.Printf("count=%v err=%v\n", count, err)44}45func TestMgo_UserUpdateOne(t *testing.T) {46	err := NewMgo().UserUpdateOne("laiki", "laixhe")47	fmt.Printf("err=%v\n", err)48}49func TestMgo_UserUpdateMany(t *testing.T) {50	err := NewMgo().UserUpdateMany("laiki", "laixhe")51	fmt.Printf("err=%v\n", err)52}53func TestMgo_UserDeleteOne(t *testing.T) {54	err := NewMgo().UserDeleteOne("laiki")55	fmt.Printf("err=%v\n", err)56}57func TestMgo_UserDeleteMany(t *testing.T) {58	err := NewMgo().UserDeleteMany("laiki")59	fmt.Printf("err=%v\n", err)60}61func TestMgo_UserAggregateGroup(t *testing.T) {62	userGroups, err := NewMgo().UserAggregateGroup()63	fmt.Printf("userGroups=%v err=%v\n", userGroups, err)64}65func TestMgo_UserAggregateGroupWhere(t *testing.T) {66	userGroups, err := NewMgo().UserAggregateGroupWhere()67	fmt.Printf("userGroups=%v err=%v\n", userGroups, err)68}...

1import (2func main() {3    session, err := mgo.Dial("localhost:27017")4    if err != nil {5        panic(err)6    }7    defer session.Close()8    session.SetMode(mgo.Monotonic, true)9    c := session.DB("test").C("people")10    err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},11        &Person{"Cla", "+55 53 8402 8510"})12    if err != nil {13        log.Fatal(err)14    }15    result := Person{}16    err = c.Find(bson.M{"name": "Ale"}).One(&result)17    if err != nil {18        log.Fatal(err)19    }20    fmt.Println("Phone:", result.Phone)21}22import (23func main() {24    session, err := mgo.Dial("localhost:27017")25    if err != nil {26        panic(err)27    }28    defer session.Close()29    session.SetMode(mgo.Monotonic, true)30    c := session.DB("test").C("people")31    err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},32        &Person{"Cla", "+55 53 8402 8510"})33    if err != nil {34        log.Fatal(err)35    }36    result := Person{}37    err = c.Find(bson.M{"name": "Ale"}).One(&result)38    if err != nil {39        log.Fatal(err)40    }41    fmt.Println("Phone:", result.Phone)42}43import (44func main() {45    session, err := mgo.Dial("localhost:27017")46    if err != nil {47        panic(err)48    }49    defer session.Close()50    session.SetMode(mgo.Monotonic, true)51    c := session.DB("test").C("people")52    err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},53        &Person{"Cla

1import (2func main() {3	session, err := mgo.Dial("localhost:27017")4	if err != nil {5		panic(err)6	}7	defer session.Close()8	session.SetMode(mgo.Monotonic, true)9	collection := session.DB("test").C("people")10	err = collection.Insert(&Person{"Ale", "+55 53 8116 9639"},11		&Person{"Cla", "+55 53 8402 8510"})12	if err != nil {13		log.Fatal(err)14	}15	result := Person{}16	err = collection.Find(bson.M{"name": "Ale"}).One(&result)17	if err != nil {18		log.Fatal(err)19	}20	fmt.Println("Phone:", result.Phone)21}22import (23func main() {24	session, err := mgo.Dial("localhost:27017")25	if err != nil {26		panic(err)27	}28	defer session.Close()29	session.SetMode(mgo.Monotonic, true)30	collection := session.DB("test").C("people")31	err = collection.Insert(&Person{"Ale", "+55 53 8116 9639"},32		&Person{"Cla", "+55 53 8402 8510"})33	if err != nil {34		log.Fatal(err)35	}36	result := Person{}37	err = collection.Find(bson.M{"name": "Ale"}).One(&result)38	if err != nil {39		log.Fatal(err)40	}41	fmt.Println("Phone:", result.Phone)42}43import (44func main() {45	session, err := mgo.Dial("localhost:27017")46	if err != nil {47		panic(err)48	}49	defer session.Close()50	session.SetMode(mgo.Monotonic, true)51	collection := session.DB("test").C("people")52	err = collection.Insert(&Person{"Ale", "+55 53 811

1import (2func main() {3	fmt.Println("Hello World")4	if err != nil {5		panic(err)6	}7	defer session.Close()8	session.SetMode(mgo.Monotonic, true)9	c := session.DB("test").C("people")10	err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},11		&Person{"Cla", "+55 53 8402 8510"})12	if err != nil {13		log.Fatal(err)14	}15	result := Person{}16	err = c.Find(bson.M{"name": "Ale"}).One(&result)17	if err != nil {18		log.Fatal(err)19	}20	fmt.Println("Phone:", result.Phone)21}

1if err != nil {2log.Fatal(err)3}4defer session.Close()5db := session.DB("test")6c := db.C("people")7err = c.Insert(&Person{"Ale", "+55 53 8116 9639"},8&Person{"Cla", "+55 53 8402 8510"})9if err != nil {10log.Fatal(err)11}12result := Person{}13err = c.Find(bson.M{"name": "Ale"}).One(&result)14if err != nil {15log.Fatal(err)16}17fmt.Println("Phone:", result.Phone)18}19if err != nil {20log.Fatal(err)21}22defer session.Close()23db := session.DB("test")24c := db.C("people")25result := []Person{}26err = c.Find(bson.M{}).All(&result)27if err != nil {28log.Fatal(err)29}30for _, v := range result {31fmt.Println("Name:", v.Name)32fmt.Println("Phone:", v.Phone)33}34}35if err != nil {36log.Fatal(err