MongDB之各种修改操作

xiaoxiao2021-02-28  8

接口IMongDaoUpdate:

package com.net.test.mongdb.dao; import com.net.test.mongdb.entity.User; public interface IMongDaoUpdate { public void updateUser(User user); public void updateUserHobby(User user); public void updateUserHobbyDiffer(User user); public void updateUserUserPsg(User user); public void deleteUserUserPsg(String name,String field); }

实现类:

package com.net.test.mongdb.dao.imp; import javax.annotation.Resource; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; import org.springframework.stereotype.Repository; import com.net.test.mongdb.dao.IMongDaoUpdate; import com.net.test.mongdb.entity.User; /** * @author *** * @Time:2017年8月4日 下午1:50:16 * @version 1.0 * Function: TODO */ @Repository public class MongDaoUpdateImp implements IMongDaoUpdate { @Resource protected MongoTemplate mongoTemplate; /** * @description 单条更新user信息 * @param user */ @Override public void updateUser(User user) { Query query = Query.query(Criteria.where("name").is(user.getName())); Update up = new Update(); up.set("sex", user.getSex()).inc("age", user.getAge()).set("hobby", user.getHobby()); mongoTemplate.updateFirst(query, up, User.class); } /** * @description 单独对user信息的某个特定数组字段继续追加数据,不管是否重复 * @param user */ @Override public void updateUserHobby(User user) { Query query = Query.query(Criteria.where("name").is(user.getName())); Update up = new Update(); String[] str = new String[user.getHobby().size()]; for(int i = 0 ; i < user.getHobby().size();i++) { str[i] = user.getHobby().get(i).toString(); } up.pushAll("hobby", str); mongoTemplate.updateFirst(query, up, User.class); } /** * @description 一次性追加多个不重复的数组元素 * @param user */ @Override public void updateUserHobbyDiffer(User user) { Query query = Query.query(Criteria.where("name").is(user.getName())); Update up = new Update(); Object[] str = new Object[user.getHobby().size()]; for(int i = 0 ; i < user.getHobby().size();i++) { str[i] = user.getHobby().get(i).toString(); } up.addToSet("hobby").each(str); mongoTemplate.updateFirst(query, up, User.class); } /** * @description 更新内置对象 * @param user */ @Override public void updateUserUserPsg(User user) { Query query = Query.query(Criteria.where("name").is(user.getName())); Update update = new Update(); update.set("psg.address", user.getPsg().getAddress()); update.set("psg.phone", user.getPsg().getPhone()); update.set("psg.county", "江苏"); mongoTemplate.updateFirst(query, update, User.class); } /** * @description 删除内置对象的某个字段 * @param name * @param field */ @Override public void deleteUserUserPsg(String name, String field) { Query query = Query.query(Criteria.where("name").is(name)); Update update = new Update(); update.unset("psg.county"); mongoTemplate.updateFirst(query, update, User.class); } }
转载请注明原文地址: https://www.6miu.com/read-850242.html

最新回复(0)