NoSQL------MongoDB之JAVA操作内嵌文档增删改查

• 有些业务需求就需要非关系型数据库来实现，特别是用到了内嵌文档，暑假的时候就已经写了但是不知道被自己误删还是别人删掉了一大段代码，心疼自己，特此来记录一下。

　　　

• 连接数据库

• //连接到mangodb服务
      static MongoClient mongoClient = new MongoClient("127.0.0.1",27017);    //ip和端口号
      public static DB getConn() {
          try{        
              //连接数据库
              DB mongoDatabase = mongoClient.getDB("xxxxx");//数据库名
              System.out.println("Connet to database successfully");
              return mongoDatabase;             
          }catch(Exception e){
              System.err.println( e.getClass().getName() + ": " + e.getMessage());
              return null;
          }
      }
      //关闭连接
      public static void close() {
          if (mongoClient != null) {
              mongoClient.close();
              mongoClient = null;
          }
      }

• 增加一条记录（包括内嵌文档）

  public static void CreateGridByUuid(int uuid) {
          DB conn=MongoDB.getConn();
          DBCollection collection = conn.getCollection("test");
          try {            
              BasicDBObject[] addrAttrs = new BasicDBObject[10];
              for(int i=0;i<10;i++){
                  BasicDBObject addrAttr = new BasicDBObject();
                  addrAttr.put("index",i+1);
                  addrAttr.put("goods_id", 0);
                  addrAttr.put("count", 0);
                  addrAttrs[i] = addrAttr;
              }
              
              BasicDBObject doc1 = new BasicDBObject ();
              doc1.put("uuid", uuid);
              doc1.put("grid",addrAttrs);
              collection.insert(doc1);//插入记录
              
              System.out.println("Document inserted successfully"); 
          } catch (Exception e) {
              e.printStackTrace();
          } 
      }

• 在内嵌集合中添加一条记录

  //单个格子创建
      public static void AddGridByUuid(int uuid,int count) {
          DB conn=MongoDB.getConn();
          DBCollection collection = conn.getCollection("test");        
          try {            
              BasicDBObject query = new BasicDBObject();
              BasicDBObject field = new BasicDBObject();
              query.put("uuid",uuid);
              field.put("grid", 1);   
              DBCursor cursor = collection.find(query,field);             
              while(cursor.hasNext()){                    
                  BasicDBObject result = (BasicDBObject) cursor.next();
                  ArrayList<BasicDBObject> versi=(ArrayList<BasicDBObject>)result.get("grid"); 
                  BasicDBObject addgrid=new BasicDBObject();
                  addgrid.put("index", count+1);
                  addgrid.put("goods_id", 0);
                  addgrid.put("count", 0);
                  versi.add(addgrid);
                  
                  BasicDBObject doc = new BasicDBObject();
                  BasicDBObject res = new BasicDBObject();                 
                  res.put("grid", versi);                
                  doc.put("$set", res);  
                  collection.update(query,doc,false,true);
              }
          }catch (Exception e) {
              e.printStackTrace();
          }
      }

• 查

  public static ArrayList<Grid> SelectGridByUuid(int uuid) {
          DB conn=MongoDB.getConn();
          DBCollection collection = conn.getCollection("test");
          ArrayList<Grid> gridlist = new ArrayList<Grid>();
          
          try {            
              BasicDBObject query = new BasicDBObject();
              BasicDBObject field = new BasicDBObject();
              query.put("uuid",uuid);//查询条件
              field.put("grid", 1);   
              DBCursor cursor = collection.find(query,field);
               
              while(cursor.hasNext()){                    
                  BasicDBObject result = (BasicDBObject) cursor.next();
                  ArrayList<BasicDBObject> versi=(ArrayList<BasicDBObject>)result.get("grid"); 
                  result.entrySet();
                  for(BasicDBObject embedded:versi){  
                      Grid grid = new Grid();                    
                      grid.setIndex(embedded.getInt("index"));
                      grid.setGoods_id(embedded.getInt("goods_id"));
                      grid.setCount(embedded.getInt("count"));
                      gridlist.add(grid);
                  }           
              }
             
          }catch (Exception e) {
              e.printStackTrace();
          }
          return gridlist;
      }

• 修改内嵌文档中的某字段

  public static void UpdateGridAndCountByIndexAndUuid(int index, int goodsId, int count, int uuid) {
          DB conn=MongoDB.getConn();
          DBCollection collection = conn.getCollection("test");
          try {
              BasicDBObject query = new BasicDBObject();
              query.put("uuid", uuid);
              query.put("grid.index", index);
              BasicDBObject doc = new BasicDBObject();  
              BasicDBObject res = new BasicDBObject();  
              int pos=index-1;
              res.put("grid."+pos+".goods_id", goodsId);
              res.put("grid."+pos+".count", count);  
              doc.put("$set", res);  
              collection.update(query,doc,false,true);  
              System.out.println("更新数据完成！");  
              logger.debug("已将物品"+goodsId+"放入到第"+index+"格中");
              
          } catch (Exception e) {
              e.printStackTrace();
          } 
      }

• Grid类

  public class Grid {
      private int uuid;
      private int index;
      private int goods_id;
      private int count;
      public int getUuid() {
          return uuid;
      }
      public void setUuid(int uuid) {
          this.uuid = uuid;
      }
      public int getIndex() {
          return index;
      }
      public void setIndex(int index) {
          this.index = index;
      }
      public int getGoods_id() {
          return goods_id;
      }
      public void setGoods_id(int goods_id) {
          this.goods_id = goods_id;
      }
      public int getCount() {
          return count;
      }
      public void setCount(int count) {
          this.count = count;
      }
      
  }