Working with MongoDB with java involves few steps
Step 1: include the java driver into the CLASSPATH
Step 2: start the mongodb service if installed
here is the demo code
Result
Step 1: include the java driver into the CLASSPATH
Step 2: start the mongodb service if installed
here is the demo code
package com.test; import java.net.UnknownHostException; import java.util.HashMap; import java.util.Map; import java.util.Set; import com.mongodb.BasicDBObject; import com.mongodb.DB; import com.mongodb.DBCollection; import com.mongodb.DBCursor; import com.mongodb.Mongo; import com.mongodb.MongoException; public class MongoHelloJava { public static void main(String[] args) { try { //Demonstrate simple hello java program with mongoDB System.out.println("Demonstarting simple insert and retrivel in MongoDB"); // connect to mongoDB on default port and IP address Mongo mongo = new Mongo("localhost",27017); // getDB() return the database from MongoDB, // mongoDB will create database automatically if not existed DB db = mongo.getDB("myMongoDB"); // getCollection() returns the collection from MongoDB // mongoDB will create collection automatically if not existed DBCollection collection = db.getCollection("myCollection"); // create a document to store key and value BasicDBObject document = new BasicDBObject(); document.put("id", 1000); document.put("print", "hello Java"); // save it into collection named "myCollection" collection.insert(document); // query for searching perticular id BasicDBObject query = new BasicDBObject(); query.put("id", 1000); // fire query DBCursor cursor = collection.find(query); // iterate through cursor while(cursor.hasNext()){ System.out.println(cursor.next()); } // Demonstrate getCollection() and getCollections() System.out.println("Demonstrate getCollection() and getCollections()"); Set<String> collections = db.getCollectionNames(); for (String collectionName : collections) { System.out.println(collectionName); } //get a particular collection DBCollection collection1 = db.getCollection("myCollection"); System.out.println("Collection Name is : "+collection1.toString()); //insert the data into the database BasicDBObject document1 = new BasicDBObject(); document1.put("post", "rajkrrsingh.blogspot.com"); document1.put("author", "Rajkumar Singh"); BasicDBObject comments = new BasicDBObject(); comments.put("user1", "text1"); comments.put("user2", "text2"); comments.put("user3", "text3"); document.put("comment", comments); collection.insert(document1); System.out.println("document1 inserted succesfully"); //insertion of the data into the database through map Map<String, Object> documentMap = new HashMap<String, Object>(); documentMap.put("post", "rajkrrsingh.blogspot.com"); documentMap.put("author", "Rajkumar Singh"); Map<String, Object> commentMap = new HashMap<String, Object>(); commentMap.put("user1", "text1"); commentMap.put("user2", "text2"); commentMap.put("user3", "text3"); documentMap.put("comment", commentMap); collection.insert(new BasicDBObject(documentMap)); DBCursor cursor1 = collection.find(); while (cursor1.hasNext()) { System.out.println(cursor1.next()); } } catch (UnknownHostException e) { e.printStackTrace(); } catch (MongoException e) { e.printStackTrace(); } } }
Result
No comments:
Post a Comment