Skip to content

Commit 1cc75fd

Browse files
committed
Database.wipe drops all tables
1 parent 48b4483 commit 1cc75fd

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

omnipath_metabo/schema/_main.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,9 @@ def create(con):
1515
Base.metadata.create_all(con.engine)
1616

1717

18+
TABLES = {'structures', 'identifiers', 'resources'}
19+
20+
1821
class Database:
1922

2023
def __init__(self, con):
@@ -56,6 +59,15 @@ def __del__(self):
5659

5760
del self.con
5861

62+
def wipe(self) -> None:
63+
64+
for tbl in TABLES:
65+
66+
query = text(f'DROP TABLE {tbl}')
67+
68+
self.con.session.execute(query)
69+
self.con.session.commit()
70+
5971

6072
class Loader():
6173

@@ -67,7 +79,7 @@ def __init__(self, resource, con):
6779

6880

6981
def load(self):
70-
82+
7183
insert_resource = insert(_structure.Resource).values(
7284
name = self.resource.name
7385
)
@@ -85,7 +97,7 @@ def load(self):
8597
"""
8698
_log("loading insert statments for structures table")
8799
psycopg2.extras.execute_values(cursor, query, self.resource, page_size = 1000)
88-
100+
89101
raw_con.commit()
90102
_log("structures have been inserted, creating mol column")
91103

0 commit comments

Comments
 (0)