WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/dtr/storage/Mongo.py

 itemCashBackMap = {}
 DataService.initialize(db_hostname="localhost")
 mc = MemCache("127.0.0.1")
+SOURCE_MAP = {1:'AMAZON',2:'FLIPKART',3:'SNAPDEAL',4:'SAHOLIC'}
 def get_mongo_connection(host='localhost', port=27017):
     global con
     if con is None:
         print "Establishing connection %s host and port %d" %(host,port)
         try:
                                                              {"$set":{'updatedOn':to_java_date(datetime.now())}},upsert=False,multi=True)
         return {1:"Document deleted successfully"}
     except Exception as e:
         print e
         return {0:"Document not deleted."}
+def searchMaster(offset, limit, search_term):
+    data = []
+    try:
+        collection = get_mongo_connection().Catalog.MasterData.find({'source_product_name':re.compile(search_term, re.IGNORECASE),'source_id':{'$in':SOURCE_MAP.keys()}}).offset(offset).limit(limit)
+        for record in collection:
+            data.append(record)
+    except:
+        pass
+    return data
 def main():
     x = getNewDeals(1, 0, 0, 500, None, None)
     for i in x:
         print i['_id'],

Subversion Repositories SmartDukaan