import java.sql.*;
public class Datenbank {



    static Connection dbConn= null;

    private static boolean loadDriver(String driver){
        //Treiber laden
        try{
            Class.forName(driver);
            System.out.println("Treiber geladen...!");
            return true;
        }
        catch(ClassNotFoundException e)
        {
            System.out.println("Konnte den JDBC-Treiber nicht laden:"+"("+e.getMessage()+")");
            return false;
        }
        }

    private static boolean connect(String URL, String login, String passwort){
        //Verbindung herstellen
        try{
            dbConn= DriverManager.getConnection(URL, login, passwort);
            System.out.println("Verbindung zur Datenbank hergestellt!!");
            return true;
            }
        catch(SQLException e){
            System.out.println("Konnte die Verbindung zur Datenbank unter "+login+"nicht herstellen"+"("+e.getMessage()+")");
            return false;
        }
    }

    private static boolean executeSQLStatement(String sqlStatement){
        //Statements ausführen(Create, Insert, Delete, update)
        Statement stmt;
        try{
            stmt=dbConn.createStatement();
            stmt.executeUpdate(sqlStatement);
            stmt.close();
            System.out.println("SQL-Statement ("+sqlStatement+") erfolgreich!!");
            return true;
        }
        catch(SQLException e){
            e.printStackTrace();
            return false;
        }
    }

    private static boolean executeQuery(String query){
        //querys ausführen(dei einen Rückgabewert liefern mittels ResultSet (Select)
        Statement stmt;
        try{
            stmt= dbConn.createStatement();
            ResultSet rs = stmt.executeQuery(query);
            ausgabeResult(rs);
            return true;
        }
        catch(SQLException e){
            e.printStackTrace();
            return false;
        }

    }

    private static void ausgabeResult(ResultSet rs) {
        // Ausgabe auf Kommandozeile von Select-Queries
        try{
            int spalte=rs.getMetaData().getColumnCount();
            while(rs.next()){
                String reihe= new String(" | ");
                for(int i=1; i<=spalte;i++){
                    reihe=reihe.concat(rs.getString(i)+" | ");
                    }
                System.out.println(reihe);
            }
        }
            catch(SQLException e){
                e.printStackTrace();
            }
        }
    private static boolean closeConnection(){
        //Verbindung abbauen
        try{
        dbConn.close();
        dbConn=null;
        System.out.println("Verbindung geschlossen!!!");
        return true;
        }
        catch(SQLException e){
            System.out.println("Fehler beim Schließen der Datenbankverbindung."+"("+e.getMessage()+")");
            return false;
        }
    }
    public static void main(String[] args){
        //Main-Funktion mit Treiber,URL,Zugangsdaten und Queries als Strings
        String DBdriver= "oracle.jdbc.driver.OracleDriver";
        String dbURL= "jdbc:oracle:thin:@gemini.informatik.uni-augsburg.de:1521:db";
        String dbLogin ="1118590";
        String dbPasswort= "1118590";
        String query1= "CREATE TABLE lol(id INTEGER PRIMARY KEY, name CHAR(20), bezeichnung CHAR(20), wert FLOAT)";
        String query2= "INSERT INTO lol VALUES (9, 'Zeitung', 'zum lesen', 2.50)";
        String query3= "SELECT * FROM lol ORDER BY id";
        String query4= "DROP TABLE lol ";
        loadDriver(DBdriver);
        connect(dbURL,dbLogin,dbPasswort);
        //executeSQLStatement(query4);
        //executeSQLStatement(query1);
        //executeSQLStatement(query2);
        executeQuery(query3);
        closeConnection();

    }

    }