for row in bar_list:
keys = ','.join(row.keys()) # 以字典形式传入sql
values = ','.join(['%s'] * len(row))
insert_sql = f"INSERT INTO {self.table}({keys}) VALUES ({values})ON DUPLICATE KEY UPDATE"
update = ','.join([f" {key} = %s" for key in row])
insert_sql += update # 如有重复则更新,没有则插
try
self.cursor.execute(insert_sql, tuple(row.values()) * 2
self.conn.commit()
except Exception as e:
self.conn.rollback()
print("???插入数据失败???执行回滚...", e.args)
keys = ','.join(row.keys()) # 以字典形式传入sql
values = ','.join(['%s'] * len(row))
insert_sql = f"INSERT INTO {self.table}({keys}) VALUES ({values})ON DUPLICATE KEY UPDATE"
update = ','.join([f" {key} = %s" for key in row])
insert_sql += update # 如有重复则更新,没有则插
try
self.cursor.execute(insert_sql, tuple(row.values()) * 2
self.conn.commit()
except Exception as e:
self.conn.rollback()
print("???插入数据失败???执行回滚...", e.args)