JAVA 操作MongoDB

本文内容纲要：

MongoDB的3.x版本Java驱动相对2.x做了全新的设计，类库和使用方法上有很大区别。例如用Document替换BasicDBObject、通过Builders类构建Bson替代直接输入$命令等，本文整理了基于3.2版本的常用增删改查操作的使用方法。为了避免冗长的篇幅，分为增删改、查询、聚合、地理索引等几部分。本篇主要介绍记录一下自己的一个mongodb的工具类，测试了简单的一些增、删、改以及建索引的一些方法。

创建一个maven项目，添加依赖

[java]viewplaincopy

print?

org.mongodb mongodb-driver 3.2.2

非maven项目可自行下载jar包

http://central.maven.org/maven2/org/mongodb/mongo-java-driver/3.2.2/mongo-java-driver-3.2.2.jar

mongodb工具类：

1packagecom.wd.util; 2 3importjava.util.ArrayList; 4importjava.util.Arrays; 5importjava.util.List; 6importorg.bson.Document; 7importorg.bson.conversions.Bson; 8importorg.bson.types.ObjectId; 9 10importcom.mongodb.BasicDBObject; 11importcom.mongodb.DB; 12importcom.mongodb.DBCollection; 13importcom.mongodb.DBCursor; 14importcom.mongodb.MongoClient; 15importcom.mongodb.MongoClientOptions; 16importcom.mongodb.MongoClientOptions.Builder; 17importcom.mongodb.WriteConcern; 18importcom.mongodb.client.AggregateIterable; 19importcom.mongodb.client.FindIterable; 20importcom.mongodb.client.ListIndexesIterable; 21importcom.mongodb.client.MongoCollection; 22importcom.mongodb.client.MongoCursor; 23importcom.mongodb.client.MongoDatabase; 24importcom.mongodb.client.MongoIterable; 25importcom.mongodb.client.model.Filters; 26importstaticcom.mongodb.client.model.Filters.*; 27importstaticcom.mongodb.client.model.Projections.*; 28importstaticcom.mongodb.client.model.Sorts.*; 29importstaticcom.mongodb.client.model.Accumulators.*; 30importstaticcom.mongodb.client.model.Aggregates.*; 31importcom.mongodb.client.model.IndexOptions; 32importcom.mongodb.client.model.Projections; 33importcom.mongodb.client.model.UpdateOptions; 34importcom.mongodb.client.model.Updates.*; 35importcom.mongodb.client.result.DeleteResult; 36importcom.wd.backend.model.AffiliationJG; 37importcom.wd.backend.model.AffiliationList; 38 39importnet.sf.json.JSONArray; 40importnet.sf.json.JSONObject; 41importnet.sf.json.JsonConfig; 42 43 44publicenumMongoUtil{ 45/** 46*定义一个枚举的元素，它代表此类的一个实例 47*/ 48instance; 49 50privatestaticMongoClientmongoClient; 51 52static{ 53System.out.println("===============MongoDBUtil初始化========================"); 54Stringip="192.168.1.75"; 55intport=27017; 56instance.mongoClient=newMongoClient(ip,port); 57//大部分用户使用mongodb都在安全内网下，但如果将mongodb设为安全验证模式，就需要在客户端提供用户名和密码： 58//booleanauth=db.authenticate(myUserName,myPassword); 59Builderoptions=newMongoClientOptions.Builder(); 60options.cursorFinalizerEnabled(true); 61//options.autoConnectRetry(true);//自动重连true 62//options.maxAutoConnectRetryTime(10);//themaximumautoconnectretrytime 63options.connectionsPerHost(300);//连接池设置为300个连接,默认为100 64options.connectTimeout(30000);//连接超时，推荐>3000毫秒 65options.maxWaitTime(5000);// 66options.socketTimeout(0);//套接字超时时间，0无限制 67options.threadsAllowedToBlockForConnectionMultiplier(5000);//线程队列数，如果连接线程排满了队列就会抛出“Outofsemaphorestogetdb”错误。 68options.writeConcern(WriteConcern.SAFE);// 69options.build(); 70} 71 72//------------------------------------共用方法--------------------------------------------------- 73/** 74*获取DB实例-指定DB 75* 76*@paramdbName 77*@return 78*/ 79publicMongoDatabasegetDB(StringdbName){ 80if(dbName!=null&&!"".equals(dbName)){ 81MongoDatabasedatabase=mongoClient.getDatabase(dbName); 82returndatabase; 83} 84returnnull; 85} 86 87/** 88*获取collection对象-指定Collection 89* 90*@paramcollName 91*@return 92*/ 93publicMongoCollection<Document>getCollection(StringdbName,StringcollName){ 94if(null==collName||"".equals(collName)){ 95returnnull; 96} 97if(null==dbName||"".equals(dbName)){ 98returnnull; 99} 100MongoCollection<Document>collection=mongoClient.getDatabase(dbName).getCollection(collName); 101returncollection; 102} 103 104/** 105*查询DB下的所有表名 106*/ 107publicList<String>getAllCollections(StringdbName){ 108MongoIterable<String>colls=getDB(dbName).listCollectionNames(); 109List<String>_list=newArrayList<String>(); 110for(Strings:colls){ 111_list.add(s); 112} 113return_list; 114} 115 116/** 117*获取所有数据库名称列表 118* 119*@return 120*/ 121publicMongoIterable<String>getAllDBNames(){ 122MongoIterable<String>s=mongoClient.listDatabaseNames(); 123returns; 124} 125 126/** 127*删除一个数据库 128*/ 129publicvoiddropDB(StringdbName){ 130getDB(dbName).drop(); 131} 132 133/** 134*查找对象-根据主键_id 135* 136*@paramcollection 137*@paramid 138*@return 139*/ 140publicDocumentfindById(MongoCollection<Document>coll,Stringid){ 141ObjectId_idobj=null; 142try{ 143_idobj=newObjectId(id); 144}catch(Exceptione){ 145returnnull; 146} 147DocumentmyDoc=coll.find(Filters.eq("_id",_idobj)).first(); 148returnmyDoc; 149} 150 151/**统计数*/ 152publicintgetCount(MongoCollection<Document>coll){ 153intcount=(int)coll.count(); 154returncount; 155} 156 157/**条件查询*/ 158publicMongoCursor<Document>find(MongoCollection<Document>coll,Bsonfilter){ 159returncoll.find(filter).iterator(); 160} 161 162/**分页查询*/ 163publicMongoCursor<Document>findByPage(MongoCollection<Document>coll,Bsonfilter,intpageNo,intpageSize){ 164BsonorderBy=newBasicDBObject("_id",1); 165returncoll.find(filter).sort(orderBy).skip((pageNo-1)*pageSize).limit(pageSize).iterator(); 166} 167 168 169/** 170*通过ID删除 171* 172*@paramcoll 173*@paramid 174*@return 175*/ 176publicintdeleteById(MongoCollection<Document>coll,Stringid){ 177intcount=0; 178ObjectId_id=null; 179try{ 180_id=newObjectId(id); 181}catch(Exceptione){ 182return0; 183} 184Bsonfilter=Filters.eq("_id",_id); 185DeleteResultdeleteResult=coll.deleteOne(filter); 186count=(int)deleteResult.getDeletedCount(); 187returncount; 188} 189 190/** 191*FIXME 192* 193*@paramcoll 194*@paramid 195*@paramnewdoc 196*@return 197*/ 198publicDocumentupdateById(MongoCollection<Document>coll,Stringid,Documentnewdoc){ 199ObjectId_idobj=null; 200try{ 201_idobj=newObjectId(id); 202}catch(Exceptione){ 203returnnull; 204} 205Bsonfilter=Filters.eq("_id",_idobj); 206//coll.replaceOne(filter,newdoc);//完全替代 207coll.updateOne(filter,newDocument("$set",newdoc)); 208returnnewdoc; 209} 210 211publicvoiddropCollection(StringdbName,StringcollName){ 212getDB(dbName).getCollection(collName).drop(); 213} 214 215/** 216*关闭Mongodb 217*/ 218publicvoidclose(){ 219if(mongoClient!=null){ 220mongoClient.close(); 221mongoClient=null; 222} 223} 224 225/** 226*测试入口 227* 228*@paramargs 229*@throwsCloneNotSupportedException 230*/ 231publicstaticvoidmain(String[]args){ 232 233StringdbName="test"; 234StringcollName="wd_paper_scie"; 235MongoCollection<Document>coll=MongoUtil.instance.getCollection(dbName,collName); 236//coll.createIndex(newDocument("validata",1));//创建索引 237//coll.createIndex(newDocument("id",1)); 238//coll.createIndex(newDocument("ut_wos",1),newIndexOptions().unique(true));//创建唯一索引 239//coll.dropIndexes();//删除索引 240//coll.dropIndex("validata_1");//根据索引名删除某个索引 241ListIndexesIterable<Document>list=coll.listIndexes();//查询所有索引 242for(Documentdocument:list){ 243System.out.println(document.toJson()); 244} 245coll.find(Filters.and(Filters.eq("x",1),Filters.lt("y",3))); 246coll.find(and(eq("x",1),lt("y",3))); 247coll.find().sort(ascending("title")); 248coll.find().sort(newDocument("id",1)); 249coll.find(newDocument("$or",Arrays.asList(newDocument("owner","tom"),newDocument("words",newDocument("$gt",350))))); 250coll.find().projection(fields(include("title","owner"),excludeId())); 251//coll.updateMany(Filters.eq("validata",1),Updates.set("validata",0)); 252//coll.updateMany(Filters.eq("validata",1),newDocument("$unset",newDocument("jigou","")));//删除某个字段 253//coll.updateMany(Filters.eq("validata",1),newDocument("$rename",newDocument("affiliation","affiliation_full")));//修改某个字段名 254//coll.updateMany(Filters.eq("validata",1),newDocument("$rename",newDocument("affiliationMeta","affiliation"))); 255//coll.updateMany(Filters.eq("validata",1),newDocument("$set",newDocument("validata",0)));//修改字段值 256//MongoCursor<Document>cursor1=coll.find(Filters.eq("ut_wos","WOS:000382970200003")).iterator(); 257//while(cursor1.hasNext()){ 258//Documentsd=cursor1.next(); 259//System.out.println(sd.toJson()); 260//coll.insertOne(sd); 261//} 262 263//MongoCursor<Document>cursor1=coll.find(Filters.elemMatch("affInfo",Filters.eq("firstorg",1))).iterator(); 264//while(cursor1.hasNext()){ 265//Documentsd=cursor1.next(); 266//System.out.println(sd.toJson()); 267//} 268//查询只返回指定字段 269//MongoCursor<Document>doc=coll.find().projection(Projections.fields(Projections.include("ut_wos","affiliation"),Projections.excludeId())).iterator(); 270//"ut_wos":"WOS:000382970200003" 271//coll.updateMany(Filters.eq("validata",1),newDocument("$set",newDocument("validata",0))); 272//coll.updateMany(Filters.eq("validata",0),newDocument("$rename",newDocument("sid","ssid")),newUpdateOptions().upsert(false)); 273//coll.updateOne(Filters.eq("ut_wos","WOS:000382970200003"),newDocument("$set",newDocument("validata",0))); 274//longisd=coll.count(Filters.elemMatch("affInfo",Filters.elemMatch("affiliationJGList",Filters.eq("sid",0)))); 275//System.out.println(isd); 276//MongoCursor<Document>doc=coll.find(Filters.elemMatch("affInfo",Filters.elemMatch("affiliationJGList",Filters.ne("sid",0)))).projection(Projections.fields(Projections.elemMatch("affInfo"),Projections.excludeId())).iterator(); 277//MongoCursor<Document>doc=coll.find().projection(Projections.include("affInfo","ssid")).iterator(); 278//while(doc.hasNext()){ 279//Documentsd=doc.next(); 280//System.out.println(sd.toJson()); 281// 282//} 283MongoUtil.instance.close(); 284//插入多条 285//for(inti=1;i<=4;i++){ 286//Documentdoc=newDocument(); 287//doc.put("name","zhoulf"); 288//doc.put("school","NEFU"+i); 289//Documentinterests=newDocument(); 290//interests.put("game","game"+i); 291//interests.put("ball","ball"+i); 292//doc.put("interests",interests); 293//coll.insertOne(doc); 294//} 295// 296/*MongoCursor<Document>sd=coll.find().iterator(); 297while(sd.hasNext()){ 298Documentdoc=sd.next(); 299Stringid=doc.get("_id").toString(); 300List<AffiliationJG>list=newArrayList<AffiliationJG>(); 301AffiliationJGjg=newAffiliationJG(); 302jg.setAddress("123"); 303jg.setCid(2); 304jg.setCname("eeee"); 305jg.setSid(3); 306jg.setSname("rrrr"); 307AffiliationJGjg2=newAffiliationJG(); 308jg2.setAddress("3242"); 309jg2.setCid(2); 310jg2.setCname("ers"); 311jg2.setSid(3); 312jg2.setSname("rasdr"); 313list.add(jg); 314list.add(jg2); 315AffiliationListaf=newAffiliationList(); 316af.setAffiliationAuthos("33333"); 317af.setAffiliationinfo("asdsa"); 318af.setAffiliationJGList(list); 319JSONObjectjson=JSONObject.fromObject(af); 320doc.put("affInfo",json); 321MongoDBUtil.instance.updateById(coll,id,doc); 322}*/ 323 324//Bsonbs=Filters.eq("name","zhoulf"); 325//coll.find(bs).iterator(); 326////根据ID查询 327//Stringid="556925f34711371df0ddfd4b"; 328//Documentdoc=MongoDBUtil2.instance.findById(coll,id); 329//System.out.println(doc); 330 331//查询多个 332//MongoCursor<Document>cursor1=coll.find(Filters.eq("name","zhoulf")).iterator(); 333//while(cursor1.hasNext()){ 334//org.bson.Document_doc=(Document)cursor1.next(); 335//System.out.println(_doc.toString()); 336//} 337//cursor1.close(); 338 339//查询多个 340//MongoCursor<WdPaper>cursor2=coll.find(WdPaper.class).iterator(); 341//while(cursor2.hasNext()){ 342//WdPaperdoc=cursor2.next(); 343//System.out.println(doc.getUt_wos()); 344//} 345//删除数据库 346//MongoDBUtil2.instance.dropDB("testdb"); 347 348//删除表 349//MongoDBUtil2.instance.dropCollection(dbName,collName); 350 351//修改数据 352//Stringid="556949504711371c60601b5a"; 353//Documentnewdoc=newDocument(); 354//newdoc.put("name","时候"); 355//MongoDBUtil.instance.updateById(coll,id,newdoc); 356 357//统计表 358//System.out.println(MongoDBUtil.instance.getCount(coll)); 359 360//查询所有 361//Bsonfilter=Filters.eq("count",0); 362//MongoDBUtil.instance.find(coll,filter); 363 364} 365 366}

本文内容总结：

原文链接：https://www.cnblogs.com/sa-dan/p/6836055.html