compile issues fix

1 files changed, 12 insertions, 11 deletions

diff --git a/cleaner.go b/cleaner.go
index 0e213c9..001542f 100644
--- a/cleaner.go
+++ b/cleaner.go
@@ -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
 		}
 	}