首页 > 数据库> > MongoDB( 五 )MongoDB普通查询和聚合查询

MongoDB( 五 )MongoDB普通查询和聚合查询

2020-12-31 09:57:41 作者：互联网

一 : 普通操作

实例:

聚合查询、排序、分组、分页、Concat拼接

聚合查询链表关联查询

一 : 普通操作

MongoDB的普通查询MongoTemplate与Mysql的JdbcTemplate或者说是Redis的RedisTemplate别无二致 , 使用方式完全相同;

在使用之间创建一个临时使用的test集合, 结构如下

db.getCollection("testDocuments").insert( {
    _id: ObjectId("5fe9439e66730000e70058d0"),
    name: "huang",
    age: 21,
    gender: "男"
} );
db.getCollection("testDocuments").insert( {
    _id: ObjectId("5fe943bb66730000e70058d1"),
    name: "lu",
    age: 26,
    gender: "男"
} );
db.getCollection("testDocuments").insert( {
    _id: ObjectId("5fe943cf66730000e70058d2"),
    name: "huang",
    age: 2,
    gender: "女"
} );

实例:

插入文档

1 . 使用mongoTemplate直接插入自定义实体类

        MongoTestDTO mongoTestDTO = new MongoTestDTO();
        mongoTestDTO.setName("huangxiapkuan");
        mongoTestDTO.setAge("21");
        mongoTestDTO.setGender("男");
        mongoTemplate.insert(mongoTestDTO , "testDocuments");

2 . 使用mongoTemplate插入Mongo自带可动态扩展实体类Document.class

import org.bson.Document

// 批量插入 改为 insertMany(List<Document>) 即可
mongoTemplate.insert(new Document("name" , "zhang")
                .append("age" , "33").append("gender" , "男"), "testDocuments");

3 . MongoTemplate提供了官方客户端驱动的封装,官方客户端有的方法，它都能调用 , 此外还提供了一种更统一的execute方法，

它通过注册一个回调，来实现MongoDB操作以及数据回传：

mongoTemplate.execute(mongodb -> {
            mongodb.getCollection("testDocuments").insertOne(new Document("name" , "isnert3")
                    .append("age" , "33").append("gender" , "男"));
            return "sucess";
        });

4 . Mongo原生SQL如下:

db.testDocuments.insert({
    name: 'huang',
    age: 2,
    gender: '男'
})

删除文档

1 . 使用mongoTemplate进行删除操作 , 需要提供Query也就是条件 , 和集合名 , 注意以下使用的 remove()更换为 findAllAndRemove() 则为批量删除

删除条件 name = ''insert3'' 的数据

Query query =  new Query();
// Criteria 可自定义创建条件 
query.addCriteria(Criteria.where("name").is("insert3"));
mongoTemplate.remove(query , "testDocuments");

删除条件 _id = ''5feae0eb47801f7dfef1bf2d'' 的数据

Query query =  new Query();
query.addCriteria(Criteria.where("_id").is(new ObjectId("5feae0eb47801f7dfef1bf2d")));
mongoTemplate.remove(query , "testDocuments");

2 . 使用 MongoTemplate.execute 来执行回调函数 ,用来进行删除操作 , 官方客户端有的方法，它都能调用

        mongoTemplate.execute( mongodb -> {
            mongodb.getCollection("testDocuments").deleteOne(new Document("name","isnert3"));
            return "sucess";
        });
        // 又或者
        mongoTemplate.execute("testDocuments" ,mongodb -> {
            mongodb.deleteOne(new Document("name","isnert3"));
            return "sucess";
        });

3 . MongoDb原生SQL删除语句如下

db.testDocuments.remove({
    'name': 'insert3'
})

更新文档

1 . 使用MongoTemplate.upsert(Query , Update , CollectionName) 进行更新操作

import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;       
        
Query query =  new Query();
        query.addCriteria(Criteria.where("_id").is(new ObjectId("5feafa9b47801f7dfef1bf2e")));
        Update update = new Update();
        update.set("name" , "new_set_values");
        UpdateResult result = mongoTemplate.upsert(query, update, "testDocuments");
        long count = result.getModifiedCount();
        if (count > 0) {
            return ApiResult.success("win!~");
        }

2 . 使用MongoTemplate.execute() 回调函数进行更新操作

            // 注意这里 使用的 不是 Update 而是 Updates
            String execute = mongoTemplate.execute("testDocuments", mongodb -> {
            UpdateResult result = mongodb.updateMany(new Document("name", "isnert3"), Updates.set("name", "upr_execute_name"));
            long count = result.getModifiedCount();
            if (count > 0) {
                return "success";
            }
            return "error";
        });

3 . 使用MongoDb原生SQl 进行更新操作

    db.getCollection('testDocuments').updateOne({
        name: 'new_set_values'
    }, {
        $set: {
            name: 'Mongo_set_name_new'
        }
    })

查询操作

由于是测试用

1 . 使用MongoTemplate进行查询操作

普通查询

// 查询所有
List<Document> testDocuments = mongoTemplate.find(new Query(), Document.class, "testDocuments");

// 条件查询 , 根据_id查询指定值
Query query = new Query();
query.addCriteria(Criteria.where("_id").is(new ObjectId("5feafa9b47801f7dfef1bf2e")));
mongoTemplate.find(query, Document.class, "testDocuments");
// 也可以直接使用MongoTemplate提供的 findById()
mongoTemplate.findById("5feafa9b47801f7dfef1bf2e",Document.class , "testDocuments");

