mongodb对数组元素及内嵌文档进行增删改查操作(转)

760176104

<!-- lang: java -->　　/**
　　*
　　* @author zhangdonghao
　　*
　　*/
　　@Component("UserrTagServiceImpl")

　　public>　　/**
　　* Mongo DB Spring Template
　　*/
　　@Resource
　　protected MongoTemplate mongoTemplate = null;
　　public UserrTagServiceImpl() {
　　}
　　/**
　　**给tags数组添加一个元素
　　*/
　　@Override

　　public Response<Integer> addTag(String>　　try {
　　Tag tag = new Tag(tagId);
　　tag.setOptDate(new Date());
　　tag.setEnable(true);
　　Query query = Query.query(Criteria.where("_id").is(id));
　　Update update = new Update();
　　update.addToSet("tags", tag);
　　mongoTemplate.upsert(query, update, User.class);
　　} catch (Exception e) {
　　return new Response<Integer>(0);
　　}
　　return new Response<Integer>(1);
　　}
　　/**
　　**修改tags数组中内嵌文档指定一个元素的值
　　*/
　　@Override

　　public Response<Integer> disableTag(String>　　try {
　　Query query = Query.query(Criteria.where("_id").is(id)
　　.and("tags.tagId").is(tagId));
　　Update update = new Update();
　　update.set("tags.$.enable", false);
　　mongoTemplate.updateFirst(query, update, User.class);
　　} catch (Exception e) {
　　return new Response<Integer>(0);
　　}
　　return new Response<Integer>(1);
　　}
　　/**
　　**删除tags数组中指定的内嵌文档
　　*/
　　@Override

　　public Response<Integer> removeTag(String>　　try {
　　Query query = Query.query(Criteria.where("_id").is(id)
　　.and("tags.tagId").is(tagId));
　　Update update = new Update();
　　update.unset("tags.$");
　　mongoTemplate.updateFirst(query, update, User.class);
　　} catch (Exception e) {
　　return new Response<Integer>(0);
　　}
　　return new Response<Integer>(1);
　　}
　　public MongoTemplate getMongoTemplate() {
　　return mongoTemplate;
　　}
　　public void setMongoTemplate(MongoTemplate mongoTemplate) {
　　this.mongoTemplate = mongoTemplate;
　　}
　　}