From 86f9dcf142bf8ff872cf0f6f2d89f23ea229f516 Mon Sep 17 00:00:00 2001 From: Daniel Langesten Date: Mon, 9 Mar 2015 15:59:23 +0100 Subject: removing processed mark on old entries before beginning to clean data --- cleaner.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/cleaner.go b/cleaner.go index 662eb2d..5bda1f4 100644 --- a/cleaner.go +++ b/cleaner.go @@ -19,6 +19,7 @@ const ( ) func cleanData() (err error) { + db, err := sql.Open("mysql", DATABASE_USER+":"+DATABASE_PASS+"@/"+DATABASE_NAME) if err != nil { log.Println("Failed to connect to db") @@ -26,6 +27,12 @@ func cleanData() (err error) { } defer db.Close() + //Remove the processed mark on entries older than 1 day + err = reprocess(db, time.Now().Add(-24*1*time.Hour)) + if err != nil { + return + } + //Fetch data that should be cleaned rDat, err := fetchRawData(db, MAXIMUM_ENTRIES) if err != nil { -- cgit v1.1