import sample.actors.Student;
import sample.actors.Teacher;
import sample.actors.Topic;


import java.sql.*;

public class DBOperations {

    private static final String URL = "jdbc:mysql://localhost:3306/database";
    private static final String USERNAME = "root";
    private static final String PASSWORD = "root";

    DBOperations(){

    }
    public static void insertStudent(Student student){
        DBWorker dbw = new DBWorker();

        try {
            String preparedstatement = "INSERT INTO students (login, name, surname, study_group, password)" +
                                      " VALUES (?, ?, ?, ?, ?)";


            PreparedStatement ps = dbw.getConnection().prepareStatement(preparedstatement);

            ps.setString(1, student.getLogin());
            ps.setString(2, student.getName());
            ps.setString(3, student.getSurname());
            ps.setString(4, student.getGroup());
            ps.setString(5, student.getPassword());
            ps.executeUpdate();

            ps.close();

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

    public static boolean loginCheckStudent(String login, String password){
        DBWorker dbw = new DBWorker();
        ResultSet result;

        String  student_login    = "\"" + login     + "\"",
                student_password = "\"" + password  + "\"";

        String query = "SELECT login, password FROM students WHERE login LIKE " + student_login
                + " AND password LIKE " + student_password;

        try {
            Statement statement = dbw.getConnection().createStatement();

            result = statement.executeQuery(query);

            while (result.next()){
                if (login.equals( result.getString(1))){
                    if (password.equals(result.getString(2))){
                        return true;
                    } else{
                        return false;
                    }

                } else {
                    return false;
                }
            }

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

    public static void insertTeacher(Teacher teacher) {
        DBWorker dbw = new DBWorker();

        try {
            String preparedstatement = "INSERT INTO teachers (login, name, surname, password)" +
                    " VALUES (?, ?, ?, ?)";


            PreparedStatement ps = dbw.getConnection().prepareStatement(preparedstatement);

            ps.setString(1, teacher.getLogin());
            ps.setString(2, teacher.getName());
            ps.setString(3, teacher.getSurname());
            ps.setString(4, teacher.getPassword());
            ps.executeUpdate();

            ps.close();

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

    public static boolean loginCheckTeacher(String login, String password){
        DBWorker dbw = new DBWorker();
        ResultSet result;

        String  teacher_login    = "\"" + login     + "\"",
                teacher_password = "\"" + password  + "\"";

        String query = "SELECT login, password FROM teachers WHERE login LIKE " + teacher_login
                + " AND password LIKE " + teacher_password;

        try {
            Statement statement = dbw.getConnection().createStatement();

            result = statement.executeQuery(query);

            while (result.next()){
                if (login.equals( result.getString(1))){
                    return password.equals(result.getString(2));

                } else {
                    return false;
                }
            }

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

    public static void insertTopic(Topic topic){
        DBWorker dbw = new DBWorker();

        try {
            String preparedstatement = "INSERT INTO topics (name, filepath)" +
                    " VALUES (?, ?)";


            PreparedStatement ps = dbw.getConnection().prepareStatement(preparedstatement);

            ps.setString(1, topic.getTopicName());
            ps.setString(2, topic.getFilePath());
            ps.executeUpdate();

            ps.close();

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