Rietveld Code Review Tool
Help | Bug tracker | Discussion group | Source code

Delta Between Two Patch Sets: sitescripts/reports/utils.py

Issue 8793015: Reports - user profile (Closed)
Left Patch Set: Reports - user profile Created Nov. 7, 2012, 9:38 a.m.
Right Patch Set: Reports - user profile Created Nov. 7, 2012, 11:39 a.m.
Left:
Right:
Use n/p to move between diff chunks; N/P to move between comments.
Jump to:
Left: Side by side diff | Download
Right: Side by side diff | Download
« no previous file with change/comment | « sitescripts/reports/template/showUser.html ('k') | sitescripts/reports/web/showUser.py » ('j') | no next file with change/comment »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
LEFTRIGHT
1 # coding: utf-8 1 # coding: utf-8
2 2
3 # This file is part of the Adblock Plus web scripts, 3 # This file is part of the Adblock Plus web scripts,
4 # Copyright (C) 2006-2012 Eyeo GmbH 4 # Copyright (C) 2006-2012 Eyeo GmbH
5 # 5 #
6 # Adblock Plus is free software: you can redistribute it and/or modify 6 # Adblock Plus is free software: you can redistribute it and/or modify
7 # it under the terms of the GNU General Public License version 3 as 7 # it under the terms of the GNU General Public License version 3 as
8 # published by the Free Software Foundation. 8 # published by the Free Software Foundation.
9 # 9 #
10 # Adblock Plus is distributed in the hope that it will be useful, 10 # Adblock Plus is distributed in the hope that it will be useful,
(...skipping 30 matching lines...) Expand all
41 (startTime, count, offset)) 41 (startTime, count, offset))
42 rows = cursor.fetchall() 42 rows = cursor.fetchall()
43 cursor.close() 43 cursor.close()
44 if len(rows) == 0: 44 if len(rows) == 0:
45 break 45 break
46 for row in rows: 46 for row in rows:
47 yield row 47 yield row
48 offset += len(rows) 48 offset += len(rows)
49 49
50 def getReportsForUser(contact): 50 def getReportsForUser(contact):
51 count = 1000 51 cursor = get_db().cursor(MySQLdb.cursors.DictCursor)
Wladimir Palant 2012/11/07 09:46:18 We don't need this complicated setup for user repo
Andrey Novikov 2012/11/07 11:39:38 Done.
52 offset = 0 52 executeQuery(cursor,
53 while True: 53 '''SELECT guid, type, UNIX_TIMESTAMP(ctime) AS ctime, status, site , contact,
54 cursor = get_db().cursor(MySQLdb.cursors.DictCursor) 54 comment, hasscreenshot, knownissues
55 executeQuery(cursor, 55 FROM #PFX#reports WHERE contact = %s ORDER BY ctime DESC LIMIT 100 ''',
56 '''SELECT guid, type, UNIX_TIMESTAMP(ctime) AS ctime, status, si te, contact, 56 (contact))
57 comment, hasscreenshot, knownissues 57 rows = cursor.fetchall()
58 FROM #PFX#reports WHERE contact = %s LIMIT %s OFFSET %s''', 58 cursor.close()
59 (contact, count, offset)) 59 return rows
60 rows = cursor.fetchall()
61 cursor.close()
62 if len(rows) == 0:
63 break
64 for row in rows:
65 yield row
66 offset += len(rows)
67 60
68 def getReport(guid): 61 def getReport(guid):
69 cursor = get_db().cursor() 62 cursor = get_db().cursor()
70 executeQuery(cursor, 63 executeQuery(cursor,
71 '''SELECT dump FROM #PFX#reports WHERE guid = %s''', 64 '''SELECT dump FROM #PFX#reports WHERE guid = %s''',
72 (guid)) 65 (guid))
73 report = cursor.fetchone() 66 report = cursor.fetchone()
74 if report == None: 67 if report == None:
75 return None 68 return None
76 69
(...skipping 184 matching lines...) Expand 10 before | Expand all | Expand 10 after
261 dbpasswd = get_config().get('reports', 'dbpassword') 254 dbpasswd = get_config().get('reports', 'dbpassword')
262 if os.name == 'nt': 255 if os.name == 'nt':
263 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8', named_pipe=True) 256 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8', named_pipe=True)
264 else: 257 else:
265 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8') 258 return MySQLdb.connect(user=dbuser, passwd=dbpasswd, db=database, use_unicod e=True, charset='utf8')
266 259
267 def executeQuery(cursor, query, args=None): 260 def executeQuery(cursor, query, args=None):
268 tablePrefix = get_config().get('reports', 'dbprefix') 261 tablePrefix = get_config().get('reports', 'dbprefix')
269 query = re.sub(r'#PFX#', tablePrefix, query) 262 query = re.sub(r'#PFX#', tablePrefix, query)
270 cursor.execute(query, args) 263 cursor.execute(query, args)
LEFTRIGHT

Powered by Google App Engine
This is Rietveld