Create db.py

routers/db.py

@@ -0,0 +1,60 @@
+# db.py
+import os
+from fastapi import FastAPI, APIRouter, HTTPException
+from pydantic import BaseModel, HttpUrl
+import databases
+import sqlalchemy
+
+# 🌐 Pega a URL do banco do ambiente
+DATABASE_URL = os.getenv("DATABASE_URL")
+if not DATABASE_URL:
+    raise ValueError("DATABASE_URL não configurada!")
+
+# ⚡ Banco assíncrono
+database = databases.Database(DATABASE_URL)
+metadata = sqlalchemy.MetaData()
+
+# 🏗️ Tabela igbio
+igbio = sqlalchemy.Table(
+    "igbio",
+    metadata,
+    sqlalchemy.Column("url_instagram", sqlalchemy.Text),
+    sqlalchemy.Column("url_web", sqlalchemy.Text),
+    sqlalchemy.Column("image", sqlalchemy.Text),
+)
+
+# 🚀 FastAPI e router
+app = FastAPI()
+router = APIRouter()
+
+# 📦 Modelo de request
+class IGPost(BaseModel):
+    url_instagram: str | None = None
+    url_web: str | None = None
+    image: str | None = None
+
+# 🔗 Connect / Disconnect DB
+@app.on_event("startup")
+async def startup():
+    await database.connect()
+
+@app.on_event("shutdown")
+async def shutdown():
+    await database.disconnect()
+
+# 📝 POST endpoint para inserir dados
+@router.post("/igbio")
+async def add_igbio(item: IGPost):
+    query = igbio.insert().values(
+        url_instagram=item.url_instagram,
+        url_web=item.url_web,
+        image=item.image,
+    )
+    try:
+        record_id = await database.execute(query)
+        return {"success": True, "id": record_id}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+
+# 🔌 Adiciona router à app
+app.include_router(router)