summaryrefslogtreecommitdiff
path: root/crawler/database.go
diff options
context:
space:
mode:
Diffstat (limited to 'crawler/database.go')
-rw-r--r--crawler/database.go7
1 files changed, 4 insertions, 3 deletions
diff --git a/crawler/database.go b/crawler/database.go
index 41ef4f0..35a23ef 100644
--- a/crawler/database.go
+++ b/crawler/database.go
@@ -99,10 +99,11 @@ func (app *App) save_offer(W []Angebot) error {
continue
}
- err := app.DB.QueryRow("SELECT 1 FROM all_view WHERE shop_id = ? AND name = ? AND long_url = ? AND original_price = ? AND discounted_price = ? AND spirit_type = ?", o.Shop, o.Name, o.Url, o.Original_price, o.Discounted_price, o.Spirit_type).Scan(&found)
+ // resembles UNIQUE constraint
+ detect_duplicate_query := `SELECT 1 FROM all_view WHERE name = ? AND shop_id = ? AND
+ volume = ? AND abv = ? AND original_price = ? AND discounted_price = ? AND valid_until = ?`
- /*
- */
+ err := app.DB.QueryRow(detect_duplicate_query, o.Name, o.Shop, o.Volume, o.Abv, o.Original_price, o.Discounted_price, o.Valid_until).Scan(&found)
if err == sql.ErrNoRows {