package db;

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

import domain.Person;

public class PersonDatabase implements PersonRepository {

	private Properties properties;
	private String url;
	private PreparedStatement statement;
	private Connection connection;

	public PersonDatabase() {
		properties = new Properties();
		url = "jdbc:postgresql://gegevensbanken.khleuven.be:51516/2TX31";
		properties.setProperty("user", "<uw r nummer>");
		properties.setProperty("password", "<uw passwoord>");
		properties.setProperty("ssl", "true");
		properties.setProperty("sslfactory", "org.postgresql.ssl.NonValidatingFactory");

		try {
			Class.forName("org.postgresql.Driver");
			connection = DriverManager.getConnection(url, properties);

		} catch (SQLException e) {
			throw new DatabaseException(e.getMessage(), e);
		} catch (ClassNotFoundException e) {
			throw new DatabaseException(e.getMessage(), e);
		}

	}

	@Override
	public void add(Person person) {

		if(person == null){
			throw new DatabaseException("person not valid");
		}

		String sql = "INSERT into <uw schema.uw tabel> (userid, password, email, firstname, lastname)"
					+ "VALUES (?,?,?,?,?)";
		try{
			statement = connection.prepareStatement(sql);
			statement.setString(1, person.getUserid());
			statement.setString(2, person.getPassword());
			statement.setString(3, person.getEmail());
			statement.setString(4, person.getFirstName());
			statement.setString(5, person.getLastName());
			statement.execute();
		} catch (SQLException e){
			throw new DatabaseException(e.getMessage(), e);
		}
	}