আপনি কীভাবে FastAPI এর সাথে একটি SQL ডাটাবেস সংযুক্ত করবেন?

Question

IT Interview Practice · Accepted Answer

Django এর বিপরীতে, FastAPI **ডাটাবেস সম্পর্কে মতামত প্রদান করে না** — আপনি লাইব্রেরি নির্বাচন করেন। সাধারণ পছন্দ হল **SQLAlchemy** (প্রায়ই **SQLModel** এর সাথে, FastAPI এর লেখক দ্বারা তৈরি, যা SQLAlchemy + Pydantic একত্রিত করে)। ডাটাবেস সেশন নির্ভরতা ইনজেকশনের মাধ্যমে প্রদান করা হয়।

## SQLAlchemy সেটআপ

```python
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker, declarative_base

engine = create_engine("postgresql://user:pass@localhost/db")
SessionLocal = sessionmaker(bind=engine)
Base = declarative_base()

class User(Base):                        # an ORM model (maps to a table)
    __tablename__ = "users"
    id = Column(Integer, primary_key=True)
    name = Column(String)
    email = Column(String, unique=True)
```

## নির্ভরতার মাধ্যমে DB সেশন প্রদান করা

```python
def get_db():
    db = SessionLocal()
    try:
        yield db                 # provide the session
    finally:
        db.close()               # ALWAYS close after the request (cleanup)

@app.get("/users/{id}")
def get_user(id: int, db: Session = Depends(get_db)):   # inject a session per request
    user = db.query(User).filter(User.id == id).first()
    if not user:
        raise HTTPException(404, "Not found")
    return user
```

`yield` নির্ভরতা প্যাটার্ন হল সেশন পরিচালনার মানদণ্ড: প্রতিটি অনুরোধের জন্য একটি খুলুন, এটি ইনজেক্ট করুন এবং পরবর্তীতে স্বয়ংক্রিয়ভাবে বন্ধ করুন — প্রতিটি এন্ডপয়েন্ট একটি পরিষ্কার, সঠিকভাবে বন্ধ সেশন পায়।

## SQLModel — SQLAlchemy + Pydantic একসাথে

```python
from sqlmodel import SQLModel, Field, Session, select

class User(SQLModel, table=True):        # ONE class = ORM model AND Pydantic model
    id: int | None = Field(default=None, primary_key=True)
    name: str
    email: str

@app.get("/users")
def list_users(db: Session = Depends(get_session)):
    return db.exec(select(User)).all()    # query; results are also valid response models
```

SQLModel ORM মডেল এবং Pydantic মডেলকে একটি ক্লাসে একীভূত করে — ডাটাবেস এবং API স্কিমার মধ্যে নকল হ্রাস করে।

## মাইগ্রেশন এবং async বিকল্প

```text
✓ Migrations: use Alembic (SQLAlchemy's migration tool) for schema changes
✓ Async: use SQLAlchemy's async engine + async session for async endpoints
  (don't use a SYNC database driver inside async def — it blocks the event loop)
```

## এটি কেন গুরুত্বপূর্ণ

ডাটাবেস ইন্টিগ্রেশন প্রায় যেকোনো বাস্তব API এর জন্য অপরিহার্য, এবং FastAPI যেহেতু ইচ্ছাকৃতভাবে এটি সম্পর্কে **মতামত প্রদান করে না** (Django এর অন্তর্নির্মিত ORM এর বিপরীতে), সাধারণ পদ্ধতিটি বোঝা গুরুত্বপূর্ণ ব্যবহারিক জ্ঞান।

মানদণ্ড প্যাটার্ন — **SQLAlchemy** (অথবা **SQLModel**, যা সুন্দরভাবে ORM এবং Pydantic মডেলকে একীভূত করে নকল হ্রাস করতে) `yield` প্যাটার্নের মাধ্যমে **নির্ভরতা-ইনজেক্ট করা সেশন** সহ — হল প্রায় প্রতিটি FastAPI অ্যাপ যা ডেটা সংরক্ষণ করতে ব্যবহার করে।

অনুরোধ-প্রতি-সেশন নির্ভরতা (আগে খুলুন, পরে বন্ধ করুন, স্বয়ংক্রিয়ভাবে) ডাটাবেস সংযোগ পরিচালনার আদর্শিক, সঠিক উপায়, এবং SQLModel এর ডাটাবেস এবং API স্কিমার একীভূতকরণ FastAPI এর নিজস্ব লেখকের থেকে একটি উল্লেখযোগ্য উৎপাদনশীলতা বৈশিষ্ট্য।

কীভাবে ডাটাবেস সেটআপ করতে হয়, DI এর মাধ্যমে সেশন প্রদান করতে হয়, প্রশ্ন সম্পাদন করতে হয় এবং মাইগ্রেশন পরিচালনা করতে হয় (Alembic) এবং async সীমাবদ্ধতা বোঝা (async এন্ডপয়েন্টে async ড্রাইভার ব্যবহার করা, কখনও সিঙ্ক ব্লক করা নয়) ডেটা-চালিত FastAPI অ্যাপ্লিকেশন তৈরির জন্য প্রয়োজনীয় — যেহেতু FastAPI আপনাকে নির্বাচনের স্বাধীনতা দেয়, প্রচলিত, সুপ্রতিষ্ঠিত পথ জানা বাস্তব অ্যাপ সঠিকভাবে তৈরির জন্য মূল্যবান।

SQLAlchemy সেটআপ

নির্ভরতার মাধ্যমে DB সেশন প্রদান করা

SQLModel — SQLAlchemy + Pydantic একসাথে

মাইগ্রেশন এবং async বিকল্প

এটি কেন গুরুত্বপূর্ণ

সম্পর্কিত প্রশ্ন