Publicado em: 09/04/2009 23:18:44

E ae galera do java, venho aqui pedir um ajuda de vcs!!!!!

Então,

Após pesquisar os tópicos referente a Blob, eu achei algo que me parece
funcional, mas tem um probleminha, ele não dá erro mas tb não inseri o
registro no banco (mensagem retorna null), veja o código abaixo e me
ajude por favor:

package pacote; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.OutputStream; import java.sql.*; public class Anexo extends Conexao{ private static final int NUMCHUNKS = 0; private Long id_anexo_forum; private int id_perguntas; private String nome_arquivo; private String descricao; private String arquivo; private String strFile; private String strDirectory; //Construtor public Anexo(){ } //get and set public String getArquivo() { return arquivo; } public void setArquivo(String arquivo) { this.arquivo = arquivo; } public String getDescricao() { return descricao; } public void setDescricao(String descricao) { this.descricao = descricao; } public Long getId_anexo_forum() { return id_anexo_forum; } public void setId_anexo_forum(Long id_anexo_forum) { this.id_anexo_forum = id_anexo_forum; } public int getId_perguntas() { return id_perguntas; } public void setId_perguntas(int id_perguntas) { this.id_perguntas = id_perguntas; } public String getNome_arquivo() { return nome_arquivo; } public void setNome_arquivo(String nome_arquivo) { this.nome_arquivo = nome_arquivo; } //Rotinas public String getIncluir() throws SQLException { //variables ResultSet resSet = null; InputStream sampleFileStream = null; OutputStream blobOutputStream = null; try { conecta(); // get new id PreparedStatement sql = conn.prepareStatement(" SELECT sigma_proj.sq_anexo_forum.nextval" + " FROM dual"); sql.executeQuery(); if (resSet.next()) { id_anexo_forum = new Long(resSet.getLong(1)); } // insert new row // The LOB column value is initialized to empty in this step, // and will be loaded in the steps below. sql = conn.prepareStatement(" INSERT INTO sigma_proj.anexo_forum (id_anexo_forum, id_perguntas, nome_arquivo, descricao, arquivo) VALUES " + " (" + id_anexo_forum + ", 1, ?, ?, empty_blob())"); sql.setString(1, nome_arquivo); sql.setString(2, descricao); sql.executeQuery(); // Retrieve BLOB locator sql = conn.prepareStatement(" SELECT arquivo FROM sigma_proj.anexo_forum WHERE id = " + id_anexo_forum + " FOR UPDATE"); resSet = sql.executeQuery(); mensagem = "Anexo incluido"; if (resSet.next()) { // Get the BLOB locator and open output stream for the BLOB BLOB BL_arquivo = ((OracleResultSet)resSet).getBLOB(1); blobOutputStream = BL_arquivo.getBinaryOutputStream(); // Open the sample file as a stream for insertion // into the BLOB column File file2Load = new File(nome_arquivo + arquivo); sampleFileStream = new FileInputStream(file2Load); // Buffer to hold chunks of data to being written to the BLOB. byte[] bBuffer = new byte[BL_arquivo.getBufferSize()*NUMCHUNKS]; // Read a chunk of data from the sample file input stream, // and write the chunk to the BLOB column output stream. // Repeat till file has been fully read. int intBytesRead = 0; // read from file until done while ((intBytesRead = sampleFileStream.read(bBuffer)) != -1) { // write to BLOB blobOutputStream.write(bBuffer,0,intBytesRead); } // closing the streams and committing sampleFileStream.close(); blobOutputStream.close(); conn.commit(); } } catch (Exception ex) { try { conn.rollback(); } catch (Exception e) {} } finally { try { sampleFileStream.close(); } catch (Exception e) {} try { blobOutputStream.close(); } catch (Exception e) {} try { resSet.close(); } catch (Exception e) {} } return mensagem; } }
_________________
Marcelo César

Publicado em: 09/04/2009 23:18:44

Olá camarada...

Na hora de fazer INSERT vc não atribui nada para o campo "ID" e na hora de fazer SELECT você colocar este campo no filtro, me parece que não está retornando nada
neste teu SELECT, logo não atribui o valor do BLOB.

Verifique sua lógica... flow !
_________________

Publicado em: 09/04/2009 23:18:44

brain

Olá camarada...

Na hora de fazer INSERT vc não atribui nada para o campo "ID"
(" + id_anexo_forum + ",1,?,?, empty_blob())
e na hora de fazer SELECT você colocar este campo no filtro, me parece que não está retornando nada
neste teu SELECT,
WHERE id_anexo_forum = " + id_anexo_forum + " FOR UPDATE"
logo não atribui o valor do BLOB.

Verifique sua lógica... flow !

Isso estaria errado??
_________________
Marcelo César

WebService restful retornar uma lista de objetos
http://javafree.uol.com.br/topic-873857-WebService-restful-retornar-uma-lista-de-objetos.html

Ajuda Calcular data
http://javafree.uol.com.br/topic-890629-Ajuda-Calcular-data.html

Threads em java
http://javafree.uol.com.br/topic-890654-Threads-em-java.html

Array Bidimensional
http://javafree.uol.com.br/topic-890672-Array-Bidimensional.html

Frequência de Letras
http://javafree.uol.com.br/topic-890670-Frequencia-de-Letras.html