Discussion :

[lalakers]

salut,

Je souhaite insérer un fichier dans un champ d'une de mes tables. J'ai une inpustream que j'aimerais insérer dans ma table par l'intermédiaire d'un champ BLOB.Mais comment transformer cet java.io.inputstream en un java.sql.Blob ?

merci



[Modéré par Didier] : ajout de tag dans le titre - Les règles du forum Java

[ZeKiD]

Pour ma part, j'ai essayé avec un PipedInputStream, et un PipedOutputStream , pour transformer mon output en input.
Mais j'ai eu des problèmes de taille.
Je suis donc passé par les ByteArrayInputStream et ByteArrayOutputStream.

[ZeKiD]

Sinon pour écrire dans un blob avec Oracle :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
try {
          // auto commit à false pour pouvoir envoyer le flux dans le BLOB Oracle
          conn.setAutoCommit(false);
 
          // On effectue un select for update nécessaire à l'envoi de fichier long dans la base de donnée
          // l'exécution simple de setBlob , ne permet pas l'envoi au dessus de 4Ko ( ou alors c'est à approfondir)
          pstmt = conn.prepareStatement(property.getProperty("Utilisateur.PreqSQL.updatePersoParamBean.selectForUpdate"));
          pstmt.setInt(1, user.getId().intValue());
          pstmt.setInt(2, Constantes.getConstante("CST_TYPE_PERSO.PERSO_PARAM_BEAN"));
          rs = pstmt.executeQuery();
          if(rs.next()) {
            try {
              // On récupère le BLOB Oracle puis l'OutputStream
              // afin d'écrire le document dedans.
              BLOB b = ((OracleResultSet)rs).getBLOB("paramBlob");
 
              if(b != null) {
                OutputStream outBlob = b.getBinaryOutputStream();
                if(outBlob != null) {
                  int bufferSize = b.getBufferSize();
                  int length = 0;
                  byte[] btab = new byte[bufferSize];
                  while((length = in.read(btab)) != -1) {
                    outBlob.write(btab, 0, length);
                  }
                  outBlob.close();
                  in.close();
                } else {
                  init.log("updatePersoParamBean(" + user.getIdWeb() + ") : outBlob==null", LogWriter.DEBUG);
                }
              } else {
                init.log("updatePersoParamBean(" + user.getIdWeb() + ") : b==null", LogWriter.DEBUG);
              }
            } catch(Exception exBlob) {
              init.log(exBlob, "updatePersoParamBean(" + user.getIdWeb() + "):exBlob:1", LogWriter.ERROR);
            }
          } else {
            init.log("updatePersoParamBean(" + user.getIdWeb() + ") : rs.next==false", LogWriter.DEBUG);
          }
          rs.close();
          pstmt.close();
          conn.commit();
        } catch(Exception exBlob2) {
          exBlob2.printStackTrace();
          init.log(exBlob2, "updatePersoParamBean(" + user.getIdWeb() + "):exBlob:2", LogWriter.ERROR);
        } finally {
          try {
            rs.close();
          } catch(Exception dummy) {
            dummy.printStackTrace();
          }
 
          try {
            pstmt.close();
          } catch(Exception dummy) {
            dummy.printStackTrace();
          }
 
          try {
            conn.rollback();
          } catch(Exception dummy) {
            dummy.printStackTrace();
          }
 
          try {
            conn.setAutoCommit(true);
          } catch(Exception dummy) {
            dummy.printStackTrace();
          }
        }

[jowo]

A l'aide de la méthode read(byte[] b, int off, int len) de InputStream et de la méthode de setBytes(long pos, byte[] bytes, int offset, int len)
de Blob

Code non testé:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
 
int pos = 0;
int read;
byte[] buffer = new byte[10 * 1024];
 
while ((read = input.read(buffer, 0, buffer.size()) != -1) {
   blob.setBytes(pos, buffer, 0, read);
   pos += read;
}

[pierre.zelb]

recupere ce qui t'interesse dans cette methode testée qui fonctionne :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
/**
     * @author pierre cellard
     * @param image : the image to be converted
     * @return a "bytearrayinputstream" which is the binary representation of the image.
     * this can be inserted in a DB column (type BLOB) by using a PreparedStatement and
     * its setBinaryStream method.
     */
    private ByteArrayInputStream getBlobByImage(Image image) {        
        if (image != null) {           
            BufferedImage buff = ImgTools.toBufferedImage(
                    image, BufferedImage.TYPE_INT_RGB);               
            byte[] imageBytes;
            if(buff != null) {
                 BufferedImage bImage = buff;
                 ByteArrayOutputStream baos = new ByteArrayOutputStream(1024);
                 //java.io.BufferedOutputStream out = new java.io.BufferedOutputStream(baos);
                 try {
                     //ImageIO.write(bImage, "jpeg", baos);
                     //java.io.BufferedOutputStream out = new java.io.BufferedOutputStream(baos);
                     com.sun.image.codec.jpeg.JPEGImageEncoder encoder = com.sun.image.codec.jpeg.JPEGCodec.createJPEGEncoder(baos);
                     com.sun.image.codec.jpeg.JPEGEncodeParam param = encoder.getDefaultJPEGEncodeParam(bImage);
                     param.setQuality((float) 1.0, true);
                     encoder.setJPEGEncodeParam(param);
                     encoder.encode(bImage);                     
                     //out.close();
                 } catch (IOException e) {
                     throw new IllegalStateException(e.toString());
                 }
                 imageBytes = baos.toByteArray();
                 //imageBytes = out.toByteArray();
 
 
            }
            else {
             imageBytes = new byte[0];
             System.out.println("PCD error : the buffered image is null");
            }
            ByteArrayInputStream inStream = new ByteArrayInputStream(imageBytes);
            return inStream;
        }
        // if nothing was returned :
        System.out.println("PCD error : the image is null");
        byte[] imageNullBytes = new byte[0];
        return new ByteArrayInputStream(imageNullBytes);
    }

[lalakers]

Auriez-vous des codes qui fonctionnent (non spécifique à oracle et à des images) avec d'un côté une insertion d'un inputstream dans un blob et inversement.
merci

[stoukou]

moi g ça bien marché

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
 File monImage = new File("image.bmp");
        FileInputStream istreamImage = new FileInputStream(monImage);
        Connection conn = null;
        PreparedStatement stmt = null;
        int rs =0; 
        //String query = "INSERT INTO HOTEL (NAME, HOTEL_ID, pic) " +
        	//	"VALUES ('NOVOTEL' ,"+i+","+pic+")";        
        try {
 
            conn = (new DriverJDBC()).initDriver();
            stmt =conn.prepareStatement("insert into Hotel (name, HOTEL_ID, pic) values (?,?,?)");
            stmt.setString(1, "NOVOTEL");
            stmt.setInt(2,i);
            stmt.setBinaryStream(3, istreamImage, (int) monImage.length());
            rs = stmt.executeUpdate();

[lalakers]

le problème c'est que qu'un setBinaryStream de peut prendre qu'une stream de 4ko maximum, comment utiliser à la place setBlob.

Comment faire la même chose que le dernier post de stoukou mais en tranformant un FileInputStream en Blob ?

Merci

[ZeKiD]

Le problème c'est que je crois que les BLOBs ne sont pas implémentés de la même manière dans toutes les bases.
C'est pour cela qu'on t'indique çà , avec notre expérience, et pour ma part d'Oracle.
Désolé de ne pas pouvoir t'aider, autrement, mais pour infos, j'ai cherché aussi sans dépendre de la base, mais sans succès.