Rename app.py0 to app.py

app.py0 → app.py

@@ -53,27 +53,28 @@ DB_FILE = "./reviewsitr.db"
 
 # Create table if it doesn't already exist
 
-db = sqlite3.connect(DB_FILE)
-try:
-    db.execute("SELECT * FROM reviews").fetchall()
-    #db.execute("SELECT * FROM reviews2").fetchall()
+#db = sqlite3.connect(DB_FILE)
+#try:
+#    db.execute("SELECT * FROM reviews").fetchall()
+#    #db.execute("SELECT * FROM reviews2").fetchall()
+#
+#    db.close()
+#except sqlite3.OperationalError:
+#    db.execute(
+#        '''
+#        CREATE TABLE reviews (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
+#                              created_at TIMESTAMP DEFAULT (datetime('now', 'localtime', '+3 hours')) NOT NULL,
+#                              name TEXT, view TEXT, duration TEXT)
+#        ''')
+#    db.commit()
+#    db.close()
 
-    db.close()
-except sqlite3.OperationalError:
-    db.execute(
-        '''
-        CREATE TABLE reviews (id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
-                              created_at TIMESTAMP DEFAULT (datetime('now', 'localtime', '+3 hours')) NOT NULL,
-                              name TEXT, view TEXT, duration TEXT)
-        ''')
-    db.commit()
-    db.close()
-
-    db = sqlite3.connect(DB_FILE)
+#    db = sqlite3.connect(DB_FILE)
 # #created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP NOT NULL,
-def get_latest_reviews(db: sqlite3.Connection):
-    reviews = db.execute("SELECT * FROM reviews ORDER BY id DESC limit 100").fetchall()
-    total_reviews = db.execute("Select COUNT(id) from reviews").fetchone()[0]
+def get_latest_reviews() #db: sqlite3.Connection):
+    #reviews = db.execute("SELECT * FROM reviews ORDER BY id DESC limit 100").fetchall()
+    #total_reviews = db.execute("Select COUNT(id) from reviews").fetchone()[0]
+    total_reviews="N"
     reviews = pd.DataFrame(reviews, columns=["id", "date_created", "name", "view", "duration"])
     return reviews, total_reviews
 
@@ -84,8 +85,8 @@ def get_latest_reviews2(db: sqlite3.Connection):
     return reviews2, total_reviews2
     
 def ccogsphere(name: str, rate: int, celsci: str):
-    db = sqlite3.connect(DB_FILE)
-    cursor = db.cursor()
+    #db = sqlite3.connect(DB_FILE)
+    #cursor = db.cursor()
       
     #try:
     celsci2=celsci.split()
@@ -103,7 +104,7 @@ def ccogsphere(name: str, rate: int, celsci: str):
         db.commit()
     
     reviews, total_reviews = get_latest_reviews(db)
-    db.close()
+    #db.close()
     r = requests.post(url='https://ccml-persistent-data2.hf.space/api/predict/', json={"data": [celsci + " ", celsci2]}) 
 
     return reviews, total_reviews
@@ -130,27 +131,27 @@ def run_ecs(inp):
     try:
         result=ecf(inp)
         df=pd.DataFrame.from_dict(result["videos"])
-    except sqlite3.OperationalError:
+    except: # sqlite3.OperationalError:
         print ("db error")
     
     df=df.drop(df.columns[4], axis=1)
 
-    db = sqlite3.connect(DB_FILE)
+    #db = sqlite3.connect(DB_FILE)
     #cursor = db.cursor()
     #cursor.execute("INSERT INTO reviews2(title, link, thumbnail,channel, description, views, uploaded, duration, durationString) VALUES(?,?,?,?,?,?,?,?,?)", [title, link, thumbnail,channel, description, views, uploaded, duration, durationString])
-    df.to_sql('reviews2', db, if_exists='replace', index=False)
+    #df.to_sql('reviews2', db, if_exists='replace', index=False)
 
     #db.commit()
     reviews2, total_reviews2 = get_latest_reviews(db)
-    db.close()
+    #db.close()
     #print ("print000", total_reviews2,reviews2)
     return reviews2, total_reviews2
     
     
 def load_data():
-    db = sqlite3.connect(DB_FILE)
+    #db = sqlite3.connect(DB_FILE)
     reviews, total_reviews = get_latest_reviews(db)
-    db.close()
+    #db.close()
     return reviews, total_reviews
 def load_data2():
     db = sqlite3.connect(DB_FILE)
@@ -177,7 +178,7 @@ with gr.Blocks(css=css) as demo:
             demo.load(load_data, None, [data, count])
             @name.change(inputs=name, outputs=celsci,_js="window.location.reload()")
             @rate.change(inputs=rate, outputs=name,_js="window.location.reload()")
-            @celsci.change(inputs=celsci, outputs=rate,_js="window.location.reload()")  
+            celsci.change(inputs=celsci, outputs=rate,_js="window.location.reload()")  
             
             def secwork(name):
                 #if name=="abc":