Golang使用MongoDB通用操作

MongoDB是Nosql中常用的一种数据库,今天笔者就简单总结一下Golang如何使用这些通用的供能的,不喜勿喷。。。

研究的事例结构如下:

type LikeBest struct {
AuthorName string `bson:"authorname,omitempty"`
BookName string `bson:"bookname,omitempty"`
PublishTime string `bson:"publishtime,omitempty"`
LastReadTime string `bson:"lastreadtime,omitempty"`
}

type Personnal struct {
UserName string `bson:"username,omitempty"`
WhereCity string `bson:"wherecity,omitempty"`
BookSCount int `bson:"bookscount,omitempty"`
FavoriteBooks []LikeBest `bson:"favoratebooks,omitempty"`
}

建立与MongoDB的连接

session, err := mgo.Dial("localhost:27017")
if err != nil {
panic(err)
}
defer session.Close()

c := session.DB("PersonManage").C("Persons")

注意:以下操作条件默认均为:username=”impressionw”

插入数据
1、使用Insert()函数是最简单且通用的方式

err := c.Insert(&p) //p为插入的结构体数据
2、使用upsert()函数【更新或插入】

change := mgo.Change{
Update: bson.M{"$set": p},
ReturnNew: false,
Remove: false,
Upsert: true,
}
_, err := c.Find(bson.M{"username": "impressionw"}).Apply(change, nil)

或许,你觉得第一种方式更简洁,但是实际场景中,第二种也非常实用
1. 它不仅只能插入数据,Update字段可以接收多个参数插入,但是关键字不能相同【不能同时有2个”$set”】
2. 它能返回处理前或处理后的document,若返回,则Apply的第二个参数即是结果
3. 它可以结合select使用

注意:$set 只修改指定字段的值,不影响其他值
查询数据
1、查询整个文档

err = c.Find(bson.M{"username": "impressionw"}).One(&result)

2、只返回 FavoriteBooks 对应的字段,忽略其他信息
这里用到了Select(),select可以设置,返回的内容:

select{‘filedname’:0},表示忽略该字段则结果不返回此字段
select{‘filedname’:1},表示关注该字段则只返回关注字段
err = c.Find(bson.M{"username": "impressionw"}).Select(bson.M{"favoratebooks": 1}).One(&result)

3、查询文档的_id

var result interface{}
err = c.Find(bson.M{"username": "impressionw"}).Select(bson.M{"_id": 1}).One(&result)

var document_id string
switch value := result.(type) {
case bson.M:
mapid := value["_id"]
if mapid != nil {
id := mapid.(bson.ObjectId)
document_id = id.Hex()
}
}

注意:若是查找username含有”impressionw”的文档,可用正则匹配查找,条件这样写:

query = bson.M{"username": bson.M{"$regex": "impressionw"}}
4、查询数组中匹配元素,只返回含有匹配元素的文档,需要用到Mongdob的聚合aggregate

相关操作符的含义如下:

$project:修改输入文档的结构。可以用来重命名、增加或删除域,也可以用于创建计算结果以及嵌套文档。
match:用于过滤数据,只输出符合条件的文档。match:用于过滤数据,只输出符合条件的文档。match使用MongoDB的标准查询操作。
$limit:用来限制MongoDB聚合管道返回的文档数。
$skip:在聚合管道中跳过指定数量的文档,并返回余下的文档。
$unwind:将文档中的某一个数组类型字段拆分成多条,每条包含数组中的一个值。
$group:将集合中的文档分组,可用于统计结果。
$sort:将输入文档排序后输出。
$geoNear:输出接近某一地理位置的有序文档。
下面的代码,将只返回FavorateBooks字段中,bookname为”The Go Programming Language”的书籍,且只关注favoratebooks,不会输出个人信息

pipe := c.Pipe([]bson.M{{"$unwind": "$favoratebooks"},
{"$match": bson.M{"username": "impressionw", "favoratebooks.bookname": "The Go Programming Language"}},
{"$project": bson.M{"favoratebooks": 1}}})
resp := []bson.M{}
err := pipe.All(&resp)

这样可以达到目的了

更新文档
1、更新WhereCity字段—关键字 $set,将WhereCity修改为”ShangHai“:

err = c.Update(bson.M{"username": "impressionw"}, bson.M{"$set": bson.M{"wherecity": "ShangHai"}})
2、更新FavoriteBooks中的LastReadTime字段

查询条件:username=”impressionw”、bookname=”The Go Programming Language”,将LastReadTime字段更改为:”Oct 26, 2017”

change := mgo.Change{
Update: bson.M{"$set": bson.M{"favoratebooks.$.lastreadtime": "Oct 26, 2017"}},
ReturnNew: false,
Remove: false,
Upsert: true,
}
query := bson.M{"username": "impressionw", "favoratebooks": bson.M{"$elemMatch": bson.M{"bookname": "The Go Programming Language"}}}
_, err = c.Find(query).Select(bson.M{"favoratebooks.bookname": 1}).Apply(change, nil)

3、更新一个 FavoriteBooks 的整个数组文档,即新增一本书的信息

给username=”impressionw”的文档新增一条书籍记录,同时将BookSCount字段自增1

