@@ -253,7 +253,7 @@ def bulk_create_or_update_on_duplicate(
253
253
return {'rowcount' : 0 , 'items_count' : 0 }
254
254
255
255
items_count = len (items )
256
- db_name = model_cls .__tablename__
256
+ table_name = model_cls .__tablename__
257
257
fields = list (items [0 ].keys ())
258
258
unique_keys = [c .name for i in model_cls .__table_args__ if isinstance (
259
259
i , UniqueConstraint ) for c in i ]
@@ -280,15 +280,15 @@ def bulk_create_or_update_on_duplicate(
280
280
sql_on_update = ', ' .join ([
281
281
f' { field } = excluded.{ field } '
282
282
for field in fields if field not in unique_keys ])
283
- sql = f"""INSERT INTO { db_name } ({ ", " .join (fields )} ) VALUES
283
+ sql = f"""INSERT INTO { table_name } ({ ", " .join (fields )} ) VALUES
284
284
({ ", " .join ([f':{ key } ' for key in fields ])} )
285
285
ON CONFLICT ({ ", " .join (unique_keys )} ) DO UPDATE SET
286
286
{ sql_on_update } """
287
287
elif engine .name == 'mysql' :
288
288
sql_on_update = '`, `' .join ([
289
289
f' `{ field } ` = new.{ field } ' for field in fields
290
290
if field not in unique_keys ])
291
- sql = f"""INSERT INTO { db_name } (`{ "`, `" .join (fields )} `) VALUES
291
+ sql = f"""INSERT INTO { table_name } (`{ "`, `" .join (fields )} `) VALUES
292
292
({ ", " .join ([f':{ key } ' for key in fields ])} ) AS new
293
293
ON DUPLICATE KEY UPDATE
294
294
{ sql_on_update } """
0 commit comments