Update app.py

app.py

@@ -70,13 +70,28 @@ except sqlite3.OperationalError:
     db.close()
 
     db = sqlite3.connect(DB_FILE)
+################db tabl2
+    
+try:
+    db.execute("SELECT * FROM reviews2").fetchall()
+    #db.execute("SELECT * FROM reviews2").fetchall()
+
+    db.close()
+except sqlite3.OperationalError:
+    db.execute(
+    '''
+    CREATE TABLE reviews2 (id TEXT, title TEXT, link TEXT,channel TEXT, description TEXT, views INTEGER, uploaded TEXT, duration INTEGER, durationString TEXT)
+    ''')
+    db.commit()
+    db.close()
 
-def get_latest_reviews(db: sqlite3.Connection):
+def get_latest_reviews11(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]
     reviews = pd.DataFrame(reviews, columns=["id", "date_created", "name", "rate", "celsci"])
     return reviews, total_reviews
 
+
 def get_latest_reviews2(db: sqlite3.Connection):
     reviews2 = db.execute("SELECT * FROM reviews2 ORDER BY id DESC limit 100").fetchall()
     total_reviews2 = db.execute("Select COUNT(id) from reviews2").fetchone()[0]
@@ -104,6 +119,29 @@ def ccogsphere(name: str, rate: int, celsci: str):
     r = requests.post(url='https://ccml-persistent-data2.hf.space/api/predict/', json={"data": [name,celsci]})
     #demo.load()
     return reviews, total_reviews
+    
+def ccogsphere11(name: str, rate: int, celsci: str):
+    db = sqlite3.connect(DB_FILE)
+    cursor = db.cursor()
+      
+    try:
+        celsci2=celsci.split()
+        print("split",celsci2,celsci)
+        celsci2=celsci2[0] + "+" + celsci2[1]
+        celsci2=ecf(celsci2)
+        celsci2=json.dumps(celsci2["videos"])
+    except:
+        celsci2=" No Info Found"
+    
+    celsci=celsci+celsci2
+    cursor.execute("INSERT INTO reviews(name, rate, celsci) VALUES(?,?,?)", [name, rate, celsci])
+    db.commit()
+    reviews, total_reviews = get_latest_reviews(db)
+    db.close()
+    r = requests.post(url='https://ccml-persistent-data2.hf.space/api/predict/', json={"data": [name,celsci]})
+    #demo.load()
+    return reviews, total_reviews
+    
 
 def run_actr():
     from python_actr import log_everything
@@ -135,10 +173,10 @@ def run_ecs(inp):
     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='append', index=False)
 
     #db.commit()
-    reviews2, total_reviews2 = get_latest_reviews(db)
+    reviews2, total_reviews2 = get_latest_reviews2(db)
     db.close()
     #print ("print000", total_reviews2,reviews2)
     return reviews2, total_reviews2
@@ -170,16 +208,16 @@ with gr.Blocks(css=css) as demo:
             celsci = gr.Textbox(label="c") #, lines=10, placeholder="Do you have any feedback on gradio?")
             #run_actr()
             submit = gr.Button(value=".")            
-            submit.click(ccogsphere, [name, rate, celsci], [data, count])
+            submit.click(run_ecs, [name, rate, celsci], [data, count])
             demo.load(load_data, None, [data, count])
-            @name.change(inputs=name, outputs=celsci,_js="window.location.reload()")
+            #@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":
                 #run_code()
-                load_data()
+                load_data2()
                 #return "Hello " + name + "!"
 def backup_db():
     shutil.copyfile(DB_FILE, "./reviews.db")