31.7. Stocker des données binaires

Exemple 31-8. Traiter des données binaires avec JDBC

Par exemple, supposez que vous avez une table contenant des noms de fichiers d'images et que vous souhaitez aussi stocker l'image dans une colonne de type bytea :

CREATE TABLE images (nomimg text, img bytea);

Pour insérer une image, vous utiliserez :

File file = new File("monimage.gif");
FileInputStream fis = new FileInputStream(file);
PreparedStatement ps = conn.prepareStatement("INSERT INTO images VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setBinaryStream(2, fis, file.length());
ps.executeUpdate();
ps.close();
fis.close();

Ici, setBinaryStream() transfère un certain nombre d'octets d'un flux dans la colonne de type bytea. Ceci pourrait aussi être fait en utilisant la méthode setBytes() si le contenu de l'image était déjà dans un byte[].

Récupérer une image est encore plus simple. (Nous utilisons PreparedStatement, mais la classe Statement pourrait très bien la remplacer.)

PreparedStatement ps = con.prepareStatement("SELECT img FROM images WHERE nomimg
= ?");
ps.setString(1, "monimage.gif");
ResultSet rs = ps.executeQuery();
if (rs != NULL) {
    while (rs.next()) {
        byte[] imgBytes = rs.getBytes(1);
        // utiliser les données ici...
    }
    rs.close();
}
ps.close();

Ici, les données binaires ont été récupérées dans un byte[]. À la place, vous pourriez avoir utilisé un objet InputStream.

Vous pouvez aussi stocker un très gros fichier et vouloir utiliser l'API LargeObject pour stocker le fichier :

CREATE TABLE imageslo (nomimg text, oidimg oid);

Pour insérer une image, vous pourriez :

// Tous les appels à l'API LargeObject doivent se faire dans un bloc de
// transaction
conn.setAutoCommit(false);

// Récupérer le gestionnaire des gros objets pour lui faire réaliser les
// opérations
LargeObjectManager lobj =
((org.postgresql.PGConnection)conn).getLargeObjectAPI();

// Créer un nouveau gros objet
int oid = lobj.create(LargeObjectManager.READ | LargeObjectManager.WRITE);

// Ouvrir le gros objet en écriture
LargeObject obj = lobj.open(oid, LargeObjectManager.WRITE);

// Maintenant, ouvrir le fichier
File file = new File("monimage.gif");
FileInputStream fis = new FileInputStream(file);

// Copier les données du fichier dans le gro objet
byte buf[] = new byte[2048];
int s, tl = 0;
while ((s = fis.read(buf, 0, 2048)) > 0) {
    obj.write(buf, 0, s);
    tl += s;
}

// Fermer le gros objet
obj.close();

// Maintenant, insérer la ligne dans imageslo
PreparedStatement ps = conn.prepareStatement("INSERT INTO imageslo VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setInt(2, oid);
ps.executeUpdate();
ps.close();
fis.close();

Pour récupérer l'image du gros objet :

// Tous les appels à l'API LargeObject doivent se faire dans un bloc de
// transaction
conn.setAutoCommit(false);

// Récupérer le gestionnaire des gros objets pour lui faire réaliser les
// opérations
LargeObjectManager lobj =
((org.postgresql.PGConnection)conn).getLargeObjectAPI();

PreparedStatement ps = con.prepareStatement("SELECT oidimg FROM imageslo
WHERE nomimg = ?");
ps.setString(1, "monimage.gif");
ResultSet rs = ps.executeQuery();
if (rs != NULL) {
    while (rs.next()) {
        // Ouvrir le gros objet en lecture
        int oid = rs.getInt(1);
        LargeObject obj = lobj.open(oid, LargeObjectManager.READ);

        // Lire les données
        byte buf[] = new byte[obj.size()];
        obj.read(buf, 0, obj.size());
        // Utiliser les données ici

        // Fermer l'objet
        obj.close();
    }
    rs.close();
}
ps.close();