file upload in oracle-db über Jdeveloper

Diese Seite verwendet Cookies. Durch die Nutzung unserer Seite erklären Sie sich damit einverstanden, dass wir Cookies setzen. Weitere Informationen

  • file upload in oracle-db über Jdeveloper

    Hallo Leute,
    ich selbst bin blutiger Anfänger im Application-Development und gerade im Praxissemester. Meine Aufgabe ist es, eine Javabasierte Applikation zu erweitern, ergänzen. Entwicklungsumgebung ist der JDeveloper 10g. Die Applikation läuft auf einem Oracle AS 10g. Mein aktuelles Problem besteht darin, dass ich einen fileupload über ein "inputFile" Feld realisieren soll, sodass BLOBS IN der Datenbank gespeichert werden. In deshalb, weil über OracleText eine Velltextsuche durch die Dokumente möglich sein soll. Leider ist dieses Projekt ein Stoß ins kalte Wasser für mich. Ausser Grundlagen DB und Java kann ich nicht viel mehr vorweisen. Ist es möglich direkt sqö-statements in den Javacode einzubinden?, benutze ich besser interMedia dafür und wie realisiere ich überhaupt meine Problemstellung? Ich bin für alle Anregungen, Hilfestellungen oder auch Codeschnipsel sehr dankbar.

  • Hello again!
    Mittlerweile bin ich etwas weitergekommen. Allerdings wird das BLOB selber noch nicht in der DB gespeichert. SQL-Developer meldet mir für den Wert des BLOB-Feldes "null". Kann dies daran liegen, dass vorher kein leeres BLOB erzeugt wurde? Vielleicht kann jemand mal meine Methode zum upload überfliegen und mir Feedback geben. Danke vorab.



    Quellcode

    1. public IfcobDocumentsIndicated createIfcobDocumentsIndicated(Integer level1, Integer level2,
    2. Integer level3, Integer level4, String lastUploadedFileName,
    3. Integer idDocumentsIndicated,
    4. String name, String shortName, String mimeType,
    5. String info, Date createDate, Date lastUpdate,
    6. String userId) {
    7. UnitOfWork uow = getSessionFactory().acquireUnitOfWork();
    8. IfcobDocumentsIndicated ifcobdocumentsindicated =
    9. (IfcobDocumentsIndicated)uow.newInstance(IfcobDocumentsIndicated.class);
    11. System.out.println("filename in bean:" + lastUploadedFileName);
    13. if (level1 != null && level2 != null && level3 != null &&
    14. level4 != null) {
    15. IfcobLevel1 ifcobLevel1 =
    16. (IfcobLevel1)uow.executeQuery("findLevel1ById",
    17. IfcobLevel1.class, level1);
    18. IfcobLevel2 ifcobLevel2 =
    19. (IfcobLevel2)uow.executeQuery("findLevel2ById",
    20. IfcobLevel2.class, level2);
    21. IfcobLevel3 ifcobLevel3 =
    22. (IfcobLevel3)uow.executeQuery("findLevel3ById",
    23. IfcobLevel3.class, level3);
    24. IfcobLevel4 ifcobLevel4 =
    25. (IfcobLevel4)uow.executeQuery("findLevel4ById",
    26. IfcobLevel4.class, level4);
    27. ifcobLevel1.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    28. ifcobLevel2.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    29. ifcobLevel3.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    30. ifcobLevel4.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    31. }
    32. else if (level1 != null && level2 != null && level3 != null &&
    33. level4 == null) {
    34. IfcobLevel1 ifcobLevel1 =
    35. (IfcobLevel1)uow.executeQuery("findLevel1ById",
    36. IfcobLevel1.class, level1);
    37. IfcobLevel2 ifcobLevel2 =
    38. (IfcobLevel2)uow.executeQuery("findLevel2ById",
    39. IfcobLevel2.class, level2);
    40. IfcobLevel3 ifcobLevel3 =
    41. (IfcobLevel3)uow.executeQuery("findLevel3ById",
    42. IfcobLevel3.class, level3);
    43. ifcobLevel1.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    44. ifcobLevel2.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    45. ifcobLevel3.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    46. }
    47. else if (level1 != null && level2 != null && level3 == null &&
    48. level4 == null) {
    49. IfcobLevel1 ifcobLevel1 =
    50. (IfcobLevel1)uow.executeQuery("findLevel1ById",
    51. IfcobLevel1.class, level1);
    52. IfcobLevel2 ifcobLevel2 =
    53. (IfcobLevel2)uow.executeQuery("findLevel2ById",
    54. IfcobLevel2.class, level2);
    55. ifcobLevel1.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    56. ifcobLevel2.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    57. }
    58. else if (level1 != null && level2 == null && level3 == null &&
    59. level4 == null) {
    60. IfcobLevel1 ifcobLevel1 =
    61. (IfcobLevel1)uow.executeQuery("findLevel1ById",
    62. IfcobLevel1.class, level1);
    63. ifcobLevel1.addIfcobDocumentsIndicated(ifcobdocumentsindicated);
    64. }
    66. ifcobdocumentsindicated.setIdDocumentsIndicated(idDocumentsIndicated);
    67. //ifcobdocumentsindicated.setBlobContent(blobContent);
    68. ifcobdocumentsindicated.setName(name);
    69. ifcobdocumentsindicated.setShortName(shortName);
    70. ifcobdocumentsindicated.setMimeType(mimeType);
    71. ifcobdocumentsindicated.setInfo(info);
    72. ifcobdocumentsindicated.setCreateDate(createDate);
    73. ifcobdocumentsindicated.setLastUpdate(lastUpdate);
    74. ifcobdocumentsindicated.setUserId(userId);
    76. //Save that away
    77. uow.commit();
    79. Connection conn;
    80. Statement stmt;
    81. ResultSet rset;
    82. String query;
    83. Integer newIdDocuments=0;
    84. //FileInputStream istream;
    86. try{
    87. FileInputStream istream=null;
    89. try{
    90. istream = new FileInputStream(lastUploadedFileName);
    91. } catch (FileNotFoundException e){
    92. // To Do
    93. }
    95. try{
    96. DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
    97. conn = DriverManager.getConnection("jdbc:oracle:thin:@****************:****", "******", "********");
    100. stmt=conn.createStatement();
    101. query="SELECT max(ID_DOCUMENTS_INDICATED) from IFCOB_DOCUMENTS_INDICATED";
    103. try{
    104. rset=stmt.executeQuery(query);
    105. rset.next();
    106. newIdDocuments=rset.getInt(1);
    107. }catch(Exception co){
    108. String msgError=co.getMessage();
    109. }
    111. /*
    112. stmt = conn.createStatement ();
    113. rset=stmt.executeQuery("INSERT INTO IFCOB_DOCUMENTS_INDICATED(BLOB_CONTENT) VALUES(EMPTY_blob() ");
    115. try
    116. {
    117. stmt.execute(query);
    118. }catch(Exception co)
    119. {
    120. String msgError=co.getMessage();
    121. }
    122. */
    126. stmt=conn.createStatement();
    127. rset = stmt.executeQuery ("SELECT BLOB_CONTENT FROM IFCOB_DOCUMENTS_INDICATED WHERE ID_DOCUMENTS_INDICATED="+newIdDocuments+"FOR UPDATE");
    129. if (rset.next ()){
    130. BLOB blob = ((OracleResultSet)rset).getBLOB(1);
    131. // Create an OutputStram object to write the blob as a stream
    132. OutputStream ostream = blob.getBinaryOutputStream ();
    133. // Create a tempory buffer
    134. byte[] buffer = new byte[1024];
    135. int length = 0;
    136. // Use the read() method to read the GIF file to the byte
    137. // array buffer, then use the write() method to write it to
    138. // the blob.
    139. while ((length = istream.read(buffer)) != -1){
    140. ostream.write(buffer, 0, length);
    141. }
    142. // Close the inputstream and outputstream
    143. istream.close();
    144. ostream.close();
    146. }
    148. conn.commit();
    149. if(rset!=null) rset.close();
    150. if(stmt!=null) stmt.close();
    151. if(conn!=null) conn.close();
    153. }catch(Exception e){
    154. e.printStackTrace();
    155. }
    156. }catch(Exception e){
    157. e.printStackTrace();
    158. }
    161. return ifcobdocumentsindicated;
    162. }
    Alles anzeigen