package DBFilling;

import java.io.IOException;
import java.sql.*;


public class main {

    public static void main(String args[]) throws IOException {
        Connection c = null;
        Statement stmt = null;
        Generators generators = new Generators();
        generators.setupGenerators();
        try {
            Class.forName("org.postgresql.Driver");
            c = DriverManager
                    .getConnection("jdbc:postgresql://localhost:5432/Karetka",
                            "postgres", "bazy");
            c.setAutoCommit(false);
            System.out.println("Opened database successfully");

            stmt = c.createStatement();
            String sql ="";

            for(int i=1 ;i<=Generators.LICZBA_DYSPOZYTOROW;i++){
                sql = generators.dyspozytorzy(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_PRACOWNIKOW;i++){
                sql = generators.pracownicy(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_PODSTACJI;i++){
                sql = generators.podstacje(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }

            for(int i=0 ;i<generators.procedures.size();i++){
                sql = generators.procedury(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
          for(int i=1 ;i<generators.icd10.size();i++){
                sql = generators.kodyicd(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
                for(int i=1 ;i<generators.cities.size();i++){
                sql = generators.miejscowosci(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }

            for(int i=1 ;i<=Generators.LICZBA_KARETEK;i++){
                sql = generators.karetki(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_PACJENTÓW;i++){
                sql = generators.pacjenci(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }

            for(int i=1 ;i<generators.hospitals.size();i++){
                sql = generators.szpitale(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_ZGLOSZEN_I_WEZWAN;i++){
                sql = generators.zgloszenie(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_ZGLOSZEN_I_WEZWAN;i++){
                sql = generators.wezwania(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
              for(int i=1 ;i<=20000;i++){
                sql = generators.wykonaneProcedury(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=10000;i++){
                sql = generators.ulice(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=Generators.LICZBA_ZESPOLOW;i++){
                sql = generators.zespolyratownictwa(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
              for(int i=1 ;i<=20000;i++){
                sql = generators.zespolydowezwania(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=20000;i++){
                sql = generators.zatrudnieniPracownicy(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            for(int i=1 ;i<=20000;i++){
                sql = generators.poszkodowani(i);
                System.out.println(sql);
                stmt.executeUpdate(sql);
            }
            stmt.close();
            c.commit();
            c.close();
        } catch (Exception e) {
            System.err.println( e.getClass().getName()+": "+ e.getMessage() );
            System.exit(0);
        }
        System.out.println("Records created successfully");
    }

}