java.sql Statement kann nicht geschlossen werden

[Carcharoth]

Guten Tag

Ich brüte jetzt schon eine ganze Weile über einen kleinen Fehler in meinem Code.
Wenn ich den Code so ausführe, bekomme ich eine Fehlermeldung

net.ucanaccess.jdbc.UcanaccessSQLException: UCAExc:::4.0.4 statement is closed

.

Kommentiere ich die Zeile 51 in der Methode executeSQL - statement.close() - aus, läuft es prima.
Für mich ist das nicht logisch denn ich brauche ja das Statement nicht mehr wenn das Resultat im ResultSet gespeichert ist.
Zusätzlich hatte ich vorher die gleiche Klasse mit HSQLDB anstatt mit UCANACCESS so am laufen, und da war es kein Problem.

Ich frage mich:
a) wieso das statement nicht geschlossen werden darf ?
b) was passiert wenn ich es einfach nicht schliesse? erledigt das der Garbage Collector?

import java.sql.*;

// <dependency>
//     <groupId>net.sf.ucanaccess</groupId>
//     <artifactId>ucanaccess</artifactId>
//     <version>4.0.4</version>
// </dependency>

public class Accdb {

    private Connection con;               
    private String path;               
    private String user;               
    private String password;           
    private String tableName;           

    // Konstruktor
    Accdb(String path, String user, String password, String tableName) {
        this.path = path;
        this.user = user;
        this.password = password;
        this.tableName = tableName;

        try{
            con = DriverManager.getConnection("jdbc:ucanaccess://" + path, user, password);
        }catch(SQLException se){
            se.printStackTrace();
        }
    }

    // Schliessen der Connection
    public void closeConnection() {
        try {
            con.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    // Ausführen des Query
    public ResultSet executeSQL(String sql) {
        Statement statement=null;
        ResultSet res=null;

        try {
            statement = con.createStatement(
                    ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_READ_ONLY);

            res = statement.executeQuery(sql);
            statement.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return res;
    }

    // Lesen aller Einträge der DB und Ausgabe über die Konsole
    public void readDB() {
        try {
            ResultSet res = executeSQL("SELECT * FROM " + tableName);

            if (res.next()) {
//                res.last();
//                System.out.println("Total rows is : " + res.getRow() + "\n");
//
//                res.beforeFirst();

                int columnCount = res.getMetaData().getColumnCount();
                int rowNumber=1;
                while (res.next()) {
                    System.out.print(rowNumber + ":  ");
                    for (int i = 1;i<=columnCount;i++ ) {
                        if (i!=columnCount) {
                            System.out.print(res.getString(i) + ", ");
                        } else System.out.print(res.getString(i));
                    }
                    System.out.println();
                    rowNumber++;
                }
            } else {
                System.out.println("No Data");
            }

            res.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        Accdb accdb = new Accdb("H:\\Database.accdb", "","","Data");
        System.out.println("DB is open.");
        System.out.println("------------------------------------------------------------------------------------------------");

        accdb.readDB();

        accdb.closeConnection();
        System.out.println("------------------------------------------------------------------------------------------------");
        System.out.println("DB has been closed !");
    }
}

 

[kneitzel]

Also im Augenblick kann ich das noch nicht ganz nachvollziehen, dass in Zeile 51 die Exception kommt. Ich würde die Exception in readDB erwarten.

Das Statement solltest Du erst schließen, wenn auch das ResultSet verarbeitet ist. Das Statement zu schließen um dann das ResultSet zu verarbeiten, wird so nicht funktionieren.

Üblich ist:
a) try with resources - Es wird also nicht selbst close aufgerufen sondern das macht das try with resources für dich.
b) Innerhalb des try blocks erfolgt auch die Verarbeitung des ResultSets.

Wenn Du das anders machen möchtest, dann geht das natürlich auch. Dazu hat das Statement ein closeOnCompletion Aufruf.
Dann wird das Statement erst mit dem schließen des ResultSets geschlossen.

Aber:
Das close gehört dann generell in ein finally:

Also das Pattern für manuelles schließen ist immer sowas wie:

Statement statement;
try {
    statement = ....;
} finally {
    if (statement != null) statement.close();
}

Wobei ich da dann gerne eine Methode safeClose(Closable) hatte, die halt die Prüfung gemacht hat und Exceptions gefangen und ignoriert hat.
Aber: Es gibt das try with resources und das sollte man nutzen!

 

[Carcharoth]

Danke.

Das Statement solltest Du erst schließen, wenn auch das ResultSet verarbeitet ist. Das Statement zu schließen um dann das ResultSet zu verarbeiten, wird so nicht funktionieren.

Diese Erkenntnis hilft schon weiter.

Ich versuch mich mal ans Try with resources.

 

[VfL_Freak]

bedeutet die meldung nicht ganz simpel, dass das Statement an dem Punkt bereits geschlossen ist ??

 

[kneitzel]

bedeutet die meldung nicht ganz simpel, dass das Statement an dem Punkt bereits geschlossen ist ??

Ja, genau. Und die Exception kommt vermutlich beim Zugriff auf das ResultSet. Das erfordert eine offenes Statement. Daher läuft es durch, wenn das Statement nicht geschlossen wird. Das Ergebnis wird in der Regel ausgewertet, ehe man das Statement schließt. (So kenne ich das eigentlich nur) Oder eben die Alternative: closeOnCompletion - dann wird es geschlossen, wenn das ResultSet geschlossen wird.

 

[Carcharoth]

Ich habe die Methode executeSQL wie folgt umgeschrieben (mit einem Try with Resources).
Ich musste leider im Catch das null zurückgeben, da Java sonst meckert, dass der return fehlt.

public ResultSet executeSQL(String sql) {
        try (ResultSet res = con.createStatement(
                    ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_READ_ONLY).executeQuery(sql)) {
            return res;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

Nachdem ich in der Methode readDB den obengenannten Code aufrufe

ResultSet res = executeSQL("SELECT * FROM " + tableName);

führt der erste Zugriff auf res.next() zu einem Fehler "invalid cursor state: identified cursor is not open".

 

[fhoffmann]

Du solltest die Idee vergessen, ein ResultSet zurückzugeben.
Sobald das Statement geschlossen ist, kann das ResultSet nicht mehr benutzt werden.

Der Grund ist folgender:
Es ist denkbar, dass das ResultSet am Anfang noch nicht alle Zeilen enthält (sondern beispielsweise nur die ersten 50 Zeilen). Erst wenn du mit resultSet.next() weitere Zeilen abfragst, werden diese von der Datenbank geholt. Und das geht nur, wenn das Statement noch offen ist.

Wenn du dazu mehr wissen willst, suche einmal nach "Datenbank Cursor".

 

[Carcharoth]

OK das leuchtet mir ein mit deinem Beispiel.
Was ist aber dann die Alternative? gleich beim lesen des Resultsets die Daten in eine andere Datenstrutkur transferieren und diese zurückgeben?

 

[kneitzel]

Du solltest den Code nicht so strukturiewren - das ist das, was ich mit

nnerhalb des try blocks erfolgt auch die Verarbeitung des ResultSets.

meinte.

Also so ein typischer Aufbau wäre bei Dir einfach ein:

    public void readDB() {
        try (Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
             ResultSet res = stmt.executeQuery(sql)) {
            
            while (res.next()) {
               // Zeile verarbeiten
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

 

[Carcharoth]

Gut, habe es jetzt wie von dir vorgeschlagen gelöst.
Danke.