31.7. Armazenamento de dados binários

Exemplo 31-8. Processamento de dados binários no JDBC

Por exemplo, supondo haver uma tabela contendo nomes de arquivos de imagem, e que se deseje armazenar estas imagens em uma coluna bytea:

CREATE TABLE tbl_imagem (nome_da_imagem text, imagem bytea);

Para inserir a imagem seria utilizado:

File file = new File("minha_imagem.jpg");
InputStream fis = new FileInputStream(file);
PreparedStatement ps = conn.prepareStatement("INSERT INTO tbl_imagem VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setBinaryStream(2, fis, (int)file.length());
ps.executeUpdate();
ps.close();
fis.close();

No exemplo acima, setBinaryStream() transfere um determinado número de bytes do arquivo para a coluna do tipo bytea. Também poderia ter sido feito utilizando o método setBytes(), se o conteúdo da imagem estivesse armazenado como byte[].

Trazer a imagem é mais fácil ainda (Foi utilizado PreparedStatement neste exemplo, mas a classe Statement também poderia ter sido utilizada).

PreparedStatement ps = conn.prepareStatement("SELECT imagem " +
                                             "FROM tbl_imagem " +
                                             "WHERE nome_da_imagem = ?");
ps.setString(1, "minha_imagem.jpg");
ResultSet rs = ps.executeQuery();
if (rs != null) {
   while (rs.next()) {
      byte[] imgBytes = rs.getBytes(1);
      // utilizar os dados de alguma maneira
      System.out.println("Tamanho da imagem: " + imgBytes.length);
   }
   rs.close();
}
ps.close();

No exemplo acima os dados binários foram trazidos como byte[]. Em vez disso, poderia ser utilizado um objeto InputStream.

Como alternativa, se estiver sendo armazenado um arquivo muito grande pode ser utilizada a API LargeObject para armazenar o arquivo:

CREATE TABLE tbl_imagem_lo (nome_da_imagem text, oid_da_imagem oid);

Para inserir a imagem seria utilizado:

// Todas as chamadas à API do LargeObject devem
// ser feitas dentro de um bloco de transação
conn.setAutoCommit(false);

// Obter o Gerenciador de Objeto Grande para realizar operações com os mesmos
LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();

// Criar o novo objeto grande
int oid = lobj.create(LargeObjectManager.READ | LargeObjectManager.WRITE);

// Abrir o objeto grande para escrita
LargeObject obj = lobj.open(oid, LargeObjectManager.WRITE);

// Abrir o arquivo
File file = new File("minha_imagem.jpg");
FileInputStream fis = new FileInputStream(file);

// Copiar os dados do arquivo para o objeto grande
byte buf[] = new byte[2048];
int s, tl = 0;
while ((s = fis.read(buf, 0, 2048)) > 0) {
   obj.write(buf, 0, s);
   tl += s;
}

// Fechar o objeto grande
obj.close();

// Inserir a linha na tabela tbl_imagem_lo
PreparedStatement ps = conn.prepareStatement("INSERT INTO tbl_imagem_lo " +
                                             "VALUES (?, ?)");
ps.setString(1, file.getName());
ps.setInt(2, oid);
ps.executeUpdate();
ps.close();
fis.close();
conn.commit();

Trazer a imagem armazenada no objeto grande:

// Todas as chamadas à API LargeObject devem
// ser feitas dentro de um bloco de transação
conn.setAutoCommit(false);

// Obter o Gerenciador de Objeto Grande para realizar operações com os mesmos
LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();

PreparedStatement ps = conn.prepareStatement("SELECT oid_da_imagem " +
                                             "FROM tbl_imagem_lo " +
                                             "WHERE nome_da_imagem = ?");
ps.setString(1, "minha_imagem.jpg");
ResultSet rs = ps.executeQuery();
if (rs != null) {
   while (rs.next()) {
      // Abrir o objeto grande para leitura
      int oid = rs.getInt(1);
      LargeObject obj = lobj.open(oid, LargeObjectManager.READ);

      // Ler os dados
      byte buf[] = new byte[obj.size()];
      obj.read(buf, 0, obj.size());
      // utilizar os dados de alguma maneira
      System.out.println("Tamanho da imagem: " + buf.length);

      // Fechar o objeto
      obj.close();
   }
   rs.close();
}
ps.close();
conn.rollback();