diff options
| author | horus_arch | 2018-02-19 15:15:45 +0100 |
|---|---|---|
| committer | horus_arch | 2018-02-19 15:15:45 +0100 |
| commit | e3312da52d0ede1c5f783feba0840c53eeca723d (patch) | |
| tree | 5eecf493a0c2bbd0d5debe4fd2fb73cfd714c9b0 /crawler/database.go | |
| parent | 8700aaaec582744a04af65eeff7e9ff8555b194a (diff) | |
| download | alkobote-e3312da52d0ede1c5f783feba0840c53eeca723d.tar.gz | |
Bugfix + detects age. (crawler)
Diffstat (limited to 'crawler/database.go')
| -rw-r--r-- | crawler/database.go | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/crawler/database.go b/crawler/database.go index cf8989a..c1e0dd7 100644 --- a/crawler/database.go +++ b/crawler/database.go @@ -23,12 +23,13 @@ func (app *App) createTables() error { query2 := `CREATE TABLE IF NOT EXISTS angebot ( id INTEGER PRIMARY KEY AUTO_INCREMENT, - shop INT NOT NULL, name VARCHAR(255) NOT NULL, - url VARCHAR(255) NOT NULL, - short_url TEXT, abv DECIMAL(10,2) NOT NULL, volume DECIMAL(10,2) NOT NULL, + age INT NOT NULL DEFAULT 0, + shop INT NOT NULL, + url VARCHAR(255) NOT NULL, + short_url TEXT, original_price INT NOT NULL, discounted_price INT NOT NULL, base_price INT NOT NULL, @@ -99,7 +100,7 @@ func (app *App) save_offer(W []Angebot) error { // 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 = ?` + 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) |