Merge remote-tracking branch 'origin/main'
This commit is contained in:
@ -1,15 +1,13 @@
|
|||||||
from typing import AsyncGenerator
|
from typing import AsyncGenerator
|
||||||
|
|
||||||
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
|
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession, async_sessionmaker
|
||||||
from sqlalchemy.orm import sessionmaker
|
|
||||||
|
|
||||||
from .config import PG_DATABASE, PG_HOST, PG_PASSWORD, PG_LOGIN
|
from .config import PG_DATABASE, PG_HOST, PG_PASSWORD, PG_LOGIN
|
||||||
|
|
||||||
DATABASE_URL = f"postgresql+asyncpg://{PG_LOGIN}:{PG_PASSWORD}@{PG_HOST}/{PG_DATABASE}"
|
DATABASE_URL = f"postgresql+asyncpg://{PG_LOGIN}:{PG_PASSWORD}@{PG_HOST}/{PG_DATABASE}"
|
||||||
engine = create_async_engine(DATABASE_URL)
|
engine = create_async_engine(DATABASE_URL)
|
||||||
session_maker = sessionmaker(
|
session_maker = async_sessionmaker(
|
||||||
engine,
|
engine,
|
||||||
class_=AsyncSession,
|
|
||||||
expire_on_commit=False,
|
expire_on_commit=False,
|
||||||
autocommit=False,
|
autocommit=False,
|
||||||
autoflush=False,
|
autoflush=False,
|
||||||
|
|||||||
Reference in New Issue
Block a user