From b757248a2922052342fbdb9540eafe50a2497129 Mon Sep 17 00:00:00 2001 From: Daniel Langesten Date: Tue, 10 Mar 2015 09:16:15 +0100 Subject: compile issues --- sqlQueries.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'sqlQueries.go') diff --git a/sqlQueries.go b/sqlQueries.go index a0c2012..aa95cba 100644 --- a/sqlQueries.go +++ b/sqlQueries.go @@ -10,13 +10,13 @@ import ( //Retrieves all rawdata older than tim func fetchRawData(db *sql.DB, tim time.Time) (rDat []RawData, err error) { - prepSel, err := db.Prepare("SELECT ip_src,ip_dst,time,port,packet_size FROM raw_data WHERE time < tim") + prepSel, err := db.Prepare("SELECT ip_src,ip_dst,time,port,packet_size FROM raw_data WHERE time < ?") if err != nil { log.Println("Failed to prepare select") return } - rows, err := prepSel.Query(numRows) + rows, err := prepSel.Query(tim) if err != nil { log.Println("Failed to query prepared selection") return @@ -59,12 +59,12 @@ func fetchRawData(db *sql.DB, tim time.Time) (rDat []RawData, err error) { } //Removes the process_time from every entry that started being proccesed before tim -func reprocess(db *sq.DB, tim time.Time) (err error) { +func reprocess(db *sql.DB, tim time.Time) (err error) { stmt, err := db.Prepare("UPDATE raw_data SET process_time = NULL WHERE process_time < ?") if err != nil { return } - _, err = stmt.Execute(tim) + _, err = stmt.Exec(tim) return } @@ -75,7 +75,7 @@ func purgeProcessed(db *sql.DB, tim time.Time) (err error) { if err != nil { return } - _, err = stmt.Execute(tim) + _, err = stmt.Exec(tim) return } -- cgit v1.1