diff options
| author | Max | 2018-02-06 00:35:39 +0100 |
|---|---|---|
| committer | Max | 2018-02-06 00:35:39 +0100 |
| commit | 71950479fbd6088f249e5fda3b180f294d1d745d (patch) | |
| tree | 06f360a7e02b7e0011bda815fa102ec54ae8d0ec /shops.go | |
| parent | 13a807854bf4d0258723ec3152b217ed4cf8e051 (diff) | |
| download | alkobote-71950479fbd6088f249e5fda3b180f294d1d745d.tar.gz | |
Moves crawler to designated directory.
Diffstat (limited to 'shops.go')
| -rw-r--r-- | shops.go | 114 |
1 files changed, 0 insertions, 114 deletions
diff --git a/shops.go b/shops.go deleted file mode 100644 index 92b11cd..0000000 --- a/shops.go +++ /dev/null @@ -1,114 +0,0 @@ -package main - -import ( - "log" -) - -func (app *App) insertShops() error { - shops := getShopsFromStruct() - - query := `INSERT IGNORE INTO shop (name, url, logo_url, shipping_costs, free_shipping) VALUES(?, ?, ?, ?, ?)` - - for _, v := range shops { - - _, err := app.DB.Exec(query, v.Name, v.Url, v.Logo_url, v.Shipping_costs, v.Free_shipping) - if err != nil { - return err - } - } - - return nil - -} - -func getShopsFromStruct() []Shop { - Shops := []Shop{} - - Shops = append(Shops, Shop{ - Name: "Bottleworld", - Url: "https://www.bottleword.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "MC Whisky", - Url: "https://www.mcwhisky.com", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Rum & Co", - Url: "https://www.rumundco.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Whic", - Url: "https://whic.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Whisky.de", - Url: "https://www.whisky.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Whiskysite.nl", - Url: "https://www.whiskysite.nl", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Whisky World", - Url: "https://www.whiskyworld.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - Shops = append(Shops, Shop{ - Name: "Whiskyzone", - Url: "https://www.whiskyzone.de", - Logo_url: "", - Shipping_costs: 0, - Free_shipping: "", - }) - - return Shops -} - -func (app *App) getShops() ([]Shop, error) { - - Shops := []Shop{} - - query := `SELECT id,name,url,logo_url,shipping_costs,free_shipping FROM shop` - - rows, err := app.DB.Queryx(query) - if err != nil { - return []Shop{}, err - } - defer rows.Close() - - for rows.Next() { - var shop Shop - err = rows.StructScan(&shop) - - if err != nil { - return []Shop{}, err - } - if app.Config.Debug { - log.Println("Appending: " + shop.Name) - } - - Shops = append(Shops, shop) - } - - return Shops, nil -} |
