package de.noellang.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

public class ErsteSchritteJDBC {

    public static void main(String[] args) {

	// Überprüfen, ob der MySQL Connector im Build Path vorhanden ist.
	try {
	    Class.forName("com.mysql.jdbc.Driver");
	} catch (ClassNotFoundException e) {
	    System.err.println("MySQL Connector konnte nicht gefunden werden.");
	    return;
	}

	// Einstellungen für die JDBC Verbindung setzen.
	Properties props = new Properties();
	props.setProperty("user", "N.Lang");
	props.setProperty("password", "N.Lang-3");
	props.setProperty("useSSL", "false");
	props.setProperty("autoReconnect", "true");

	// Variablen deklarieren und SQL Query definieren.
	String query = "SELECT * FROM CUSTOMER WHERE CITY LIKE 'Dallas'";
	Connection conn = null;
	Statement sql = null;
	ResultSet rs = null;
	List<Person> result = new ArrayList<>();

	try {
	    // Connection aufbauen.
	    conn = DriverManager.getConnection("jdbc:mysql://192.168.0.206:3306/E2IT1-N.Lang", props);

	    // Leeres Statement erstellen.
	    sql = conn.createStatement();

	    // Statement ausführen und im ResultSet abspeichern.
	    rs = sql.executeQuery(query);

	    // Durch das ResultSet iterieren und die Ergebnisse in der ArrayList
	    // speichern.
	    while (rs.next()) {
		Person person = new Person();
		person.setFirstName(rs.getString("first_name"));
		person.setLastName(rs.getString("last_name"));
		result.add(person);
	    }

	    // Ergebnis anzeigen.
	    System.out.println(MessageFormat.format("Es wurden insgesamt {0} Ergebnisse gefunden.", result.size()));
	    result.forEach(person -> System.out.println(person.getPersonDetails()));

	    // Zugänge schließen.
	    sql.close();
	    rs.close();
	    conn.close();
	} catch (SQLException e) {
	    System.err.println("Fehler beim Ausführen des SQL Statements.");
	    System.err.println(query);
	    return;
	}

    }

}