PostgreSQL Bytea INSERT

[Samofan]

Hallo Community,

ich bin gerade dabei, eine Oberfläche für eine Datenbank zu programmieren, welche verschiedene Datentypen beinhalten soll. Es soll "text" und "bytea" gespeichert werden. Das bytea brauche ich, um PDF Dateien zu speichern. Wie sinnvoll das ist, sei jetzt mal dahingestellt. Ich habe eine Eingabemaske für die einzelnen Daten, sowie einen FileChooser, mit dem man die PDF auswählen soll. Dann soll mit einem Button ein prepared Statement abgesetzt werden. Im Moment ist es so, dass ich einfach nur die File Location als String abspeichere, aber das soll geändert werden. Ist es denn überhaupt möglich, bytea mit den Strings zu senden? Und wenn ja, würde ich mich sehr über Tipps und/oder die Anpassung meines Quelltextes freuen. Wie man merkt bin ich noch ein Anfänger und hoffe, dass ich in dem Thread hier richtig bin.

So sieht mein FileChooser aus. Die File Location wird als String gespeichert. Falls keine PDF verfügbar ist, wird der String "Keine PDF verfügbar" an die Datenbank geschickt und dann später in meiner Oberfläche anstatt der File Location angezeigt, wie man bei "addData" sieht.

@FXML
  private void actionChooseFile(ActionEvent event)
  {
    fileChooser = new FileChooser();
    // title of fileChooser
    fileChooser.setTitle("PDF wählen...");
    // set the initialDirectory for FileChooser
    fileChooser.setInitialDirectory(new File(System.getProperty("user.home") + System.getProperty("file.separator") + "Desktop"));
    //only able to choose pdf files
    fileChooser.getExtensionFilters().add(new FileChooser.ExtensionFilter("PDF (*.pdf)", "*.PDF"));

    //open FileChooser
    File pdf = fileChooser.showOpenDialog(dataTable.getScene().getWindow());
    if (pdf != null)
    {
      Data.setFile(pdf.toString());
      System.out.println(pdf);
    }
    else
    {
      //do nothing
    }
  }

Ich lese dann die Daten aus den Textfeldern aus und übergebe sie an die Klasse, welche das Statement absetzt.

@FXML
  private void addData(ActionEvent event)
  {
    if (Data.getFile() == null)
    {
      Data.setFile("Keine PDF verfügbar");
    }
    else
    {
       //do nothing
    }
    try
    {
        DataDAO.insertData(textKunde.getText(), textLand.getText(), textWerkort.getText(), textGeraet.getText(), Integer.parseInt(textSeriennummer.getText()), Data.getPasswortHash(), Data.getFile());
        System.out.println("Daten hinzugefügt\n");
    }
    ...
  }

Danach kommt dann das Statement woran es bei mir hakt. Ich weiß nicht, wie ich die PDF in die Spalte als bytea eingefügt bekomme. Aktuell sieht das Statement noch so (siehe unten) aus.

public static void insertData(String kunde, String land, String werkort, String geraet, Integer seriennummer, String passwort, String pdf) throws SQLException, ClassNotFoundException
  {
    //Declare a INSERT statement
    String updateStmt
           = "    INSERT INTO maschinenliste\n"
             + "    (kunde, land, werkort, geraet, seriennummer, passwort, pdf)\n"
             + "    VALUES\n"
             + "    ('" + kunde + "', '" + land + "', '" + werkort + "', '" + geraet + "', '" + seriennummer + "', '" + passwort + "', '" + pdf + "');\n";

    //Execute INSERT operation
    try
    {
      DBUtil.dbExecuteUpdate(updateStmt);
      System.out.println(updateStmt);
    }
    catch (SQLException e)
    {
      System.out.print("Fehler: " + e);
      throw e;
    }
  }

Ich bedanke mich jetzt schonmal für die Hilfe! Anbei ist noch ein Bild der Anwendung, damit man sich das etwas leichter vorstellen kann, was ich vorhabe

 

[httpdigest]

Google "BYTEA insert JDBC":
- https://jdbc.postgresql.org/documentation/80/binary-data.html
- https://stackoverflow.com/questions/21285165/how-to-store-byte-from-java-into-a-bytea-in-postgresql

 

[Samofan]

Google "BYTEA insert JDBC":
- https://jdbc.postgresql.org/documentation/80/binary-data.html

