Mongodb使用总结

Mongodb使用总结

• 基于内存操作，便于与网站交互
  
• 数据库-集合-文档（存储多种数据类型），我们的操作都是基于单文档进行操作，并且通过冗余字段进行操作
  
• 嵌入式数组文档减少了对昂贵连接的需求
  
  
  
  • DoucmentArray:[子文档（动态）]
    
  
  

操作

都是基于文档操作

1. @Document("wf_process")
2. @Data
3. @NoArgsConstructor
4. @FieldNameConstants
5. public class ProcessDefinition implements SynchronizerSign {
6.     /**
7.      * 流程ID
8.      */
9.     @Id  //与数据库_id映射，@Document("wf_process")
10.     @Indexed(unique = true)索引3
11.     @JsonSerialize(using = ToStringSerializer.class) 精度丢失
12.     private Long procId;

复制代码

文档

1. //增加文档
2. ProcessDefinition resProcess = mongoTemplate.insert(wfProcess);
4. //改
5. Query query = new Query();
6. Update update = new Update();
7. Criteria criteriaOne = Criteria.where(ProcessDefinition.Fields.procId).is(processVo.getProcId());//找到文档
8. update.set(ProcessDefinition.Fields.procName, procName);//修改的属性
9. mongoTemplate.updateMulti(query,update,ProcessDefinition.class);//批量修改
11. //查询
12. ProcessDefinition wfProcess = mongoTemplate.findOne(query, ProcessDefinition.class);//find查询满足条件的文档集合
14. //删除 逻辑删除 update     物理删除        remove
15. //query.fields进行字段过滤

复制代码

文档数组

1. Query query = new Query();
2. Update update = new Update();
3.             query.addCriteria(Criteria.where(ProcessDefinition.Fields.procId).is(pub.getProcId()));//找到文档
5. //添加元素到数组  addToSet去重
6. update.addToSet(ProcessDefinition.Fields.flowNodes,pub);
7.              mongoTemplate.upsert(query,update,ProcessDefinition.class);//upsert 找不到文档时会自动创建文档
8. //不去重效率高
9. update.push("likes").each(objects);
11. //更新数组元素
12. Criteria.where(ProcessDefinition.Fields.flowNodes).
13.                  elemMatch(Criteria.where(PublicFlowNode.Fields.nodeId).is(pub.getNodeId())));//elemMatch找到数组元素  flowNodes.nodeID = nodeID
14. update.set("flowNodes.$",pub);//$获取到的元素
16.         query.addCriteria(Criteria.where(ProcessInstanceData.Fields.dataId)
17.                 .is(dataId)
18.                 .and("instanceData.flowNodeId")
19.                 .is(deleteId));
23.                 mongoTemplate.updateFirst(query,update,ProcessDefinition.class);
25. //更新数组元素某个属性
26. update.set("flowNodes.$.nextId", nodeId);
29. //获取数组中的元素
30. query.fields().elemMatch(ProcessInstanceData.Fields.instanceData,
31.                 Criteria.where(InstanceData.Fields.flowNodeId).
32.                         is(nodeId));//fields()过滤字段
33.         ProcessInstanceData processInstanceData = mongoTemplate.findOne(query, ProcessInstanceData.class);
34. List<InstanceData> instanceDatas = processInstanceData.getInstanceData();
35. instanceDatas.get(0);
37. //获取数组中的指定几个元素
38. //封装对象列表查询条件
39.         List<AggregationOperation> commonOperations = new ArrayList<>();
40.         //1. 指定查询主文档
41.         MatchOperation match = Aggregation.match(Criteria.where(ProcessInstanceData.Fields.dataId).
42.                 is(dataId));
43.         commonOperations.add(match);
44.         //2. 指定投影，返回哪些字段
45.         ProjectionOperation project = Aggregation.project(ProcessInstanceData.Fields.instanceData);
46.         commonOperations.add(project);
47.         //3. 拆分内嵌文档,  可以查询需要的记录
48.         UnwindOperation unwind = Aggregation.unwind(ProcessInstanceData.Fields.instanceData);
49.         commonOperations.add(unwind);
50.         //4. 指定查询  指定几个数组元素
51.         MatchOperation match2 = Aggregation.match(
52.                 Criteria.where("instanceData.flowNodeId").in(nodeIds));
53.         commonOperations.add(match2);
55.         //5.创建管道查询对象
56.         Aggregation aggregation = Aggregation.newAggregation(commonOperations);
57.         AggregationResults<JSONObject> aggregate = mongoTemplate
58.                 .aggregate(aggregation, ProcessInstanceData.class, JSONObject.class);
59. //删除数组元素
60. instanceData = 删除的对象
61. update.pull(ProcessInstanceData.Fields.instanceData,instanceData);

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！