Datenbank-Werte dynamisch ausgeben

[RezaScript]

Hallo,

ich habe eine Methode geschrieben, welche mir Daten von der Datenbank ausgibt:

public List<String> getData(String sql, Map column) {
    this.driver();
    try {
        Connection conn = DriverManager.getConnection(this.url);
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);

        List<String> result = new ArrayList<>();
        if (column.containsKey("string")) {
            for (Object i : column.values()) {
                while (rs.next()) {
                    result.add(rs.getString(String.valueOf(i)));
                }
            }
            return result;
        }

    }
    catch (SQLException e) {
        e.printStackTrace();
    }
    return null;
}

/**
 * Get the driver of MariaDB
 */
private void driver() {
    // Ensure we have mariadb Driver in classpath
    try {
        Class.forName("org.mariadb.jdbc.Driver");
    }
    catch (ClassNotFoundException e) {
        e.printStackTrace();
    }
}

Und so rufe ich die Methode auf:

public List<String> getAll() {
    Database databse = new Database();
    HashMap<String, String> columns = new HashMap<>();
    columns.put("string", "name")
    return databse.getData("SELECT * FROM zt_productions.comments", columns);
}

Somit bekomme ich alle Daten aus dem Column "name". Ich möchte nun aber die Werte von mehreren Columns und habe es so probiert:

    public List<String> getAll() {
    Database databse = new Database();
    HashMap<String, String> columns = new HashMap<>();
    columns.put("string", "comment");
    columns.put("string", "name")
    return databse.getData("SELECT * FROM zt_productions.comments", columns);
}

Ich bekomme aber immer nur die Werte von "name" und nicht alle Werte. Was mache ich falsch?

 

[httpdigest]

Eine Map kann nur einen Wert pro selbem Schlüssel speichern:

HashMap<String, String> columns = new HashMap<>();
columns.put("string", "comment");
columns.put("string", "name")

Hier überschreibst du den Schlüssel "string" mit dem neuen Wert "name". Deine Map hat anschließend genau einen Eintrag ("string" -> "name").

 

[RezaScript]

Gut zu wissen, danke. Und wie müsste ich genau vorgehen, damit ich zum Ziel komme?

 

[httpdigest]

Naja... da dich in der Methode `List<String> getData(String sql, Map column)` sowieso nur String Columns interessieren, kannst du ja einfach ein Set/List übergeben mit den Namen der String Columns, deren Werte du auslesen und zurückliefern möchtest.

 

[Xyz1]

Ja Spalten haben ja üblicherweise eine Bezeichnung - und diese kannst (als keys) nutzen.

 

[mihe7]

Und wie müsste ich genau vorgehen, damit ich zum Ziel komme?

Worin besteht denn der Sinn des Ganzen?

 

[RezaScript]

@mihe7 ich möchte alle Daten in einer Array oder als JSON ausgeben. Am liebsten hätte ich auch gerne nur einen Parameter, denn im ersten Parameter gebe ich als SQL ja schon mit welche Daten ich benötige.

 

[RezaScript]

@httpdigest ich hab's jetzt so probiert:

public List<String> getAll() {
    Database database = new Database();
    List<String> columns = Arrays.asList("comment", "name");
    return database.getData("SELECT * FROM zt_productions.comments", columns);
}

public List<String> getData(String sql, List<String> column) {
    this.driver();
    try {
        Connection conn = DriverManager.getConnection(this.url);
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);

        List<String> result = new ArrayList<>();

            for (String i : column) {
                while (rs.next()) {
                    result.add(rs.getString(String.valueOf(i)));
                }
            }
            return result;


    }
    catch (SQLException e) {
        e.printStackTrace();
    }
    return null;
}

Bekomme aber immer noch nur eine Spalte zurück geliefert.

 

[httpdigest]

Du holst ja auch immer nur eine Spalte aus einer Zeile/Row:

while (rs.next()) {
  result.add(rs.getString(String.valueOf(i)));
}

