码迷，mamicode.com
首页 > 数据库 > 详细

MongoDB（online） 优化

时间：2018-05-14 17:37:32      阅读：221      评论：0      收藏：0      [点我收藏+]

标签：created   int   查询   condition   ids   line   isp   convert   obj   

MongoDB（online） 优化

1. find、findOne

  • 项目实例
MongoTemplate mongoTemplate = mongodbClient.getMongoTemplate();
DBCollection cursor = mongoTemplate.getCollection("vip_batchsend_message");
BasicDBObject query = new BasicDBObject();
query.put("sms_code", sms_code);
query.put("open_id", open_id);

JSONObject message = new JSONObject();

DBCursor cursor1 = cursor.find(query);
LOGGER.info("-------------sms_code:" + sms_code + "----open_id:" + open_id + "--" + cursor1.size());
if (cursor1.size() > 0) {
    DBObject dBObject = cursor1.next();
    String corp_code = dBObject.get("corp_code").toString();
    .....
  • 简单阐述
    1. 代码意图是如果记录存在就修改
    2. 只需要判断是否存在就完成目的
    3. find返回的是DBCursor，这里不合适，我们只需要知道是否存在即可
    4. 修改建议
      1. 固定的条件提前预先组合
      2. find改成findOne
      3. 判断只需要查询一条记录即可，用findOne就可以，直接获取一个Object，判断后即可根据Key获取Value进行后续操作
  • 建议修改
BasicDBObject query = new BasicDBObject();
query.put("sms_code", sms_code);
query.put("open_id", open_id);
MongoTemplate mongoTemplate = mongodbClient.getMongoTemplate();
JSONObject message = new JSONObject();
DBCollection cursor = mongoTemplate.getCollection("vip_batchsend_message");
DBObject dbObject = cursor.findOne(query);
if (dbObject.isPartialObject()) {
    LOGGER.info("-------------sms_code:" + sms_code + "----open_id:" + open_id + "--" + 1);
    String corp_code = dbObject.get("corp_code").toString();
    String vip_id = dbObject.get("vip_id").toString();
    Data data_corp_code = new Data("corp_code", corp_code, ValueType.PARAM);
    Data data_vip_id = new Data("vip_ids", vip_id, ValueType.PARAM);
    ......

2. 操作 vip_emp_relation 的一个公共方法

  • 项目实例
 public DBCursor selectRelation(String app_user_name, String open_id) throws SQLException {
        MongoTemplate mongoTemplate = mongodbClient.getMongoTemplate();
        DBCollection cursor = mongoTemplate.getCollection(WxConst.table_vip_emp_relation);

        Map keyMap = new HashMap();
        keyMap.put("_id", app_user_name + open_id);
        BasicDBObject queryCondition = new BasicDBObject();
        queryCondition.putAll(keyMap);
        DBCursor dbCursor = cursor.find(queryCondition);
        return dbCursor;
    }

  • 简单阐述

    1. 查看此方法的引用，基本是做判断使用，没必要返回一个Cursor
    2. 如果引用的方法，有长任务，然后再操作，就会等待很长时间不释放资源

  • 建议修改

     public DBObject selectRelation(String app_user_name, String open_id) throws SQLException {
    Map keyMap = new HashMap();
    keyMap.put("_id", app_user_name + open_id);
    BasicDBObject queryCondition = new BasicDBObject();
    queryCondition.putAll(keyMap);
    MongoTemplate mongoTemplate = mongodbClient.getMongoTemplate();
    DBCollection cursor = mongoTemplate.getCollection(WxConst.table_vip_emp_relation);
    DBObject dbCursor = cursor.findOne(queryCondition);
    return dbCursor;
}

3. 查询记录数

  • 项目实例
BasicDBObject basicDBObject=new BasicDBObject();
basicDBObject.put("activity_code",activity_code);
basicDBObject.put("open_id",open_id);
basicDBObject.put("status","1");
int count=cursor.find(basicDBObject).count();
basicDBObject.put("sign_status","Y");
int sign_count=cursor.find(basicDBObject).count();
if(sign_count>0){
    result="您已签到成功,请勿重复签到";
}else {
    if (count > 0) {
        BasicDBObject query=new BasicDBObject();
        query.put("activity_code",activity_code);
        query.put("open_id",open_id);
    ......

  • 简单阐述

    1. 根据条件获取记录数
    2. 没必要先获取文档游标再查询记录数

  • 建议修改

BasicDBObject basicDBObject=new BasicDBObject(); basicDBObject.put("activity_code",activity_code);
basicDBObject.put("open_id",open_id);
basicDBObject.put("status","1");
Long count=cursor.count(basicDBObject);
basicDBObject.put("sign_status","Y");
Long sign_count=cursor.count(basicDBObject);
if(sign_count>0){
    result="您已签到成功,请勿重复签到";
}else {
    if (count > 0) {
        BasicDBObject query=new BasicDBObject();
        query.put("activity_code",activity_code);
        query.put("open_id",open_id);
    ......

4. save、insert

  • 项目实例
if (cursor.find(basicDBObject).count() > 0){
    BasicDBObject basicDBObject1=new BasicDBObject();
    basicDBObject1.put("sign_status","Y");
    basicDBObject1.put("sign_date",Common.DATETIME_FORMAT.format(new Date()));
    BasicDBObject update=new BasicDBObject();
    update.put("$set",basicDBObject1);
    cursor.update(basicDBObj,update,true,false);
}else {
    BasicDBObject dbObject = new BasicDBObject();
    dbObject.put("_id", app_id + "_" + activity_code  + "_" + open_id);
    dbObject.put("corp_code", corp_code);
    dbObject.put("sign_status","Y");
    dbObject.put("sign_date",Common.DATETIME_FORMAT.format(new Date()));
    dbObject.put("app_id", app_id);
    dbObject.put("activity_code", activity_code);
    dbObject.put("status", "0");
    dbObject.put("open_id", open_id);
    dbObject.put("vip", vip_array.getJSONObject(0));
    dbObject.put("modified_date", Common.DATETIME_FORMAT.format(new Date()));
    dbObject.put("created_date", Common.DATETIME_FORMAT.format(new Date()));
    cursor.save(dbObject);
}
    ......

  • 简单阐述

    1. save 是先根据_id查询再修改，如果已经确认记录不存在可以省去查找的功能直接insert

  • 建议修改

if (cursor.find(basicDBObject).count() > 0){
    BasicDBObject basicDBObject1=new BasicDBObject();
    basicDBObject1.put("sign_status","Y");
    basicDBObject1.put("sign_date",Common.DATETIME_FORMAT.format(new Date()));
    BasicDBObject update=new BasicDBObject();
    update.put("$set",basicDBObject1);
    cursor.update(basicDBObj,update,true,false);
}else {
    BasicDBObject dbObject = new BasicDBObject();
    dbObject.put("_id", app_id + "_" + activity_code  + "_" + open_id);
    dbObject.put("corp_code", corp_code);
    dbObject.put("sign_status","Y");
    dbObject.put("sign_date",Common.DATETIME_FORMAT.format(new Date()));
    dbObject.put("app_id", app_id);
    dbObject.put("activity_code", activity_code);
    dbObject.put("status", "0");
    dbObject.put("open_id", open_id);
    dbObject.put("vip", vip_array.getJSONObject(0));
    dbObject.put("modified_date", Common.DATETIME_FORMAT.format(new Date()));
    dbObject.put("created_date", Common.DATETIME_FORMAT.format(new Date()));
    cursor.insert(dbObject);
}
    ......

5. 总结

  1. 以上是目前发现的问题及建议，会继续Review
  2. 涉及到IO的操作标配就是尽晚打开尽早释放
  3. 阿里的MongoDB默认没有启动读写分离（我已经测试确认过），我测试后会加上
  4. 业务实现过程，尽可能结构化数据，介绍拼接出错或Key不存在的异常
  5. 涉及到Cursor尽快手动关闭
  6. 其它项目也可以参考，或者抛出来

MongoDB（online） 优化

标签：created   int   查询   condition   ids   line   isp   convert   obj   

原文地址：https://www.cnblogs.com/lzh-boy/p/9037053.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！