เชื่อม API กับ DB (CRUD API)

from fastapi import FastAPI, HTTPException
from pydantic import BaseModel
import sqlite3

app = FastAPI()

class Item(BaseModel):
    name: str
    price: float

def db():
    conn = sqlite3.connect("shop.db")
    conn.row_factory = sqlite3.Row   # ให้ผลเป็น dict-like
    return conn

@app.post("/items", status_code=201)
def create_item(item: Item):
    conn = db()
    cur = conn.execute(
        "INSERT INTO items (name, price) VALUES (?, ?)",  # ? กัน injection
        (item.name, item.price),
    )
    conn.commit()
    return {"id": cur.lastrowid, **item.model_dump()}

@app.get("/items/{item_id}")
def get_item(item_id: int):
    row = db().execute("SELECT * FROM items WHERE id = ?", (item_id,)).fetchone()
    if row is None:
        raise HTTPException(status_code=404, detail="ไม่พบสินค้า")
    return dict(row)

from fastapi import HTTPException

if row is None:
    raise HTTPException(status_code=404, detail="ไม่พบ")