diff options
Diffstat (limited to 'sqlQueries.go')
| -rw-r--r-- | sqlQueries.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/sqlQueries.go b/sqlQueries.go index e7eb06f..79b3847 100644 --- a/sqlQueries.go +++ b/sqlQueries.go @@ -67,7 +67,7 @@ func fetchRawData(db *sql.DB, cfg *Config, tim time.Time) (rDat []RawData, err e for rows.Next() { var r RawData var tim []byte - err = rows.Scan(&r.IpSrc, &r.IpDst, &r.AsSrc, &r.AsDst, &r.PortSrc, &r.PortDst, &r.Packets, &r.PktLenDist, &tim) + err = rows.Scan(&r.Ip_src, &r.Ip_dst, &r.As_src, &r.As_dst, &r.Port_src, &r.Port_dst, &r.Packets, &r.Pkt_len_distrib, &tim) if err != nil { slogger.Println("Failed to scan result of query") return @@ -78,7 +78,7 @@ func fetchRawData(db *sql.DB, cfg *Config, tim time.Time) (rDat []RawData, err e return } - _, err = prepUp.Exec(time.Now(), r.IpSrc, r.IpDst, r.AsSrc, r.AsDst, r.PortSrc, r.PortDst, r.Packets, r.PktLenDist, r.time) + _, err = prepUp.Exec(time.Now(), r.Ip_src, r.Ip_dst, r.As_src, r.As_dst, r.Port_src, r.Port_dst, r.Packets, r.Pkt_len_distrib, tim) if err != nil { slogger.Println("Failed to query prepared update") tx.Rollback() @@ -121,7 +121,7 @@ func purgeRawData(tx *sql.Tx, cfg *Config, rDat []RawData) (err error) { } for _, r := range rDat { - _, err = prepStmt.Exec(r.IpSrc, r.IpDst, r.AsSrc, r.AsDst, r.PortSrc, r.PortDst, r.Packets, r.PktLenDist) + _, err = prepStmt.Exec(r.Ip_src, r.Ip_dst, r.As_src, r.As_dst, r.Port_src, r.Port_dst, r.Packets, r.Pkt_len_distrib) if err != nil { return } |