Tabelle zu Datenbank hinzufügen / Apache Derby

[KinaFina]

Aufgabe: Nutzerdaten (Name und Passwort) sollen aus einer Datenbank kommen.
Es gibt schon eine Datenbank mit Tabellen zum Speichern von versendeten und eingegangenen E-Mails.
Jetzt habe ich eine weitere Tabelle (nutzer) in die bestehende Datenbank eingefügt , die aber nicht erkannt wird. Ich finde den Fehler nicht.

public class MiniMailDatenbankAnlegen extends JFrame {
    // automatisch über Eclipse erzeugt
    private static final long serialVersionUID = 7908452154759854933L;

    // für das Protokoll
    private String protokoll = "jdbc:derby:";

    // für die Verbindung
    // ACHTUNG! Es gibt mehrere Connection-Klassen!
    // benötigt wird die Klasse aus dem Paket java.sql.
    private Connection verbindung;
    

    // die innere Klasse für den ActionListener
    class MeinListener implements ActionListener {
        @Override
        public void actionPerformed(ActionEvent e) {
            // wurde auf Anlegen geklickt?
            if (e.getActionCommand().equals("anlegen"))
                // dann die Datenbank anlegen
                anlegenDB();
            // wurde auf neue Einträge geklickt?
            if (e.getActionCommand().equals("eintraege"))
                // dann die Testeinträge anlegen
                anlegenEintraege();
            // wurde auf Beenden geklickt?
            if (e.getActionCommand().equals("ende"))
                // dann beenden
                System.exit(0);
        }
    }

    public MiniMailDatenbankAnlegen(String titel) {
        super(titel);

        // ein FlowLayout
        setLayout(new FlowLayout(FlowLayout.LEFT));

        // die Schaltflächen
        JButton anlegen = new JButton("Datenbank anlegen");
        anlegen.setActionCommand("anlegen");
        JButton test = new JButton("Testeinträge erzeugen");
        test.setActionCommand("eintraege");
        JButton beenden = new JButton("Beenden");
        beenden.setActionCommand("ende");

        MeinListener listener = new MeinListener();
        anlegen.addActionListener(listener);
        test.addActionListener(listener);
        beenden.addActionListener(listener);

        add(anlegen);
        add(test);
        add(beenden);

        // Größe setzen, Standardverhalten festlegen und anzeigen
        pack();
        setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        setVisible(true);
    }

    private void oeffnenDB(String arg) {
        try {
            verbindung = DriverManager.getConnection(arg);
        } catch (Exception e) {
            JOptionPane.showMessageDialog(this, "Problem: \n" + e.toString());
        }
    }

    private void schliessenDB() {
        // das Schließen löst bei Erfolg eine Exception aus!!!
        boolean erfolg = false;
        try {
            DriverManager.getConnection(protokoll + "mailDB; shutdown = true");
        } catch (SQLException e) {
            erfolg = true;
        }
        if (erfolg != true)
            JOptionPane.showMessageDialog(this, "Das DBMS konnte nicht heruntergefahren werden.");
    }

    public static void main(String[] args) {
        new MiniMailDatenbankAnlegen("Datenbank-Werkzeuge");
    
        
    }

    private void anlegenDB() {
        // die Datenbank ist mailDB, sie wird neu angelegt
        oeffnenDB(protokoll + "mailDB; create = true");
        JOptionPane.showMessageDialog(this, "Die Datenbank wurde angelegt bzw. geöffnet.");
        // ein Statement zum Erstellen der Tabelle
        // bitte auch hier auf die richtige Klasse aus dem Paket sql achten!
        try {
            Statement state = verbindung.createStatement();
            state.execute("CREATE TABLE gesendet("
                    + "iNummer int NOT NULL GENERATED ALWAYS AS IDENTITY(START WITH 1, INCREMENT BY 1),"
                    + "empfaenger varchar(255) NOT NULL," + "betreff varchar(255)," + "inhalt CLOB(64 K),"
                    + "PRIMARY KEY (iNummer))");
            JOptionPane.showMessageDialog(this, "Die Tabelle gesendet wurde angelegt.");
            state.execute("CREATE TABLE empfangen("
                    + "iNummer int NOT NULL GENERATED ALWAYS AS IDENTITY(START WITH 1, INCREMENT BY 1),"
                    + "sender varchar(255) NOT NULL," + "betreff varchar(255)," + "inhalt CLOB(64 K),"
                    + "PRIMARY KEY (iNummer))");
            JOptionPane.showMessageDialog(this, "Die Tabelle empfangen wurde angelegt.");
            state.execute("CREATE TABLE nutzer("
                    + "iNummer int NOT NULL GENERATED ALWAYS AS IDENTITY(START WITH 1, INCREMENT BY 1),"
                    + "name varchar(255) NOT NULL," + "kennwort varchar(255)," + "PRIMARY KEY (iNummer))");
            JOptionPane.showMessageDialog(this, "Die Tabelle nutzer wurde angelegt.");

            // Verbindung schließen
            state.close();
            verbindung.close();
            // und die Datenbank schließen
            schliessenDB();
        } catch (Exception e) {
            JOptionPane.showMessageDialog(this, "Problem: \n" + e.toString());
        }
    }
    

