数组的查稍微有点不同,篇幅原因,分开来写。
需要完全一样才能匹配到,包括元素的顺序。且演示输出时转化成字符串形式:
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)
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) {
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) {
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) {
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) {
result := cur.Current.Lookup("intlist")
fmt.Println(result)
cur.Close(ctx)
按照数组长度查询,结果还可以用Lookup取嵌套文档的键值
func ArraySize(mongo *mongo.Database, ctx context.Context) {
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) {
result := cur.Current.Lookup("object", "id")
fmt.Println(result)
cur.Close(ctx)
查询不包含元素的数组:
findFilter := bson.M{"intlist": bson.M{"$nin": bson.A{0, 7}}}
// 数组的查询还可以用点加下标,如.0
:对比下标为0的元素是否满足条件:
findFilter := bson.M{"intlist.0": bson.M{"$gt": 5}}
指定仅查询数组的第N个元素:
func ArrayElement(mongo *mongo.Database, ctx context.Context) {
filter := bson.M{}
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