import asyncio
from sqlalchemy.ext.asyncio import create_async_engine, AsyncSession
from sqlalchemy.orm import sessionmaker
from sqlalchemy import text
from app.models.material_detail import MaterialDetail

engine = create_async_engine('mysql+aiomysql://root:@localhost:3306/cems_db')
AsyncSessionLocal = sessionmaker(bind=engine, class_=AsyncSession, expire_on_commit=False)

async def run():
    async with AsyncSessionLocal() as db:
        try:
            db_obj = MaterialDetail(material_id=1, site_id=1, order_quantity=10)
            db.add(db_obj)
            await db.commit()
            print("Success")
        except Exception as e:
            print(f"Error: {e}")

asyncio.run(run())