diff options
Diffstat (limited to 'cleaner.go')
| -rw-r--r-- | cleaner.go | 23 |
1 files changed, 12 insertions, 11 deletions
@@ -6,22 +6,23 @@ import ( "fmt" _ "github.com/go-sql-driver/mysql" "log" + "os" "time" ) var ( - logger *log.Logger + cllogger *log.Logger ) func init() { - logger = log.New(os.Stdout, "[ Cleaner ]", log.LstdFlags) + cllogger = log.New(os.Stdout, "[ Cleaner ]", log.LstdFlags) } func cleanFromDB(cfg *Config) (rowsLeft int, err error) { db, err := sql.Open("mysql", cfg.DBUser+":"+cfg.DBPass+"@"+cfg.DBConn+"/"+cfg.DBName) if err != nil { - logger.Println("Failed to connect to db") + cllogger.Println("Failed to connect to db") return } defer db.Close() @@ -41,20 +42,20 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) { //Fetch data that should be cleaned rDat, err := fetchRawData(db, cfg, cleanLimit) if err != nil { - logger.Println("Faild to fetch raw data") + cllogger.Println("Faild to fetch raw data") return } cDat, err := clean(rDat, cfg) if err != nil { - logger.Println("Failed to clean data from db:", err) + cllogger.Println("Failed to clean data from db:", err) return } //Begin transaction tx, err := db.Begin() if err != nil { - logger.Println("Failed to initialize transaction") + cllogger.Println("Failed to initialize transaction") return } @@ -62,7 +63,7 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) { err = insertCleanData(tx, cfg, cDat) if err != nil { tx.Rollback() - logger.Println("Failed to save cleaned data") + cllogger.Println("Failed to save cleaned data") return } @@ -70,13 +71,13 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) { err = purgeRawData(tx, cfg, rDat) if err != nil { tx.Rollback() - logger.Println("Failed to remove old data") + cllogger.Println("Failed to remove old data") return } rowsLeft, err = availableRows(tx, cfg, cleanLimit) if err != nil { tx.Rollback() - logger.Println("Failed to fetch available rows") + cllogger.Println("Failed to fetch available rows") return } @@ -88,12 +89,12 @@ func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error { for rDat := range rDatChan { cDat, err := clean(rDat, cfg) if err != nil { - logger.Println("Failed to clean data from stdin:", err) + cllogger.Println("Failed to clean data from stdin:", err) return err } err = insertCleanDataToDB(cfg, cDat) if err != nil { - logger.Println("Failed to insert clean data from stdin:", err) + cllogger.Println("Failed to insert clean data from stdin:", err) return err } } |