ronis_0505/telegram-bot-for-manipulate-orders
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clear and fix database modul

Browse Source
This commit is contained in:
ronis_0505
2025-09-26 21:12:23 +03:00
parent 369bd7a6e1
commit 77a00d7623
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
app/database/database_engine.py
View File

@@ -1,14 +1,8 @@
import os import os
import asyncpg
from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine, session from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine, session
import dotenv
# connection = psycopg2.connect(*(os.getenv(key) for key in ["DATABASE", "DB_HOST", "DB_USER", "DB_PASSWORD"]))
# connection.autocommit = True
dotenv.load_dotenv(".env")
DATABASE_URL = (f"postgresql+asyncpg://{os.getenv('DB_USER')}:{os.getenv('DB_PASSWORD')}@" DATABASE_URL = (f"postgresql+asyncpg://{os.getenv('DB_USER')}:{os.getenv('DB_PASSWORD')}@"
f"{os.getenv('DB_HOST')}/{os.getenv('DATABASE')}") f"{os.getenv('DB_HOST')}/{os.getenv('DATABASE')}")
print(DATABASE_URL)
engine = create_async_engine(DATABASE_URL, echo=True) engine = create_async_engine(DATABASE_URL, echo=True)
async_session_ = async_sessionmaker(bind=engine, expire_on_commit=False) async_session_ = async_sessionmaker(bind=engine, expire_on_commit=False)