diff options
| -rw-r--r-- | crawler/database.go | 7 |
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 { |