Source code for aiogbserver.database.db_connector

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker


[docs]class DataAccessLayer: """ access to DB fabric""" def __init__(self, conn_string, base, echo=False): self.engine = None self.Session = None self.session = None self.conn_string = conn_string self.echo = echo self.Base = base
[docs] def connect(self): self.engine = create_engine(self.conn_string, echo=self.echo) self.Base.metadata.create_all(self.engine)
self.Session = sessionmaker(bind=self.engine)