    private void anlegenEintraege() {
        // die Datenbank öffnen
        oeffnenDB(protokoll + "mailDB");
        try {
            // einen Eintrag in der Tabellen nutzer anlegen
            // über ein vorbereitetes Statement
            PreparedStatement prepState;
            prepState = verbindung.prepareStatement("insert into nutzer (name, kennwort) values (?,?");
            prepState.setString(1, "kina.stuff@gmail.com");
            prepState.setString(2, "***");
            // das Statement ausführen
            prepState.executeUpdate();
            verbindung.commit();

            // Änderungen von außen werden sichtbar und der Cursor kann beliebig bewegt
            // werden
            Statement state;
            state = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            // die Ergebnismenge erzeugen
            // dazu beschaffen wir alle Einträge in der Tabelle empfangen
            ResultSet ergebnisMenge;
            ergebnisMenge = state.executeQuery("SELECT * FROM nutzer");
            // ganz nach vorne gehen
            ergebnisMenge.first();

            // zum Test die Werte in der Konsole ausgeben
            // hier wird direkt die Spalte angegeben
            System.out.println(ergebnisMenge.getInt("iNummer"));
            System.out.println(ergebnisMenge.getString("name"));
            System.out.println(ergebnisMenge.getString("kennwort"));

            // zum letzten Eintrag gehen
            ergebnisMenge.last();
            System.out.println("In der Tabelle nutzer stehen jetzt " + ergebnisMenge.getRow() + " Einträge");

            // Verbindung schließen
            prepState.close();
            state.close();
            ergebnisMenge.close(); // auskommentieren wenn noch eine weitere Tabelle folgt???

            // einen Eintrag in der Tabelle empfangen anlegen
            // über ein vorbereitetes Statement
            // PreparedStatement prepState;
            prepState = verbindung.prepareStatement("insert into empfangen (sender, betreff, inhalt) values (?,?,?)");
            prepState.setString(1, "kina.stuff@gmail.com");
            prepState.setString(2, "Testnachricht");
            prepState.setString(3, "Der Text der empfangenen Nachricht als CLOB");
            // das Statement ausführen
            prepState.executeUpdate();
            verbindung.commit();

            // Änderungen von außen werden sichtbar und der Cursor kann beliebig bewegt
            // werden
            state = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            // die Ergebnismenge erzeugen
            // dazu beschaffen wir alle Einträge in der Tabelle empfangen
            ergebnisMenge = state.executeQuery("SELECT * FROM empfangen");
            // ganz nach vorne gehen
            ergebnisMenge.first();

            // zum Test die Werte in der Konsole ausgeben
            // hier wird direkt die Spalte angegeben
            System.out.println(ergebnisMenge.getInt("iNummer"));
            System.out.println(ergebnisMenge.getString("sender"));
            System.out.println(ergebnisMenge.getString("betreff"));
            Clob clob;
            clob = ergebnisMenge.getClob("inhalt");
            System.out.println(clob.getSubString(1, (int) clob.length()));

            // zum letzten Eintrag gehen
            ergebnisMenge.last();
            System.out.println("In der Tabelle empfangen stehen jetzt " + ergebnisMenge.getRow() + " Einträge");

            // Verbindung schließen
            prepState.close();
            state.close();
            ergebnisMenge.close();

            // und einen Eintrag für die Tabelle gesendet anlegen
            // über ein vorbereitetes Statement
            prepState = verbindung.prepareStatement("insert into gesendet (empfaenger, betreff, inhalt) values (?,?,?)");
            prepState.setString(1, "kina.fina.stuff@gmail.com");
            prepState.setString(2, "Testnachricht");
            prepState.setString(3, "Der Text der gesendeten Nachricht als CLOB");
            // das Statement ausführen
            prepState.executeUpdate();
            verbindung.commit();

            // Änderungen von außen werden sichtbar und der Cursor kann beliebig bewegt
            // werden
            state = verbindung.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
            // die Ergebnismenge erzeugen
            // dazu beschaffen wir alle Einträge in der Tabelle empfangen
            ergebnisMenge = state.executeQuery("SELECT * FROM gesendet");
            // ganz nach vorne gehen
            ergebnisMenge.first();

            // zum Test die Werte in der Konsole ausgeben
            // hier wird direkt die Spalte angegeben
            System.out.println(ergebnisMenge.getInt("iNummer"));
            System.out.println(ergebnisMenge.getString("empfaenger"));
            System.out.println(ergebnisMenge.getString("betreff"));
            clob = ergebnisMenge.getClob("inhalt");
            System.out.println(clob.getSubString(1, (int) clob.length()));

            // zum letzten Eintrag gehen
            ergebnisMenge.last();
            System.out.println("In der Tabelle gesendet stehen jetzt " + ergebnisMenge.getRow() + " Einträge");

            // Verbindung schließen
            prepState.close();
            state.close();
            // ergebnisMenge.close(); //habe ich hinzugefügt

            // letzte Anweisung im try-Zweig
            verbindung.close();
            // und die Datenbank schließen
            schliessenDB();
        } catch (Exception e) {
            JOptionPane.showMessageDialog(this, "Problem: \n" + e.toString());
        }
    }
    
    
}

 

