JAVA单例MongoDB工具类
本文内容纲要：
我经常对MongoDB进行一些基础操作，将这些常用操作合并到一个工具类中，方便自己开发使用。
没用SpringData、Morphia等框架是为了减少学习、维护成本，另外自己直接JDBC方式的话可以更灵活，为自己以后的积累留一个脚印。
JAVA驱动版本：
<!--MongoDB驱动-->
<dependency>
<groupId>org.mongodb</groupId>
<artifactId>mongo-java-driver</artifactId>
<version>3.0.2</version>
</dependency>
工具类代码如下：
packageutils;
importjava.util.ArrayList;
importjava.util.List;
importorg.apache.commons.configuration.CompositeConfiguration;
importorg.apache.commons.configuration.ConfigurationException;
importorg.apache.commons.configuration.PropertiesConfiguration;
importorg.bson.Document;
importorg.bson.conversions.Bson;
importorg.bson.types.ObjectId;
importcom.mongodb.BasicDBObject;
importcom.mongodb.MongoClient;
importcom.mongodb.MongoClientOptions;
importcom.mongodb.MongoClientOptions.Builder;
importcom.mongodb.WriteConcern;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importcom.mongodb.client.MongoIterable;
importcom.mongodb.client.model.Filters;
importcom.mongodb.client.result.DeleteResult;
/**
*MongoDB工具类Mongo实例代表了一个数据库连接池，即使在多线程的环境中，一个Mongo实例对我们来说已经足够了<br>
*注意Mongo已经实现了连接池，并且是线程安全的。<br>
*设计为单例模式，因MongoDB的Java驱动是线程安全的，对于一般的应用，只要一个Mongo实例即可，<br>
*Mongo有个内置的连接池（默认为10个）对于有大量写和读的环境中，为了确保在一个Session中使用同一个DB时，<br>
*DB和DBCollection是绝对线程安全的<br>
*
*@authorzhoulingfei
*@date2015-5-29上午11:49:49
*@version0.0.0
*@Copyright(c)1997-2015NavInfoCo.Ltd.AllRightsReserved.
*/
publicenumMongoDBUtil{
/**
*定义一个枚举的元素，它代表此类的一个实例
*/
instance;
privateMongoClientmongoClient;
static{
System.out.println("===============MongoDBUtil初始化========================");
CompositeConfigurationconfig=newCompositeConfiguration();
try{
config.addConfiguration(newPropertiesConfiguration("mongodb.properties"));
}catch(ConfigurationExceptione){
e.printStackTrace();
}
//从配置文件中获取属性值
Stringip=config.getString("host");
intport=config.getInt("port");
instance.mongoClient=newMongoClient(ip,port);
//or,toconnecttoareplicaset,withauto-discoveryoftheprimary,supplyaseedlistofmembers
//List<ServerAddress>listHost=Arrays.asList(newServerAddress("localhost",27017),newServerAddress("localhost",27018));
//instance.mongoClient=newMongoClient(listHost);
//大部分用户使用mongodb都在安全内网下，但如果将mongodb设为安全验证模式，就需要在客户端提供用户名和密码：
//booleanauth=db.authenticate(myUserName,myPassword);
Builderoptions=newMongoClientOptions.Builder();
//options.autoConnectRetry(true);//自动重连true
//options.maxAutoConnectRetryTime(10);//themaximumautoconnectretrytime
options.connectionsPerHost(300);//连接池设置为300个连接,默认为100
options.connectTimeout(15000);//连接超时，推荐>3000毫秒
options.maxWaitTime(5000);//
options.socketTimeout(0);//套接字超时时间，0无限制
options.threadsAllowedToBlockForConnectionMultiplier(5000);//线程队列数，如果连接线程排满了队列就会抛出“Outofsemaphorestogetdb”错误。
options.writeConcern(WriteConcern.SAFE);//
options.build();
}
//------------------------------------共用方法---------------------------------------------------
/**
*获取DB实例-指定DB
*
*@paramdbName
*@return
*/
publicMongoDatabasegetDB(StringdbName){
if(dbName!=null&&!"".equals(dbName)){
MongoDatabasedatabase=mongoClient.getDatabase(dbName);
returndatabase;
}
returnnull;
}
/**
*获取collection对象-指定Collection
*
*@paramcollName
*@return
*/
publicMongoCollection<Document>getCollection(StringdbName,StringcollName){
if(null==collName||"".equals(collName)){
returnnull;
}
if(null==dbName||"".equals(dbName)){
returnnull;
}
MongoCollection<Document>collection=mongoClient.getDatabase(dbName).getCollection(collName);
returncollection;
}
/**
*查询DB下的所有表名
*/
publicList<String>getAllCollections(StringdbName){
MongoIterable<String>colls=getDB(dbName).listCollectionNames();
List<String>_list=newArrayList<String>();
for(Strings:colls){
_list.add(s);
}
return_list;
}
/**
*获取所有数据库名称列表
*
*@return
*/
publicMongoIterable<String>getAllDBNames(){
MongoIterable<String>s=mongoClient.listDatabaseNames();
returns;
}
/**
*删除一个数据库
*/
publicvoiddropDB(StringdbName){
getDB(dbName).drop();
}
/**
*查找对象-根据主键_id
*
*@paramcollection
*@paramid
*@return
*/
publicDocumentfindById(MongoCollection<Document>coll,Stringid){
ObjectId_idobj=null;
try{
_idobj=newObjectId(id);
}catch(Exceptione){
returnnull;
}
DocumentmyDoc=coll.find(Filters.eq("_id",_idobj)).first();
returnmyDoc;
}
/**统计数*/
publicintgetCount(MongoCollection<Document>coll){
intcount=(int)coll.count();
returncount;
}
/**条件查询*/
publicMongoCursor<Document>find(MongoCollection<Document>coll,Bsonfilter){
returncoll.find(filter).iterator();
}
/**分页查询*/
publicMongoCursor<Document>findByPage(MongoCollection<Document>coll,Bsonfilter,intpageNo,intpageSize){
BsonorderBy=newBasicDBObject("_id",1);
returncoll.find(filter).sort(orderBy).skip((pageNo-1)*pageSize).limit(pageSize).iterator();
}
/**
*通过ID删除
*
*@paramcoll
*@paramid
*@return
*/
publicintdeleteById(MongoCollection<Document>coll,Stringid){
intcount=0;
ObjectId_id=null;
try{
_id=newObjectId(id);
}catch(Exceptione){
return0;
}
Bsonfilter=Filters.eq("_id",_id);
DeleteResultdeleteResult=coll.deleteOne(filter);
count=(int)deleteResult.getDeletedCount();
returncount;
}
/**
*FIXME
*
*@paramcoll
*@paramid
*@paramnewdoc
*@return
*/
publicDocumentupdateById(MongoCollection<Document>coll,Stringid,Documentnewdoc){
ObjectId_idobj=null;
try{
_idobj=newObjectId(id);
}catch(Exceptione){
returnnull;
}
Bsonfilter=Filters.eq("_id",_idobj);
//coll.replaceOne(filter,newdoc);//完全替代
coll.updateOne(filter,newDocument("$set",newdoc));
returnnewdoc;
}
publicvoiddropCollection(StringdbName,StringcollName){
getDB(dbName).getCollection(collName).drop();
}
/**
*关闭Mongodb
*/
publicvoidclose(){
if(mongoClient!=null){
mongoClient.close();
mongoClient=null;
}
}
/**
*测试入口
*
*@paramargs
*/
publicstaticvoidmain(String[]args){
StringdbName="GC_MAP_DISPLAY_DB";
StringcollName="COMMUNITY_BJ";
MongoCollection<Document>coll=MongoDBUtil.instance.getCollection(dbName,collName);
//插入多条
//for(inti=1;i<=4;i++){
//Documentdoc=newDocument();
//doc.put("name","zhoulf");
//doc.put("school","NEFU"+i);
//Documentinterests=newDocument();
//interests.put("game","game"+i);
//interests.put("ball","ball"+i);
//doc.put("interests",interests);
//coll.insertOne(doc);
//}
////根据ID查询
//Stringid="556925f34711371df0ddfd4b";
//Documentdoc=MongoDBUtil2.instance.findById(coll,id);
//System.out.println(doc);
//查询多个
//MongoCursor<Document>cursor1=coll.find(Filters.eq("name","zhoulf")).iterator();
//while(cursor1.hasNext()){
//org.bson.Document_doc=(Document)cursor1.next();
//System.out.println(_doc.toString());
//}
//cursor1.close();
//查询多个
//MongoCursor<Person>cursor2=coll.find(Person.class).iterator();
//删除数据库
//MongoDBUtil2.instance.dropDB("testdb");
//删除表
//MongoDBUtil2.instance.dropCollection(dbName,collName);
//修改数据
//Stringid="556949504711371c60601b5a";
//Documentnewdoc=newDocument();
//newdoc.put("name","时候");
//MongoDBUtil.instance.updateById(coll,id,newdoc);
//统计表
//System.out.println(MongoDBUtil.instance.getCount(coll));
//查询所有
Bsonfilter=Filters.eq("count",0);
MongoDBUtil.instance.find(coll,filter);
}
}
也请多提宝贵意见和建议。
本文内容总结：
原文链接：https://www.cnblogs.com/zhoulf/p/4571647.html