java连接mongodb进行增删改查的操作
1.创建数据库的连接,进行增删改查
(分别为接口和实现类)
package com.dao; import java.util.list; import org.springframework.beans.factory.annotation.autowired; 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.stereotype.repository; import com.bean.company; @repository public class repositoryimpl implements abstractrepository { @autowired private mongotemplate mongotemplate; // 查询所有数据 public list<?> findall(class<?> entity) { return mongotemplate.findall(entity); } // 更新数据 public company findone(string id, class<?> entity) { return (company) mongotemplate.findone(new query(criteria.where("id") .is(id)), entity); } // 添加到数据库 public void updateentity(company company) { mongotemplate.save(company); } // 删除选中的数据 public void delete(string id, class<company> class1) { criteria criteria = criteria.where("id").in(id); if (criteria != null) { query query = new query(criteria); if (query != null && mongotemplate.findone(query, class1) != null) mongotemplate.remove(mongotemplate.findone(query, class1)); } } //增加到数据库 public void insert(company company) { mongotemplate.insert(company); } }
package com.dao; import java.util.list; import com.bean.company; public interface abstractrepository { public list<?> findall(class<?> entity); public company findone(string id,class<?> entity); public void updateentity(company company); public void delete(string id, class<company> class1); public void insert(company company); }
总结:与关系型数据库的连接一样,没有什么区别。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
如对本文有疑问, 点击进行留言回复!!
网友评论