Monday, October 13, 2014

mongo with net beans not tested..

package com.mongodb.UserManager_mvn;

import java.net.UnknownHostException;
import java.util.Date;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.MongoClient;
import com.mongodb.MongoException;

public class TestMongo {

public static void main(String[] args) {
// TODO Auto-generated method stub
try {

/**** Connect to MongoDB ****/
// Since 2.10.0, uses MongoClient
MongoClient mongo = new MongoClient("localhost", 27017);

/**** Get database ****/
// if database doesn't exists, MongoDB will create it for you
DB db = mongo.getDB("testdb");

/**** Get collection / table from 'testdb' ****/
// if collection doesn't exists, MongoDB will create it for you
DBCollection table = db.getCollection("user");

/**** Insert ****/
// create a document to store key and value
BasicDBObject document = new BasicDBObject();
document.put("name", "mkyong");
document.put("age", 30);
document.put("createdDate", new Date());
table.insert(document);


System.out.println("Inserted : ");

/**** Find and display ****/
BasicDBObject searchQuery = new BasicDBObject();
searchQuery.put("name", "mkyong");

DBCursor cursor = table.find(searchQuery);

while (cursor.hasNext()) {
System.out.println(cursor.next());
}

/**** Update ****/
// search document where name="mkyong" and update it with new values
BasicDBObject query = new BasicDBObject();
query.put("name", "mkyong");

BasicDBObject newDocument = new BasicDBObject();
newDocument.put("name", "mkyong-updated");

BasicDBObject updateObj = new BasicDBObject();
updateObj.put("$set", newDocument);

table.update(query, updateObj);

System.out.println("\n Updated : ");

/**** Find and display ****/
BasicDBObject searchQuery2
   = new BasicDBObject().append("name", "mkyong-updated");

DBCursor cursor2 = table.find(searchQuery2);

while (cursor2.hasNext()) {
System.out.println(cursor2.next());
}




/**** Find and Delete ****/

BasicDBObject searchQuery3 = new BasicDBObject();
searchQuery3.put("name", "mkyong-updated" );

table.remove(searchQuery3);

System.out.println("\n Deleted");
/**** Done ****/
System.out.println("Done");

   } catch (UnknownHostException e) {
e.printStackTrace();
   } catch (MongoException e) {
e.printStackTrace();
   }

 }

}

No comments:

Post a Comment