diff options
| author | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-12 11:05:29 +0100 |
|---|---|---|
| committer | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-12 11:05:29 +0100 |
| commit | dc28b63102b26c34db2e056972d0b7173e263652 (patch) | |
| tree | 4083daae3d9d6234e1604240c487954d8e84f6f8 /sqlQueries.go | |
| parent | 5a1a9adba51f858c45b6cba7e7a8c174d8cda481 (diff) | |
removed constants from cleaner and added them as parameters so the code is more modular
Diffstat (limited to 'sqlQueries.go')
| -rw-r--r-- | sqlQueries.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/sqlQueries.go b/sqlQueries.go index ef0c791..99a35d2 100644 --- a/sqlQueries.go +++ b/sqlQueries.go @@ -85,6 +85,7 @@ func purgeProcessed(db *sql.DB, tim time.Time) (err error) { return } +//Removes all rawdata that is in rDat from the database func purgeRawData(tx *sql.Tx, rDat []RawData) (err error) { prepStmt, err := tx.Prepare("DELETE FROM raw_data WHERE ip_src = ? AND ip_dst = ? AND time = ? AND port = ? AND packet_size = ? AND process_time IS NOT NULL LIMIT 1") if err != nil { |