db_cleaner.py

import db_save


def db_oranlar_clean():
    # Database connection
    conn = db_save.get_db_connection()
    cur = conn.cursor()

    # Silme işlemi sorgusu
    delete_query = """
    DELETE FROM oranlar
    WHERE baz = 'TL'
    AND (kod, propertyname, donem) IN (
        SELECT kod, propertyname, donem
        FROM oranlar
        GROUP BY kod, propertyname, donem
        HAVING COUNT(*) > 1
    );
    """

    try:
        # Sorguyu çalıştır
        cur.execute(delete_query)
        # Değişiklikleri kaydet
        conn.commit()
        print("Oranlar tablosuna ait gereksiz veriler başarıyla temizlendi.")
    except Exception as e:
        # Hata durumunda değişiklikleri geri al
        conn.rollback()
        print("Bir hata oluştu:", e)
    finally:
        # Veritabanı bağlantısını kapat
        cur.close()
        conn.close()


def db_karlilik_clean():
    # Database connection
    conn = db_save.get_db_connection()
    cur = conn.cursor()

    # Silme işlemi sorgusu
    delete_query = """
    DELETE FROM karlilik
    WHERE baz = 'USD'
    AND (kod, propertyname, donem, deger) IN (
        SELECT kod, propertyname, donem, deger
        FROM karlilik
        GROUP BY kod, propertyname, donem, deger
        HAVING COUNT(*) > 1
    );
    """

    try:
        # Sorguyu çalıştır
        cur.execute(delete_query)
        # Değişiklikleri kaydet
        conn.commit()
        print("Karlılık tablosuna ait gereksiz veriler başarıyla temizlendi.")
    except Exception as e:
        # Hata durumunda değişiklikleri geri al
        conn.rollback()
        print("Bir hata oluştu:", e)
    finally:
        # Veritabanı bağlantısını kapat
        cur.close()
        conn.close()


def db_mali_tablo_clean():
    # Database connection
    conn = db_save.get_db_connection()
    cur = conn.cursor()

    # Silme işlemi sorgusu
    delete_query = """
    DELETE FROM mali_tablo
    WHERE (kod, kalemid) IN (
        SELECT kod, kalemid
        FROM mali_tablo
        GROUP BY kod, kalemid
        HAVING SUM(deger) = 0
    );
    """

    try:
        # Sorguyu çalıştır
        cur.execute(delete_query)
        # Değişiklikleri kaydet
        conn.commit()
        print("Mali Tabloya ait gereksiz veriler başarıyla temizlendi.")
    except Exception as e:
        # Hata durumunda değişiklikleri geri al
        conn.rollback()
        print("Bir hata oluştu:", e)
    finally:
        # Veritabanı bağlantısını kapat
        cur.close()
        conn.close()