Skip to content

Commit

Permalink
__del__ for Connection and Database
Browse files Browse the repository at this point in the history
  • Loading branch information
deeenes committed Sep 26, 2024
1 parent e387347 commit ac16a7e
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 2 deletions.
7 changes: 6 additions & 1 deletion omnipath_metabo/schema/_connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,13 @@ def _uri(self) -> str:
)

def connect(self):

self.engine = create_engine(self._uri)
Session = sessionmaker(bind=self.engine)
self.session = Session()



def __del__(self):

self.session.close()
self.engine.dispose()
14 changes: 13 additions & 1 deletion omnipath_metabo/schema/_main.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,17 @@ def create(self) -> None:

def load(self, resource) -> None:

loader = Loader(resource, self.session)
loader = Loader(resource, self.con.session)
loader.load()


def __del__(self):

if hasattr(self, 'con'):

del self.con


class Loader():
#accept scheme and resource.
def __init__(self, resource, session):
Expand All @@ -44,10 +51,15 @@ def __init__(self, resource, session):


def load(self):

for row in self.resource:

insert_statement = self.scheme.insert().values(
smiles=row['smiles'],
accession=row['accession'],
inchi=row['inchi']
)

self.session.execute(insert_statement)

self.session.commit()

0 comments on commit ac16a7e

Please sign in to comment.