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;
//查询所有数据
publicListfindAll(Classentity){
returnmongoTemplate.findAll(entity);
}
//更新数据
publicCompanyfindOne(Stringid,Classentity){
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{
publicListfindAll(Classentity);
publicCompanyfindOne(Stringid,Classentity);
publicvoidupdateEntity(Companycompany);
publicvoiddelete(Stringid,Classclass1);
publicvoidinsert(Companycompany);
}
总结：与关系型数据库的连接一样，没有什么区别。
感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！