Subversion Repositories SmartDukaan

package com.spice.profitmandi.dao.repository;

import java.net.UnknownHostException;

import org.json.JSONObject;

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.MongoClient;
import com.mongodb.util.JSON;


public class Mongo {

        private static MongoClient mongo_local;
        private static MongoClient mongo_dtr;
        private static final String CONTENT ="CONTENT";
        private static final String SITE_CONTENT = "siteContent";
        private static final String CATALOG_DB = "Catalog";
        private static final String MASTER_DATA = "MasterData";
        private static final int MONGO_PORT = 27017;

        static {
                synchronized(Mongo.class){
                        try {
                                mongo_local = new MongoClient( "localhost" , MONGO_PORT );
                                mongo_dtr = new MongoClient("localhost", MONGO_PORT);
                        } catch (UnknownHostException e) {
                                e.printStackTrace();
                        }
                }
        }

        public static JSONObject getEntityById(long id) throws Exception{
                DB db = mongo_local.getDB(CONTENT);
                DBCollection collection = db.getCollection(SITE_CONTENT);
                BasicDBObject obj = new BasicDBObject();
                obj.append("_id", id);
                DBObject result = collection.findOne(obj);
                if (result==null){
                        throw new Exception();
                }
                return new JSONObject(JSON.serialize(result));
        }
        
        public static JSONObject getItemsByBundleId(long bundleId) throws Exception{
                DB db = mongo_dtr.getDB(CATALOG_DB);
                DBCollection collection = db.getCollection(MASTER_DATA);
                BasicDBObject obj = new BasicDBObject();
                BasicDBObject in_query = new BasicDBObject();
                obj.append("skuBundleId", bundleId);
                in_query.append("$in",new int[] {1,2,3,4,5,6,7});
                obj.append("source_id", in_query);
                DBObject result = collection.findOne(obj);
                if (result==null){
                        throw new Exception();
                }
                return new JSONObject(JSON.serialize(result));
        }
        
        public static JSONObject getItemByID(long id) throws Exception{
                DB db = mongo_dtr.getDB(CATALOG_DB);
                DBCollection collection = db.getCollection(MASTER_DATA);
                BasicDBObject obj = new BasicDBObject();
                obj.append("_id", id);
                DBObject result = collection.findOne(obj);
                if (result==null){
                        throw new Exception();
                }
                return new JSONObject(JSON.serialize(result));
        }

}