国产探花免费观看_亚洲丰满少妇自慰呻吟_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); } 

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 广平县| 仙游县| 黄大仙区| 南江县| 宜阳县| 宁津县| 乌兰察布市| 兴宁市| 嵊州市| 通化市| 天门市| 平罗县| 娄烦县| 枝江市| 北碚区| 邻水| 民权县| 莱州市| 襄垣县| 镇赉县| 盐源县| 五河县| 普格县| 大丰市| 武川县| 陆丰市| 宾川县| 崇仁县| 宣武区| 古田县| 镇坪县| 龙江县| 井研县| 隆德县| 新丰县| 咸宁市| 中卫市| 乐安县| 武穴市| 江永县| 金平|