Improve documentation of MysqlRed.flush()
This commit is contained in:
@@ -89,14 +89,19 @@ class MysqlRed:
|
|||||||
|
|
||||||
# Execute insert query
|
# Execute insert query
|
||||||
if cls._cached_insert_data:
|
if cls._cached_insert_data:
|
||||||
print( cls._cached_insert_data )
|
# Since cls._cached_insert_data is a dict, we need to have a custom
|
||||||
cursor.executemany( cls._insert_query, ( cls._cached_insert_data[ key ] for key in cls._cached_insert_data ) )
|
# Generator to iterate over it
|
||||||
|
cursor.executemany( cls._insert_query,
|
||||||
|
( cls._cached_insert_data[ key ]
|
||||||
|
for key in cls._cached_insert_data ) )
|
||||||
|
# Reset after writing
|
||||||
cls._cached_insert_data = {}
|
cls._cached_insert_data = {}
|
||||||
|
|
||||||
# Execute update query
|
# Execute update query
|
||||||
# Use executemany since update could not be reduced to one query
|
# Use executemany since update could not be reduced to one query
|
||||||
if cls._cached_update_data:
|
if cls._cached_update_data:
|
||||||
cursor.executemany( cls._update_query, cls._cached_update_data )
|
cursor.executemany( cls._update_query, cls._cached_update_data )
|
||||||
|
# Reset after writing
|
||||||
cls._cached_update_data = []
|
cls._cached_update_data = []
|
||||||
|
|
||||||
# Commit db changes
|
# Commit db changes
|
||||||
|
|||||||
Reference in New Issue
Block a user