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);
}
总结:与关系型数据库的连接一样,没有什么区别。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
热门推荐
10 八一幼儿祝福语大全简短
11 公司乔迁食堂祝福语简短
12 婚礼结束聚餐祝福语简短
13 儿媳买车妈妈祝福语简短
14 毕业送礼老师祝福语简短
15 同事辞职正常祝福语简短
16 恭贺新婚文案祝福语简短
17 金店立秋祝福语简短英文
18 婆婆高寿祝福语大全简短