package dal;

import com.sun.xml.internal.bind.v2.model.core.ID;
import dto.UserDTO;

import java.sql.*;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Scanner;

public class UserDAOImpls185017 implements IUserDAO {

    private Connection createConnection() throws DALException {
        try {
            return DriverManager.getConnection("jdbc:mysql://ec2-52-30-211-3.eu-west-1.compute.amazonaws.com:3306/?user=s185017",
                    "s185017",
                    "oRJI59AKrhyxR4q5tG5Af\n");
        } catch (SQLException e) {
            throw new DALException(e.getMessage());
        }
    }

    @Override
    public List<Integer> getUser(int userId) throws DALException, SQLException {

        Scanner sc = new Scanner(System.in);
        int Id = 0;
        Connection c = createConnection();
        Statement statement = c.createStatement();
        ResultSet resultSet = statement.executeQuery("SELECT * FROM s185017.User_tabel_aflevering1");

        System.out.print("What user do you want? Write ID number for a specific user or 'all' for all users");
        String userRequest = sc.next();
        if (userRequest == "all"){
            while (resultSet.next()){
                System.out.println("UserID is: " + resultSet.getInt(1) + " and the UserName is: " + resultSet.getString(2));
                Id = resultSet.getInt(1);
            } return Collections.singletonList(Id);
        }
        else {
            //Den første forgrening i if-statementet printer alle brugerne ud, men jeg ville også implementere en metode der kunne printe en
            //enkelt bruger ud, dette er forsøgt nedenunder, men jeg var i tvivl om, hvordan resultSet fungerede, så jeg prøvede bare at skrive
            //noget der gav mening for mig, men formentligt ikke fungerer.
            int userRequestIntID = Integer.parseInt(userRequest);
            System.out.print("User ID is: " + resultSet.getInt(userRequestIntID) + " and the UserName is: " + resultSet.getString(userRequest));
            Id = resultSet.getInt(userRequestIntID);
        }   return Collections.singletonList(Id);

        //Mit bedste bud på en implementering.

        List<Integer> userDTOList = new ArrayList<>();
        userDTOList.add(Id);

        try {
            c.close();
        } catch (SQLException e) {
            throw new DALException(e.getMessage());
        }
        return Collections.singletonList(userId);
    }

    @Override
    public List<UserDTO> getUserList() throws DALException {
        Connection c = createConnection();
        getUserList();
        return null;
    }

    @Override
    public void createUser(UserDTO user) throws DALException {
        Connection c = createConnection();
        try {
            String cU = "Insert into User_tabel_aflevering1 (userId, UserName, Ini, Roles) Values (?, ?, ?, ?)";
            PreparedStatement PcU = c.prepareStatement(cU);
            PcU.setInt(1, user.getUserId());
            PcU.setString(2, user.getUserName());
            PcU.setString(3, user.getIni());
            PcU.setString(4, String.valueOf(user.getRoles()));
            PcU.executeUpdate();

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

    @Override
    public void updateUser(UserDTO user) throws DALException {
        Connection cU = createConnection();
        try {
            PreparedStatement preparedStatement = cU.prepareStatement("UPDATE User_tabel_aflevering1 SET UserName = ? WHERE user_id = ?");
            preparedStatement.setString(1, user.getUserName());
            preparedStatement.setInt(2, user.getUserId());
            preparedStatement.executeUpdate();

            cU.prepareStatement("UPDATE User_tabel_aflevering1 SET Ini = ? Where user_id = ?");
            preparedStatement.setString(1, user.getIni());
            preparedStatement.setInt(2, user.getUserId());
            preparedStatement.executeUpdate();

            cU.prepareStatement("UPDATE User_tabel_aflevering1 SET Roles = ? Where user_id = ?");
            preparedStatement.setString(1, String.valueOf(user.getRoles()));
            preparedStatement.setInt(2, user.getUserId());
            preparedStatement.executeUpdate();

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

    @Override
    public void deleteUser(int userId) throws DALException {
        Connection cU = createConnection();

        PreparedStatement preparedStatement = null;
        try {

            preparedStatement = cU.prepareStatement("Delete From User_tabel_aflevering1 where user_id =" + userId);
            preparedStatement.executeUpdate();

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