Added fetchTweets method in datalink with epooch timestamp support

Author: Sudhanshu

main.py

@@ -1,12 +1,12 @@
 from src import features, datalink, hashtags
+import time
 
 dblink = datalink.DatabaseConnectionDown('perilipsi_tweets')
 emoTest = features.Emoticons()
 dictTest = features.DictionaryTest()
-testTweet = dblink.fetchTweet()
 hashtest = hashtags.hashtags()
-print hashtest.analyseHashtagTweet(testTweet)
-
-print "\n\n"+testTweet+"\n\n"
+testTweet, tweetTime = dblink.fetchTweet()['tweet'], dblink.fetchTweet()['time']
+print testTweet+" Time:"+`tweetTime`
 print "Emoticons:", emoTest.analyse(testTweet)
 print "DictionaryTest:", dictTest.analyse(testTweet)
+print "Hashtags: ",hashtest.analyseHashtagTweet(testTweet)

src/datalink.py

@@ -1,4 +1,4 @@
-import MySQLdb, random
+import MySQLdb, random, time
 
 class DatabaseConnectionDown:
 	def __init__(self,adb):
@@ -14,12 +14,30 @@ def __init__(self,adb):
 
 	def fetchTweet(self):
 		'''
-		This method returns a random tweet from the Database
+		This method returns a dictionary of tweet and its timestamp from the Database
+		DictKeys: 'tweet', 'time'
 		'''
 		randomNo = random.randint(1,10000);
 		with self.db:
 			cur=self.db.cursor()
-			query = "Select `text` from `"+self.adb+"`.`tweet` where `iso_language` ='en' LIMIT "+`randomNo`+", "+`randomNo+1`
+			query = "Select `text`, `created_at` from `"+self.adb+"`.`tweet` where `iso_language` ='en' LIMIT "+`randomNo`+", "+`randomNo+1`
 			cur.execute(query)
 			temp = cur.fetchone()
-			return temp[0]
+			return {'tweet':temp[0], 'time':int(time.mktime(time.strptime(str(temp[1]),'%Y-%m-%d %H:%M:%S')))}
+
+	def fetchTweets(self, limit):
+		'''
+		This method returns a dictionary of list of tweets and list of timestamps from the Database
+		DictKeys: 'tweets', 'time'
+		'''
+		with self.db:
+			cur=self.db.cursor()
+			query = "Select `text`, `created_at` from `"+self.adb+"`.`tweet` where `iso_language` ='en' LIMIT 0,"+`limit`
+			cur.execute(query)
+			temp = cur.fetchall()
+			tweets = []
+			timestamps = []
+			for i in temp:
+				tweets.append(i[0])
+				timestamps.append(int(time.mktime(time.strptime(str(i[1]),'%Y-%m-%d %H:%M:%S'))))
+			return {'tweets':tweets, 'time':timestamps}