try_except_for_tgBot

Python/TeleBot/tableCreator.py

@@ -3,22 +3,31 @@ import wget
 import parser
 import config
 
+
 connection = psycopg2.connect(host=config.hostname, dbname=config.databname, user=config.username, password=config.passw)
 cursor = connection.cursor()
-
 creat_qwery = """ create table Parser 
     (id serial primary key, page_name varchar(100), price varchar(10), priceDis varchar(30), mark varchar(10), scr varchar(100))"""
+# cursor.execute(creat_qwery)
+# connection.commit()
+try:
+    cursor.execute(creat_qwery)
+    connection.commit()
+except psycopg2.errors.DuplicateTable:
+    print("s")
+
 
-cursor.execute(creat_qwery)
-connection.commit()
 for i in range(15):
     print(i)
     url = 'https://amwine.ru' + parser.pictures[i].find('a').find('img').attrs['data-src']
     filename = f"Python\\TeleBot\img\{i}.jpg"
     wget.download(url, filename)
-    ins_qwery = f"""insert into public.Parser(page_name, price, priceDis, mark, scr) values ('{parser.name[i].text}', '{parser.price[i].text}', '{parser.priceDis[i].text}',  '{parser.mark[i].text}', '{filename}')"""
-    cursor.execute(ins_qwery)
-    connection.commit()
+    try:
+        ins_qwery = f"""insert into public.Parser(page_name, price, priceDis, mark, scr) values ('{parser.name[i].text}', '{parser.price[i].text}', '{parser.priceDis[i].text}',  '{parser.mark[i].text}', '{filename}')"""
+        cursor.execute(ins_qwery)
+        connection.commit()
+    except:
+        connection.rollback()
 
 cursor.close()