| from sqlalchemy import Column, Integer, String, Text, create_engine |
| from sqlalchemy.ext.declarative import declarative_base |
| from sqlalchemy.orm import sessionmaker |
| from src.config.settings import Settings |
|
|
| Base = declarative_base() |
|
|
| class MemoryModel(Base): |
| __tablename__ = 'memory' |
| id = Column(Integer, primary_key=True) |
| key = Column(String, unique=True, index=True) |
| value = Column(Text) |
| created_at = Column(Integer) |
|
|
| |
| engine = create_engine(Settings.DATABASE_URL) |
| SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine) |
|
|
| def get_db(): |
| db = SessionLocal() |
| try: |
| yield db |
| finally: |
| db.close() |
|
|
| def init_db(): |
| Base.metadata.create_all(bind=engine) |