X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2dms%2Fadapter%2Fdms_repository.py;fp=o2dms%2Fadapter%2Fdms_repository.py;h=5dd2bb1d339214046ad763d22d3170dcff73e43f;hb=c3ab2dcb442a0e66b7a621c59c6c7a679c26cee9;hp=c69acff2a652f20a4ce5acc71620851e882d0610;hpb=66318dfadc702f79ee8bc2a7c2289803b1b01033;p=pti%2Fo2.git diff --git a/o2dms/adapter/dms_repository.py b/o2dms/adapter/dms_repository.py index c69acff..5dd2bb1 100644 --- a/o2dms/adapter/dms_repository.py +++ b/o2dms/adapter/dms_repository.py @@ -28,10 +28,16 @@ class NfDeploymentDescSqlAlchemyRepository(dms_repo def _get(self, nfdeployment_desc_id) -> dms.NfDeploymentDesc: return self.session.query(dms.NfDeploymentDesc).filter_by( - nfDeploymentDescId=nfdeployment_desc_id).first() + id=nfdeployment_desc_id).first() def _list(self) -> List[dms.NfDeploymentDesc]: return self.session.query() - def _update(self, nfdeployment_desc: dms.NfDeploymentDesc): - self.session.add(nfdeployment_desc) + def _update(self, nfdeployment_desc_id, **kwargs): + self.session.query(dms.NfDeploymentDesc).filter_by( + id=nfdeployment_desc_id).update(**kwargs) + + def _delete(self, nfdeployment_desc_id): + self.session.query(dms.NfDeploymentDesc).filter_by( + id=nfdeployment_desc_id + ).delete()