Java连接MongoDB进行增删改查的操作
Java连接MongoDB进行增删改查的操作
1.创建数据库的连接,进行增删改查
(分别为接口和实现类)
packagecom.dao; importjava.util.List; importorg.springframework.beans.factory.annotation.Autowired; importorg.springframework.data.mongodb.core.MongoTemplate; importorg.springframework.data.mongodb.core.query.Criteria; importorg.springframework.data.mongodb.core.query.Query; importorg.springframework.stereotype.Repository; importcom.bean.Company; @Repository publicclassRepositoryImplimplementsAbstractRepository{ @Autowired privateMongoTemplatemongoTemplate; //查询所有数据 publicList>findAll(Class>entity){ returnmongoTemplate.findAll(entity); } //更新数据 publicCompanyfindOne(Stringid,Class>entity){ return(Company)mongoTemplate.findOne(newQuery(Criteria.where("id") .is(id)),entity); } //添加到数据库 publicvoidupdateEntity(Companycompany){ mongoTemplate.save(company); } //删除选中的数据 publicvoiddelete(Stringid,Classclass1){ Criteriacriteria=Criteria.where("id").in(id); if(criteria!=null){ Queryquery=newQuery(criteria); if(query!=null&&mongoTemplate.findOne(query,class1)!=null) mongoTemplate.remove(mongoTemplate.findOne(query,class1)); } } //增加到数据库 publicvoidinsert(Companycompany){ mongoTemplate.insert(company); } }
packagecom.dao; importjava.util.List; importcom.bean.Company; publicinterfaceAbstractRepository{ publicList>findAll(Class>entity); publicCompanyfindOne(Stringid,Class>entity); publicvoidupdateEntity(Companycompany); publicvoiddelete(Stringid,Classclass1); publicvoidinsert(Companycompany); }
总结:与关系型数据库的连接一样,没有什么区别。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!