File tree Expand file tree Collapse file tree 1 file changed +8
-1
lines changed
Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -24,6 +24,8 @@ def __init__(self, **kwargs):
2424 self ._db = kwargs .get ('db_name' , None ) or self .DB_SCHEMA ['db_name' ]
2525 self .DB_SCHEMA ['db_name' ] = self ._db # if came from kwargs
2626
27+ self .verbose = kwargs .get ('verbose' , False )
28+
2729 # Common connection and cursor for interacting with databse.
2830 self ._conn = None
2931 self ._cursor = None
@@ -70,6 +72,8 @@ def init_connection(self):
7072 self ._cursor = self ._conn .cursor ()
7173
7274 def commit (self ):
75+ if self .verbose :
76+ log .debug ("Performing COMMIT via %s" , self .connection )
7377 self .connection .commit ()
7478
7579 def close (self , commit = True ):
@@ -79,6 +83,8 @@ def close(self, commit=True):
7983 if conn == self ._conn :
8084 self ._conn = None
8185 self ._cursor = None
86+ if self .verbose :
87+ log .debug ("Clossing connection %s" , conn )
8288 conn .close ()
8389
8490 def __enter__ (self ):
@@ -153,7 +159,8 @@ def create_table(self, schema):
153159 pkey = schema .get ('primary_key' , None )
154160
155161 if self .table_exists (tbl_name ):
156- log .info ("Table %s exists, skipped from creation" , tbl_name )
162+ if self .verbose :
163+ log .debug ("Table %s exists, skipped from creation" , tbl_name )
157164 return
158165
159166 cols = []
You can’t perform that action at this time.
0 commit comments