summaryrefslogtreecommitdiff
path: root/crawler
diff options
context:
space:
mode:
authorhorus_arch2018-02-17 18:04:04 +0100
committerhorus_arch2018-02-17 18:04:04 +0100
commit482cd21eafb78d6ed1a52497258699c4e36e979b (patch)
tree5b99b0460e5f9b5b4ec663b66daf895b3e8693f0 /crawler
parenta5febb8c285ca68e34f55c34d32d24aacd41a52d (diff)
downloadalkobote-482cd21eafb78d6ed1a52497258699c4e36e979b.tar.gz
Fix detect duplicates query, prevents error message. (crawler)
Diffstat (limited to 'crawler')
-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 {