compile issues

1 files changed, 5 insertions, 5 deletions

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
 }