SQLAlchemy ile CRUD İşlemleri

3. Derse hoş geldiniz! Bugün, FastAPI ve SQLAlchemy kullanarak CRUD işlemlerinde ustalaşacağız. CRUD şunları ifade eder:

• Create (Oluşturma): Yeni veri ekleme.
• Read (Okuma): Mevcut verileri alma.
• Update (Güncelleme): Mevcut verileri değiştirme.
• Delete (Silme): Verileri kaldırma.

Bu dört işlem, veritabanı ile etkileşime giren hemen hemen her uygulamanın temelini oluşturur.

CRUD işlemlerine dalmadan önce, SQLAlchemy modelimizi ve Pydantic şemalarımızı hazırlayalım. Çalıştırılabilir örneklerimiz için bellek içi (in-memory) bir SQLite veritabanı kullanacağız.

İlk olarak, bir görevi temsil etmesi için SQLAlchemy Todo modelimiz:

from sqlalchemy import Column, Integer, String, Boolean
from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

class Todo(Base):
    __tablename__ = "todos"
    id = Column(Integer, primary_key=True, index=True)
    title = Column(String, index=True)
    description = Column(String, default="")
    completed = Column(Boolean, default=False)

Ve istek/yanıt işlemleri için Pydantic şemalarımız:

from pydantic import BaseModel

class TodoCreate(BaseModel):
    title: str
    description: str = ""
    completed: bool = False

class TodoResponse(TodoCreate):
    id: int

    class Config:
        orm_mode = True

FastAPI'de veritabanı oturumlarını bağımlılıklar (dependencies) kullanarak yönetiriz. Bu, her isteğin yeni bir oturum almasını ve bu oturumun düzgün bir şekilde kapatılmasını sağlar.

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

SQLALCHEMY_DATABASE_URL = "sqlite:///./test.db"
engine = create_engine(SQLALCHEMY_DATABASE_URL, connect_args={"check_same_thread": False})
SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)

def get_db():
    db = SessionLocal()
    try:
        yield db
    finally:
        db.close()

Bu get_db fonksiyonu, FastAPI uç noktalarımıza (endpoints) enjekte edilecektir.

Yeni bir öğe oluşturmak için bir POST isteği kullanacağız. Uç nokta, verileri bir Pydantic modeli aracılığıyla alacak ve bunu veritabanına eklemek için SQLAlchemy kullanacaktır.

from fastapi import FastAPI, Depends
from sqlalchemy.orm import Session

# ... (Base, Todo, TodoCreate, TodoResponse, get_db, engine için içe aktarmalar)

app = FastAPI()
Base.metadata.create_all(bind=engine) # Tabloları oluştur

@app.post("/todos/", response_model=TodoResponse)
def create_todo(todo: TodoCreate, db: Session = Depends(get_db)):
    db_todo = Todo(title=todo.title, description=todo.description, completed=todo.completed)
    db.add(db_todo)
    db.commit()
    db.refresh(db_todo) # ID ve güncellenmiş alanları almak için yenile
    return db_todo

db.refresh() çağrısı, db_todo nesnemizi id gibi veritabanı tarafından oluşturulan değerlerle günceller.

SQLAlchemy 'Create' adımlarını iş başında görelim. Bu çalıştırılabilir betik, bellek içi veritabanımıza yeni bir yapılacak iş ekleyecektir.

Verileri okumak için GET isteklerini kullanırız. İki uç noktamız olacak: biri tüm yapılacaklar listesini (todos) almak için, diğeri ise ID'sine göre tek bir yapılacak öğeyi almak için.

# ... (FastAPI uygulaması, içe aktarmalar, get_db, modeller)

@app.get("/todos/", response_model=list[TodoResponse])
def read_todos(db: Session = Depends(get_db)):
    todos = db.query(Todo).all()
    return todos

@app.get("/todos/{todo_id}", response_model=TodoResponse)
def read_todo(todo_id: int, db: Session = Depends(get_db)):
    todo = db.query(Todo).filter(Todo.id == todo_id).first()
    if todo is None:
        raise HTTPException(status_code=404, detail="Todo bulunamadı")
    return todo

