技术开发 频道

Mongodb快速入门之使用Java操作Mongodb

  完整的代码如下所示:

  packagecom.mkyong.core;
  importjava.net.UnknownHostException;
  importjava.util.HashMap;
  importjava.util.Map;
  importcom.mongodb.BasicDBObject;
  importcom.mongodb.BasicDBObjectBuilder;
  importcom.mongodb.DB;
  importcom.mongodb.DBCollection;
  importcom.mongodb.DBCursor;
  importcom.mongodb.DBObject;
  importcom.mongodb.Mongo;
  importcom.mongodb.MongoException;
  importcom.mongodb.util.JSON;
  
/**
  * Java MongoDB : Insert a Document
  *
  
*/
  publicclass InsertDocumentApp {
  publicstaticvoid main(String[] args){
  
try{
  Mongo mongo
=new Mongo("localhost", 27017);
  DB db
= mongo.getDB("yourdb");
  
// get a single collection
  DBCollection collection = db.getCollection("dummyColl");
  
// BasicDBObject example
  System.out.println("BasicDBObject example...");
  BasicDBObject document
=new BasicDBObject();
  document.put(
"database", "mkyongDB");
  document.put(
"table", "hosting");
  BasicDBObject documentDetail
=new BasicDBObject();
  documentDetail.put(
"records", "99");
  documentDetail.put(
"index", "vps_index1");
  documentDetail.put(
"active", "true");
  document.put(
"detail", documentDetail);
  collection.insert(document);
  DBCursor cursorDoc
= collection.find();
  
while(cursorDoc.hasNext()){
  System.out.println(cursorDoc.next());
  }
  collection.remove(
new BasicDBObject());
  
// BasicDBObjectBuilder example
  System.out.println("BasicDBObjectBuilder example...");
  BasicDBObjectBuilder documentBuilder
= BasicDBObjectBuilder.start()
  .add(
"database", "mkyongDB")
  .add(
"table", "hosting");
  BasicDBObjectBuilder documentBuilderDetail
= BasicDBObjectBuilder.start()
  .add(
"records", "99")
  .add(
"index", "vps_index1")
  .add(
"active", "true");
  documentBuilder.add(
"detail", documentBuilderDetail.get());
  collection.insert(documentBuilder.get());
  DBCursor cursorDocBuilder
= collection.find();
  
while(cursorDocBuilder.hasNext()){
  System.out.println(cursorDocBuilder.next());
  }
  collection.remove(
new BasicDBObject());
  
// Map example
  System.out.println("Map example...");
  Map documentMap
=new HashMap();
  documentMap.put(
"database", "mkyongDB");
  documentMap.put(
"table", "hosting");
  Map documentMapDetail
=new HashMap();
  documentMapDetail.put(
"records", "99");
  documentMapDetail.put(
"index", "vps_index1");
  documentMapDetail.put(
"active", "true");
  documentMap.put(
"detail", documentMapDetail);
  collection.insert(
new BasicDBObject(documentMap));
  DBCursor cursorDocMap
= collection.find();
  
while(cursorDocMap.hasNext()){
  System.out.println(cursorDocMap.next());
  }
  collection.remove(
new BasicDBObject());
  
// JSON parse example
  System.out.println("JSON parse example...");
  String json
="{'database' : 'mkyongDB','table' : 'hosting',"+
  
"'detail' : {'records' : 99, 'index' : 'vps_index1', 'active' : 'true'}}}";
  DBObject dbObject
=(DBObject)JSON.parse(json);
  collection.insert(dbObject);
  DBCursor cursorDocJSON
= collection.find();
  
while(cursorDocJSON.hasNext()){
  System.out.println(cursorDocJSON.next());
  }
  collection.remove(
new BasicDBObject());
  }
catch(UnknownHostException e){
  e.printStackTrace();
  }
catch(MongoException e){
  e.printStackTrace();
  }
  }
  }
1
相关文章