Java-SQL

Auf dieser Seite wird erklärt, wie man aus Java heraus SQL-Abfragen auf einer Datenbank ausführen kann.

Einschränkung der Allgemeingültigkeit dieser Seite:
Hier werden die Klassen DatabaseConnector.java und QueryResult.java verwendet, deren Schnittstelle vom Zentralabitur NRW vorgegeben ist

Erklärvideo

Mit Java auf Datenbanken zugreifen (gemäß Schnittstelle NRW-Zentralabitur)

Fachbegriffe

SQL-Abfrage, Parameter, QueryResult, 2-dimensionales Array, Zeile und Spalte(im 2-dim. Array)

Schnittstelle des Zentralabitur

Datei:DatabaseConnector QueryResult Abi 2018.pdf

Beispiel

Vorüberlegungen

Das folgende Beispiel bezieht sich auf die Datenbank Schule, die auch im Unterricht häufig zum Einsatz kommt.
Das Datenbank-Modell und alle Daten der Datenbank finden sich hier:

Beispieldatenbank Schule

Es soll jetzt eine Java-Methode entwickelt werden, die alle Schüler einer Klasse als eine Liste vom Inhaltstyp Person zurückgibt.
Die Klasse soll man als Parameter pKlasse übergeben können.

D.h. die Methodenkopf soll wie folgt aussehen:

  public List<Person> schuelerDerKlasse(String pKlasse)

(Die Klasse Person hat einen Konstruktor public Person(String pName, String pVorname) - mehr muss man über die Klasse Person hier nicht wissen.)

Datenbank-Abfrage

Die Datenbank-Abfrage, die das ermöglicht, ist die folgende - hier aufgezeigt am Beispiel der 8B:

 SELECT s.name, s.vorname
 FROM schueler s JOIN klasse k
 ON s.klasse_id = k.id
 WHERE k.name = '8B'

Diese Datenbank-Abfrage sollte man vorab entwickelt und getestet haben.

Es ist besser, wenn man für die SQL-Abfrage einfach Anführungszeichen nimmt!
Die doppelten Anführungszeichen braucht man für Java!

Strategie

Die möglichen Fehlerbehandlungen werden in der Strategie nicht berücksichtigt.

1. Es gibt ein Attribut connector vom Typ DatabaseConnector
2. Im Konstruktor wird der connector erzeugt.
3. In der Methode schuelerDerKlasse(String pKlasse) geht man so vor:
   1. SQL-Statement "zusammenbauen":
      String sqlStatement = " SELECT ..."
   2. SQL-Statement ausführen:
      connector.executeStatement(sqlStatement);
   3. Das Ergebnis der SQL-Abfrage ermitteln:
      QueryResult queryResult = connector.getCurrentQueryResult()
   4. Die Daten des Ergebnisses ermitteln:
      String[][] data = queryResult.getData();
      Man erhält ein 2-dimensionales Array.
      Dabei ist die erste Dimension für die Zeilen, die zweite Dimension für die Spalten.
   5. Die Zeilen werden mit einer for-Schleife durchlaufen:
      for (int i = 0; i < data.length; i++)
   6. Jetzt liest man die einzelnen Werte nach Spaltennummer aus, z.B. für den Namen
      String name = data[i][0];
   7. Man erhält grundsätzlich Objekte vom Typ String.
      Evtl. muss man sie noch in einen richtigen Datentyp konvertieren.

Java-Code

 public class DatenbankTest {
   private DatabaseConnector connector;
   
   public DatenbankTest() {
       // Die Verbindung zur Datenbank aufbauen
       //                                    ip       port database  user     password
       connector = new DatabaseConnector("localhost", 3306, "demo", "admin", "geheim");
       String errorMessage = connector.getErrorMessage();
       if(errorMessage != null) System.err.println(errorMessage);
   }

   public List<Person> schuelerDerKlasse(String pKlasse){
       List<Person> ergebnis = new List<Person>();

       //Das SQL-Statement zusammenbauen       
       // Der Paramenter pKlasse wird "eingebaut". - man muss auf die Leerzeichen achten!!       
       // Dabei muss man muss auf die Leerzeichen achten...       
       // ... und die einfachen Anführungszeichen für SQL mitschreiben!        

       String sqlStatement =
         " SELECT s.name, s.vorname "+
         " FROM schueler s JOIN klasse k "+
         " ON s.klasse_id = k.id "+
         " WHERE k.name = '" + pKlasse + "' ";
 
       // Zur Kontrolle das SQL-Statement ausgeben       
       System.out.println(sqlStatement);

       // Das SQL-Statement ausführen       
       connector.executeStatement(sqlStatement);

       // Abbruchbedingung für einen Error       
       String errorMessage = connector.getErrorMessage();
       if(errorMessage != null)
       {
            // Die Fehlernachricht ausgeben       
           System.err.println(errorMessage);
           return null;
       }

       // Das Ergebnis der Datenbankabfrage ermitteln:             
       // Man erhält ein Objekt vom Typ QueryResult             
       QueryResult queryResult = connector.getCurrentQueryResult();

       // Die Daten aus QueryResult auslesen             
       // Die Daten werden als 2-dim. Array wiedergegeben:             
       //   1. Dimension: Zeile des Ergebnisses             
       //   2. Dimension: Spalte des Ergebnisses (in der Reihenfolge wie im SQL-Statement        
       String[][] data = queryResult.getData();

       // Die Zeilen durchlaufen              
       for (int i = 0; i < data.length; i++) {
            // Die einzelnen Spalten einer Zeile abfragen              
           String name = data[i][0];
           String vorname = data[i][1];

           // ein Person-Objekt erzeugen ...         
           Person p = new Person(name, vorname);

           // ... und an die Liste ergebnis anhaengen         
           ergebnis.append(p);
       }
       return ergebnis;
   }
  
   public static void main(String[] args) {
       new GUI(new DatenbankTest());
   }
}