Act := []LikeBest{
LikeBest{
AuthorName: "YuHen",
BookName: "Go Learning",
PublishTime: "Dec 27, 2014",
LastReadTime: "Dec 29, 2016",
},
}
change := mgo.Change{
Update: bson.M{"$inc": bson.M{"bookscount": 1}, "$push": bson.M{"favoratebooks": bson.M{"$each": Act}}},
ReturnNew: false,
Remove: false,
Upsert: true,
}
_, err := c.Find(bson.M{"username": "impressionw"}).Apply(change, nil)

注意:

1、此处可用addToSet代替addToSet代替push,addToSet不会添加已有的数据,addToSet不会添加已有的数据,push 会添加重复的数据,可以分别应用于不同场景
2、$inc 对文档的某个值为数字型(只能为满足要求的数字)的键进行增减的操作, 值为正数表示自增,值为负数表示自减

删除文档
1、删除喜欢的一本书籍信息,同时喜欢书记数量自减1

var option = bson.M{"$pull": bson.M{"favoratebooks": bson.M{"bookname": "Go Learning"}}, "$inc": bson.M{"bookscount": -1}}
err := c.Update(bson.M{"username": "impressionw"}, option)

2、删除所有喜欢的书籍,同时将bookscount字段置为 0

var data = bson.M{"$unset": bson.M{"favoratebooks": true}, "$set": bson.M{"bookscount": 0}}
err = c.Update(bson.M{"username": "impressionw"}, data)

3、删除整个文档,根据”_id”字段删除文档

err := session.DB("PersonManage").C("Persons").Remove(bson.M{"_id":bson.ObjectIdHex("5b6c0536a8ab29200debcb0b")})

原文地址:https://www.cnblogs.com/dfsxh/p/10208780.html

时间: 2024-10-14 15:29:11

Golang使用MongoDB通用操作的相关文章

java 对mongodb的操作

java 对mongodb的操作 1.1连单台mongodb Mongo mg = newMongo();//默认连本机127.0.0.1  端口为27017 Mongo mg = newMongo(ip);//可以指定ip 端口默认为27017 Mongo mg = newMongo(ip,port);//也可以指定ip及端口号 1.2连双台mongodb //ip为主机ip地址,port为端口号,dataBaseName相当于数据库名 DBAddress left = new DBAddre

golang解析mongodb中的ISODate类型

在golang中可以使用time.Time数据类型来保存mongodb中的ISODate时间. g type Model struct {     uploadDate time.Time `bson:"uploadDate"` } m := Model{} if err := c.Find(nil).Select({"_id": 0, "uploadDate": 1}).One(&m); err != nil {     fmt.Pri

MongoDB常用操作

1.MongoDB常用操作 1.1数据库的操作命令 1.创建数据库,使用命令 use 数据库名称 ,如 use sxf. *注意: 1.use 命令后跟的数据库名,如果存在就进入此数据库,如果不存在就创建,所以这种创建方式又叫隐式创建 2.使用命令use sxf创建数据库后,并没有真正生成对应的数据文件,如果此时退出,此数据库将被删除,只有在此数据库中创建集合后,才会真正生成数据文件 2. 删除当前数据库,使用命令 db.dropDatabase() 3.查看所有数据库,使用命令 show db

Mongodb聚合操作之读书笔记

Mongodb聚合操作 读书笔记 mongodb,两种计算聚合pipeline和mapreduce pipeline查询速度快于mapreduce,但MapReduce能够在多台Server上并行执行复杂的聚合逻辑. mongodb不允许Pipeline的单个聚合操作占用过多的系统内存,如果一个聚合操作消耗20%以上的内存,那么mongodb直接停止操作,并向客户端输出错误消息. Pipeline方式使用db.collection.aggregate()函数进行聚合运算,运算速度较快,操作简单.

.NET下对MongoDB进行操作(二)

这次说下关于利用C#driver,对mongoDB进行简单的查询. 我们可以利用Query类中的静态方法来创建一系列query,达到查询的目的. Query在using MongoDB.Driver.Builders这一名称空间中. 1. 单一条件查询,可以参考如下代码: var query = Query.EQ("ColName", "Value"); foreach (BsonDocument doc in collection.Find(query)) { D

安装golang的mongodb驱动mgo速记

这里介绍的方法只适用于Centos平台,测试版本为centos 6.5 下载源码安装实在麻烦,这里采用比较简单的方法给GO安装mongodb驱动 安装mgo之前,需要先安装bzr yum -y install bzr 安装完成后,执行如下命令: go get labix.org/v2/mgo 成功后什么内容也不显示,没有出错提示,表示安装成功. 详细使用教程:http://labix.org/mgo 安装golang的mongodb驱动mgo速记,布布扣,bubuko.com

NoSql数据库初探-mongoDB读操作

MongoDB以文档的形式来存储数据,此结果类似于JSON键值对.文档类似于编程语言中将键和值关联起来的结构(比如:字典.Map.哈希表.关联数组).MongoDB文档是以BOSN文档的形式存在的.BSON是JSON附加了类型信息的一种二进制的表现形式. 文档中的字段可以是任何BSON类型,比如(文档类型.数组.文档数组) MongoDB将所有文档存储在collection中,collection是一组相关的文档集合,这一组文档集合拥有共同的索引,collection类似于关系型数据库中的表.

Spring集成MongoDB及操作

1.Spring集成MongoDB的集成配置 若使用Maven项目,则添加包依赖. <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.2.0.RELEASE</version> </dependency> 在Spring配置文件中对Mon

MongoDB 常用操作

MongoDB常用操作