@@ -77,7 +77,8 @@ def connect(self):
77
77
78
78
self .cursor = self .open_cursor ()
79
79
80
- def _get_driver (self , driver ):
80
+ @staticmethod
81
+ def _get_driver (driver ):
81
82
"""Funzione che permette di ottenere il driver
82
83
83
84
Arguments:
@@ -109,7 +110,8 @@ def _make_connection_string(self):
109
110
"""Crea stringa contenente credenziali per accedere al server MSSQL
110
111
111
112
Raises:
112
- ValueError: Restituisce errore se sono contemporaneamente impostate la connessione tramite username/password e autenticazione windows
113
+ ValueError: Restituisce errore se sono contemporaneamente impostate
114
+ la connessione tramite username/password e autenticazione windows
113
115
114
116
Returns:
115
117
str: Restituisce stringa di connessione
@@ -248,10 +250,10 @@ def insert_one(self, table_name, values, dbname=None):
248
250
"""Inserisce una nuova riga all'interno di una tabella
249
251
250
252
Args:
251
- dbname (str): Nome del database contenente la tabella a cui si vuole aggiugnere la riga
252
253
table_name (str): Nome della tabella a cui si vuole aggiungere la riga
253
- values (dict): dizionario contenente i valori che compongono la nuova riga che si desidera aggiungere
254
- fields (list, optional): colonne a cui vengono associati i nuovi valori. Defaults to None.
254
+ values (dict): dizionario contenente i valori che compongono la nuova riga che si desidera
255
+ aggiungere
256
+ dbname (str): Nome del database contenente la tabella a cui si vuole aggiugnere la riga
255
257
"""
256
258
257
259
logger .debug ("insert_one {0}.{1}" .format (dbname , table_name ))
@@ -300,8 +302,7 @@ def bulk_insertion(
300
302
301
303
multiple_values .append ("(" + values + ")" )
302
304
303
- if (idx > 0 and idx % record_each_statement == 0 or
304
- idx + 1 == len_data ):
305
+ if idx > 0 and idx % record_each_statement == 0 or idx + 1 == len_data :
305
306
306
307
statement = self .bulk_insert_statement .format (
307
308
table_name ,
@@ -315,13 +316,12 @@ def bulk_insertion(
315
316
executions += 1
316
317
317
318
except :
318
- logger .error ("Errore a idx {0}" .format (idx + 1 ))
319
+ logger .error ("Errore a idx {0}" .format (idx + 1 ))
319
320
logger .error ("Statement {}" .format (statement ))
320
321
logger .exception ("" )
321
322
return 1
322
323
323
- if (idx > 0 and idx % commit_every == 0 or
324
- idx + 1 == len_data ):
324
+ if idx > 0 and idx % commit_every == 0 or idx + 1 == len_data :
325
325
logger .info (
326
326
"Arrivato a {}/{} ({} executions)" .format (
327
327
idx , len_data , executions
@@ -393,6 +393,7 @@ def insert_many(self, data, dbname, table_name, step=5000):
393
393
logger .exception ("" )
394
394
return 1
395
395
396
+ @staticmethod
396
397
def _handle_datetimeoffset (dto_value ):
397
398
# ref: https://github.com/mkleehammer/pyodbc/issues/134#issuecomment-281739794
398
399
# https://github.com/mkleehammer/pyodbc/wiki/Using-an-Output-Converter-function
@@ -410,7 +411,8 @@ def _handle_datetimeoffset(dto_value):
410
411
timezone (timedelta (hours = tup [7 ], minutes = tup [8 ])),
411
412
)
412
413
413
- def _sql_clean (self , value ):
414
+ @staticmethod
415
+ def _sql_clean (value ):
414
416
"""Pulisce valori nulli e stringhe.
415
417
416
418
Ricevuto il valore da inserire nel db, esegue dei controlli per codificare
0 commit comments