文档章节

mongodb的初级操作

jackLicy
 jackLicy
发布于 2016/07/05 19:07
字数 536
阅读 11
收藏 0

1. 查询一条数据:(多用于保存时判断db中是否已有当前数据,这里 is  精确匹配,模糊匹配 使用 regex...)

public PageUrl getByUrl(String url) {
        return findOne(new Query(Criteria.where("url").is(url)),PageUrl.class);
    }

2. 查询多条数据:linkUrl.id 属于分级查询

public List<PageUrl> getPageUrlsByUrl(int begin, int end,String linkUrlid) {        
        Query query = new Query();
        query.addCriteria(Criteria.where("linkUrl.id").is(linkUrlid));
        return find(query.limit(end - begin).skip(begin), PageUrl.class);        
    }

3. 模糊查询:

public long getProcessLandLogsCount(List<Condition> conditions)
    {
        Query query = new Query();
        if (conditions != null && conditions.size() > 0) {
            for (Condition condition : conditions) {
                query.addCriteria(Criteria.where(condition.getKey()).regex(".*?\\" +condition.getValue().toString()+ ".*"));
            }
        }
        return count(query, ProcessLandLog.class);
    }

4. gte: 大于等于,lte小于等于...注意查询的时候各个字段的类型要和mongodb中数据类型一致

public List<ProcessLandLog> getProcessLandLogs(int begin,int end,List<Condition> conditions,String orderField,Direction direction)
    {
        Query query = new Query();
        if (conditions != null && conditions.size() > 0) {
            for (Condition condition : conditions) {
                if(condition.getKey().equals("time")){
                    query.addCriteria(Criteria.where("time").gte(condition.getValue())); //gte: 大于等于
                }else if(condition.getKey().equals("insertTime")){
                    query.addCriteria(Criteria.where("insertTime").gte(condition.getValue()));
                }else{
                    query.addCriteria(Criteria.where(condition.getKey()).is(condition.getValue()));
                }
            }
        }
        return find(query.limit(end - begin).skip(begin).with(new Sort(new Sort.Order(direction, orderField))), ProcessLandLog.class);
    }

public List<DpsLand> getDpsLandsByTime(int begin, int end, Date beginDate,Date endDate) {
  return find(new Query(Criteria.where("updateTime").gte(beginDate).lte(endDate)).limit(end - begin).skip(begin),
    DpsLand.class);
 }

   查询字段不存在的数据

public List<GoodsDetail> getGoodsDetails2(int begin, int end) {
        Query query = new Query();
        query.addCriteria(Criteria.where("goodsSummary").not());
        return find(query.limit(end - begin).skip(begin),GoodsDetail.class);
    }

5. 查询数量:

public long getPageInfosCount(List<Condition> conditions) {
        Query query = new Query();
        if (conditions != null && conditions.size() > 0) {
            for (Condition condition : conditions) {
                query.addCriteria(Criteria.where(condition.getKey()).is(condition.getValue()));
            }
        }
        return count(query, PageInfo.class);
    }

6. 更新一条数据的一个字段:

public WriteResult updateTime(PageUrl pageUrl) {
        String id = pageUrl.getId();
        return updateFirst(new Query(Criteria.where("id").is(id)),Update.update("updateTime", pageUrl.getUpdateTime()), PageUrl.class);
    }

7. 更新一条数据的多个字段:

//调用更新
private void updateProcessLandLog(ProcessLandLog processLandLog,
            int crawlResult) {
        List<String> fields = new ArrayList<String>();
        List<Object> values = new ArrayList<Object>();
        fields.add("state");
        fields.add("result");
        fields.add("time");
        values.add("1");
        values.add(crawlResult);
        values.add(Calendar.getInstance().getTime());
        processLandLogReposity.updateProcessLandLog(processLandLog, fields,
                values);
    }
//更新
public void updateProcessLandLog(ProcessLandLog land, List<String> fields,List<Object> values) {
        Update update = new Update();
        int size = fields.size();
        for(int i = 0 ; i < size; i++){
            String field = fields.get(i);
            Object value = values.get(i);
            update.set(field, value);
        }
        updateFirst(new Query(Criteria.where("id").is(land.getId())), update,ProcessLandLog.class);
    }

