[JDBC]comment transformer une inpustream en un BLOB

Version imprimable

18/08/2005, 12h07
lalakers

[JDBC]comment transformer une inpustream en un BLOB

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
18/08/2005, 12h21
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.

Sinon pour écrire dans un blob avec Oracle :

Code:

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();
          }
        }

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:

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; }

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

Code:

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);
    }

18/08/2005, 16h44
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

moi g ça bien marché

Code:

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();

18/08/2005, 17h52
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
18/08/2005, 19h56
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.