From 465d1e927b9309eb8bf997c0ec857ab3fc60c3dc Mon Sep 17 00:00:00 2001 From: jonnybravo Date: Thu, 16 Nov 2023 18:23:25 +0100 Subject: [PATCH] commit message from python script --- my_movies/database.py | 39 +++++++++++++++++++++++++-------------- 1 file changed, 25 insertions(+), 14 deletions(-) diff --git a/my_movies/database.py b/my_movies/database.py index 49066b4..924e1ff 100644 --- a/my_movies/database.py +++ b/my_movies/database.py @@ -1,4 +1,4 @@ -import sqlite3, os +import sqlite3, os, argv class db_work: def __init__(self,db_file = str ) -> None: @@ -22,8 +22,8 @@ class db_work: 'genre' TEXT PRIMARY KEY, 'beschreibung' TEXT ); """ - cursor.execute(sql_code - ) + cursor.execute(sql_code) + con_db.commit() def add_value_db(self): @@ -57,20 +57,31 @@ class db_work: cursor.execute(sql) - def show_value(self, sql_query = str): - with sqlite3.connect(self.db_file) as con_db: - cursor = con_db.cursor() - sql_code = sql_query - cursor.execute(sql_code) - ergebnis = cursor.fetchall() - return ergebnis - + def ausgabe_abfrage(self, sql_abfrage): + with sqlite3.connect(self.db_file) as daten: + try: + zeiger = daten.cursor() + zeiger.execute(sql_abfrage) + for datensatz in zeiger: + for wert in datensatz: + wert = str(wert) + print('| ', wert, " " * (9 - len(wert)), end="") + print("|") + except sqlite3.OperationalError: + print("Tabelle nicht gefunden!") + except: + print("Daten konnten nicht bearbeitet werden!") if __name__ == "__main__": script_folder = os.path.dirname(os.path.realpath(__file__)) db_file_full = script_folder + os.sep + "my_moviedb.db" my_db = db_work(db_file=db_file_full) - my_db.create_db() - add_value_to_db = my_db.add_value_db() + + for query in argv.sys.argv[1:]: + if query == '-q': + my_db.ausgabe_abfrage(sql_abfrage="""SELECT * FROM movies;""") + + + #my_db.create_db() + #add_value_to_db = my_db.add_value_db() #print (add_value_to_db) - print(my_db.show_value(sql_query="""SELECT * FROM movies;""")) \ No newline at end of file