|
ongo){ if(mongo!=null){ mongo.close(); } } } //利用方法重载实现不同情况的传参 /** * 获取指定的集合 * @param collectionName :要链接的集合 * @param dbName:集合所在的数据库 * @return */ public DBCollection getDBCollection(String collectionName,String dbName){ DBCollection dBCollection=null; if(getDB(dbName,null, null)){ db.requestStart(); if(collectionName==null){//如果为空则从配置文件中查找 collectionName=MyPro.getInstance().getProperty("collectionName"); } dBCollection=db.getCollection(collectionName); }else{ //抛出异常 throw new RuntimeException("数据库连接失败"); } return dBCollection; } /** * * @param collectionName * @param dbName * @param name * @param password * @return */ public DBCollection getDBCollection(String collectionName,String dbName,String name,String password){ DBCollection dBCollection=null; if(getDB(dbName,name, password)){ db.requestStart(); if(collectionName==null){//如果为空则从配置文件中查找 collectionName=MyPro.getInstance().getProperty("collectionName"); } dBCollection=db.getCollection(collectionName); }else{ //抛出异常 throw new RuntimeException("数据库连接失败"); } return dBCollection; } /** * 只传递集合名字 * @param collectionName * @return */ public DBCollection getDBCollection(String collectionName){ DBCollection dBCollection=null; String dbName=MyPro.getInstance().getProperty("dbName"); if(getDB(dbName,null, null)){ db.requestStart(); if(collectionName==null){//如果为空则从配置文件中查找 collectionName=MyPro.getInstance().getProperty("collectionName"); } dBCollection=db.getCollection(collectionName); }else{ //抛出异常 throw new RuntimeException("数据库连接失败"); } return dBCollection; }
|