Skip to content
Snippets Groups Projects
Commit 2325c4d1 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Context component:

- corrected slice_unset query filters
parent e75818fc
No related branches found
No related tags found
2 merge requests!54Release 2.0.0,!34Context Scalability extensions using CockroachDB + Removal of Stateful database inside Device + other
......@@ -202,21 +202,24 @@ def slice_unset(db_engine : Engine, request : Slice) -> Tuple[Dict, bool]:
def callback(session : Session) -> bool:
num_deletes = 0
num_deletes += session.query(SliceServiceModel)\
.filter(and_(
SliceServiceModel.slice_uuid == slice_uuid,
SliceServiceModel.service_uuid.in_(slice_service_uuids)
)).delete()
num_deletes += session.query(SliceSubSliceModel)\
.filter_by(and_(
SliceSubSliceModel.slice_uuid == slice_uuid,
SliceSubSliceModel.subslice_uuid.in_(slice_subslice_uuids)
)).delete()
num_deletes += session.query(SliceEndPointModel)\
.filter_by(and_(
SliceEndPointModel.slice_uuid == slice_uuid,
SliceEndPointModel.endpoint_uuid.in_(slice_endpoint_uuids)
)).delete()
if len(slice_service_uuids) > 0:
num_deletes += session.query(SliceServiceModel)\
.filter(and_(
SliceServiceModel.slice_uuid == slice_uuid,
SliceServiceModel.service_uuid.in_(slice_service_uuids)
)).delete()
if len(slice_subslice_uuids) > 0:
num_deletes += session.query(SliceSubSliceModel)\
.filter_by(and_(
SliceSubSliceModel.slice_uuid == slice_uuid,
SliceSubSliceModel.subslice_uuid.in_(slice_subslice_uuids)
)).delete()
if len(slice_endpoint_uuids) > 0:
num_deletes += session.query(SliceEndPointModel)\
.filter_by(and_(
SliceEndPointModel.slice_uuid == slice_uuid,
SliceEndPointModel.endpoint_uuid.in_(slice_endpoint_uuids)
)).delete()
return num_deletes > 0
updated = run_transaction(sessionmaker(bind=db_engine), callback)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment