first commit

tables/cath_table.py

@@ -0,0 +1,25 @@
+# Таблица с категориями и действия с ними
+
+from dbtable import *
+
+class CathTable(DbTable):
+    def table_name(self):
+        return self.dbconn.prefix + "cath"
+
+    def columns(self):
+        return {"id": ["serial", "PRIMARY KEY"],
+                "cath_name": ["varchar(32)", "NOT NULL"]}
+
+    def table_constraints(self):
+        return ['CONSTRAINT "Name" UNIQUE (cath_name)']
+    
+    
+    def find_by_position(self, num):
+        sql = "SELECT * FROM " + self.table_name()
+        sql += " ORDER BY "
+        sql += ", ".join(self.primary_key())
+        sql += " LIMIT 1 OFFSET %(offset)s"
+        cur = self.dbconn.conn.cursor()
+        cur.execute(sql, {"offset": num - 1})
+        return cur.fetchone()       
+    

tables/dish_table.py

@@ -0,0 +1,29 @@
+# Таблица с блюдами и действия с ними
+
+from dbtable import *
+
+class DishTable(DbTable):
+    def table_name(self):
+        return self.dbconn.prefix + "dish"
+
+    def columns(self):
+        return {"id": ["serial", "PRIMARY KEY"],
+                "cath_id": ["integer", "REFERENCES cath(id)", "NOT NULL"],
+                "dish_name": ["varchar(32)", "NOT NULL"],
+                "cook_time": ["interval"], 
+                "manual": ["text"]}
+
+    def table_constraints(self):
+        return ['CONSTRAINT "Name Dish" UNIQUE (dish_name)']
+
+
+
+    def find_by_position(self, num):
+        sql = "SELECT * FROM " + self.table_name()
+        sql += " ORDER BY "
+        sql += ", ".join(self.primary_key())
+        sql += " LIMIT 1 OFFSET %(offset)s"
+        cur = self.dbconn.conn.cursor()
+        cur.execute(sql, {"offset": num - 1})
+        return cur.fetchone()       
+    

tables/people_table.py

@@ -0,0 +1,23 @@
+# Таблица персоны и особые действия с ней
+
+from dbtable import *
+
+class PeopleTable(DbTable):
+    def table_name(self):
+        return self.dbconn.prefix + "people"
+
+    def columns(self):
+        return {"id": ["serial", "PRIMARY KEY"],
+                "last_name": ["varchar(32)", "NOT NULL"],
+                "first_name": ["varchar(32)", "NOT NULL"],
+                "second_name": ["varchar(32)"]}
+
+    def find_by_position(self, num):
+        sql = "SELECT * FROM " + self.table_name()
+        sql += " ORDER BY "
+        sql += ", ".join(self.primary_key())
+        sql += " LIMIT 1 OFFSET %(offset)s"
+        cur = self.dbconn.conn.cursor()
+        cur.execute(sql, {"offset": num - 1})
+        return cur.fetchone()       
+    

tables/phones_table.py

@@ -0,0 +1,27 @@
+# Таблица Телефоны и особые действия с ней.
+
+from dbtable import *
+
+class PhonesTable(DbTable):
+    def table_name(self):
+        return self.dbconn.prefix + "phones"
+
+    def columns(self):
+        return {"person_id": ["integer", "REFERENCES people(id)"],
+                "phone": ["varchar(12)", "NOT NULL"]}
+    
+    def primary_key(self):
+        return ['person_id', 'phone']    
+
+    def table_constraints(self):
+        return ["PRIMARY KEY(person_id, phone)"]
+
+    def all_by_person_id(self, pid):
+        sql = "SELECT * FROM " + self.table_name()
+        sql += " WHERE person_id = %s"
+        sql += " ORDER BY "
+        sql += ", ".join(self.primary_key())
+        cur = self.dbconn.conn.cursor()
+        cur.execute(sql, str(pid))
+        return cur.fetchall()           
+