Java操作Mongodb数据库实现数据的增删查改功能示例
本文实例讲述了Java操作Mongodb数据库实现数据的增删查改功能。分享给大家供大家参考,具体如下:
首先,我们在windows下安装mongodb数据库,安装教程可查看前面一篇文章:https://www.nhooo.com/article/85605.htm
代码如下:
packageio.mogo; importjava.util.Map; importorg.apache.commons.lang3.StringUtils; importcom.mongodb.BasicDBObject; importcom.mongodb.DB; importcom.mongodb.DBCollection; importcom.mongodb.DBCursor; importcom.mongodb.DBObject; importcom.mongodb.Mongo; importcom.mongodb.WriteResult; /** *Helloworld! * */ publicclassApp { privatestaticfinalStringhost="localhost"; privatestaticfinalintport=27017; privatestaticfinalStringuserName=""; privatestaticfinalStringpassword=""; privatestaticfinalStringdataBaseName="test"; privatestaticDBdb; publicstaticvoidmain(String[]args)throwsException { System.out.println("HelloWorld!"); connMongoDB(); find("person","name","xiaoming"); DBObjectnewObj=newBasicDBObject(); newObj.put("name","xiaoming"); newObj.put("desc","iamxiaoming"); update("person","name","xiaoming",newObj); find("person","name","xiaoming"); } publicstaticvoidconnMongoDB()throwsException{ Mongomongo=newMongo(host,port); db=mongo.getDB(dataBaseName); if(!StringUtils.isEmpty(userName)||!StringUtils.isEmpty(password)){ db.authenticate(userName,password.toCharArray()); } } publicstaticvoidfind(StringtableName,Stringkey,Stringvalue){ DBObjectobj=newBasicDBObject(); obj.put(key,value); DBCollectiondbCollection=db.getCollection(tableName); DBCursordbCursor=dbCollection.find(obj); while(dbCursor.hasNext()){ Mapmap=(Map)dbCursor.next(); System.out.println(map); } } publicstaticbooleandelete(StringtableName,Stringkey,Stringvalue){ DBObjectobj=newBasicDBObject(); obj.put(key,value); DBCollectiondbCollection=db.getCollection(tableName); WriteResultresult=dbCollection.remove(obj); if(result.getN()>0){ System.out.println("删除数据成功!"); returntrue; }else{ returnfalse; } } publicstaticbooleaninsert(StringtableName,DBObjectobj){ DBCollectiondbCollection=db.getCollection(tableName); longnum=dbCollection.count(); dbCollection.insert(obj); if(dbCollection.count()-num>0){ System.out.println("插入数据成功!"); returntrue; }else{ returnfalse; } } publicstaticbooleanupdate(StringtableName,Stringkey,Stringvalue,DBObjectnewValue){ DBObjectobj=newBasicDBObject(); obj.put(key,value); DBCollectiondbCollection=db.getCollection(tableName); DBObjectoldValue=dbCollection.findOne(obj); WriteResultresult=dbCollection.update(oldValue,newValue); if(result.getN()>0){ System.out.println("数据更新成功!"); returntrue; }else returnfalse; } }
附:完整实例代码点击此处本站下载。
更多关于java相关内容感兴趣的读者可查看本站专题:《Java+MySQL数据库程序设计总结》、《Java操作Excel技巧总结》、《Java数据结构与算法教程》、《Java文件与目录操作技巧汇总》及《Java操作DOM节点技巧总结》
希望本文所述对大家java程序设计有所帮助。