Merge pull request #56 from OpenDataAlex/process_tracker_python-51

Process tracker python 51

Author: OpenDataAlex

dbscripts/mysql_process_tracker.sql

@@ -300,3 +300,40 @@ create table process_tracker.cluster_process
 )
 comment 'Relationship tracking between processes and performance clusters.';
 
+create table process_tracker.source_object_lkup
+(
+	source_object_id int auto_increment,
+	source_id int not null,
+	source_object_name varchar(250) null,
+	constraint source_object_lkup_pk
+		primary key (source_object_id),
+	constraint source_object_lkup_udx01
+		unique (source_id, source_object_name),
+	constraint source_object_lkup_source_lkup_source_id_fk
+		foreign key (source_id) references process_tracker.source_lkup (source_id)
+);
+
+create table process_tracker.process_target_object
+(
+	process_id int not null,
+	target_object_id int not null,
+	constraint process_target_object_pk
+		primary key (process_id, target_object_id),
+	constraint process_target_object_fk01
+		foreign key (process_id) references process_tracker.process (process_id),
+	constraint process_target_object_fk02
+		foreign key (target_object_id) references process_tracker.source_object_lkup (source_object_id)
+);
+
+create table process_tracker.process_source_object
+(
+	process_id int not null,
+	source_object_id int not null,
+	constraint process_source_object_pk
+		primary key (process_id, source_object_id),
+	constraint process_source_object_fk01
+		foreign key (process_id) references process_tracker.process (process_id),
+	constraint process_source_object_fk02
+		foreign key (source_object_id) references process_tracker.source_object_lkup (source_object_id)
+);
+

dbscripts/postgresql_process_tracker.sql

@@ -454,3 +454,53 @@ comment on table cluster_process is 'Relationship tracking between processes and
 
 alter table cluster_process owner to pt_admin;
 
+create table process_tracker.source_object_lkup
+(
+	source_object_id serial not null
+		constraint source_object_lkup_pk
+			primary key,
+	source_id integer not null
+		constraint source_object_lkup_fk01
+			references process_tracker.source_lkup,
+	source_object_name varchar(250)
+);
+
+comment on table process_tracker.source_object_lkup is 'Reference table for source/target objects.';
+
+alter table process_tracker.source_object_lkup owner to pt_admin;
+
+create unique index source_object_lkup_udx01
+	on process_tracker.source_object_lkup (source_id, source_object_name);
+
+create table process_tracker.process_target_object
+(
+	process_id integer not null
+		constraint process_target_object_fk01
+			references process_tracker.process,
+	target_object_id integer not null
+		constraint process_target_object_fk02
+			references process_tracker.source_object_lkup,
+	constraint process_target_object_pk
+		primary key (process_id, target_object_id)
+);
+
+comment on table process_tracker.process_target_object is 'Relationship between processes and target objects';
+
+alter table process_tracker.process_target_object owner to pt_admin;
+
+create table process_tracker.process_source_object
+(
+	process_id integer not null
+		constraint process_source_object_fk01
+			references process_tracker.process,
+	source_object_id integer not null
+		constraint process_source_object_fk02
+			references process_tracker.source_object_lkup,
+	constraint process_source_object_pk
+		primary key (process_id, source_object_id)
+);
+
+comment on table process_tracker.process_source_object is 'Relationship between processes and source objects';
+
+alter table process_tracker.process_source_object owner to pt_admin;
+

process_tracker/models/process.py

@@ -173,8 +173,8 @@ class ProcessSource(Base):
         nullable=False,
     )
 
-    sources = relationship("Source", passive_deletes="all")
     processes = relationship("Process", passive_deletes="all")
+    sources = relationship("Source", passive_deletes="all")
 
     def __repr__(self):
 
@@ -184,6 +184,33 @@ def __repr__(self):
         )
 
 
+class ProcessSourceObject(Base):
+    __tablename__ = "process_source_object"
+    __table_args__ = {"schema": "process_tracker"}
+
+    process_id = Column(
+        Integer,
+        ForeignKey("process_tracker.process.process_id"),
+        primary_key=True,
+        nullable=False,
+    )
+    source_object_id = Column(
+        Integer,
+        ForeignKey("process_tracker.source_object_lkup.source_object_id"),
+        primary_key=True,
+        nullable=False,
+    )
+
+    objects = relationship("SourceObject", passive_deletes="all")
+    processes = relationship("Process", passive_deletes="all")
+
+    def __repr__(self):
+        return "<ProcessSourceObject (process_id=%s, source_object=%s)>" % (
+            self.process_id,
+            self.source_object_id,
+        )
+
+
 class ProcessTarget(Base):
     __tablename__ = "process_target"
     __table_args__ = {"schema": "process_tracker"}
@@ -201,13 +228,41 @@ class ProcessTarget(Base):
         nullable=False,
     )
 
-    targets = relationship("Source", passive_deletes="all")
     processes = relationship("Process", passive_deletes="all")
+    targets = relationship("Source", passive_deletes="all")
 
     def __repr__(self):
         return "<ProcessSource (process=%s, target_source=%s)>" % (
             self.process_id,
-            self.source_id,
+            self.target_source_id,
+        )
+
+
+class ProcessTargetObject(Base):
+
+    __tablename__ = "process_target_object"
+    __table_args__ = {"schema": "process_tracker"}
+
+    process_id = Column(
+        Integer,
+        ForeignKey("process_tracker.process.process_id"),
+        primary_key=True,
+        nullable=False,
+    )
+    target_object_id = Column(
+        Integer,
+        ForeignKey("process_tracker.source_object_lkup.source_object_id"),
+        primary_key=True,
+        nullable=False,
+    )
+
+    objects = relationship("SourceObject", passive_deletes="all")
+    processes = relationship("Process", passive_deletes="all")
+
+    def __repr__(self):
+        return "<ProcessTargetObject (process_id=%s, target_object=%s)>" % (
+            self.process_id,
+            self.target_object_id,
         )
 
 

process_tracker/models/source.py

@@ -1,7 +1,8 @@
 # SQLAlchemy Models
 # Models for Source entities
 
-from sqlalchemy import Column, Integer, Sequence, String
+from sqlalchemy import Column, ForeignKey, Integer, Sequence, String, UniqueConstraint
+from sqlalchemy.orm import relationship
 
 from process_tracker.models.model_base import Base
 
@@ -22,3 +23,36 @@ class Source(Base):
     def __repr__(self):
 
         return "<Source (name=%s)>" % self.source_name
+
+
+class SourceObject(Base):
+
+    __tablename__ = "source_object_lkup"
+    __table_args__ = {"schema": "process_tracker"}
+
+    source_object_id = Column(
+        Integer,
+        Sequence("source_object_lkup_source_object_id_seq", schema="process_tracker"),
+        primary_key=True,
+        nullable=False,
+    )
+    source_id = Column(
+        Integer, ForeignKey("process_tracker.source_lkup.source_id"), nullable=False
+    )
+    source_object_name = Column(String(250), nullable=False)
+
+    UniqueConstraint(source_id, source_object_name)
+
+    source_processes = relationship(
+        "ProcessSourceObject", back_populates="objects", passive_deletes="all"
+    )
+    target_processes = relationship(
+        "ProcessTargetObject", back_populates="objects", passive_deletes="all"
+    )
+
+    def __repr__(self):
+
+        return "<SourceObject (source_id=%s, source_object_name=%s)>" % (
+            self.source_id,
+            self.source_object_name,
+        )