Subversion Repositories SmartDukaan

Rev

Rev 22169 | Rev 22171 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 22169 Rev 22170
Line 1... Line 1...
1 
package com.spice.profitmandi.dao.repository.dtr;
 1 
package com.spice.profitmandi.dao.repository.dtr;
2 
 
 2 
 
3 
import java.lang.reflect.Type;
 3 
import java.lang.reflect.Type;
4 
import java.net.UnknownHostException;
 - 
 
5 
import java.util.ArrayList;
 4 
import java.util.ArrayList;
6 
import java.util.List;
 5 
import java.util.List;
7 
import java.util.Map;
 6 
import java.util.Map;
8 
 
 7 
 
9 
import javax.annotation.PostConstruct;
 - 
 
10 
 
 - 
 
11 
import org.json.JSONObject;
 8 
import org.json.JSONObject;
- 
 
 9 
import org.slf4j.Logger;
- 
 
 10 
import org.slf4j.LoggerFactory;
12 
import org.springframework.beans.factory.annotation.Value;
 11 
import org.springframework.beans.factory.annotation.Value;
13 
import org.springframework.stereotype.Component;
 - 
 
14 
 
 12 
 
15 
import com.google.gson.Gson;
 13 
import com.google.gson.Gson;
16 
import com.google.gson.reflect.TypeToken;
 14 
import com.google.gson.reflect.TypeToken;
17 
import com.mongodb.BasicDBObject;
 15 
import com.mongodb.BasicDBObject;
18 
import com.mongodb.DB;
 16 
import com.mongodb.DB;
Line 22... Line 20...
22 
import com.mongodb.MongoClient;
 20 
import com.mongodb.MongoClient;
23 
import com.mongodb.util.JSON;
 21 
import com.mongodb.util.JSON;
24 
import com.spice.profitmandi.dao.model.FofoForm;
 22 
import com.spice.profitmandi.dao.model.FofoForm;
25 
 
 23 
 
26 
public class Mongo {
 24 
public class Mongo {
- 
 
 25
- 
 
 26 
	private static final Logger LOGGER = LoggerFactory.getLogger(Mongo.class);
27 
 
 27 
 
28 
	private static final String CONTENT = "CONTENT";
 28 
	private static final String CONTENT = "CONTENT";
29 
	private static final String SITE_CONTENT = "siteContent";
 29 
	private static final String SITE_CONTENT = "siteContent";
30 
	private static final String CATALOG_DB = "Catalog";
 30 
	private static final String CATALOG_DB = "Catalog";
31 
	private static final String MASTER_DATA = "MasterData";
 31 
	private static final String MASTER_DATA = "MasterData";
32 
	private static final String FOFO_DB = "Fofo";
 32 
	private static final String FOFO_DB = "Fofo";
33 
	private static final String FOFO_FORM_COLLECTION = "RegistrationForm";
 33 
	private static final String FOFO_FORM_COLLECTION = "RegistrationForm";
34 
	private static final int MONGO_PORT = 27017;
 34 
	private static final int MONGO_PORT = 27017;
35 
 
 35 
 
- 
 
 36
36 
	@Value("${mongo.host}")
 37 
	@Value("${mongo.host}")
37 
	private String mongoHost;
 38 
	private String mongoHost;
38 
 
 39 
 
39 
	@Value("${content.mongo.host}")
 40 
	@Value("${content.mongo.host}")
40 
	private String contentMongoHost;
 41 
	private String contentMongoHost;
Line 42... Line 43...
42 
	private MongoClient mongoClient;
 43 
	private MongoClient mongoClient;
43 
	private MongoClient contentMongoClient;
 44 
	private MongoClient contentMongoClient;
44 
 
 45 
 
45 
	public Mongo() {
 46 
	public Mongo() {
46 
		try {
 47 
		try {
- 
 
 48 
			LOGGER.info("mongoHost => {}, contentMongoHost {} ", mongoHost, contentMongoHost);
47 
			mongoClient = new MongoClient(mongoHost, MONGO_PORT);
 49 
			mongoClient = new MongoClient(mongoHost, MONGO_PORT);
48 
			contentMongoClient = new MongoClient(contentMongoHost, MONGO_PORT);
 50 
			contentMongoClient = new MongoClient(contentMongoHost, MONGO_PORT);
49 
		} catch (Exception e) {
 51 
		} catch (Exception e) {
50 
			e.printStackTrace();
 52 
			e.printStackTrace();
51 
		}
 53 
		}