国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > MongoDB > 正文

詳解MongoDB數據庫基礎操作及實例

2020-10-29 18:45:13
字體:
來源:轉載
供稿:網友

詳解數據庫基礎操作及實例

          廢話不多說,直接上代碼,注釋寫的比較清楚,大家參考下,

 示例代碼:

/**  * 插入一條DB對象  */ public static void addDBObject(DBCollection collection,BasicDBObject object){   collection.insert(object); }  /**  * 根據id查詢DBObject  */ public static DBObject getDBObjectById(String value) throws UnknownHostException, MongoException{   dbc = getDBCollection("company", "users").find(new BasicDBObject("_id",new ObjectId(value)));   DBObject ob = null;   int i = 0;   while(dbc.hasNext()){     ob = dbc.next();     i++;   }   if(i == 1){     return ob;   }else{     return null;   } }  /**  * 根據key和value值查詢  */ public static DBObject getDBObject(String key,String value) throws UnknownHostException, MongoException{   dbc = getDBCollection("company", "users").find(new BasicDBObject(key,value));   DBObject ob = null;   int i = 0;   while(dbc.hasNext()){     ob = dbc.next();     i++;   }   if(i == 1){     return ob;   }else{     return null;   } }  /**  * 根據數據庫名獲取(新增)下面所有聚集名(表名)  */ public static Set<String> getCollectionsNames(String DBName) throws MongoException, UnknownHostException{   return getDB(DBName).getCollectionNames(); }  /**  * 遍歷聚集中的db對象集合(相當于關系數據庫中的數據)  */ public static Set<DBObject> getDBObjects(DBCollection collection){   Set<DBObject> dbObjects = new HashSet<DBObject>();   DBCursor cursor = collection.find();   while(cursor.hasNext()){     DBObject object = cursor.next();     dbObjects.add(object);   }   return dbObjects; }  /**  * 獲取/新增聚集(相當于關系數據庫表)  */ public static DBCollection getDBCollection(String DBName,String collectionName) throws UnknownHostException, MongoException{   return getDB(DBName).getCollection(collectionName); }  /**  * 獲取/新增數據庫  */ public static DB getDB(String DBName) throws UnknownHostException, MongoException{   return getMongo().getDB(DBName); }  /**  * 連接數據庫  */ public static Mongo getMongo() throws UnknownHostException, MongoException{   Mongo mg = null;   if(mg == null){     mg = new Mongo();   }   return mg; }  /**  * 關閉連接  */ public static void destory(Mongo mg) {   if (mg != null){     mg.close();     mg = null;    }   System.gc();   }  /**  * 獲取數據庫名  */ public static List<String> getDBNames() throws MongoException, UnknownHostException{   return getMongo().getDatabaseNames(); }  /**  * 刪除數據庫  */ public static void deleteDB(String DBName) throws MongoException, UnknownHostException{   getMongo().dropDatabase(DBName); } 

如有疑問請留言或者到本站社區交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對本站的支持!

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 建宁县| 抚州市| 根河市| 凤山县| 吴旗县| 南京市| 荃湾区| 淮滨县| 特克斯县| 仙游县| 洛浦县| 木兰县| 禄丰县| 阜新市| 内黄县| 云梦县| 揭阳市| 江永县| 曲阳县| 太湖县| 柳河县| 重庆市| 汤阴县| 读书| 建瓯市| 花莲市| 新干县| 田阳县| 扶风县| 忻州市| 南江县| 三亚市| 台山市| 惠水县| 仁怀市| 汉川市| 北票市| 新蔡县| 汉阴县| 苏州市| 扶余县|