mongodb BSON basic usage tutorial

Find Find

m := bson.M{
    "create_time": bson.M{
      "$gte": start,
      "$lte": end,
    },
    "account": account,
    "tag": "tag",
  }
  session.DB("db").C("collect").Find(m).Count()

Look for the data within the timestamp, account number account, label tag, and count the number.

The aggregation pipeline in mgo is Pipe(pipeline interface{})

This is similar to the pipes used in bash, where data can be processed layer by layer. 1 Normally the parameter passed in is [] bson.M. This [] bson. M also USES [] bson. M if there is nested

- For example, here first match the tag and account

- The timestamp is within 1 period of time

- Then group the Numbers by name

- The last sorting takes the first three.

  // This one can be passed in Pipe
  m := []bson.M{
    {"$match": bson.M{"tag": "tag", "account": account, "create_time": bson.M{"$gte": start, "$lte": end}}},
    {"$group": bson.M{"_id": "$TagName", "count": bson.M{"$sum": 1}}},
    {"$sort": bson.M{"count": -1}},
    {"$limit": 3},
  }
  // And here you can get the output 
  var values []result
  session.DB("db").C("collect").Pipe(m).All(&values)

A simple introduction

package main
import (
 "gopkg.in/mgo.v2"
 "log"
 "gopkg.in/mgo.v2/bson"
)
type User struct {
 Id    bson.ObjectId `bson:"_id"`
 Name   string    `bson:"name"`
 PassWord string    `bson:"pass_word"`
 Age   int      `bson:"age"`
}
func main() {
 db, err := mgo.Dial("mongodb://192.168.2.28:27017,192.168.2.28:27018,192.168.2.28:27019/?replicaSet=howie")
 if err != nil {
 log.Fatalln(err)
 }
 defer db.Close()
 db.SetMode(mgo.Monotonic, true)
 c := db.DB("howie").C("person")
 // insert 
 /*c.Insert(&User{
 Id:    bson.NewObjectId(),
 Name:   "JK_CHENG",
 PassWord: "123132",
 Age: 2,
 }, &User{
 Id:    bson.NewObjectId(),
 Name:   "JK_WEI",
 PassWord: "qwer",
 Age: 5,
 }, &User{
 Id:    bson.NewObjectId(),
 Name:   "JK_HE",
 PassWord: "6666",
 Age: 7,
 })*/
 var users []User
 c.Find(nil).All(&users) // Query all data 
 log.Println(users)
 c.FindId(users[0].Id).All(&users) // through ID The query 
 log.Println(users)
 c.Find(bson.M{"name": "JK_WEI"}).All(&users) // Single conditional query (=)
 log.Println(users)
 c.Find(bson.M{"name": bson.M{"$ne": "JK_WEI"}}).All(&users) // Single conditional query (!=)
 log.Println(users)
 c.Find(bson.M{"age": bson.M{"$gt": 5}}).All(&users) // Single conditional query (>)
 log.Println(users)
 c.Find(bson.M{"age": bson.M{"$gte": 5}}).All(&users) // Single conditional query (>=)
 log.Println(users)
 c.Find(bson.M{"age": bson.M{"$lt": 5}}).All(&users) // Single conditional query (<)
 log.Println(users)
 c.Find(bson.M{"age": bson.M{"$lte": 5}}).All(&users) // Single conditional query (<=)
 log.Println(users)
 /*c.Find(bson.M{"name": bson.M{"$in": []string{"JK_WEI", "JK_HE"}}}).All(&users) // Single conditional query (in)
 log.Println(users)
 c.Find(bson.M{"$or": []bson.M{bson.M{"name": "JK_WEI"}, bson.M{"age": 7}}}).All(&users) // Multiconditional query (or)
 log.Println(users)
 c.Update(bson.M{"_id": users[0].Id}, bson.M{"$set": bson.M{"name": "JK_HOWIE", "age": 61}}) // Modify the value of the field ($set)
 c.FindId(users[0].Id).All(&users)
 log.Println(users)
 c.Find(bson.M{"name": "JK_CHENG", "age": 66}).All(&users) // Multiconditional query (and)
 log.Println(users)
 c.Update(bson.M{"_id": users[0].Id}, bson.M{"$inc": bson.M{"age": -6,}}) // Field value added ($inc)
 c.FindId(users[0].Id).All(&users)
 log.Println(users)*/
 //c.Update(bson.M{"_id": users[0].Id}, bson.M{"$push": bson.M{"interests": "PHP"}}) // Add from the array 1 An element ($push)
 c.Update(bson.M{"_id": users[0].Id}, bson.M{"$pull": bson.M{"interests": "PHP"}}) // Delete from the array 1 An element ($pull)
 c.FindId(users[0].Id).All(&users)
 log.Println(users)
 c.Remove(bson.M{"name": "JK_CHENG"})// delete 
}

conclusion