package dao;

import util.InstanceFactory;

import com.mongodb.DB;
import com.mongodb.MongoClient;
import org.apache.log4j.Logger;

public class MongoConnector {

private static MongoConnector mongoConnectorInstance;

private DB DbConnection;

public static DB getConnection(String dbName) {

  MongoConnector.mongoConnectorInstance = InstanceFactory.instantiateAsSingleton(MongoConnector.class);

  if (MongoConnector.mongoConnectorInstance.DbConnection == null) {

    synchronized (MongoConnector.mongoConnectorInstance) {

      if (MongoConnector.mongoConnectorInstance.DbConnection == null) {
        MongoConnector.mongoConnectorInstance.DbConnection = MongoConnector.mongoConnectorInstance
.getDbConnection(dbName);
      }
    }
  }

  return MongoConnector.mongoConnectorInstance.DbConnection;

}

private DB getDbConnection(String dbName) {

  DB db = null;

  try {

    MongoClient mongoClient = new MongoClient("some ip address of mongos", 27017);

   // Now connect to your databases
   db = mongoClient.getDB(dbName);

   System.out.println("Connect to database successfully");

  } catch (Exception e) {
    System.err.println(e.getClass().getName() + ": " + e.getMessage());
  }

  return db;
  }
}

public static boolean insert(DBObject object, String table) {
    boolean status = false;
    if (object != null) {
        try {
            DB db = MongoConnector.getConnection("somedb");
            DBCollection collection = db.getCollection(table);
            //System.out.println(collection);
            if (collection == null) {
                db.createCollection(table, null);
            }
            collection.insert(object);
            status = true;
        } catch (Exception e) {
            MongoDao.logger.error("Could not insert in database" + e);
        }
    }
    return status;
}

DBobject o=new BasicDBObject("SomeColumn":"somevalue")
           .append("shardKey":"UP");
MongoDAO.insert(o,"sometable");

DBobject o = new BasicDBObject("SomeColumn" : "somevalue")
    .append("shardKey" : "UP");

DBobject o = new BasicDBObject("SomeColumn" : "somevalue")
    .append("State" : "UP");