@@ -56,6 +56,14 @@ def __init__(self, filename):
5656 def __enter__ (self ):
5757 return self
5858
59+ def commit (operation ):
60+ def wrapper (self , tablename , fields ):
61+ operation (self , tablename , fields )
62+ self .connection .commit ()
63+ print (f"{ datetime .datetime .now ()} : Commit is successful!!" )
64+ return wrapper
65+
66+ @commit
5967 def create_table (self , tablename , columns ):
6068 columns = list (columns )
6169 columns = " text, " .join (columns ) + " text"
@@ -69,6 +77,7 @@ def create_table(self, tablename, columns):
6977 finally :
7078 print (f"{ tablename } : created successfully!" )
7179
80+ @commit
7281 def insert (self , tablename , columns , values ):
7382 column = ", " .join (columns ) if len (columns ) > 1 else columns
7483 value = ", " .join (values ) if len (values ) > 1 else values
@@ -78,6 +87,7 @@ def insert(self, tablename, columns, values):
7887 except sql3 .Error as er :
7988 print (f"SQLite error: { ' ' .join (er .args )} " )
8089
90+ @commit
8191 def select (self , tablename , columns ):
8292 columns = ", " .join (columns ) if len (columns ) > 1 else columns
8393 command = f"SELECT { columns } FROM { tablename } "
@@ -88,6 +98,7 @@ def select(self, tablename, columns):
8898 finally :
8999 return self .cursor .fetchall ()
90100
101+ @commit
91102 def delete (self , tablename , conditions , logic = "AND" ):
92103 conditions = f" { logic } " .join (conditions ) if len (conditions ) > 1 else conditions
93104 command = f"DELETE FROM { tablename } WHERE { conditions } "
@@ -98,6 +109,7 @@ def delete(self, tablename, conditions, logic="AND"):
98109 finally :
99110 print (f"{ tablename } : deleted successfully!" )
100111
112+ @commit
101113 def update (self , tablename , columns , values ):
102114 columns = list (columns )
103115 values = list (values )
0 commit comments