JAVA mongodb数据库连接、集合读取、集合大小

判官007

package mongodb;
import java.net.UnknownHostException;
import java.util.Iterator;
import java.util.Set;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
/**
* java  
* mongodb连接开启、关闭、从mongodb中获取集合的名称、获取某个集合的大小
*/
public class MongodbLink {
public static void main(String[] args) {
Mongo m = null;
DB db = null;
try {
//Mongo(p1, p2):p1=>IP地址     p2=>端口
m = new Mongo("127.0.0.1", 27017);
//根据mongodb数据库的名称获取mongodb对象
db = m.getDB("sdap");
//校验用户密码是否正确
if (!db.authenticate("sdap", "sdap123".toCharArray())){
System.out.println("连接MongoDB数据库,校验失败！");
}else{
System.out.println("连接MongoDB数据库,校验成功！");
db.requestStart();
//获取集合名称
Set<String> colNameSet = db.getCollectionNames();
Iterator<String> colNameItr = colNameSet.iterator();
while(colNameItr.hasNext()){
String colName = colNameItr.next();
System.out.println(&quot;数据集合的名称：&quot;+colName);
}
//获取集合对象
DBCollection dbCol = db.getCollection(&quot;ADMIN1352528239201&quot;);
if(dbCol != null){
//获取集合大小
Integer colSize = (Integer) dbCol.getStats().get(&quot;size&quot;);
System.out.println(&quot;数据集大小为[单位：B]：&quot;+colSize);
}
db.requestDone();
}
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
//mongodb连接关闭
finally{
if (null != m) {
if (null != db) {
// 结束Mongo数据库的事务请求
try {
db.requestDone();
} catch(Exception e) {
e.printStackTrace();
}
}
try
{
m.close();
} catch(Exception e1) {
e1.printStackTrace();
}
m = null;
}
}
}
}

　　



版权声明：本文为博主原创文章，未经博主允许不得转载。