Requirement:
Download Java driver for mongoDB and add it to the classpath in the java script.
import java.lang.String;
import java.net.UnknownHostException;
import java.util.Set;
import com.mongodb.BasicDBObject;
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 lrapi.lr;
public class Actions
{
static String HostName ="localhost";
static Integer Port = 27017;
static String Username ="Harinder";
static String Password ="Password";
Mongo mDB;
DB db;
public int init() throws Throwable{
try {
mDB= new Mongo( HostName , Port ); //connect to MongoDB using HostName and Port
db = mDB.getDB("test"); // get test database from MongoDB
boolean auth = db.authenticate(Username, Password.toCharArray()); //authenticate user access to test database
if (auth = true)
lr.output_message("Successfully Authenticated");
else
lr.output_message("Incorrect Username/Password");
}catch (UnknownHostException e) {
e.printStackTrace();
}
return 0;
}//end of init function
public int action() throws Throwable {
try {
InsertInToMongoDB("Harinder1", "Seera1", "ThisIsMongoDB1@gmail.com");
}catch (MongoException e){
e.printStackTrace();
}
try {
SearchMongoDB("Harinder");
}catch (MongoException e){
e.printStackTrace();
}
return 0;
}//end of action function
public int end() throws Throwable {
mDB.close();
return 0;
}//end of end function
public void InsertInToMongoDB(String FirstName, String LastName, String Email)
{
// Get collection from mongoDB.
// If collection doesn't exist, mongoDB will create it automatically
DBCollection collection = db.getCollection("MyCollection");
BasicDBObject document = new BasicDBObject(); // create a document to store key and value
document.put("FirstName",FirstName);
document.put("LastName", LastName);
document.put("Email", Email);
collection.insert(document); //save the document into collection
}
public void SearchMongoDB(String FirstName)
{
DBCollection collection = db.getCollection("MyCollection");
BasicDBObject srchQuery = new BasicDBObject(); // search query
srchQuery.put("FirstName", FirstName);
DBCursor cur = collection.find(srchQuery); // query it
// loop over the cursor and display the retrieved result
while (cur.hasNext()) {
System.out.println(cur.next()); //I am using it only for the blog purpose to show the output.
}
}
}
mongoDB output:


No comments:
Post a Comment