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程序设计有所帮助。