Oder mit anderen Worten: Deine Schleifen haben die falsche Reihenfolge. Zuerst musst du über die Rows iterieren und darin dann über die Spalten. Aktuell machst du es genau anders herum. Denke einfach erstmal darüber nach, was du da genau machst.

 

[mihe7]

Eine etwas allgemeinere Lösung könnte etwa so aussehen:

List<String> getColumnNames(ResultSet rs) throws SQLException {
    ResultSetMetaData rsmd = rs.getMetaData();
    List<String> result = new ArrayList<>();
    for (int i = 1, n = rsmd.getColumnCount(); i <= n; i++) {
        result.add(rsmd.getColumnName(i));
    }
    return result;
}

Map<String, Object> readRow(ResultSet rs, List<String> columnNames) throws SQLException {
    Map<String, Object> row = new HashMap<>();
    for (String name : columnNames) {
        row.put(name, rs.getObject(name));
    }
    return row;
}

void process(ResultSet rs, Consumer<Map<String, Object>> c) throws SQLException {
    List<String> columns = getColumnNames(rs);
    while (rs.next()) {
        c.accept(readRow(rs, columns));
    }
}

void getData(String sql, Consumer<Map<String, Object>> visitor) {
    this.driver();
    try(Connection conn = DriverManager.getConnection(this.url);
            Statement stmt = conn.createStatement();       
            ResultSet rs = stmt.executeQuery(sql)) {
        process(rs, visitor);
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

 

[RezaScript]

@mihe7 danke für deine Mühe, sieht schon mal sehr interessant aus. Könntest du vielleicht kurz bitte beschreiben was das Script gemau macht? Was ich z.B. u.a. nicht verstanden habe ist c.accept(readRow(rs, columns)); und der zweite Parameter von getData().

 

[mihe7]

Das Prinzip ist als Visitor Pattern bekannt.

process lässt sich erstmal die Spaltennamen zurückgeben, geht durch das ResultSet und liest jede Zeile in eine Map ein (readRow). Diese Map (=eingelesene Zeile) wird an den übergebenen Consumer (das ist der Visitor) weitergeleitet.

Ein Consumer ist einfach Objekt, das die Consumer-Schnittstelle (https://docs.oracle.com/javase/8/docs/api/java/util/function/Consumer.html) implementiert.

Wenn Du jetzt beispielsweise die Spalte "NAME" aller Zeilen ausgeben willst:

Consumer<Map<String, Object>> print = new Consumer<>() {
    @Override
    public void accept(Map<String, Object> row) {
        System.out.println(row.get("NAME"));
    }
};

getData("SELECT NAME, VORNAME FROM personen", print);

Da fällt mir auf, dass getData() ein schlechter Name ist... forEachRow wäre besser.

Oder wenn Du per JSON-P ein JSON-Array zusammenbauen willst:

final JsonArrayBuilder ab = Json.createArrayBuilder();
Consumer<Map<String, Object>> toJson = new Consumer<>() {
    @Override
    public void accept(Map<String, Object> row) {
        ab.add(Json.createObjectBuilder().
            .add("name", row.getOrDefault("NAME", "")
            .build());
    }
};
getData("SELECT NAME, VORNAME FROM personen", toJson);
System.out.println(ab.build().toString());

Statt den Interfaces kannst Du natürlich auch Lambdas verwenden.

 

[looparda]

.build());

Gehört das innerhalb der accept?

 

[mihe7]

Ja, das ist das build für das Object.

Was natürlich auch cool wäre, wäre eine Stream-Variante für den ganzen Käse

 

[looparda]

Ja, das ist das build für das Object.

Huch, das hab ich übersehen. Hatte es für ab gelesen.

 

[mihe7]

Huch, das hab ich übersehen. Hatte es für ab gelesen.

Gut zu wissen, evtl. sollte man das anders formatieren, zumal ich gerade sehe, dass davor eine schließende Klammer fehlt

    public void accept(Map<String, Object> row) {
        JsonObject obj = Json.createObjectBuilder()
                .add("name", row.getOrDefault("NAME", ""))
                .build();
        ab.add(obj);
    }

Wäre es so besser?

 

[Xyz1]

Wäre es so besser

Einfach viel besser, mihe!

 

[RezaScript]

@mihe7 danke, da ich nicht alles zu 100% verstanden habe, habe ich es versucht auf meine Art zu lösen, was definitiv nicht die beste Lösung ist.

public List<ArrayList<ArrayList<String>>> getData(String sql, List<String> columns) {
    this.driver();
    try {
        Connection conn = DriverManager.getConnection(this.url);
        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);

        List<ArrayList<ArrayList<String>>> result = new ArrayList<>();

        while (rs.next()) {
            ArrayList<ArrayList<String>> rows = new ArrayList<>();
            for (String column : columns) {
                ArrayList<String> col = new ArrayList<>();
                col.add(column);
                rows.add(col);
            }
            for (ArrayList<String> i : rows) {
                i.add(rs.getString(i.toString().replaceAll("[\\[\\]]", "")));
            }
            result.add(rows);
        }

        return result;

    }
    catch (SQLException e) {
        e.printStackTrace();
    }
    return null;
}

Ich bekomme nun eine dreidimensionale Array, was auch gut ist. Ich möchte nun aber an alle Werte rankommen, welche den Column "comment" haben.

for (ArrayList<ArrayList<String>> getRow : getAll()) {
    for(ArrayList<String> getColumn : getRow) {
        for (String getValue : getColumn) {
            System.out.println(getValue);
        }
    }
}

Das gibt mir aber ALLES aus, d.h. Spaltennamen und Werte in allen Spalten. Kann es sein, dass ich das nicht schaffe, weil die innerste Array keine Keys hat, sondern nur Werte? Wenn ja, wie kann ich das ändern?

 

[mihe7]

Ich bekomme nun eine dreidimensionale Array, was auch gut ist.

Ich weiß nicht, was daran gut sein soll.

Wenn ich Dich richtig verstehe, willst Du doch nur über einen Spaltennamen auf den Wert zugreifen, richtig? Das macht man mit einer Map. Wenn Du nicht für jede Zeile die Spaltennamen speichern willst, dann schreibst Du Dir halt eine entsprechende Klasse. Die könnte z. B. neben den Werten der Zeile (List) auch eine Map entgegennehmen, die Spaltennamen auf Array-Indizes abbildet.

Mal skizziert:

public class Row {
    private final Map<String, Integer> columnIndex;
    private final List<String> row;

    public Row(List<String> row, Map<String, Integer> columnIndex) {
        this.row = row;
        this.columnIndex = columnIndex;
    }

    public Set<String> getColumnNames() {
        return Collections.unmodifiableSet(columnIndex.keySet());
    }

    public String get(String columnName) {
        String result = null;
        Integer index = columnIndex.get(columnName);
        if (index != null) {
            result = row.get(index);
        }
        return result;
    }
}

Dann gibst Du halt in Deiner Abfrage eine Liste solcher Row-Objekte zurück:

public List<Row> getData(String sql, List<String> columns) {
    this.driver();    

    Map<String, Integer> columnIndex = new HashMap<>();
    int ix = 0;
    for (String column : columns) {
        columnIndex.put(column, ix);
        ix++;
    }

    // try-with-resources, um die geoeffneten Objekte wieder zu schliessen!
    try(Connection conn = DriverManager.getConnection(this.url);
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery(sql)) {

        List<Row> result = new ArrayList<>();

        while (rs.next()) {
            List<String> row = new ArrayList<>();
            for (String column : columns) {
                row.add(rs.getString(column.replaceAll("[\\[\\]]", "")));
            }
            result.add(new Row(row, columnIndex));
        }

        return result;
    }
    catch (SQLException e) {
        e.printStackTrace();
    }
    return null;
}

List<Row> result = getAll();
for (Row row : result) {
    for (String columnName : row.getColumnNames()) {
        System.out.println(columnName + ": " + row.get(columnName));
    }
}

 

[RezaScript]

Das ist perfekt so. Vielen vielen Dank!!