[WIP] Testing and reformuling

This commit is contained in:
2026-02-08 18:55:16 +01:00
parent 1531a5dc77
commit b00c35f19b
22 changed files with 144 additions and 30 deletions

View File

@@ -0,0 +1 @@
from .install import install

View File

@@ -1,11 +1,12 @@
from sqlalchemy import create_engine
from sqlalchemy.orm import Session
from ....schema.config.base import Base
from ....db.config.config import get_engine_configuration
def install():
engine_string, echo = get_engine_configuration()
engine = create_engine(engine_string, echo=echo)
metadata = Base.metadata(engine)
metadata.create_all()
engine = create_engine(engine_string, echo=echo=="true", future=True) # TODO
metadata = Base.metadata
metadata.create_all(engine)
return engine

View File

@@ -0,0 +1,4 @@
from .create import create
from .read import read
from .update import update
from .delete import delete

View File

@@ -1,6 +1,14 @@
from sqlalchemy.orm import Session
from .....schema.config.library import LibraryConfig
from .....schema.config.library import Library
def create(session:Session, library:LibraryConfig):
import logging
logger = logging.getLogger(__name__)
def create(session:Session, library:Library):
logger.debug("Add Library")
session.add(library)
session.commit()
logger.debug("Added Library")
session.commit()
logger.debug("Committed Library")
session.refresh(library)
logger.debug("Rerfreshed Library")

View File

@@ -1,7 +1,7 @@
from sqlalchemy.orm import Session
from .....schema.config.library import LibraryConfig
from .....schema.config.library import Library
def delete(session:Session, library:LibraryConfig):
def delete(session:Session, library:Library):
session.delete(library)
session.commit()

View File

@@ -1,8 +1,8 @@
from sqlalchemy.orm import Session
from sqlalchemy import select
from .....schema.config.library import LibraryConfig
from .....schema.config.library import Library
def read(session:Session, _id:int):
stmt = select(LibraryConfig).where(LibraryConfig.id == _id)
stmt = select(Library).where(Library.id == _id)
return session.scalars(stmt).one()

View File

@@ -1,6 +1,6 @@
from sqlalchemy.orm import Session
from .....schema.config.library import LibraryConfig
from .....schema.config.library import Library
def update(session:Session, library:LibraryConfig):
def update(session:Session, library:Library):
session.commit()

View File

@@ -0,0 +1,6 @@
from sqlalchemy.orm import Session
from .....schema.config.path import Path
def create(session:Session, path:Path):
session.add(path)
session.commit()

View File

@@ -0,0 +1,7 @@
from sqlalchemy.orm import Session
from .....schema.config.path import Path
def delete(session:Session, path:Path):
session.delete(path)
session.commit()

View File

@@ -0,0 +1,10 @@
import os
from sqlalchemy.orm import Session
from sqlalchemy import select
from .....schema.config.path import Path
def read(session:Session, _id:int):
stmt = select(Path).where(Path.id == _id)
path:Path = session.scalars(stmt).one()
return path

View File

@@ -0,0 +1,7 @@
import os
from sqlalchemy.orm import Session
from .....schema.config.path import Path
def update(session:Session, path:Path):
session.commit()