Den ersten Link habe ich offen und ehrlich gesagt hat er mich nur mehr verwirrt. Aber Den Beitrag auf stackoverflow schaue ich mir mal näher an. Den habe ich vorher nicht gefunden.

 

[httpdigest]

Was verwirrt dich denn daran? Du erzeugst einfach ein Standard JDBC PreparedStatement und setzt das Byte-Array als InputStream (per ByteArrayInputStream) via PreparedStatement.setBinaryStream(paramPos, InputStream, array.length). Fertig.

 

[Samofan]

Wo Du recht hast, hast Du recht. Ich werde mich mal dran versuchen und mein neues "insertData" hier rein posten. Vielleicht kann es noch jemand gebrauchen.

 

[Samofan]

Ich bin jetzt so weit gekommen

public static void dbExecuteByteaUpdate(String kunde, String land, String werkort, String geraet, Integer seriennummer, String passwort, FileInputStream pdf)
  {
    String stm = "    INSERT INTO maschinenliste\n"
                 + "    (kunde, land, werkort, geraet, seriennummer, passwort, pdfbytea)\n"
                 + "    VALUES(?,?,?,?,?,?,?)";
    System.out.println(stm);
    try
    {
      PreparedStatement pst;
      pst = conn.prepareStatement(stm);
      pst.setString(1, kunde);
      pst.setNString(2, land);
      pst.setString(3, werkort);
      pst.setString(4, geraet);
      pst.setInt(5, seriennummer);
      pst.setString(6, passwort);
      pst.setBinaryStream(7, pdf, (int)Data.getFile().length());
      pst.executeUpdate();
      pst.close();
      KundeViewController.fis.close();
      System.out.println("Test");
    }
    catch (Exception e)
    {
    }
  }

Aber leider überspringt der alles nach dem "pst = conn.prepareStatement(stm);". Aus irgendeinem Grund werden die Strings für das Statement nicht gesetzt...

 

[httpdigest]

Naja, geschickterweise verschluckst du ja auch jede mögliche Exception, ohne sie irgendwie auszugeben oder weiterzuwerfen. Es wird ganz sicherlich eine Exception geworfen.

 

[Samofan]

Naja, geschickterweise verschluckst du ja auch jede mögliche Exception, ohne sie irgendwie auszugeben oder weiterzuwerfen. Es wird ganz sicherlich eine Exception geworfen.

Als ich das gelesen habe musste ich ein bisschen schmunzeln. Da hast du natürlich recht. Die Verbindung wird vor der Absetzung des Statements geschlossen und es kommt der Fehler "Die Methode org.postgresql.jdbc4.Jdbc4PreparedStatement.setNString(int, String) ist noch nicht implementiert.".

 

[Samofan]

In meinem pgAdmin steht, dass es funktioniert hat (es steht zumindest "binary data" in meinem bytea Feld. Meine Methode sieht jetzt so aus:

public static void dbExecuteByteaUpdate(String kunde, String land, String werkort, String geraet, Integer seriennummer, String passwort, FileInputStream pdf) throws SQLException, ClassNotFoundException
  {
    String stm = "    INSERT INTO maschinenliste\n"
                 + "    (kunde, land, werkort, geraet, seriennummer, passwort, pdfbytea)\n"
                 + "    VALUES(?,?,?,?,?,?,?)";
    System.out.println(stm);
    PreparedStatement pst = null;
    dbConnect();
    try
    {
      pst = conn.prepareStatement(stm);
      pst.setString(1, kunde);
      pst.setString(2, land);
      pst.setString(3, werkort);
      pst.setString(4, geraet);
      pst.setInt(5, seriennummer);
      pst.setString(6, passwort);
      pst.setBinaryStream(7, pdf, (int)Data.getFile().length());
      pst.executeUpdate();
      KundeViewController.fis.close();
      System.out.println("Test");
    }
    catch (IOException | SQLException e)
    {
      Logger.getLogger(KundeViewController.class.getName()).log(Level.SEVERE, null, e);
    }
    finally
    {
      if (pst != null)
      {
        //Close statement
        pst.close();
      }
      //Close connection
      dbDisconnect();
    }
  }

In meiner POM musste ich noch eine Dependency hinzufügen:

<dependency>
      <groupId>org.postgresql</groupId>
      <artifactId>postgresql</artifactId>
      <version>9.3-1100-jdbc41</version>
</dependency>

Ich hatte noch den etwas älteren Treiber drin wo das .setString noch nicht implementiert war. So wie es in der Exception steht.