Optimize scada sql
This commit is contained in:
@@ -113,7 +113,7 @@ def delete_scada_device(name: str, cs: ChangeSet) -> ChangeSet:
|
|||||||
def clean_scada_device_cmd(name: str) -> ChangeSet:
|
def clean_scada_device_cmd(name: str) -> ChangeSet:
|
||||||
cs = ChangeSet()
|
cs = ChangeSet()
|
||||||
|
|
||||||
rows = read_all(name, 'select * from scada_device')
|
rows = read_all(name, 'select id from scada_device acs')
|
||||||
for row in rows:
|
for row in rows:
|
||||||
cs.delete({ 'type': 'scada_device', 'id': row['id'] })
|
cs.delete({ 'type': 'scada_device', 'id': row['id'] })
|
||||||
|
|
||||||
|
|||||||
@@ -139,7 +139,7 @@ def delete_scada_element(name: str, cs: ChangeSet) -> ChangeSet:
|
|||||||
def clean_scada_element_cmd(name: str) -> ChangeSet:
|
def clean_scada_element_cmd(name: str) -> ChangeSet:
|
||||||
cs = ChangeSet()
|
cs = ChangeSet()
|
||||||
|
|
||||||
rows = read_all(name, 'select * from scada_element')
|
rows = read_all(name, 'select id from scada_element acs')
|
||||||
for row in rows:
|
for row in rows:
|
||||||
cs.delete({ 'type': 'scada_element', 'id': row['id'] })
|
cs.delete({ 'type': 'scada_element', 'id': row['id'] })
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user