Java操作MongoDB插入数据进行模糊查询与in查询功能

2023-09-04 18:10:07 79

由于需要用MongoDB缓存数据，所以自己写了一套公共的存放和读取方法

具体如下：

存放mongodb：

/**
*公共方法：设置Object类型缓存
*@authorshijing
*@paramparam
*@paramsysGuid
*/
publicvoidsetObjData(Mapparam,StringsysGuid,StringenumBpd){
DBObjectdbObject=newBasicDBObject();
dbObject.putAll(param);
StringcollectionName=EnumBpd.getBpdType(enumBpd)+sysGuid;
mongoDao.insertToCol(dbObject,collectionName);
}
/**
*公共方法：设置List缓存
*@authorshijing
*@paramparamList
*@paramsysGuid
*/
publicvoidsetListData(List>paramList,StringsysGuid,StringenumBpd){
Listlist=newArrayList<>();
if(CollectionUtils.isNotNull(paramList)){
for(Mapparam:paramList){
DBObjectdbObject=newBasicDBObject();
dbObject.putAll(param);
list.add(dbObject);
}
}
StringcollectionName=EnumBpd.getBpdType(enumBpd)+sysGuid;
mongoDao.insertToCol(list,collectionName);

mongoDao里面的方法：

publicvoidinsertToCol(DBObjectdocument,StringcollectionName){
dropCol(collectionName);
DBCollectiondbCollection=mongoTemplate.createCollection(collectionName);
dbCollection.insert(document);
}
publicvoidinsertToCol(Listdocuments,StringcollectionName){
dropCol(collectionName);
DBCollectiondbCollection=mongoTemplate.createCollection(collectionName);
dbCollection.insert(documents);
}

读取方法

/**
*通过关键字模糊查询问题和答案库
*@paramparam
*@return
*/
@Override
publicList>searchQuestionAndAnswerByKeyword(Mapparam){
List>searchList=newArrayList<>();
MapuserInfo=SessionUtils.getUserInfo();
StringsysGuid=userInfo.get("sys_guid").toString();
StringcollectionName=EnumBpd.getBpdType(EnumBpd.HELP_PAGE_LIST.getType())+sysGuid;
//注释里面这种方式虽然能模糊查询，但是容易漏掉数据，切记切记！！！
//Patternpattern=Pattern.compile("^.*"+param.get("keyword")+".*$",Pattern.CASE_INSENSITIVE);
BasicDBObjectquery=newBasicDBObject();
//模糊查询的字段设置
query.put("page_html",Pattern.compile((String)param.get("keyword")));
DBCursordbCursor=mongoDao.findAll(query,collectionName);
Listlist=dbCursor.toArray();
for(DBObjectdbObject:list){
searchList.add(dbObject.toMap());
}
//模糊查到的数据进行组装
returngetQuestionAndAnswerList(searchList);
}
/**
*公共方法：批量——in方法查询List数据
*@authorshijing
*@paramidsid集合
*@paramparamMap其他参数
*@paramcolumnNamein字段列名
*@paramcollectionName表名
*@return
*/
@Override
publicList>batchSearchPageListByIds(Listids,MapparamMap,StringcolumnName,StringcollectionName){
List>searchList=newArrayList<>();
BasicDBObjectquery=newBasicDBObject();
//批量查询，in
if(CollectionUtils.isNotEmpty(ids)){
BasicDBListvalues=newBasicDBList();
values.addAll(ids);
query.put(columnName,newBasicDBObject("$in",values));
}
//拼接参数
if(MapUtils.isNotEmpty(paramMap)){
for(StringmapKey:paramMap.keySet()){
query.put(mapKey,paramMap.get(mapKey));
}
}
DBCursordbCursor=mongoDao.findAll(query,collectionName);
Listlist=dbCursor.toArray();
if(dbCursor!=null&&dbCursor.size()>0){
for(DBObjectdbObject:list){
searchList.add(dbObject.toMap());
}
}
returnsearchList;
}
/**
*公共方法：通过参数获取List数据
*@authorshijing
*@paramparamMap参数
*@paramcollectionName表名
*@return
*/
@Override
publicList>getListByParam(MapparamMap,StringcollectionName){
List>searchList=newArrayList<>();
BasicDBObjectquery=newBasicDBObject();
//拼接参数
if(MapUtils.isNotEmpty(paramMap)){
for(StringmapKey:paramMap.keySet()){
query.put(mapKey,paramMap.get(mapKey));
}
}
DBCursordbCursor=mongoDao.findAll(query,collectionName);
Listlist=dbCursor.toArray();
if(dbCursor!=null&&dbCursor.size()>0){
for(DBObjectdbObject:list){
searchList.add(dbObject.toMap());
}
}
returnsearchList;
}
/**
*公共方法：通过参数获取Object数据
*@authorshijing
*@paramparamMap
*@paramcollectionName表名
*@return
*/
@Override
publicMapgetObjectByParam(MapparamMap,StringcollectionName){
MapwebSiteInfo=newHashMap<>();
BasicDBObjectquery=newBasicDBObject();
//拼接参数
if(MapUtils.isNotEmpty(paramMap)){
for(StringmapKey:paramMap.keySet()){
query.put(mapKey,paramMap.get(mapKey));
}
}
DBObjectdbObject=mongoDao.findOne(query,collectionName);
if(dbObject!=null){
returndbObject.toMap();
}
returnwebSiteInfo;
}

注意事项：

mongodb模糊查询时

Patternpattern=Pattern.compile("^.*"+param.get("keyword")+".*$"

这种方式存在bug，容易漏掉数据

应该使用下面这种方式：

query.put("page_html",Pattern.compile((String)param.get("keyword")));

先记录到这吧，有需要在补充，批量in方法也在上述代码里面。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对毛票票的支持。如果你想了解更多相关内容请查看下面相关链接

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

Java操作MongoDB插入数据进行模糊查询与in查询功能

热门推荐

随机推荐