import sqlite3

DB = "towary.db"

# -------------------- POŁĄCZENIE --------------------
con = sqlite3.connect(DB)
cur = con.cursor()

# -------------------- TABELA --------------------
cur.execute("""
CREATE TABLE IF NOT EXISTS towary (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    nazwa TEXT NOT NULL,
    ilosc INTEGER NOT NULL,
    cena REAL NOT NULL
)
""")
con.commit()

# -------------------- INSERT --------------------
def dodaj_towar(nazwa, ilosc, cena):
    cur.execute(
        "INSERT INTO towary (nazwa, ilosc, cena) VALUES (?, ?, ?)",
        (nazwa, ilosc, cena)
    )
    con.commit()

# -------------------- UPDATE --------------------
def zmien_towar(id, ilosc=None, cena=None):
    if ilosc is not None:
        cur.execute(
            "UPDATE towary SET ilosc=? WHERE id=?",
            (ilosc, id)
        )
    if cena is not None:
        cur.execute(
            "UPDATE towary SET cena=? WHERE id=?",
            (cena, id)
        )
    con.commit()

# -------------------- SELECT --------------------
def pokaz_towary():
    cur.execute("SELECT id, nazwa, ilosc, cena FROM towary")
    return cur.fetchall()

# -------------------- TEST --------------------
dodaj_towar("Śruba M8", 100, 0.45)
dodaj_towar("Nakrętka M8", 200, 0.25)

zmien_towar(1, ilosc=120)
zmien_towar(2, cena=0.30)

for r in pokaz_towary():
    print(r)

con.close()