revert upgrade datawipe
This commit is contained in:
parent
b571b26433
commit
5eea698695
|
@ -23,32 +23,6 @@ def get_inv():
|
||||||
return INV
|
return INV
|
||||||
|
|
||||||
|
|
||||||
def upgrade_data():
|
|
||||||
con = op.get_bind()
|
|
||||||
|
|
||||||
sql = f"select * from {get_inv()}.data_wipe;"
|
|
||||||
for d in con.execute(sql):
|
|
||||||
document_id = d.document_id
|
|
||||||
author_id = d.author_id
|
|
||||||
name = d.name
|
|
||||||
device_id = d.device_id
|
|
||||||
description = d.description
|
|
||||||
start_time = d.start_time
|
|
||||||
end_time = d.end_time
|
|
||||||
severity = d.severity
|
|
||||||
|
|
||||||
sql = f"""insert into {get_inv()}.erase_data_wipe
|
|
||||||
(name, description, start_time, end_time, severity, device_id,
|
|
||||||
author_id, document_id)
|
|
||||||
values
|
|
||||||
({name}, {description}, {start_time}, {end_time}, {severity},
|
|
||||||
{device_id}, {author_id}, {document_id});
|
|
||||||
"""
|
|
||||||
con.execute(sql)
|
|
||||||
|
|
||||||
con.execute(sql)
|
|
||||||
|
|
||||||
|
|
||||||
def upgrade():
|
def upgrade():
|
||||||
op.create_table(
|
op.create_table(
|
||||||
'erase_data_wipe',
|
'erase_data_wipe',
|
||||||
|
|
Reference in a new issue