// 条件查询,查询特定name值
Query query = new Query();
query.addCriteria(Criteria.where("name").is("huang"));
List<Document> testDocuments = mongoTemplate.find(query, Document.class, "testDocuments");

// 条件查询,查询特定name值 ,或者age年龄大于30的
Query query = new Query();
Criteria criteria = new Criteria();
criteria.orOperator(Criteria.where("name").is("huang") , Criteria.where("age").gte(30));
query.addCriteria(criteria);
List<Document> testDocuments = mongoTemplate.find(query, Document.class, "testDocuments");

// 条件查询,查询特定name值,并且年龄大于20的
Query query = new Query();
Criteria criteria = new Criteria();
criteria.andOperator(Criteria.where("name").is("huang") , Criteria.where("age").gte(20));
query.addCriteria(criteria);
List<Document> testDocuments = mongoTemplate.find(query, Document.class, "testDocuments");

//条件查询 , 分页查询 skip(0)  从第0条开始 , limit(2) 查询两条
Query query = new Query();
query.skip(0);
query.limit(2);
mongoTemplate.find(query, Document.class, "testDocuments");

//条件查询 , 排序 sort 可同时针对多个字段进行排序, 不过当数据量过大时可能会出现内存不足
// 具体解决办法可参照  https://blog.csdn.net/qq_42543063/article/details/111380373
Query query = new Query();
// query.with(Sort.by("age").descending()); // 倒序
query.with(Sort.by("age").ascending()); // 正序
mongoTemplate.find(query, Document.class, "testDocuments");

2 . MongoTemplate提供的回调与正常方法别无二致, 可按照增删改的样例自行探索..........

二 : 聚合操作

MongoDB 中聚合(aggregate)主要用于处理数据(诸如统计平均值，求和等)，并返回计算后的数据结果。

有点类似 SQL 语句中的 count(*)。

aggregate() 方法

MongoDB中聚合的方法使用aggregate()。

语法

aggregate() 方法的基本语法格式如下所示：

>db.COLLECTION_NAME.aggregate(AGGREGATE_OPERATION)

聚合基础查询

一下是本次测是使用的数据

聚合查询、排序、分组、分页、Concat拼接

Aggregation aggregation = Aggregation.newAggregation(
                Aggregation.group("name")
                        .max("age").as("maxAge")
        );
AggregationResults<Document> testDocuments = 
                mongoTemplate.aggregate(aggregation, "testDocuments", Document.class);

等同于Mongo原生SQL如下:

、

查询结果 , 可以发现 , name被当做了_id , 且只查询出来了两个属性

{"_id":"upr_execute_name","maxAge":33},{"_id":"huang","maxAge":21},{"_id":"lu","maxAge":26}

可以将上面的聚合操作修改为如下

// 除却max 函数外 聚合操作还提供了  avg  min  sum 等常用计算函数
Aggregation aggregation = Aggregation.newAggregation(
                Aggregation.match(Criteria.where("gender").is("男")), // 查询条件
                Aggregation.project("name", "age", "gender")
                        .andExpression("concat('$gender', '人')").as("genderNew")
                ,// 可利用 andExpression() 继续操作某些特定值  加减乘如 或者拼接字符串
                Aggregation.group("name")
                        .max("age").as("maxAge") // 取最大年龄 , 别名为 maxAge
                .first("name").as("name") // 分组后取该组内第一条name
                .first("age").as("age")   
                .first("gender").as("gender"),
                Aggregation.skip(0L), // 始于第几条 mongo建议使用long类型
                Aggregation.limit(2L), // 查询多少条 
                Aggregation.sort(Sort.Direction.DESC,
                "age" , "name") // 可同时使用多字段排序 , 需注意当数据量过大时容易造成内存不足 具体解决办法 请参照 https://blog.csdn.net/qq_42543063/article/details/111380373
        );
AggregationResults<Document> testDocuments =
                mongoTemplate.aggregate(aggregation, "testDocuments", Document.class);

查询结果样例为:

{"_id":"huang","maxAge":21,"name":"huang","age":21,"gender":"男"},{"_id":"lu","maxAge":26,"name":"lu","age":26,"gender":"男"}

聚合查询链表关联查询

为了验证关联查询操作 , 此处需新建一个mongo的集合 , 旨在测试用 , 具体业务不严谨!!!

主表为 testDocuments 关联表为 testRel

        // 创建条件集合
        List<AggregationOperation> aggregationOptions = new ArrayList<>();
        LookupOperation lookupOperation = LookupOperation.newLookup()
                .from("testRel") // 指定关联表
                .localField("name") // 关联表字段
                .foreignField("name") // 关联表字段
                .as("rel"); // 关联表别名
        aggregationOptions.add(lookupOperation); // 作为条件添加至条件集合
        // 为关联表创建条件
        aggregationOptions.add(Aggregation.match(Criteria.where("rel").elemMatch(Criteria.where("name").ne("").ne(null))));
        aggregationOptions.add(Aggregation.group("name")
                .max("age").as("maxAge")
                .first("name").as("name")
                .first("age").as("age")
                .first("gender").as("gender")
                .first("rel.address").as("assress"));
        // 将条件集合创建成聚合操作Aggregation
        Aggregation aggregation = Aggregation.newAggregation(aggregationOptions);
        AggregationResults<Document> testDocuments =
                mongoTemplate.aggregate(aggregation, "testDocuments", Document.class);

标签：聚合,name,MongoDB,查询,mongoTemplate,new,query,testDocuments
来源： https://blog.csdn.net/qq_42543063/article/details/111831334