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

/**
   * 公共方法：设置object类型缓存
   * @author shijing
   * @param param
   * @param sysguid
   */
  public void setobjdata(map<string,object> param, string sysguid, string enumbpd){
  dbobject dbobject = new basicdbobject();
  dbobject.putall(param);
  string collectionname = enumbpd.getbpdtype(enumbpd) + sysguid;
  mongodao.inserttocol(dbobject,collectionname);
  }
  /**
   * 公共方法：设置list缓存
   * @author shijing
   * @param paramlist
   * @param sysguid
   */
  public void setlistdata(list<map<string,object>> paramlist, string sysguid, string enumbpd){
  list<dbobject> list = new arraylist<>();
  if(collectionutils.isnotnull(paramlist)){
    for (map<string,object> param : paramlist){
    dbobject dbobject = new basicdbobject();
    dbobject.putall(param);
    list.add(dbobject);
    }
  }
  string collectionname = enumbpd.getbpdtype(enumbpd) + sysguid;
  mongodao.inserttocol(list,collectionname);

public void inserttocol(dbobject document, string collectionname) {
  dropcol(collectionname);
  dbcollection dbcollection = mongotemplate.createcollection(collectionname);
  dbcollection.insert(document);
  }
  public void inserttocol(list<dbobject> documents, string collectionname) {
  dropcol(collectionname);
  dbcollection dbcollection = mongotemplate.createcollection(collectionname);
  dbcollection.insert(documents);
  }

/**
   * 通过关键字模糊查询问题和答案库
   * @param param
   * @return
   */
  @override
  public list<map<string, object>> searchquestionandanswerbykeyword(map<string, object> param) {
  list<map<string,object>> searchlist = new arraylist<>();
  map<string,object> userinfo = sessionutils.getuserinfo();
  string sysguid = userinfo.get("sys_guid").tostring();
  string collectionname = enumbpd.getbpdtype(enumbpd.help_page_list.gettype())+sysguid;
  //注释里面这种方式虽然能模糊查询，但是容易漏掉数据，切记切记！！！
  //pattern pattern = pattern.compile("^.*" + param.get("keyword") +".*$", pattern.case_insensitive);
  basicdbobject query= new basicdbobject();
  //模糊查询的字段设置
  query.put("page_html", pattern.compile((string) param.get("keyword")));
  dbcursor dbcursor = mongodao.findall(query,collectionname);
  list<dbobject> list = dbcursor.toarray();
  for (dbobject dbobject: list){
    searchlist.add(dbobject.tomap());
  }
  //模糊查到的数据进行组装
  return getquestionandanswerlist(searchlist);
  }
  /**
   * 公共方法：批量—— in方法查询list数据
   * @author shijing
   * @param ids id集合
   * @param parammap 其他参数
   * @param columnname in字段列名
   * @param collectionname 表名
   * @return
   */
  @override
  public list<map<string, object>> batchsearchpagelistbyids(list<string> ids, map<string,
    object> parammap, string columnname, string collectionname) {
  list<map<string,object>> searchlist = new arraylist<>();
  basicdbobject query= new basicdbobject();
  //批量查询，in
  if (collectionutils.isnotempty(ids)){
    basicdblist values = new basicdblist();
    values.addall(ids);
    query.put(columnname, new basicdbobject("$in",values));
  }
  //拼接参数
  if(maputils.isnotempty(parammap)){
    for (string mapkey: parammap.keyset()){
    query.put(mapkey, parammap.get(mapkey));
    }
  }
  dbcursor dbcursor = mongodao.findall(query,collectionname);
  list<dbobject> list = dbcursor.toarray();
  if (dbcursor!=null && dbcursor.size()>0){
    for (dbobject dbobject: list){
    searchlist.add(dbobject.tomap());
    }
  }
  return searchlist;
  }
  /**
   * 公共方法：通过参数获取list数据
   * @author shijing
   * @param parammap 参数
   * @param collectionname  表名
   * @return
   */
  @override
  public list<map<string, object>> getlistbyparam(map<string, object> parammap,string collectionname){
  list<map<string,object>> searchlist = new arraylist<>();
  basicdbobject query= new basicdbobject();
  //拼接参数
  if(maputils.isnotempty(parammap)){
    for (string mapkey: parammap.keyset()){
    query.put(mapkey, parammap.get(mapkey));
    }
  }
  dbcursor dbcursor = mongodao.findall(query,collectionname);
  list<dbobject> list = dbcursor.toarray();
  if (dbcursor!=null && dbcursor.size()>0){
    for (dbobject dbobject: list){
    searchlist.add(dbobject.tomap());
    }
  }
  return searchlist;
  }
  /**
   * 公共方法：通过参数获取object数据
   * @author shijing
   * @param parammap
   * @param collectionname 表名
   * @return
   */
  @override
  public map<string, object> getobjectbyparam(map<string, object> parammap, string collectionname) {
  map<string,object> websiteinfo = new hashmap<>();
  basicdbobject query= new basicdbobject();
  //拼接参数
  if(maputils.isnotempty(parammap)){
    for (string mapkey: parammap.keyset()){
    query.put(mapkey, parammap.get(mapkey));
    }
  }
  dbobject dbobject = mongodao.findone(query,collectionname);
  if(dbobject!=null){
    return dbobject.tomap();
  }
  return websiteinfo;
  }

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

query.put("page_html", pattern.compile((string) param.get("keyword")));