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.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 * FROM 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("form"));
				d.setData(rs.getObject("data", LocalDate.class));

                list.append(d);
            }

            return list;

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

    public void deleteOne(Dogovor d) {
        try {
            PreparedStatement preparedStatement = conn.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 = conn.prepareStatement("INSERT INTO dogovora (nomer, tip, kontr, otvl, form, 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 = conn.prepareStatement("UPDATE dogovora SET tip = ?, kontr = ?, otvl = ?, form = ?, 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;
        }
    }

}