package projektas.duombaze.veiksmai;

import projektas.duombaze.config.DbKonfiguracija;
import projektas.duombaze.entities.Preke;

import java.sql.*;
import java.util.ArrayList;

public class PrekesDuomenuGavimas
{
    /** Metodas paima visas prekes iš duomenų bazės ir jas išsaugo ArrayList'e
     *
     * @return ArrayList<Preke>, kuriame yra išsaugotos visos prekės.
     */
    public static ArrayList<Preke> visuPrekiuGavimas()
    {
        Connection jungtis;
        Statement sakinys;
        String sqlUzklausa = "SELECT * FROM preke";
        ResultSet prekiuInfo;

        ArrayList<Preke> prekes = new ArrayList<>();

        try
        {
            jungtis = DbKonfiguracija.sukurtiJungti();

            sakinys = jungtis.createStatement();

            prekiuInfo = sakinys.executeQuery(sqlUzklausa);

            while (prekiuInfo.next())
            {
                int id = prekiuInfo.getInt("id");
                String pav = prekiuInfo.getString("pav");
                double kaina = prekiuInfo.getDouble("kaina");
                int kiekis = prekiuInfo.getInt("kiekis");

                Preke laikinaPreke = new Preke(id, pav, kaina, kiekis);

                prekes.add(laikinaPreke);
            }

            prekiuInfo.close();
            sakinys.close();
            jungtis.close();
        }
        catch (SQLException e)
        {
            e.printStackTrace();
        }
        return prekes;
    }


    public static double visuPrekiuKainuSuma()
    {
        Connection jungtis;
        Statement sakinys;
        String sqlUzklausa = "SELECT SUM(kaina) as sumkaina FROM preke";            // galima ir nerašyti "as sumkaina", tieisog tada apačioje negalima naudoti šito column labelio
        ResultSet suma;
        double kaina = -1;

        try
        {
            jungtis = DbKonfiguracija.sukurtiJungti();

            sakinys = jungtis.createStatement();

            suma = sakinys.executeQuery(sqlUzklausa);

            if (suma.next())
            {
                kaina = suma.getDouble("sumkaina");                  // jeigu viršuje sql užklausos bus nenaudojamas "as sumkaina", tada reikėtų naudoti čia "SUM(kaina)"
                System.out.println(kaina);
            }
            suma.close();
            sakinys.close();
            jungtis.close();
        }
        catch (SQLException e)
        {
            e.printStackTrace();
        }
        return kaina;
    }


    public static Preke prekesPaieskaPagalId(int id)
    {
        Connection jungtis;
        PreparedStatement prepSt;
        String sqlUzklausa = "SELECT * FROM preke WHERE id = ?";
        ResultSet ieskomaPreke;

        Preke laikinaPreke = null;

        try
        {
            jungtis = DbKonfiguracija.sukurtiJungti();

            prepSt = jungtis.prepareStatement(sqlUzklausa);

            prepSt.setInt(1, id);

            ieskomaPreke = prepSt.executeQuery();

            if (ieskomaPreke.next())
            {
                int tempId = ieskomaPreke.getInt("id");
                String pav = ieskomaPreke.getString("pav");
                double kaina = ieskomaPreke.getDouble("kaina");
                int kiekis = ieskomaPreke.getInt("kiekis");

                laikinaPreke = new Preke(tempId, pav, kaina, kiekis);
            }
            ieskomaPreke.close();
            prepSt.close();
            jungtis.close();
        }
        catch (SQLException e)
        {

        }
        return laikinaPreke;
    }


    public static ArrayList<Preke> prekiuPaieskaPagalPavadinima(String pav)
    {
        Connection jungtis;
        PreparedStatement prepSt;
        String sqlUzklausa = "SELECT * FROM preke WHERE pav = ?";
        ResultSet ieskomosPrekes;
        ArrayList<Preke> prekes = new ArrayList<>();

        try
        {
            jungtis = DbKonfiguracija.sukurtiJungti();

            prepSt = jungtis.prepareStatement(sqlUzklausa);

            prepSt.setString(1, pav);

            ieskomosPrekes = prepSt.executeQuery();

            while (ieskomosPrekes.next())
            {
                int id = ieskomosPrekes.getInt("id");
                String tempPav = ieskomosPrekes.getString("pav");
                double kaina = ieskomosPrekes.getDouble("kaina");
                int kiekis = ieskomosPrekes.getInt("kiekis");

                Preke laikinaPreke = new Preke(id, tempPav, kaina, kiekis);

                prekes.add(laikinaPreke);
            }
        }
        catch (SQLException e)
        {
            e.printStackTrace();
        }
        return prekes;
    }
}