package server;

import ch.makery.address.model.Dogovor;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.Serializable;
import java.net.InetAddress;
import java.net.Socket;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.List;

public class Database {

    Connection db;

    public Database() {
        try {
            db = DriverManager.getConnection("jdbc:mysql://localhost:3306/dogovora?serverTimezone=UTC", "root", "123456");

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public List<Dogovor> getAll() {
        try {

            Statement sql = db.createStatement();
            ResultSet rs = sql.executeQuery("SELECT * FROMA dogovora");
            List<Dogovor> list = new ArrayList<>();

            while (rs.next()) {

                Dogovor d = new Dogovor();

                d.setNomer(rs.getInt("nomer"));
                d.setTip(rs.getString("tip"));
                d.setKontr(rs.getString("kontr"));
                d.setOtvl(rs.getString("otvl"));
                d.setForm(rs.getString("forma"));
                d.setData(rs.getObject("data", LocalDate.class));

                list.add(d);
            }

            return list;

        } catch (SQLException e) {
            e.printStackTrace();
            return null;
        }
    }

    public void deleteOne(Dogovor d) {
        try {
            PreparedStatement preparedStatement = db.prepareStatement("DELETE FROM dogovora WHERE nomer = ?");
            preparedStatement.setInt(1, d.getNomer());
            int count = preparedStatement.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public boolean addOne(Dogovor d) {
        try {
            PreparedStatement preparedStatement = db.prepareStatement("INSERT INTO dogovora (nomer, tip, kontr, otvl, forma, data) VALUES(?, ?, ?, ?, ?, ?)");
            preparedStatement.setInt(1, d.getNomer());
            preparedStatement.setString(2, d.getTip());
            preparedStatement.setString(3, d.getKontr());
            preparedStatement.setString(4, d.getOtvl());
            preparedStatement.setString(5, d.getForm());
            preparedStatement.setObject(6, d.getData());

            int count = preparedStatement.executeUpdate();

            return count > 0;
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
    }

    public boolean editOne(Dogovor d) {
        try {
            PreparedStatement preparedStatement = db.prepareStatement("UPDATE dogovora SET tip = ?, kontr = ?, otvl = ?, forma = ?, data = ? WHERE nomer = ?");
            preparedStatement.setInt(6, d.getNomer());
            preparedStatement.setString(1, d.getTip());
            preparedStatement.setString(2, d.getKontr());
            preparedStatement.setString(3, d.getOtvl());
            preparedStatement.setString(4, d.getForm());
            preparedStatement.setObject(5, d.getData());

            int count = preparedStatement.executeUpdate();

            return count > 0;
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
    }

}