import sqlite3
import csv
import os

baza = 'szkola2.db'

def pobierz_rekordy(zapytanie):
    with sqlite3.connect(baza) as pol:
        kursor = pol.cursor()
        kursor.execute(zapytanie)
        return kursor.fetchall()

def popraw_znaki(dane):
    poprawki = {
        'ialek': 'iałek', 'ezyc':'ężyc', 'nsk': 'ńsk', 'lawa': 'ława',
        'lows': 'łows', 'mila': 'miła', 'razyna': 'rażyna', 'slaw': 'sław', 'scie': 'ście'
    }
    for indeks, rekord in enumerate(dane):
        rekord = ','.join([str(pole) for pole in rekord])
        for znajdz, zamien  in poprawki.items():
            if znajdz in rekord:
                rekord = rekord.replace(znajdz, zamien)
        dane[indeks] = rekord.split(',')

def zapisz_csv(dane, plik_csv):
    with open(plik_csv, 'w', newline='', encoding='utf-8') as plik:
        writer = csv.writer(plik)
        writer.writerows(dane)
        print("Dane zapisano w pliku", plik_csv)

def czytaj_csv(plik_csv):
    dane = []
    if not os.path.isfile(plik_csv):
        return dane
    with open(plik_csv, newline='', encoding='utf-8') as plik:
        for wiersz in csv.reader(plik, delimiter=','):
            dane.append(wiersz)
    return dane

def zmien_rekordy(zapytanie, dane):
    with sqlite3.connect(baza) as pol:
        kursor = pol.cursor()
        kursor.executemany(zapytanie, dane)
        print("Liczba zmodyfikowanych rekordów:", kursor.rowcount)
        pol.commit()

# poniżej wpisz kod