LEFT | RIGHT |
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-2015 Eyeo GmbH | 4 # Copyright (C) 2006-2015 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, |
11 # but WITHOUT ANY WARRANTY; without even the implied warranty of | 11 # but WITHOUT ANY WARRANTY; without even the implied warranty of |
12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 12 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
13 # GNU General Public License for more details. | 13 # GNU General Public License for more details. |
14 # | 14 # |
15 # You should have received a copy of the GNU General Public License | 15 # You should have received a copy of the GNU General Public License |
16 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 16 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 |
18 import itertools | 18 import itertools |
19 | 19 |
20 from sitescripts.filterhits import db | 20 from sitescripts.filterhits import db |
21 | 21 |
22 def update(interval, data): | 22 def update(interval, data): |
23 """ | 23 """ |
24 Generator that provides all the SQL and parameters needed to update the | 24 Generator that provides all the SQL and parameters needed to update the |
25 aggregations for the given data + interval in the database. | 25 aggregations for the given data + interval in the database. |
26 """ | 26 """ |
27 for filter, filter_data in data['filters'].iteritems(): | 27 for filter, filter_data in data["filters"].iteritems(): |
28 yield ("""INSERT IGNORE INTO `filters` | 28 yield ("""INSERT IGNORE INTO `filters` |
29 (filter, sha1) VALUES (%s, UNHEX(SHA1(filter)))""", filter) | 29 (filter, sha1) VALUES (%s, UNHEX(SHA1(filter)))""", filter) |
30 | 30 |
31 domains = itertools.chain(filter_data.get("thirdParty", {}).iteritems(), | 31 domains = itertools.chain(filter_data.get("thirdParty", {}).iteritems(), |
32 filter_data.get("firstParty", {}).iteritems()) | 32 filter_data.get("firstParty", {}).iteritems()) |
33 for domain, domain_data in domains: | 33 for domain, domain_data in domains: |
34 yield ("""INSERT INTO `frequencies` | 34 yield ("""INSERT INTO `frequencies` |
35 (filter_sha1, domain, frequency, timestamp) | 35 (filter_sha1, domain, frequency, timestamp) |
36 VALUES (UNHEX(SHA1(%s)), %s, %s, FROM_UNIXTIME(%s)) | 36 VALUES (UNHEX(SHA1(%s)), %s, %s, FROM_UNIXTIME(%s)) |
37 ON DUPLICATE KEY UPDATE | 37 ON DUPLICATE KEY UPDATE |
38 frequency = ( | 38 frequency = ( |
39 POW(frequency, 1 - (UNIX_TIMESTAMP(VALUES(timestamp)) - | 39 POW(frequency, 1 - (UNIX_TIMESTAMP(VALUES(timestamp)) - |
40 UNIX_TIMESTAMP(timestamp)) / %s) * | 40 UNIX_TIMESTAMP(timestamp)) / %s) * |
41 POW(VALUES(frequency), (UNIX_TIMESTAMP(VALUES(timestamp)) - | 41 POW(VALUES(frequency), (UNIX_TIMESTAMP(VALUES(timestamp)) - |
42 UNIX_TIMESTAMP(timestamp)) / %s)), | 42 UNIX_TIMESTAMP(timestamp)) / %s)), |
43 timestamp = VALUES(timestamp)""", | 43 timestamp = VALUES(timestamp)""", |
44 filter, domain, domain_data["hits"], | 44 filter, domain, domain_data["hits"], |
45 int(domain_data["latest"] / 1000), interval, interval) | 45 int(domain_data["latest"] / 1000), interval, interval) |
LEFT | RIGHT |