package dbConnection;
import java.sql.*;

public class TestProgramm {
	static private boolean log = true;
	static private String driverName = "com.mysql.jdbc.Driver";
	// url, user, pw
	static private String user = "ju";
	static private String pw = "ju";
	static private String dataBaseName = "jk3_personenundartikel";
	static private String basicUrl = "jdbc:mysql://localhost:3306/";
	static private String url = basicUrl + dataBaseName;
	static private Connection conn = null;

	public static void main(String[] args) {
		// 1.) Treiber laden
		loadDriver();
		// 2.) Connection herstellen
		connect();
		// 3.) Sql Abfrage an den DB-Server schicken
		// 3.a) SqlText zusammenbauen
		String tableName = "personen";
		String sqlSelectText = "SELECT * FROM `" + tableName + "`";

		System.out.println("\nSQL-Text vor Verwendung immer ausgeben: ");
		System.out.println("\"" + sqlSelectText + "\"\n");
		// 3.b) Statement kreieren
		Statement statement = createStatement();
		// 3.c) Statement ausführen, SQL-Text als Parameter verwenden
		ResultSet rs = executeSelect(statement, sqlSelectText);
		// 4.) Resultat auslesen
		printResultSet(rs);
		// 0.) Connection schließen
		close();
	}
	static private void log(String lText) {
		if(log)
			System.out.println(lText);
	}
	public static boolean loadDriver() {
		boolean ok = false;
		// Treiber laden
		try {
			// Treiberklasse zur Laufzeit nachladen
			Class.forName(driverName);
			String lText = "Treiber '" + driverName + "' erfolgreich geladen.";
			log(lText);
			ok = true;
		} catch(Exception ex) {
			System.out.println("Laden des Treibers fehlgeschlagen!");
			System.out.println("    " + ex.getMessage());
		} return ok;
	}
	public static boolean connect() {
		boolean ok = false;
		try {
			conn = DriverManager.getConnection(url,user, pw);
			if(conn != null) {
				log("Verbindung erfolgreich instanziert.");

				if(!conn.isClosed()) {
					log("Verbindung erfolgreich hergestellt.");
				}
			}	ok = true;
		} catch(Exception ex) {
			System.out.println("Herstellen der DB-Verbindung fehlgeschlagen!");
			System.out.println("    " + ex.getMessage());
		} return ok;
	}
	public static boolean close() {
		boolean ok = false;
		try {
			conn.close();
			if(conn.isClosed()) {
				log("DB-Verbindung erfolgreich geschlossen.");
			}	ok = true;
		} catch(Exception ex) {
			System.out.println("Schließen der DB-Verbindung fehlgeschlagen!");
			System.out.println("    " + ex.getMessage());
		} return ok;
	}
	static public Statement createStatement() {
		Statement  statement = null;
		try {
			statement = conn.createStatement();
			if(statement != null)
				log("Statement erfolgreich kreiert.");
		} catch(Exception ex) {
			System.out.println("Fehler beim Kreieren eines Staements!");
			System.out.println("    " + ex.getMessage());
		} return statement;
	}
	public static ResultSet executeSelect(Statement statement, String sqlSelectText) {
		ResultSet resultSet = null;
		try {
			resultSet = statement.executeQuery(sqlSelectText);
			if(resultSet != null)
				log("Select-Statement erfolgreich ausgeführt.");
		} catch (Exception ex) {
			System.out.println("Fehler beim Ausführen des Select-Statements!");
			System.out.println("    " + ex.getMessage());
		} return resultSet;
	}
	static public void printResultSet(ResultSet rs) {
		// ResultSet in zwei Schleifen auslesen
		try {
			int spaltenAnzahl = 5;
			// 1.) Datensatz für Datensatz
			while(rs.next()) {
				// 2.) durch die Spalten eines Datensatzes ->
				for(int columnIndex = 1; columnIndex < spaltenAnzahl; columnIndex++) {
					String element = "NULL";
					Object o = rs.getObject(columnIndex);
					if(o != null) {
						element = String.valueOf(o);
					}	System.out.print(element + " ");
				}		System.out.println();
			}
		} catch(Exception ex) {
			System.out.println("Fehler bei der Ausgabe des Reult-Sets!");
		}
	}
}