Mongodb driver for java 使用样例

下面是脚本之家 jb51.cc 通过网络收集整理的代码片段。

脚本之家小编现在分享给大家，也给大家做个参考。

importorg.bson.Document;
importcom.mongodb.BasicDBObject;
importcom.mongodb.DBCollection;
importcom.mongodb.DBObject;
importcom.mongodb.MapReduceCommand;
importcom.mongodb.MapReduceOutput;
importcom.mongodb.MongoClient;
importcom.mongodb.client.FindIterable;
importcom.mongodb.client.MapReduceIterable;
importcom.mongodb.client.MongoCollection;
importcom.mongodb.client.MongoCursor;
importcom.mongodb.client.MongoDatabase;
importcom.mongodb.util.JSON;

publicclassMongoDBClientTest{
privatestaticMongoClientmongoClient;
privatestaticMongoDatabasedb;
static{
mongoClient=newMongoClient("localhost",27017);
db=mongoClient.getDatabase("local");
}

publicMongoDBClientTest(){
super();
}

publicstaticvoidmain(String[]args){
MongoDBClientTestclientTest=newMongoDBClientTest();
clientTest.testQuery();
clientTest.testInsert();
clientTest.testDelete();
clientTest.testToJsonObject();
clientTest.testMapReduce();
}
//testsearch
privatevoidtestQuery(){
System.err.println("===========goingtoselect==========");
MongoCollectioncollection=db.getCollection("posts");
BasicDBObjectquery=newBasicDBObject("cust_id","B212");
BasicDBObjectreturnField1=newBasicDBObject("cust_id",1);
BasicDBObjectreturnField2=newBasicDBObject("status",1);
FindIterableiterable=collection.find(query);
MongoCursorcursor=iterable.iterator();
while(cursor.hasNext()){
org.bson.Documentuser=cursor.next();
System.out.println(user.get("cust_id"));
System.out.println(user.toString());
}
cursor.close();
}

//testinsert
privatevoidtestInsert(){
System.err.println("===========goingtoinsert==========");
MongoCollectioncollection=db.getCollection("posts");
Documentdoc=newDocument();
doc.put("cust_id","A111");
doc.put("amount",210);
doc.put("status","C");
collection.insertOne(doc);
FindIterableiterable=collection.find();
MongoCursorcursor=iterable.iterator();
while(cursor.hasNext()){
org.bson.Documentuser=cursor.next();
//System.out.println(user.get("cust_id"));
System.out.println(user.toString());
}
}

//testdelete
privatevoidtestDelete(){
System.err.println("===========goingtodelete==========");
MongoCollectioncollection=db.getCollection("posts");
BasicDBObjectquery=newBasicDBObject("status","C");
collection.deleteMany(query);
FindIterableiterable=collection.find();
MongoCursorcursor=iterable.iterator();
while(cursor.hasNext()){
org.bson.Documentuser=cursor.next();
System.out.println(user.toString());
}
}

//teststringtojsonobject
privatevoidtestToJsonObject(){
System.err.println("===========tojsonobject==========");
StringjsonString="{'title':'NoSQLOverview','description':'Nosqldatabaseisveryfast','by_user':'tutorialspoint','url':'http://www.tutorialspoint.com','tags':['mongodb','database','NoSQL'],'likes':10}";
BasicDBObjectdoc=(BasicDBObject)JSON.parse(jsonString);
System.out.println(doc);
System.out.println(doc.get("tags").getClass().getCanonicalName());
}

//testthemapreduce
privatevoidtestMapReduce(){
System.err.println("===========testmapreduce==========");
MongoCollectioncollection=db.getCollection("posts");
Stringmap="function(){emit(this.cust_id,this.amount);}";
Stringreduce="function(key,values){returnArray.sum(values)}";
//MapReduceCommandcmd=newMapReduceCommand(collection,map,reduce,//null,MapReduceCommand.OutputType.INLINE,null);
MapReduceIterableout=collection.mapReduce(map,reduce);
MongoCursorcursor=out.iterator();
while(cursor.hasNext()){
System.out.println(cursor.next());
}
BasicDBObjectquery=newBasicDBObject("status","C");
DBCollectiondbcol=mongoClient.getDB("local").getCollection("posts");
MapReduceCommandcmd=newMapReduceCommand(dbcol,"outputCollection",query);
MapReduceOutputout2=dbcol.mapReduce(cmd);
for(DBObjecto:out2.results()){
System.out.println(o.toString());
}
System.out.println("Done");

}
}

以上是脚本之家(jb51.cc)为你收集整理的全部代码内容，希望文章能够帮你解决所遇到的程序开发问题。

如果觉得脚本之家网站内容还不错，欢迎将脚本之家网站推荐给程序员好友。

（编辑：安卓应用网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!