Skip to content
Snippets Groups Projects
Commit 979f3d41 authored by Carlos Manso's avatar Carlos Manso
Browse files

Topology model updated to SQLAlchemy

parent 1a9c0447
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
...@@ -195,7 +195,7 @@ class ContextServiceServicerImpl(ContextServiceServicer): ...@@ -195,7 +195,7 @@ class ContextServiceServicerImpl(ContextServiceServicer):
return TopologyList(topologies=[db_topology.dump() for db_topology in db_topologies]) return TopologyList(topologies=[db_topology.dump() for db_topology in db_topologies])
@safe_and_metered_rpc_method(METRICS, LOGGER) @safe_and_metered_rpc_method(METRICS, LOGGER)
def GetTopology(self, request: TopologyId, contextt : grpc.ServicerContext) -> Topology: def GetTopology(self, request: TopologyId, context : grpc.ServicerContext) -> Topology:
context_uuid = request.context_id.context_uuid.uuid context_uuid = request.context_id.context_uuid.uuid
topology_uuid = request.topology_uuid.uuid topology_uuid = request.topology_uuid.uuid
...@@ -215,10 +215,9 @@ class ContextServiceServicerImpl(ContextServiceServicer): ...@@ -215,10 +215,9 @@ class ContextServiceServicerImpl(ContextServiceServicer):
with self.session() as session: with self.session() as session:
db_context: ContextModel = session.query(ContextModel).filter_by(context_uuid=context_uuid).one() db_context: ContextModel = session.query(ContextModel).filter_by(context_uuid=context_uuid).one()
topology_add = TopologyModel(topology_uuid=topology_uuid, context_fk=context_uuid) topology_add = TopologyModel(topology_uuid=topology_uuid, context_fk=context_uuid)
topology_add.context = db_context topology_add.context = db_context
updated = True updated = True
with self.session() as session:
result = session.query(TopologyModel).join(TopologyModel.context).filter(TopologyModel.topology_uuid==topology_uuid).options(contains_eager(TopologyModel.context)).one_or_none() result = session.query(TopologyModel).join(TopologyModel.context).filter(TopologyModel.topology_uuid==topology_uuid).options(contains_eager(TopologyModel.context)).one_or_none()
if not result: if not result:
......
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