-# Copyright (C) 2021 Wind River Systems, Inc.\r
-#\r
-# Licensed under the Apache License, Version 2.0 (the "License");\r
-# you may not use this file except in compliance with the License.\r
-# You may obtain a copy of the License at\r
-#\r
-# http://www.apache.org/licenses/LICENSE-2.0\r
-#\r
-# Unless required by applicable law or agreed to in writing, software\r
-# distributed under the License is distributed on an "AS IS" BASIS,\r
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
-# See the License for the specific language governing permissions and\r
-# limitations under the License.\r
-\r
-# pylint: disable=attribute-defined-outside-init\r
-from __future__ import annotations\r
-from sqlalchemy import create_engine\r
-from sqlalchemy.orm import sessionmaker\r
-from sqlalchemy.orm.session import Session\r
-\r
-from o2common.config import config\r
-from o2common.service.unit_of_work import AbstractUnitOfWork\r
-\r
-from o2ims.adapter import ocloud_repository\r
-from o2dms.adapter import dms_repository\r
-\r
-from o2common.helper import o2logging\r
-logger = o2logging.get_logger(__name__)\r
-\r
-\r
-engine = create_engine(\r
- config.get_postgres_uri(),\r
- isolation_level="REPEATABLE READ",\r
- pool_size=200, max_overflow=0,\r
- pool_recycle=3600\r
-)\r
-\r
-DEFAULT_SESSION_FACTORY = sessionmaker(\r
- autocommit=False, autoflush=False, bind=engine\r
-)\r
-\r
-\r
-class SqlAlchemyUnitOfWork(AbstractUnitOfWork):\r
-\r
- def __init__(self, session_factory=DEFAULT_SESSION_FACTORY):\r
- self.session_factory = session_factory\r
-\r
- def __enter__(self):\r
- self.session = self.session_factory() # type: Session\r
- self.oclouds = ocloud_repository\\r
- .OcloudSqlAlchemyRepository(self.session)\r
- self.resource_types = ocloud_repository\\r
- .ResouceTypeSqlAlchemyRepository(self.session)\r
- self.resource_pools = ocloud_repository\\r
- .ResourcePoolSqlAlchemyRepository(self.session)\r
- self.resources = ocloud_repository\\r
- .ResourceSqlAlchemyRepository(self.session)\r
- self.subscriptions = ocloud_repository\\r
- .SubscriptionSqlAlchemyRepository(self.session)\r
- self.configurations = ocloud_repository\\r
- .ConfigurationSqlAlchemyRepository(self.session)\r
- self.deployment_managers = ocloud_repository\\r
- .DeploymentManagerSqlAlchemyRepository(self.session)\r
- self.nfdeployment_descs = dms_repository\\r
- .NfDeploymentDescSqlAlchemyRepository(self.session)\r
- self.nfdeployments = dms_repository\\r
- .NfDeploymentSqlAlchemyRepository(self.session)\r
- self.ocloudvresources = dms_repository\\r
- .NfOCloudVResourceSqlAlchemyRepository(self.session)\r
- return super().__enter__()\r
-\r
- def __exit__(self, *args):\r
- super().__exit__(*args)\r
- self.session.close()\r
-\r
- def _commit(self):\r
- self.session.commit()\r
-\r
- def rollback(self):\r
- self.session.rollback()\r
-\r
- def _collect_new_events(self):\r
- for entry in self.oclouds.seen:\r
- # while hasattr(entry, 'events') and len(entry.events) > 0:\r
- while entry.events is not None and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.resource_pools.seen:\r
- while entry.events is not None and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.resources.seen:\r
- while entry.events is not None and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.resource_types.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.deployment_managers.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.subscriptions.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.configurations.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.nfdeployment_descs.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.nfdeployments.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
- for entry in self.ocloudvresources.seen:\r
- while hasattr(entry, 'events') and len(entry.events) > 0:\r
- yield entry.events.pop(0)\r
+# Copyright (C) 2021 Wind River Systems, Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# pylint: disable=attribute-defined-outside-init
+from __future__ import annotations
+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+from sqlalchemy.orm.session import Session
+
+from o2common.config import config
+from o2common.service.unit_of_work import AbstractUnitOfWork
+
+from o2ims.adapter import ocloud_repository
+from o2dms.adapter import dms_repository
+
+from o2common.helper import o2logging
+logger = o2logging.get_logger(__name__)
+
+
+engine = create_engine(
+ config.get_postgres_uri(),
+ isolation_level="REPEATABLE READ",
+ pool_size=200, max_overflow=0,
+ pool_recycle=3600
+)
+
+DEFAULT_SESSION_FACTORY = sessionmaker(
+ autocommit=False, autoflush=False, bind=engine
+)
+
+
+class SqlAlchemyUnitOfWork(AbstractUnitOfWork):
+
+ def __init__(self, session_factory=DEFAULT_SESSION_FACTORY):
+ self.session_factory = session_factory
+
+ def __enter__(self):
+ self.session = self.session_factory() # type: Session
+ self.oclouds = ocloud_repository\
+ .OcloudSqlAlchemyRepository(self.session)
+ self.resource_types = ocloud_repository\
+ .ResouceTypeSqlAlchemyRepository(self.session)
+ self.resource_pools = ocloud_repository\
+ .ResourcePoolSqlAlchemyRepository(self.session)
+ self.resources = ocloud_repository\
+ .ResourceSqlAlchemyRepository(self.session)
+ self.subscriptions = ocloud_repository\
+ .SubscriptionSqlAlchemyRepository(self.session)
+ self.configurations = ocloud_repository\
+ .ConfigurationSqlAlchemyRepository(self.session)
+ self.deployment_managers = ocloud_repository\
+ .DeploymentManagerSqlAlchemyRepository(self.session)
+ self.nfdeployment_descs = dms_repository\
+ .NfDeploymentDescSqlAlchemyRepository(self.session)
+ self.nfdeployments = dms_repository\
+ .NfDeploymentSqlAlchemyRepository(self.session)
+ self.ocloudvresources = dms_repository\
+ .NfOCloudVResourceSqlAlchemyRepository(self.session)
+ return super().__enter__()
+
+ def __exit__(self, *args):
+ super().__exit__(*args)
+ self.session.close()
+
+ def _commit(self):
+ self.session.commit()
+
+ def rollback(self):
+ self.session.rollback()
+
+ def _collect_new_events(self):
+ for entry in self.oclouds.seen:
+ # while hasattr(entry, 'events') and len(entry.events) > 0:
+ while entry.events is not None and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.resource_pools.seen:
+ while entry.events is not None and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.resources.seen:
+ while entry.events is not None and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.resource_types.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.deployment_managers.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.subscriptions.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.configurations.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.nfdeployment_descs.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.nfdeployments.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
+ for entry in self.ocloudvresources.seen:
+ while hasattr(entry, 'events') and len(entry.events) > 0:
+ yield entry.events.pop(0)
Code Review / pti / o2.git / blobdiff