- def _update(self, ocloud: ocloud.Ocloud):
- self.session.add(ocloud)
+ def _list(self) -> List[ocloud.ResourcePool]:
+ return self.session.query()
+
+ def _update(self, resourcePool: ocloud.ResourcePool):
+ self.session.add(resourcePool)
+
+
+class ResourceSqlAlchemyRepository(ResourceRepository):
+ def __init__(self, session):
+ super().__init__()
+ self.session = session
+
+ def _add(self, resource: ocloud.Resource):
+ self.session.add(resource)
+
+ def _get(self, resource_id) -> ocloud.Resource:
+ return self.session.query(ocloud.Resource).filter_by(
+ resourceId=resource_id).first()
+
+ def _list(self) -> List[ocloud.Resource]:
+ return self.session.query()