package emailverwaltung;

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

public class EmailKontaktDao2 extends EmailKontakt {

	private String user;
	private String password;
	private String url;
	private String server;
	private Connection conn;

	public EmailKontaktDao2()  {
		this.server = "sys3";
		this.user = "DM1719";
		this.url = "jdbc:as400://" + server + "/" + user;
		this.password = "DM1719";
		try {
			Class.forName("com.ibm.as400.access.AS400JDBCDriver");
			this.conn = DriverManager.getConnection(url, user, password);
		} catch (ClassNotFoundException | SQLException e) {
			e.printStackTrace();
		}
	}


	public void delete(EmailKontakt emailkontakt) {
		EmailKontakt emailKontakt = new EmailKontakt();
		try {
			String sql = "DELETE FROM email WHERE id = "+ emailKontakt.getId();
			PreparedStatement statement = this.conn.prepareStatement(sql);
			ResultSet resultSet = statement.executeQuery();
			resultSet.next();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void insert(EmailKontakt emailkontakt) {
		EmailKontakt emailKontakt = new EmailKontakt();
		try {
			String sql = "INSERT INTO email VALUES "+ emailKontakt.getId() + ", '" + emailKontakt.getVorname() + "', '" + emailKontakt.getNachname() + "', '" + emailKontakt.getEmail() + "'";
			PreparedStatement statement = this.conn.prepareStatement(sql);
			ResultSet resultSet = statement.executeQuery();
			resultSet.next();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public void update(EmailKontakt emailkontakt) {
		// bonusaufgabe!
	}

	public EmailKontakt next(EmailKontakt emailkontakt) {
		EmailKontakt emailKontakt = new EmailKontakt();
		try {
			int naechsterEmailKontakt = emailKontakt.getId() + 1;
			String sql = "SELECT * FROM email WHERE id = " + naechsterEmailKontakt;
			PreparedStatement statement = this.conn.prepareStatement(sql);
			ResultSet resultSet = statement.executeQuery();
			resultSet.next();
			emailKontakt.setId(resultSet.getInt("id"));
			emailKontakt.setVorname(resultSet.getString("vorname"));
			emailKontakt.setNachname(resultSet.getString("nachname"));
			emailKontakt.setEmail(resultSet.getString("email"));
			return emailKontakt;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	public EmailKontakt previous(EmailKontakt emailkontakt) {
		EmailKontakt emailKontakt = new EmailKontakt();
		try {
			int vorherigerEmailKontakt = emailKontakt.getId() - 1;
			String sql = "SELECT * FROM email WHERE id = " + vorherigerEmailKontakt;
			PreparedStatement statement = this.conn.prepareStatement(sql);
			ResultSet resultSet = statement.executeQuery();
			resultSet.next();
			emailKontakt.setId(resultSet.getInt("id"));
			emailKontakt.setVorname(resultSet.getString("vorname"));
			emailKontakt.setNachname(resultSet.getString("nachname"));
			emailKontakt.setEmail(resultSet.getString("email"));
			return emailKontakt;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	public EmailKontakt first() {

		return null;
	}

	public EmailKontakt last() {

		return null;
	}

	public EmailKontakt select(int id) throws ClassNotFoundException, SQLException {
		EmailKontakt emailKontakt = new EmailKontakt();
			try {
				String sql = "SELECT * FROM email WHERE id = " + id;
				PreparedStatement statement = this.conn.prepareStatement(sql);
				ResultSet resultSet = statement.executeQuery();
				resultSet.next();
				emailKontakt.setId(resultSet.getInt("id"));
				emailKontakt.setVorname(resultSet.getString("vorname"));
				emailKontakt.setNachname(resultSet.getString("nachname"));
				emailKontakt.setEmail(resultSet.getString("email"));
				return emailKontakt;
			} catch (Exception e) {
				e.printStackTrace();
			}
			return null;
	}

}