golang-mongodb范例

package main

import (
"log"

"gopkg.in/mgo.v2"
"gopkg.in/mgo.v2/bson"
)

type Address struct {
Address string
}
type Location struct {
Longitude float64
Latitude  float64
}

type Person struct {
Id       bson.ObjectId `bson:"_id"`
Name     string
Age_Int  int
Address  []Address
Location Location
}

func main() {
log.SetFlags(log.Flags() | log.Lshortfile)
//连接
session, err := mgo.Dial("127.0.0.1:27017")
if err != nil {
log.Println(err)
return
}
//设置模式
session.SetMode(mgo.Monotonic, true)
//获取文档集
collection := session.DB("test").C("person")
// 创建索引
index := mgo.Index{
Key:        []string{"name"}, // 索引字段， 默认升序,若需降序在字段前加-
Unique:     true,             // 唯一索引 同mysql唯一索引
DropDups:   true,             // 索引重复替换旧文档,Unique为true时失效
Background: true,             // 后台创建索引
}
if err := collection.EnsureIndex(index); err != nil {
log.Println(err)
return
}
if err := collection.EnsureIndexKey("$2dsphere:location"); err != nil { // 创建一个范围索引
log.Println(err)
return
}
//添加记录
person := Person{
Id:      bson.NewObjectId(),
Name:    "逍遥",
Age_Int: 24,
Address: []Address{
Address{
Address: "仙灵岛",
},
},
Location: Location{
Longitude: 1,
Latitude:  1,
},
}
if err := collection.Insert(person); err != nil {
log.Println(err)
return
}
//查找记录
newPerson := &Person{}
if err := collection.Find(bson.M{"age_int": 24}).One(newPerson); err != nil {
log.Println(err)
return
}
//修改记录
if err := collection.Update(bson.M{"age_int": 24}, bson.M{"$set": bson.M{"age_int": 26}}); err != nil {
log.Println(err)
return
}
//删除记录
//if err := collection.Remove(bson.M{"age_int": 26}); err != nil {
//  log.Println(err)
//  return
//}
//位置搜索
selector := bson.M{
"location": bson.M{
"$near": bson.M{
"$geometry": bson.M{
"type":        "Point",
"coordinates": []float64{1, 1},
},
"$maxDistance": 1,
//"$minDistance": 0,
},
},
}
if err := collection.Find(selector).One(newPerson); err != nil {
log.Println(err)
return
}
//
session.Close()
}