package com.epam.repository;

import com.epam.ObjectMapper;
import com.epam.exceptions.UserAlreadyCreatedException;
import com.epam.exceptions.UserNotFoundException;
import com.epam.model.User;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.dao.EmptyResultDataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;

import javax.sql.DataSource;

import java.sql.SQLException;
import java.util.List;


public class UserDaoImpl implements UserDao {
    private static Logger log = LogManager.getLogger(UserDaoImpl.class.getName());
    private NamedParameterJdbcTemplate jdbcTemplateObject;

    public void setDataSource(DataSource dataSource) {
        this.jdbcTemplateObject = new NamedParameterJdbcTemplate(dataSource);
    }


    @Override
    public User getUser(Integer id) {
//        try {
//            String SQL = "select * from User where USER_ID = ?";
//            User user = jdbcTemplateObject.queryForObject(SQL,
//                    new Object[]{id}, new ObjectMapper.RowMapperUser());
//            log.warn(user.toString());
//            return user;
//        } catch (EmptyResultDataAccessException e) {
//            log.error(e);
//            throw new UserNotFoundException(" No such user in database");
//        }


        SqlParameterSource namedParameters = new MapSqlParameterSource().addValue("id", id);
        User user = jdbcTemplateObject.queryForObject("SELECT USER_NAME FROM EMPLOYEE WHERE USER_ID = :id", namedParameters, User.class);
        return user;
    }


    @Override
    public List<User> getAllUsers() {
        String SQL = "select * from User";
        List<User> usersList = jdbcTemplateObject.query(SQL, new ObjectMapper.RowMapperUser());
        for (User user : usersList) {
            log.warn(user.toString());
        }
        return usersList;
    }

    @Override
    public User deleteUser(Integer id) {
        try {
            String sql = "SELECT * FROM USER WHERE USER_ID = ?";
            User deletedUser = jdbcTemplateObject.queryForObject(
                    sql, new Object[]{id},
                    new ObjectMapper.RowMapperUser());

            String SQL = "DELETE FROM USER WHERE USER_ID = ?";
            jdbcTemplateObject.update(SQL, id);
            log.warn(deletedUser.toString());
            return deletedUser;

        } catch (EmptyResultDataAccessException e) {
            log.error(e);
            throw new UserNotFoundException(" There is not suck user ind Database");
        }
    }

    @Override
    public User updateUser(User user) throws SQLException {

        try {
            getUser(user.getId());
            String password = user.getPassword();
            String name = user.getName();
            String mail = user.getMail();
            Integer id = user.getId();

            Object[] objects = {password, name, mail, id};
            String sqlStatement = "UPDATE USER SET USER_NAME = ?, USER_MAIL=? ,USER_PASSWORD = ? WHERE USER_ID =?";
            jdbcTemplateObject.update(sqlStatement, objects);

            log.warn(user.toString());
        } catch (EmptyResultDataAccessException e) {
            log.error(e);
            throw new UserNotFoundException("No such user in Database");
        }


        return user;
    }

    @Override
    public User getUserByEmail(String mail) {
        try {
            String SQL = "select * from User where USER_MAIL = ?";
            User user = jdbcTemplateObject.queryForObject(SQL,
                    new Object[]{mail}, new ObjectMapper.RowMapperUser());
            log.warn(mail);
            return user;
        } catch (EmptyResultDataAccessException e) {
            log.error(e);
            throw new UserNotFoundException(" No such user in database");
        }
    }


    // Done
    @Override
    public User createUser(User user) {
        boolean flag = true;

        try {
            String sqlFind = "select * from User where USER_MAIL = ?";
            jdbcTemplateObject.queryForObject(
                    sqlFind, new Object[]{user.getMail()},
                    new ObjectMapper.RowMapperUser());

        } catch (EmptyResultDataAccessException e) {
            String name = user.getName();
            String mail = user.getMail();
            String password = user.getPassword();
            String role = user.getRole();
            String SQL = "insert into User (user_name, user_mail, user_role, user_password) values (?, ?, ?, ? )";
            jdbcTemplateObject.update(SQL, name, mail, role, password);
            log.warn(user.toString());
            flag = false;
        } finally {
            if (flag) {
                log.error(" User already in database");
                throw new UserAlreadyCreatedException(" User already in database");
            }
        }
        return null;
    }


}