Bir liste almak için .all(), tek bir öğe almak için ise .first() kullanırız. Bir öğenin bulunamadığı durumları yönetmeyi unutmayın!

'Oku' işlemi için bir demo çalıştıralım. Öncelikle birkaç yapılacak iş (todo) oluşturacağız, ardından hepsini getireceğiz ve son olarak ID'ye göre belirli bir tanesini getireceğiz.

Güncelleme (Update) işlemi (PUT veya PATCH), mevcut bir öğeyi değiştirmemize olanak tanır. Genellikle öğeyi ID ile bulur, niteliklerini günceller ve değişiklikleri kaydederiz.

# ... (FastAPI uygulaması, içe aktarmalar, get_db, modeller)

class TodoUpdate(BaseModel):
    title: str | None = None
    description: str | None = None
    completed: bool | None = None

@app.put("/todos/{todo_id}", response_model=TodoResponse)
def update_todo(todo_id: int, todo_update: TodoUpdate, db: Session = Depends(get_db)):
    db_todo = db.query(Todo).filter(Todo.id == todo_id).first()
    if db_todo is None:
        raise HTTPException(status_code=404, detail="Todo bulunamadı")
    
    # Alanları yalnızca sağlandıklarında güncelle
    for key, value in todo_update.dict(exclude_unset=True).items():
        setattr(db_todo, key, value)
    
    db.add(db_todo) # Güncelleme takibi için oturuma tekrar ekle
    db.commit()
    db.refresh(db_todo)
    return db_todo

Pydantic içinde exclude_unset=True kullanmak, yalnızca sağlanan alanların güncellenmesini sağlar.

İşte SQLAlchemy kullanarak bir yapılacaklar öğesinin başlığını ve tamamlanma durumunu nasıl güncelleyeceğinizi gösteren çalıştırılabilir bir örnek.

Silme (Delete) işlemi, veritabanından bir öğeyi kaldırır. Bu işlem genellikle bir öğeyi kimliğine (ID) göre hedefleyen bir DELETE isteği ile yapılır.

# ... (FastAPI uygulaması, içe aktarmalar, get_db, modeller)

@app.delete("/todos/{todo_id}", status_code=204) # Başarılı silme işlemi için 204 No Content
def delete_todo(todo_id: int, db: Session = Depends(get_db)):
    db_todo = db.query(Todo).filter(Todo.id == todo_id).first()
    if db_todo is None:
        raise HTTPException(status_code=404, detail="Todo bulunamadı")
    
    db.delete(db_todo)
    db.commit()
    return {"message": "Todo başarıyla silindi"} # FastAPI otomatik olarak 204 durum kodunu yönetir

Başarılı bir silme işlemi genellikle 204 No Content durum kodunu döndürür; bu, isteğin yerine getirildiği ancak geri gönderilecek bir içerik olmadığı anlamına gelir.

Bir yapılacaklar öğesini silmeyi göstermek için bir betik çalıştıralım. Bir tane oluşturacağız, ardından sileceğiz ve kaldırıldığını doğrulamak için tekrar okumaya çalışacağız.

Temel CRUD işlemlerini öğrendiniz! Şimdi, SQLAlchemy metotlarının bu işlemlerle nasıl eşleştiğine dair anlayışınızı test edelim.

Harika iş çıkardın! Bu derste, SQLAlchemy kullanarak FastAPI'de temel CRUD işlemlerini uygulamayı öğrendin:

• Create (POST): db.add(), db.commit() ve db.refresh() kullanarak.
• Read (GET): Listeler için db.query().all() ve tekil öğeler için db.query().filter().first() kullanarak.
• Update (PUT): Bir öğeyi getirip niteliklerini değiştirdikten sonra db.commit() ve db.refresh() kullanarak.
• Delete (DELETE): Bir öğeyi getirip ardından db.delete() ve db.commit() kullanarak.

Bu beceriler, veri odaklı herhangi bir API oluşturmak için çok önemlidir. Bir sonraki kursta, API uç noktalarınızı güvenli hale getirmek için kullanıcı kimlik doğrulaması ve yetkilendirme gibi ileri düzey konulara dalacağız!