• MongoDB操作


    一、MongoDB的DML语句

    在发布生产云服务器的时候,经常会出现导入脚本报错。以阿里云的MongoDB为例,目前只支持.csv,且导入经常失败,此时需要DML语句。

    insert()方法:

    下面是在inventory集合中插入一个三个字段的文档:

    db.inventory.insert( { _id: 10, type: "misc", item: "card", qty: 15 } )

    save()方法:

    使用save()方法插入一个文档,通过该方法保存一个不包含_id字段的文档或者包含_id字段但该字段值不存在集合中的文档。下面的示例创建一个新的文档在inventory集合:

    db.inventory.save( { type: "book", item: "notebook", qty: 40 } )

    当在使用save方法时,插入不指定_id时,会自动生成一个。

    Insert和Save的区别是:如果插入的集合的“_id”值,在集合中已经存在,用Insert执行插入操作会报异常,已经存在"_id"的键。用Save如果系统中没有相同的"_id"就执行插入操作,有的话就执行覆盖掉原来的值。相当于修改操作。

    update()方法:

    调用update()方法使用upsert标志创建一个新文档当没有匹配查询条件的文档时。下面的例子当inventory集合中没有包含{type:"books",item:"journal"}的文档时创建一个新文档:

    db.s_city.update(
      {
    
      cityName : "深圳"
      },
      {
      $set: {cityName:"深圳市"}
    });

    二、Criteria操作MongoDB

    基于:org.springframework.data.mongodb.core.query

    简单查询
    public List<Msg> getUserVideo(int userId) {
    Query query = createQuery("userId",userId);
    addToQuery(query, "body.type", 4);
    return queryListsByQuery(query);
    }
    查询返回一个字段
     public List<ObjectId> getPraiseIds(Integer userId) {
            Query query = createQuery("userId", userId);
            List<ObjectId> msgIds = getDatastore().findDistinct(query, "msgId", Praise.class, ObjectId.class);
            return msgIds;
        }
     public List<Integer> queryBlacklistUserId(int userId) {
            Query query = createQuery("userId", userId);
            addToQuery(query, "blacklist", 1);
            return distinct("toUserId", query, Integer.class);
        }
    in查询
     public long getPraiseCountByMsg(List<String> msgId) {
            Query query = new Query();
            query.addCriteria(Criteria.where("msgId").in(msgId));
            return count(query);
        }
    or查询
    query.addCriteria(new Criteria().orOperator(Criteria.where("manualPay_status").is(2),
    new Criteria().andOperator(Criteria.where("status").is(1)
    )));
    修改
    public void updateByCommentId(ObjectId commentId, Map<String, Object> map) {
            Query query = createQuery("commentId", commentId);
            Update ops = createUpdate();
            map.forEach((key, value) -> {
                ops.set(key, value);
            });
            update(query, ops);
        }
    模糊查询
    if(null != nickName){
                query.addCriteria(Criteria.where("nickName").regex(".*" + nickName + ".*"));
            }
    删除
    public void deleteMsg(int userId) {
            Query query = createQuery("userId", userId);
            deleteByQuery(query);
        }

     其他操作参考《MongoDB--Spring Data MongoDB详细的操作手册

  • 相关阅读:
    python excel导入到数据库
    ubuntu14.04修改mysql默认编码
    python 向MySQL里插入中文数据
    hbase框架原理
    hive框架原理
    Hadoop的MapReduce模型基本原理
    机器学习模型效果评价
    spark架构原理
    Hadoop架构原理
    特征工程
  • 原文地址:https://www.cnblogs.com/zeussbook/p/15003672.html
走看看 - 开发者的网上家园