diff --git a/tasks/afc_copyvios.py b/tasks/afc_copyvios.py index 749edcb..4e6880a 100644 --- a/tasks/afc_copyvios.py +++ b/tasks/afc_copyvios.py @@ -207,11 +207,12 @@ class AFCCopyvios(Task): query2 = "INSERT INTO cache VALUES (?, DEFAULT, ?, ?)" query3 = "INSERT INTO cache_data VALUES (DEFAULT, ?, ?, ?, ?)" cache_id = sha256("1:1:" + page.get().encode("utf8")).digest() - data = [(cache_id, source.url, source.confidence, source.skipped) + buff = buffer(cache_id) + data = [(buff, source.url, source.confidence, source.skipped) for source in result.sources] with self.conn.cursor() as cursor: cursor.execute("START TRANSACTION") - cursor.execute(query1, (cache_id,)) - cursor.execute(query2, (cache_id, result.queries, result.time)) + cursor.execute(query1, (buff,)) + cursor.execute(query2, (buff, result.queries, result.time)) cursor.executemany(query3, data) cursor.execute("COMMIT") diff --git a/tasks/schema/afc_copyvios.sql b/tasks/schema/afc_copyvios.sql index 04a7845..b93a6d3 100644 --- a/tasks/schema/afc_copyvios.sql +++ b/tasks/schema/afc_copyvios.sql @@ -31,7 +31,7 @@ CREATE TABLE `cache_data` ( `cdata_cache_id` BINARY(32) NOT NULL, `cdata_url` VARCHAR(512) NOT NULL, `cdata_confidence` FLOAT NOT NULL DEFAULT 0, - `cdata_skipped` BOOLEAN NOT NULL DEFAULT "false", + `cdata_skipped` BOOLEAN NOT NULL DEFAULT 0, PRIMARY KEY (`cdata_id`), FOREIGN KEY (`cdata_cache_id`) REFERENCES `cache` (`cache_id`)