Python Flask API'sini Veritabanına Bağlama (SQLAlchemy ile) (1 Görüntüleyici)

from flask import Flask, jsonify, request # Gerekli Flask modüllerini içe aktar
from flask_sqlalchemy import SQLAlchemy # SQLAlchemy modülünü içe aktar
import os

# Flask Uygulaması ve Veritabanı Ayarları
basedir = os.path.abspath(os.path.dirname(__file__))
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///' + os.path.join(basedir, 'site.db') # SQLite veritabanı yolu
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # Modifikasyon izlemeyi kapat
db = SQLAlchemy(app) # SQLAlchemy objesini oluştur

# Veritabanı Modeli - Product tablosunu temsil eder
class Product(db.Model):
    id = db.Column(db.Integer, primary_key=True) # Ürün ID'si (Anahtar)
    ad = db.Column(db.String(100), nullable=False) # Ürün Adı
    fiyat = db.Column(db.Float, nullable=False) # Ürün Fiyatı

    # SQLAlchemy objesini JSON'a çevirmeden önce Python dict'e çevirmek için yardımcı metot
    def to_dict(self):
        return {
            'id': self.id,
            'ad': self.ad,
            'fiyat': self.fiyat
        }

    # print ile yazdırmak için (opsiyonel)
    def __repr__(self):
        return f"Product('{self.ad}', {self.fiyat})"

# Veritabanı tablolarını oluşturma (Uygulama bağlamı içinde bir kere çalıştırılır)
with app.app_context():
    db.create_all()
    print("Veritabanı tabloları kontrol edildi/oluşturuldu.")

# !!! Route'lar buraya gelecek !!!

# Uygulama çalıştırma kısmı
if __name__ == '__main__':
    app.run(debug=True)

# Product modelinin içindeki to_dict metodu:
# def to_dict(self):
#     return {
#         'id': self.id,
#         'ad': self.ad,
#         'fiyat': self.fiyat
#     }

# Kullanımı:
# product_obj = Product.query.get(1) # DB'den Product nesnesini çek
# product_dict = product_obj.to_dict() # Nesneyi sözlüğe çevir
# return jsonify(product_dict) # Sözlüğü JSON olarak döndür

# Önceki Flask, SQLAlchemy, Product model tanımlamaları ve db.create_all() buraya gelecek

# !!! Route'lar başlıyor !!!

# Tüm ürünleri listeleme (Read All) - GET /products
@app.route('/products', methods=['GET'])
def get_products():
    products = Product.query.all() # Veritabanından tüm Product nesnelerini çek

    # Nesne listesini JSON formatına çevirmek için sözlük listesine dönüştür
    # Her product objesi için to_dict() metodunu çağırıp bir liste oluştur
    products_list = [product.to_dict() for product in products]

    return jsonify(products_list) # Sözlük listesini JSON olarak döndür

# Belirli bir ürünü ID'ye göre getirme (Read One) - GET /products/<id>
@app.route('/products/<int:product_id>', methods=['GET'])
def get_product(product_id):
    # ID'ye göre ürünü veritabanından çek, bulunamazsa 404 hatası döndür
    product = Product.query.get_or_404(product_id)

    return jsonify(product.to_dict()) # Bulunan ürünü JSON olarak döndür

# Yeni ürün ekleme (Create) - POST /products
@app.route('/products', methods=['POST'])
def create_product():
    data = request.get_json() # İstekten JSON veriyi al

    # Gelen verinin geçerliliğini kontrol et (Basit kontrol)
    if not data or not 'ad' in data or not 'fiyat' in data:
        return jsonify({'message': 'Geçersiz veri sağlandı (ad veya fiyat eksik)'}), 400 # 400 Bad Request

    # Yeni Product nesnesi oluştur
    new_product = Product(ad=data['ad'], fiyat=data['fiyat'])

    # Nesneyi veritabanına ekle ve kaydet
    db.session.add(new_product)
    db.session.commit() # Veritabanına ekleme burada gerçekleşir

    # Başarı mesajı ve eklenen ürünü 201 status kodu ile döndür
    return jsonify({'message': 'Ürün başarıyla eklendi', 'product': new_product.to_dict()}), 201

# Ürün güncelleme (Update) - PUT /products/<id>
@app.route('/products/<int:product_id>', methods=['PUT'])
def update_product(product_id):
    # Güncellenecek ürünü ID'ye göre veritabanından çek
    product_to_update = Product.query.get_or_404(product_id)

    data = request.get_json() # İstekten JSON veriyi al

    # Gelen veriyi kullanarak ürün özelliklerini güncelle
    # Eğer 'ad' veya 'fiyat' veri içinde varsa güncelle, yoksa mevcut değeri kalsın
    if 'ad' in data:
        product_to_update.ad = data['ad']
    if 'fiyat' in data:
        product_to_update.fiyat = data['fiyat']

    # Değişiklikleri veritabanına kaydet
    db.session.commit()

    # Güncellenmiş ürünü JSON olarak döndür
    return jsonify({'message': 'Ürün başarıyla güncellendi', 'product': product_to_update.to_dict()}) # Varsayılan 200 OK

# Ürün silme (Delete) - DELETE /products/<id>
@app.route('/products/<int:product_id>', methods=['DELETE'])
def delete_product(product_id):
    # Silinecek ürünü ID'ye göre veritabanından çek
    product_to_delete = Product.query.get_or_404(product_id)

    # Ürünü session'dan sil ve veritabanına kaydet
    db.session.delete(product_to_delete)
    db.session.commit()

    # Başarı mesajı döndür
    return jsonify({'message': 'Ürün başarıyla silindi'}) # Varsayılan 200 OK

# !!! Route'lar bitti !!!

# Uygulama çalıştırma kısmı
if __name__ == '__main__':
    app.run(debug=True) # debug=True geliştirme için iyidir