SQL_TO_CSV

import psycopg2
import csv
from datetime import datetime

# Pobierz aktualną datę i czas
current_datetime = datetime.now()


# Konfiguracja parametrów połączenia
host = "localhost"
port = "5432"
user = "user"
password = "password"
database = "baza"
output_file = f"nazwa_pliku_{current_datetime.strftime('%Y-%m-%d_%H-%M-%S')}.csv"
query = """select * from artykuly;"""

# Utwórz połączenie z bazą danych
connection = psycopg2.connect(
    host=host,
    port=port,
    user=user,
    password=password,
    database=database
)

# Utwórz kursor do wykonywania zapytań
cursor = connection.cursor()

# Wykonaj zapytanie SQL
cursor.execute(query)

# Pobierz wynik zapytania
results = cursor.fetchall()

# Zapisz wynik do pliku CSV z separatorem średnika
with open(output_file, "w", newline="", encoding="utf-8") as csvfile:
    # Zapisz nagłówki kolumn
    column_names = [desc[0] for desc in cursor.description]
    csv_writer = csv.writer(csvfile, delimiter=';')  # Ustaw separator na średnik
    csv_writer.writerow(column_names)

    # Zapisz dane
    for row in results:
        formatted_row = [str(item) if item is not None else "" for item in row]  # Obsłuż None jako puste pole
        csv_writer.writerow(formatted_row)




# Zamknij kursor i połączenie
cursor.close()
connection.close()

print(f"Wynik zapisano w pliku {output_file}")