package CodersLab.entity;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import CodersLab.dao.UserDao;

public class MySqlUserDao implements UserDao {

	private static final String FIND_ALL_USERS = "SELECT * FROM users;";
	private static final String INSERT_USER_QUERY = "INSERT INTO users(name, surname, email, password) "
			+ "VALUES (?, ?, ?, ?);";

	private final String jdbcUrl;
	private final String password;
	private final String user;

	public MySqlUserDao(String jdbcUrl, String password, String user) {
		this.jdbcUrl = jdbcUrl;
		this.password = password;
		this.user = user;
	}

	private Connection createConnection() throws SQLException {
		return DriverManager.getConnection(jdbcUrl, user, password);

	}
	@Override
	public User insert(User user) {
		try (Connection connection = createConnection();
				PreparedStatement insertStm = connection.prepareStatement(INSERT_USER_QUERY,
						PreparedStatement.RETURN_GENERATED_KEYS)) {
			insertStm.setString(1, user.getName());
			insertStm.setString(2, user.getSurname());
			insertStm.setString(3, user.getEmail());
			insertStm.setString(4, user.getPassword());

			int result = insertStm.executeUpdate();
			if (result != 1) {
				throw new RuntimeException("Execute updated return " + result);
			}

			try (ResultSet generatedKeys = insertStm.getGeneratedKeys()) {
				if (generatedKeys.first()) {
					user.setId(generatedKeys.getInt(1));
					return user;
				} else {
					throw new RuntimeException("Generated key was not found");
				}
			}
		} catch (SQLException e) {
			throw new RuntimeException(e);
		}

	}

	@Override
	public List<User> findAll() {
		return null;
	}


}