mongodb官方的golang驱动基础使用教程分享

go get github.com/mongodb/mongo-go-driver/mongo

if client, err = mongo.Connect(getContext(), url); err != nil {
  checkErr(err)
 }

if err = client.Ping(getContext(), readpref.Primary()); err != nil {
  checkErr(err)
 }

collection = client.Data (\"testing_ \").Collection(\"howie\")

collection.Drop(getContext())

if insertOneRes, err = collection.InsertOne(getContext(), howieArray[0]); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"InsertOne插入的消息ID:%v\\n\", insertOneRes.InsertedID)

if insertManyRes, err = collection.InsertMany(getContext(), howieArray); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"InsertMany插入的消息ID:%v\\n\", insertManyRes.InsertedIDs)

if err = collection.FindOne(getContext(), bson.D{{\"name\", \"howie_2\"}, {\"age\", 11}}).Decode(&howie); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"FindOne查询到的数据:%v\\n\", howie)

if err = collection.FindOneAndDelete(getContext(), bson.D{{\"name\", \"howie_3\"}}).Decode(&howie); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"FindOneAndDelete查询到的数据:%v\\n\", howie)

if err = collection.FindOneAndUpdate(getContext(), bson.D{{\"name\", \"howie_4\"}}, bson.M{\"$set\": bson.M{\"name\": \"这条数据我需要修改了\"}}).Decode(&howie); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"FindOneAndUpdate查询到的数据:%v\\n\", howie)

if err = collection.FindOneAndReplace(getContext(), bson.D{{\"name\", \"howie_5\"}}, bson.M{\"hero\": \"这条数据我替换了\"}).Decode(&howie); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"FindOneAndReplace查询到的数据:%v\\n\", howie)

if cursor, err = collection.Find(getContext(), bson.M{\"createtime\": bson.M{\"$gte\": 2}}, options.Find().SetLimit(2), options.Find().SetSort(bson.M{\"createtime\": -1})); err != nil {
  checkErr(err)
 }
 if err = cursor.Err(); err != nil {
  checkErr(err)
 }
 defer cursor.Close(context.Background())
 for cursor.Next(context.Background()) {
  if err = cursor.Decode(&howie); err != nil {
   checkErr(err)
  }
  howieArrayEmpty = append(howieArrayEmpty, howie)
 }
 fmt.Printf(\"Find查询到的数据:%v\\n\", howieArrayEmpty)

if size, err = collection.Count(getContext(), nil); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"Count里面有多少条数据:%d\\n\", size)

if size, err = collection.Count(getContext(), bson.M{\"createtime\": bson.M{\"$gte\": 3}}); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"Count里面有多少条数据:%d\\n\", size)

if updateRes, err = collection.UpdateOne(getContext(), bson.M{\"name\": \"howie_2\"}, bson.M{\"$set\": bson.M{\"name\": \"我要改了他的名字\"}}); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"UpdateOne的数据:%d\\n\", updateRes)

if updateRes, err = collection.UpdateMany(getContext(), bson.M{\"createtime\": bson.M{\"$gte\": 3}}, bson.M{\"$set\": bson.M{\"name\": \"我要批量改了他的名字\"}}); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"UpdateMany的数据:%d\\n\", updateRes)

if delRes, err = collection.DeleteOne(getContext(), bson.M{\"name\": \"howie_1\"}); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"DeleteOne删除了多少条数据:%d\\n\", delRes.DeletedCount)

if delRes, err = collection.DeleteMany(getContext(), bson.M{\"createtime\": bson.M{\"$gte\": 7}}); err != nil {
  checkErr(err)
 }
 fmt.Printf(\"DeleteMany删除了多少条数据:%d\\n\", delRes.DeletedCount)