Go语言下Mongo使用

(一)mongodb简介：

• MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。它支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。Mongo最大的特点是它支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。
• 它的特点是高性能、易部署、易使用，存储数据非常方便。主要功能特性有：面向集合存储，易存储对象类型的数据。模式自由。支持动态查询。支持完全索引，包含内部对象。支持查询。

(二)crud操作.mongodb

db.account.insertMany([{
  open_id:"456",
  login_count:0,
},{
  open_id:"789",
  login_count:5,
}])
db.account.find({
  "_id": ObjectId("62cfcb7ea75df6b17391a90a")
})

db.account.deleteOne({
  "_id":ObjectId("62cfcb99d3bdeef097702118")
})

db.account.find()

account = db.account.findOne({
  "_id": ObjectId("62cfcabfd727ed80def64e17")
})
db.account.update({
  _id: ObjectId("62cfcabfd727ed80def64e17")
},{
  $set: {
    login_count: account.login_count+1
  }
})

db.account.update({
  _id: ObjectId("62cfcabfd727ed80def64e17")
},{
  $inc: {
    login_count: 1
  },
  $set: {
    open_id:"1234"
  }
})


db.account.find({
  login_count :{$gte:5},
  open_id:"1234"
})



db.account.find({
  $or:[
  {
    login_count :{$gt:4},
    open_id:"1234",
  },
  {
    login_count :0,
  }
  ]
})

db.account.updateOne({
  _id: ObjectId("62cfcabfd727ed80def64e17")
},{
  $set: {
    profile: {
      name:'abc',
      age:28,
      proto_url:'https://example.com/123'
    }
  }
})

db.account.find({
  "profile.age":{$lte:30}
})


db.account.createIndex({
  "profile.age":1
})

db.account.createIndex({
  "open_id":-1
})

(三)用mongodb模拟用户登录.mongodb

db.account.insertMany([
  {open_id:'123'},
  {open_id:'456'}
])


function resolveOpenId(open_id){
  return db.account.findOne({
    open_id:open_id
  })
}
resolveOpenId('123')



function resolveOpenId2(open_id){
  return db.account.updateOne({
    open_id:open_id
  },{
    $set:{
      open_id:open_id
    }
  },{
    upsert:true
  })
}
resolveOpenId2('789')


function resolveOpenId3(open_id){
  return db.account.findAndModify({
    query:{open_id:open_id},
    update:{
      $set:{open_id:open_id}
    },
    upsert:true,
    new:true
  })
}
// resolveOpenId3('789')
// resolveOpenId3('abc')
resolveOpenId3('def')

db.account.createIndex({
    open_id:1
  },{
    unique:true
  }
)

db.account.find()

###（四）Go语言链接Mongo

package main

import (
	"context"
	"fmt"

	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/bson/primitive"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

func main() {
	c := context.Background()
	mc, err := mongo.Connect(c, options.Client().ApplyURI("mongodb://localhost:27017/coolcar?readPreference=primary&ssl=false"))
	if err != nil {
		panic(err)
	}
	defer mc.Disconnect(c)
	col := mc.Database("coolcar").Collection("account")

	findRows(c, col)
}

func findRows(c context.Context, col *mongo.Collection) {
	cur, err := col.Find(c, bson.M{})
	if err != nil {
		panic(err)
	}
	for cur.Next(c) {
		var row struct {
			ID     primitive.ObjectID `bson:"_id"`
			OpenID string             `bson:"open_id"`
		}
		err = cur.Decode(&row)
		if err != nil {
			panic(err)
		}
		fmt.Printf("%+v\n", row)
	}
}

func insertRows(c context.Context, col *mongo.Collection) {
	res, err := col.InsertMany(c, []interface{}{
		bson.M{
			"open_id": "123",
		},
		bson.M{
			"open_id": "456",
		},
	})
	if err != nil {
		panic(err)
	}

	fmt.Printf("%+v", res)
}

赏

谢谢你请我吃糖果

支付宝

微信

• 本文作者： LQbank
• 本文链接： http://example.com/2022/05/28/Go语言下mongo使用/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！