def METHOD_NAME(db_connectionn: str, echo=False) -> sessionmaker:
    # ToDo add schema version check
    try:
        engine = create_engine(db_connectionn, echo=echo)  # pool_size=40, max_overflow=0,
        Base.metadata.create_all(engine)
        return sessionmaker(autoflush=True, bind=engine)
    except OperationalError as e:
        sys.exit(e)