添加链接
link管理
链接快照平台
  • 输入网页链接,自动生成快照
  • 标签化管理网页链接

数组的查稍微有点不同,篇幅原因,分开来写。

需要完全一样才能匹配到,包括元素的顺序。且演示输出时转化成字符串形式:

// 最基本的查询数组相关数据,下面数组的匹配,需要完全一样才能匹配到,包括元素的顺序
// 参考:https://www.mongodb.com/docs/manual/tutorial/query-arrays/
func Array(mongo *mongo.Database, ctx context.Context) {
	stringlist := []string{"test1", "test2", "test3"}
	findFilter := bson.M{"stringlist": stringlist}
	result := mongo.Collection("test").FindOne(ctx, findFilter)
	// 转化成string输出
	rawByte, _ := result.DecodeBytes()
	fmt.Println(rawByte.String())

用all关键字实现:查询数组中包含以下元素,且与顺序无关的查询。遍历结果时可以转化成只包含值而不包含key的数组:

func ArrayAll(mongo *mongo.Database, ctx context.Context) {
	stringlist := []string{"test3", "test2"}
	findFilter := bson.M{"stringlist": bson.M{"$all": stringlist}}
	result := mongo.Collection("test").FindOne(ctx, findFilter)
	// 将文档的字段的值转化成数组,然后逐个输出,这种方式仅包含值,而没有键
	rawByte, _ := result.DecodeBytes()
	rawV, _ := rawByte.Values()
	for i := 0; i < len(rawV); i++ {
		fmt.Println("rawV:", rawV[i])

数组类型的字段后面对应一个值,表明是查询数组中是否包含该元素。遍历结果时转化成键值对的数组形式:

// 数组类型的字段后面对应一个值,表明是查询数组中是否包含该元素
func ArrayAtLeastOne(mongo *mongo.Database, ctx context.Context) {
	// 还可以使用gte等关键字去匹配是否有大于小于某值的元素
	findFilter := bson.M{"stringlist": "test3"}
	result := mongo.Collection("test").FindOne(ctx, findFilter)
	// 将文档的字段转化成数组,然后逐个输出,这种方式是键值对的形式
	rawByte, _ := result.DecodeBytes()
	rawV, _ := rawByte.Elements()
	for i := 0; i < len(rawV); i++ {
		fmt.Println("rawV:", rawV[i])

多个条件的查询和我们正常的理解不太一样,结果还可以按数组下标去取:

// 有多个条件时的查询
func ArrayGtAndLt(mongo *mongo.Database, ctx context.Context) {
	// 这两个条件,不需要都作用到同一个元素身上,只要有某个元素大于20,且有某个元素小于10,所以下面语句可以查出多条记录
	findFilter := bson.M{"intlist": bson.M{"$gt": 20, "$lt": 10}}
	cur, err := mongo.Collection("test").Find(ctx, findFilter)
	if err != nil {
		fmt.Println("err")
	// 遍历数据
	for cur.TryNext(ctx) {
		// 这种方式是转化成数组后,用数组下标去取数据,输出是键值对形式
		result := cur.Current.Index(0)
		fmt.Println(result)
	cur.Close(ctx)

下面这种多条件查询才和我们正常的理解差不多。结果还可以用key去取值:

// 和上面这种方法正好相反,必须得有元素同时满足所有条件,才算查询成功
func ArrayElemMatch(mongo *mongo.Database, ctx context.Context) {
	// 需要有某个元素同时满足两个条件才可,不可能有元素满足大于20小于10,所以查询会失败
	findFilter := bson.M{"intlist": bson.M{"$elemMatch": bson.M{"$gt": 20, "$lt": 10}}}
	cur, err := mongo.Collection("test").Find(ctx, findFilter)
	if err != nil {
		fmt.Println("err")
	// 遍历数据
	for cur.TryNext(ctx) {
		// 这种方式是转化成数组后,用key值去取数据,输出对应的值
		result := cur.Current.Lookup("intlist")
		fmt.Println(result)
	cur.Close(ctx)

按照数组长度查询,结果还可以用Lookup取嵌套文档的键值

// 按数组长度查询
func ArraySize(mongo *mongo.Database, ctx context.Context) {
	// 需要有某个元素同时满足两个条件才可,不可能有元素满足大于20小于10,所以查询会失败
	findFilter := bson.M{"intlist": bson.M{"$size": 11}}
	cur, err := mongo.Collection("test").Find(ctx, findFilter)
	if err != nil {
		fmt.Println("err")
	// 遍历数据
	for cur.TryNext(ctx) {
		// 还可以有多个key,这些key是层次关系的,先获取键object的值,然后再从值里面找键id的值,非常方便我们获取深层嵌套的数据
		result := cur.Current.Lookup("object", "id")
		fmt.Println(result)
	cur.Close(ctx)

查询不包含元素的数组:

	// 查询不包括0 和7的数组,特别注意,如果文档中就没有intlist字段,也满足条件
	findFilter := bson.M{"intlist": bson.M{"$nin": bson.A{0, 7}}}

// 数组的查询还可以用点加下标,如.0:对比下标为0的元素是否满足条件:

	// 查询数组的第1个元素是否大于5
	findFilter := bson.M{"intlist.0": bson.M{"$gt": 5}}

指定仅查询数组的第N个元素:

func ArrayElement(mongo *mongo.Database, ctx context.Context) {
	filter := bson.M{} // 空结构体匹配所有
	// 用slice关键指定查询第N个元素,-1表示查询最后一个元素
	options := options.FindOptions{Projection: bson.M{"intlist": bson.M{"$slice": -1}, "_id": 0}}
	cur, err := mongo.Collection("test").Find(ctx, filter, &options)
	if err != nil {
		fmt.Println("err")
	// 遍历数据
	for cur.TryNext(ctx) {
		result, _ := cur.Current.LookupErr("intlist")
		fmt.Println(result)
	cur.Close(ctx)
                                    Golang Mongo分页包mongo-go-driver
 对于所有对聚合管道的简单询,这都是简单易用的分页驱动程序,其信息包括Total,Page,PerPage,Prev,Next,TotalPage和您的实际mongo结果。
$ go get -u -v github.com/gobeam/mongo-go-pagination
 或搭配dep 
$ dep ensure -add github.com/gobeam/mongo-go-pagination
对于聚合管道询
package main
import (
	"context"
	"fmt"
	. "github.
	"context"
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
	"log"
var db *mongo.Database			// 数据库
var stuColl *mongo.Collecti
之前的询我们都是返回所有字段,还可以选择询指定字段:
与上面相反,可以指定一个字段不要,询剩余字段:
对于嵌套的文档也同样受用,且用LookupErr遍历时,仅获取想要的key值:...
                                    更复杂的询一时也想不到什么场合用得着,所以以后有了再慢慢补充。and 和or组合:
我认为复杂的询往往是组合各种关键字进行询,所以,下面将一些还未实践过的关键字给列出来,方便以后询。...
      address1: dds-2***1.mongodb.rds.aliyuncs.com
      port1: 3717
      address2: dds-2***2.mongodb.rds.aliyuncs.com
      port2: 3717
      database: demo
      user: root
      password: Demo@123!
#      pool_size: 100
                                    [直接上代码(依赖代码请看之前的博客):public void query() {// $or (询id等于1或者id等于2的数据)BasicDBObject queryObject = new BasicDBObject().append(DBObject o=(DBObject) JSON.parse("{ groups.groupName : 'group1' }");DBObject ...
                                    title: mongodb-2 mongodb-java-driver做基本的CRUD–基本询date: 2017-01-11 16:25:59tags:categories: mongodb如何连接mongodb?http://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/其中Mongo...
ObjectID
MongoDB中经常会接触到一个自动生成的字段:”_id”,类型为ObjectId。
MongoDB采用了一个称之为ObjectId的类型来做主键。ObjectId是一个12字节的 BSON类型字符串。
6273 f481 4ca1 7097 3448 131f
(1) 6273 f481(4字节):UNIX时间戳
6273f481(16进制时间戳)→ 
	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
func GetMongo() (*mongo.Database, error) {
	credential := options.Credential{
		AuthMechanism: "SCRAM-SHA-256",
		Username