8. 删除数据:

public void deleteObject(Class<T> clazz,String id) {
        remove(new Query(Criteria.where("id").is(id)),clazz);
    }

9.保存数据:

//插入一条数据
public void saveObject(Object obj) {
        insert(obj);
    }

//插入多条数据    
public void saveObjects(List<T> objects) {
        for(T t:objects){
            insert(t);
        }
    }

© 著作权归作者所有

共有 人打赏支持
jackLicy

jackLicy

粉丝 0
博文 3
码字总数 3592
作品 0
朝阳
Nosql数据库教程之初探MongoDB - 第一部分

日期:2012/01/16 来源:GBin1.com 大家都听说过nosql解决方案吧?现在是web开发中很流行的技术。 是不是也有听说过MongoDB? 你是不是准备好了来学习一下web开发中最酷的技术之一MongoDB? ...

gbin1
2012/02/06
0
0
mongodb 3.2.5安装过程详细记录

2016-10-19 mongodb 3.2.5安装 1 准备安装介质 安装介质下载: mongodb的安装方式,我通常使用二进制包的方式,内网不能配置连接外网的yum源; 官方建议的mongodb下载地址为: Downloads.mo...

yumushui991
06/26
0
0
MongoDB 4.0 正式发布,支持多文档事务

MongoDB 4.0 已正式发布,MongoDB 是一个开源文档数据库,提供高性能、高可用性和自动扩展。 下载地址:MongoDB Download Center 在 4.0 正式发布之前,我们已经报道了其相关更新信息,此次正...

h4cd
06/29
0
27
MongoDB 基本操作与MongoDB for JAVA

一、准备工作 1、 下载mongoDB 下载地址:http://www.mongodb.org/downloads 选择合适你的版本 相关文档:http://www.mongodb.org/display/DOCS/Tutorial 2、 安装mongoDB A、 不解压模式: ...

IT_小翼
2013/08/07
0
1
阿里专家视频课限时抢!精讲+实操12节课学懂MongoDB数据库!

想要学习MongoDB却不知道如何入门? 漫天的培训课程却无一讲解实战案例? 云栖社区联手阿里云大学独家出品—— 阿里云MongoDB技术负责人、MongoDB中文社区联席主席联合操刀 12期精讲+实操,全...

a独家记忆
07/12
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

Nginx防盗链、访问控制、Nginx解析PHP相关配置、Nginx代理

Nginx防盗链 在配置文件里写入以下内容: 用curl测试 访问控制 Nginx限制某些IP不能访问或者只允许某些IP访问。 配置文件写入如下内容: allow 表示允许访问的IP,deny限制访问的IP。 匹配正...

黄昏残影
14分钟前
0
0
自己动手实现RPC服务调用框架

转载 TCP的RPC 引言 本文利用java自带的socket编程实现了一个简单的rpc调用框架,由两个工程组成分别名为battercake-provider(服务提供者)、battercake-consumer(服务调用者)。 设计思路...

雨中漫步的鱼
17分钟前
0
0
Centos6.x安装之后的9件事

Centos6.x安装之后的9件事 这些不是必须都做的,只不过是我个人的习惯,在此记录一下。 1.修改yum源到国内 CentOS系统更换软件安装源 备份你的原镜像文件,以免出错后可以恢复。 mv /etc/yu...

叶云轩
22分钟前
5
0
springboot2 使用jsp NoHandlerFoundException

开发图片上传功能,为验证测试功能是否正常,使用JSP编写表单提交进行测试 开发完成后,请求API提示如下异常: No mapping found for HTTP request with URI [/WEB-INF/jsp/avatar_upload.j...

showlike
28分钟前
0
0
springboot踩坑记--springboot正常启动但访问404

一 spring boot的启动类不能直接放在main(src.java.main)这个包下面,把它放在有包的里面就可以了。 二 正常启动了,但是我写了一个controller ,用的@RestController 注解去配置的controlle...

onedotdot
29分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部