X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fadapter%2Form.py;h=f59a235bb5e19f572ee1fc2c715a73239a50c710;hb=209f349b35b0919ac133bc2264f25753a73e5b8f;hp=61c3157545f6514deb5a05dc82048b25f54b7e6e;hpb=62f8863960ebd439c714b0ceed204731d9b31266;p=pti%2Fo2.git diff --git a/o2ims/adapter/orm.py b/o2ims/adapter/orm.py index 61c3157..f59a235 100644 --- a/o2ims/adapter/orm.py +++ b/o2ims/adapter/orm.py @@ -12,15 +12,19 @@ # See the License for the specific language governing permissions and # limitations under the License. +# from typing_extensions import Required from sqlalchemy import ( Table, MetaData, Column, Integer, String, + Text, + Enum, # Date, DateTime, ForeignKey, + # Boolean, # engine, # event, ) @@ -29,6 +33,9 @@ from sqlalchemy.orm import mapper, relationship # from sqlalchemy.sql.sqltypes import Integer from o2ims.domain import ocloud as ocloudModel +from o2ims.domain import subscription_obj as subModel +from o2ims.domain import configuration_obj as confModel +from o2ims.domain.resource_type import ResourceTypeEnum from o2common.helper import o2logging logger = o2logging.get_logger(__name__) @@ -59,6 +66,7 @@ resourcetype = Table( Column("hash", String(255)), Column("resourceTypeId", String(255), primary_key=True), + Column("resourceTypeEnum", Enum(ResourceTypeEnum), nullable=False), Column("oCloudId", ForeignKey("ocloud.oCloudId")), Column("name", String(255)), Column("vendor", String(255)), @@ -97,11 +105,11 @@ resource = Table( Column("resourceId", String(255), primary_key=True), Column("resourceTypeId", ForeignKey("resourcetype.resourceTypeId")), Column("resourcePoolId", ForeignKey("resourcepool.resourcePoolId")), + Column("name", String(255)), # Column("globalAssetId", String(255)), - # Column("oCloudId", ForeignKey("ocloud.oCloudId")), Column("parentId", String(255)), Column("description", String(255)), - # Column("elements", String(255)) + Column("elements", Text()) # Column("extensions", String(1024)) ) @@ -111,6 +119,7 @@ deploymentmanager = Table( Column("updatetime", DateTime), Column("createtime", DateTime), Column("hash", String(255)), + Column("version_number", Integer), Column("deploymentManagerId", String(255), primary_key=True), Column("oCloudId", ForeignKey("ocloud.oCloudId")), @@ -137,6 +146,19 @@ subscription = Table( Column("filter", String(255)), ) +configuration = Table( + "configuration", + metadata, + Column("updatetime", DateTime), + Column("createtime", DateTime), + + Column("configurationId", String(255), primary_key=True), + Column("conftype", String(255)), + Column("callback", String(255)), + Column("status", String(255)), + Column("comments", String(255)), +) + def start_o2ims_mappers(engine=None): logger.info("Starting O2 IMS mappers") @@ -160,7 +182,8 @@ def start_o2ims_mappers(engine=None): "resourcePools": relationship(resourcepool_mapper) } ) - mapper(ocloudModel.Subscription, subscription) + mapper(subModel.Subscription, subscription) + mapper(confModel.Configuration, configuration) if engine is not None: metadata.create_all(engine)