香港马会开奖结果,六合彩资料 六开彩开奖现场直播 六合彩资料大全 地下六合彩 六合彩图库 六合彩图 香港六合彩网站 六合彩大全 香港六合彩图库 六合彩开 六合彩挂牌 香港六合彩挂牌 六合彩票 六合彩现场直播 六合彩玄机 香港六合彩公司 www.dq-ccg.com六合彩官网 香港六合彩特码 六合彩管家婆 六合彩走势图 六合彩结果 六合彩马报 香港六合彩现场直播 六合彩白小姐 白小姐六合彩 六合彩直播 六合彩特码资料 六合彩免费资料 六合彩曾道人 香港六合彩资料大全 六合彩开码结果 香港六合彩管家婆 六合彩综合资料 香港六合彩网址 六合彩彩图 香港六合彩图 六合彩信息 今晚六合彩开什么 六合彩开什么 六合彩图纸 香港六合彩特码资料 香港马会六合彩 六合彩图片 六合彩预测 香港六合彩网 香港六合彩直播 香港地下六合彩 香港六合彩官方网站 六合彩全年资料 六合彩脑筋急转弯 六合彩官方网站 六合彩查询 六合彩开码现场 六合彩报 香港六合彩论坛 六合彩天线宝宝 香港六合彩结果

Baidu

一聚教程网:一个值得你收藏的教程网站

详解MongoDB数据库基础操作及实例

时间:2017-09-25 15:45:49 编辑:猪哥 来源:转载

详解数据库基础操作及实例

          废话不多说,直接上代码,注释写的比较清楚,大家参考下,

 示例代码:

/** 
 * 插入一条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); 
} 

文章评论

热门栏目

香港马会开奖结果,六合彩资料 六开彩开奖现场直播 六合彩资料大全 地下六合彩 六合彩图库 六合彩图 香港六合彩网站 六合彩大全 香港六合彩图库 六合彩开 六合彩挂牌 香港六合彩挂牌 六合彩票 六合彩现场直播 六合彩玄机 香港六合彩公司 六合彩官网 香港六合彩特码 六合彩管家婆 六合彩走势图 六合彩结果 六合彩马报 香港六合彩现场直播 六合彩白小姐 白小姐六合彩 www.dq-ccg.com六合彩直播 六合彩特码资料 六合彩免费资料 六合彩曾道人 香港六合彩资料大全 六合彩开码结果 香港六合彩管家婆 六合彩综合资料 香港六合彩网址 六合彩彩图 香港六合彩图 六合彩信息 今晚六合彩开什么 六合彩开什么 六合彩图纸 香港六合彩特码资料 香港马会六合彩 六合彩图片 六合彩预测 香港六合彩网 香港六合彩直播 香港地下六合彩 香港六合彩官方网站 六合彩全年资料 六合彩脑筋急转弯 六合彩官方网站 六合彩查询 六合彩开码现场 六合彩报 香港六合彩论坛 六合彩天线宝宝 香港六合彩结果