[Oneixee5]

Wie ist denn die Fehlermeldung?

 

[Oneixee5]

Hier fehlte eine Klammer:

            prepState = this.verbindung.prepareStatement("insert into nutzer (name, kennwort) values (?,?)");

 

[Oneixee5]

Ich weiß nicht auf welchem Level ihr bereits in eurem Kurs seit. Ich muss aber sagen, die Aufgabe ist sehr schlecht umgesetzt und enthält einige Probleme/Fehler. Ich weiß aber nicht ob Interesse besteht über die gewünschte Fehlersuche hinaus, noch weiter Probleme zu besprechen.

 

[KinaFina]

Hier fehlte eine Klammer:

            prepState = this.verbindung.prepareStatement("insert into nutzer (name, kennwort) values (?,?)");

Die fehlende Klammer ist mir dann auch aufgefallen vielen Dank!!

 

[KinaFina]

Ich weiß nicht auf welchem Level ihr bereits in eurem Kurs seit. Ich muss aber sagen, die Aufgabe ist sehr schlecht umgesetzt und enthält einige Probleme/Fehler. Ich weiß aber nicht ob Interesse besteht über die gewünschte Fehlersuche hinaus, noch weiter Probleme zu besprechen.

gerne!

 

[Oneixee5]

Zunächst das Öffnen der DB:

    private void oeffnenDB(final String arg) {
        try {
            this.verbindung = DriverManager.getConnection(arg);
        } catch (final Exception e) {
            JOptionPane.showMessageDialog(this, "Problem: \n" + e.toString());
        }
    }

    private void anlegenDB() {
        // die Datenbank ist mailDB, sie wird neu angelegt
        oeffnenDB(this.protokoll + "mailDB; create = true");
        ...

Nehmen wir mal an, das Öffnen der DB geht schief. Du fängst die Exception ab und gibst eine Meldung aus. Das wäre in Ordnung wenn du dann nicht einfach mit der weiterhin geschlossenen DB weiterarbeiten würdest als wäre nichts passiert. Das endet dann in weiteren Fehlern. Es ist also völlig nutzlos den Fehler auszugeben. Der Nutzer kann gar nicht reagieren. Er bekommt einfach weitere Fehler angezeigt.

So wie du vorgehst wäre es am besten die Klassenvariable zu entfernen:

    // für die Verbindung
    // ACHTUNG! Es gibt mehrere Connection-Klassen!
    // benötigt wird die Klasse aus dem Paket java.sql.
    private Connection verbindung;

Die Connection kannst du problemlos als lokale Variable in der Methode benutzen. Das wäre auch für das weiter Vorgehen und die Fehlerbehandlung sinnvoller.

Wenn du das verstanden und geändert hast, können wir mit dem nächsten Problem weitermachen.

 

[LaraCroft96]

@KinaFina Huhu, ich stehe aktuell vor der gleichen Aufgabe! Also du hast quasi die mitgegebene Klasse zum anlegen der DB verwendet. Ich habe sie im CMD selbst angelegt und bin jetzt am Tüfteln, wie ich das mache. Hast du hier dann eine separate Klasse für die Anmeldung angelegt oder in einer vorhandenen Klasse eine neue Methode geschrieben ? Wäre dir sehr dankbar für Hilfe. Liebe Grüße