X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=o2ims%2Fadapter%2Focloud_repository.py;h=32dced90b0f665d76507e58fb395ee1748292638;hb=8be81dfad35b08c4de77168e885bb18253069771;hp=ca902099c5ab68d29520c426022459d8b818b121;hpb=f1946a1e90036bb8a758b49f94ac4d3b40bae66e;p=pti%2Fo2.git diff --git a/o2ims/adapter/ocloud_repository.py b/o2ims/adapter/ocloud_repository.py index ca90209..32dced9 100644 --- a/o2ims/adapter/ocloud_repository.py +++ b/o2ims/adapter/ocloud_repository.py @@ -12,46 +12,10 @@ # See the License for the specific language governing permissions and # limitations under the License. -import abc -from typing import List, Set +from typing import List # from o2ims.adapter import orm from o2ims.domain import ocloud - - -class OcloudRepository(abc.ABC): - def __init__(self): - self.seen = set() # type: Set[ocloud.Ocloud] - - def add(self, ocloud: ocloud.Ocloud): - self._add(ocloud) - self.seen.add(ocloud) - - def get(self, ocloudid) -> ocloud.Ocloud: - ocloud = self._get(ocloudid) - if ocloud: - self.seen.add(ocloud) - return ocloud - - def list(self) -> List[ocloud.Ocloud]: - return self._list() - - def update(self, ocloud: ocloud.Ocloud): - self._update(ocloud) - - # def update_fields(self, ocloudid: str, updatefields: dict): - # self._update(ocloudid, updatefields) - - @abc.abstractmethod - def _add(self, ocloud: ocloud.Ocloud): - raise NotImplementedError - - @abc.abstractmethod - def _get(self, ocloudid) -> ocloud.Ocloud: - raise NotImplementedError - - @abc.abstractmethod - def _update(self, ocloud: ocloud.Ocloud): - raise NotImplementedError +from o2ims.domain.ocloud_repo import OcloudRepository class OcloudSqlAlchemyRepository(OcloudRepository): @@ -68,7 +32,8 @@ class OcloudSqlAlchemyRepository(OcloudRepository): oCloudId=ocloudid).first() def _list(self) -> List[ocloud.Ocloud]: - return self.session.query() + return self.session.query(ocloud.Ocloud).order_by( + ocloud.Ocloud.name).all() def _update(self, ocloud: ocloud.Ocloud): self.session.add(ocloud)