@@ -724,37 +724,34 @@ def transfer(self) -> None:
724
724
safe_identifier_length (column [0 ]) for column in self ._sqlite_cur .description
725
725
]
726
726
if self ._mysql_insert_method .upper () == "UPDATE" :
727
+ sql : str
727
728
if check_mysql_values_alias_support (self ._mysql_version ):
728
- sql : str = (
729
- """
729
+ sql = """
730
730
INSERT
731
731
INTO `{table}` ({fields})
732
732
VALUES ({placeholders}) AS `__new__`
733
733
ON DUPLICATE KEY UPDATE {field_updates}
734
734
""" .format (
735
- table = safe_identifier_length (table ["name" ]),
736
- fields = ("`{}`, " * len (columns )).rstrip (" ," ).format (* columns ),
737
- placeholders = ("%s, " * len (columns )).rstrip (" ," ),
738
- field_updates = ("`{}`=`__new__`.`{}`, " * len (columns ))
739
- .rstrip (" ," )
740
- .format (* list (chain .from_iterable ((column , column ) for column in columns ))),
741
- )
735
+ table = safe_identifier_length (table ["name" ]),
736
+ fields = ("`{}`, " * len (columns )).rstrip (" ," ).format (* columns ),
737
+ placeholders = ("%s, " * len (columns )).rstrip (" ," ),
738
+ field_updates = ("`{}`=`__new__`.`{}`, " * len (columns ))
739
+ .rstrip (" ," )
740
+ .format (* list (chain .from_iterable ((column , column ) for column in columns ))),
742
741
)
743
742
else :
744
- sql : str = (
745
- """
743
+ sql = """
746
744
INSERT
747
745
INTO `{table}` ({fields})
748
746
VALUES ({placeholders})
749
747
ON DUPLICATE KEY UPDATE {field_updates}
750
748
""" .format (
751
- table = safe_identifier_length (table ["name" ]),
752
- fields = ("`{}`, " * len (columns )).rstrip (" ," ).format (* columns ),
753
- placeholders = ("%s, " * len (columns )).rstrip (" ," ),
754
- field_updates = ("`{}`=`{}`, " * len (columns ))
755
- .rstrip (" ," )
756
- .format (* list (chain .from_iterable ((column , column ) for column in columns ))),
757
- )
749
+ table = safe_identifier_length (table ["name" ]),
750
+ fields = ("`{}`, " * len (columns )).rstrip (" ," ).format (* columns ),
751
+ placeholders = ("%s, " * len (columns )).rstrip (" ," ),
752
+ field_updates = ("`{}`=`{}`, " * len (columns ))
753
+ .rstrip (" ," )
754
+ .format (* list (chain .from_iterable ((column , column ) for column in columns ))),
758
755
)
759
756
print (sql )
760
757
else :
0 commit comments