add: order paths & mds
This commit is contained in:
@@ -45,16 +45,24 @@ def create_all():
|
||||
with engine.begin() as conn:
|
||||
Base.metadata.create_all(bind=conn)
|
||||
|
||||
def run_scripts():
|
||||
from db.models import table_models
|
||||
with get_db() as session:
|
||||
for model in table_models:
|
||||
if hasattr(model, "__scripts__"):
|
||||
scripts = model.__scripts__
|
||||
for script in scripts:
|
||||
session.execute(script)
|
||||
session.commit()
|
||||
|
||||
def init_payload():
|
||||
|
||||
from db.models import table_models
|
||||
with get_db() as session:
|
||||
session.execute(text("SET FOREIGN_KEY_CHECKS = 0;"))
|
||||
for model in table_models:
|
||||
print(f"MODEL -- {model}, {hasattr(model, '__pay_load__')}")
|
||||
if hasattr(model, "__pay_load__"):
|
||||
payload =model.__pay_load__[ENVIRONMENT]
|
||||
payload = model.__pay_load__[ENVIRONMENT]
|
||||
print(f"- - [ - ] hasattr, {ENVIRONMENT} - {payload}")
|
||||
stmt = insert(model.__table__).values(payload).prefix_with("IGNORE")
|
||||
print(f"- - [ - ] {stmt}\n")
|
||||
@@ -74,6 +82,8 @@ def setup_db():
|
||||
print("[ x ] db cleared")
|
||||
create_all()
|
||||
print("[ x ] db created")
|
||||
run_scripts()
|
||||
print("[ x ] db scripts executed")
|
||||
init_payload()
|
||||
print("[ x ] payload loaded")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user