From ed197e2a5d7ac73ef21d1c8c1db88fb9ddb5f8ca Mon Sep 17 00:00:00 2001 From: Sebastian Reichel Date: Mon, 16 Feb 2015 00:28:02 +0100 Subject: web: support setting product deprecation state --- src/database/database.vala | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) (limited to 'src/database/database.vala') diff --git a/src/database/database.vala b/src/database/database.vala index 9335b35..9c4e495 100644 --- a/src/database/database.vala +++ b/src/database/database.vala @@ -83,6 +83,8 @@ public class DataBase : Object { /* setup queries */ queries["product_name"] = "SELECT name FROM products WHERE id = ?"; queries["product_amount"] = "SELECT amount FROM products WHERE id = ?"; + queries["product_deprecated"]= "SELECT deprecated FROM products WHERE id = ?"; + queries["product_set_deprecated"] = "UPDATE products SET deprecated=? WHERE id = ?"; queries["products"] = "SELECT id, name, amount FROM products ORDER BY name"; queries["purchase"] = "INSERT INTO sales ('user', 'product', 'timestamp') VALUES (?, ?, ?)"; queries["last_purchase"] = "SELECT product FROM sales WHERE user = ? ORDER BY timestamp DESC LIMIT 1"; @@ -367,6 +369,34 @@ public class DataBase : Object { } } + public bool get_product_deprecated(uint64 article) throws DatabaseError { + statements["product_deprecated"].reset(); + statements["product_deprecated"].bind_text(1, "%llu".printf(article)); + + int rc = statements["product_deprecated"].step(); + + switch(rc) { + case Sqlite.ROW: + return statements["product_deprecated"].column_int(0) == 1; + case Sqlite.DONE: + throw new DatabaseError.PRODUCT_NOT_FOUND("unknown product: %llu", article); + default: + throw new DatabaseError.INTERNAL_ERROR("internal error: %d", rc); + } + } + + public void product_deprecate(uint64 article, bool value) throws DatabaseError { + int rc; + + statements["product_set_deprecated"].reset(); + statements["product_set_deprecated"].bind_int(1, value ? 1 : 0); + statements["product_set_deprecated"].bind_text(2, "%llu".printf(article)); + + rc = statements["product_set_deprecated"].step(); + if(rc != Sqlite.DONE) + throw new DatabaseError.INTERNAL_ERROR("internal error: %d", rc); + } + public Price get_product_price(int user, uint64 article) throws DatabaseError { int64 timestamp = (new DateTime.now_utc()).to_unix(); bool member = user != 0; -- cgit v1.2.3