> document=({"empId" : "10001","empName" :"Dinesh Rajput" ,"date_of_join" : "10/04/2010"
,"education" :"M.C.A." , "profession" : "DEVELOPER","interest" : "MUSIC","community_name"
:["MODERN MUSIC", "CLASSICAL MUSIC","WESTERN MUSIC"],"community_moder_id" : ["MR. BBB","MR.
JJJ","MR MMM"],"community_members" : [500,200,1500],"friends_id" :
["MMM123","NNN123","OOO123"],"ban_friends_id" :["BAN123","BAN456","BAN789"]});

> db.employees.insert(document)

BasicDBObject document = new BasicDBObject();
document.put("database", "dineshonjavaDB");
document.put("table", "employees");
BasicDBObject documentDetail = new BasicDBObject();
documentDetail.put("empId", "10001");
documentDetail.put("empName", "Dinesh");
documentDetail.put("salary", "70000");
document.put("detail", documentDetail);
collection.insert(document);
2. BasicDBObjectBuilder exampleBasicDBObjectBuilder documentBuilder = BasicDBObjectBuilder.start()
.add("database", "dineshonjavaDB")
.add("table", "employees");
BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start()
.add("empId", "10001")
.add("empName", "Dinesh")
.add("salary", "70000");
documentBuilder.add("detail", documentBuilderDetail.get());
collection.insert(documentBuilder.get());
Map<String, Object> documentMap = new HashMap<String, Object>();
documentMap.put("database", "dineshonjavaDB");
documentMap.put("table", "employees");
Map<String, Object> documentMapDetail = new HashMap<String, Object>();
documentMapDetail.put("empId", "10001");
documentMapDetail.put("empName", "Dinesh");
documentMapDetail.put("salary", "70000");
documentMap.put("detail", documentMapDetail);
collection.insert(new BasicDBObject(documentMap));
4. JSON parse exampleString json = "{'database' : 'dineshonjavaDB','table' : 'employees'," +
"'detail' : {'empId' : 10001, 'empName' : 'Dinesh', 'salary' : 70000}}}";
DBObject dbObject = (DBObject)JSON.parse(json);
collection.insert(dbObject);
package com.dineshonjava.mongo.test;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.Map;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBObjectBuilder;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.util.JSON;
/**
* @author Dinesh Rajput
*
*/
public class InsertDocumentDemo {
/**
* @param args
*/
public static void main(String[] args) {
try {
// connect to mongoDB, IP and port number
Mongo mongo = new Mongo("localhost", 27017);
// get database from MongoDB,
// if database doesn't exists, mongoDB will create it automatically
DB db = mongo.getDB("dineshonjavaDB");
// get a single collection
DBCollection collection = db.getCollection("employees");
// BasicDBObject example
System.out.println("BasicDBObject example...");
BasicDBObject document = new BasicDBObject();
document.put("database", "dineshonjavaDB");
document.put("table", "employees");
BasicDBObject documentDetail = new BasicDBObject();
documentDetail.put("empId", "10001");
documentDetail.put("empName", "Dinesh");
documentDetail.put("salary", "70000");
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", "dineshonjavaDB")
.add("table", "employees");
BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilder.start()
.add("empId", "10001")
.add("empName", "Dinesh")
.add("salary", "70000");
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<String, Object> documentMap = new HashMap<String, Object>();
documentMap.put("database", "dineshonjavaDB");
documentMap.put("table", "employees");
Map<String, Object> documentMapDetail = new HashMap<String, Object>();
documentMapDetail.put("empId", "10001");
documentMapDetail.put("empName", "Dinesh");
documentMapDetail.put("salary", "70000");
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' : 'dineshonjavaDB','table' : 'employees'," +
"'detail' : {'empId' : 10001, 'empName' : 'Dinesh', 'salary' : '70000'}}}";
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());
System.out.println("Done");
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (MongoException e) {
e.printStackTrace();
}
}
}
Labels: mongodb