Не удается получить данные BFILE из базы данных на Java (WebService) - PullRequest
0 голосов
/ 06 октября 2019

Это мой веб-сервис для моего приложения для Android, мне нужно получить BFILE (изображения) из базы данных Oracle 12c. Я делаю это

Модель:

package com.inv.entities;

import java.sql.Blob;
import java.sql.Date;

import oracle.sql.BFILE;

public class ArchivoImagen {
    private String codEmpresa;
    private int codArchivoImagen;
    private String codUsuarioAlta;
    private Date fecAlta;
    private Blob archivoBlob;
    private BFILE archivoImagen;
    private String filename;
    private String codArticuloRef;

    public ArchivoImagen() {
        super();
    }

    public String getCodEmpresa() {
        return codEmpresa;
    }

    public void setCodEmpresa(String codEmpresa) {
        this.codEmpresa = codEmpresa;
    }

    public int getCodArchivoImagen() {
        return codArchivoImagen;
    }

    public void setCodArchivoImagen(int codArchivoImagen) {
        this.codArchivoImagen = codArchivoImagen;
    }

    public String getCodUsuarioAlta() {
        return codUsuarioAlta;
    }

    public void setCodUsuarioAlta(String codUsuarioAlta) {
        this.codUsuarioAlta = codUsuarioAlta;
    }

    public Date getFecAlta() {
        return fecAlta;
    }

    public void setFecAlta(Date fecAlta) {
        this.fecAlta = fecAlta;
    }

    public Blob getArchivoBlob() {
        return archivoBlob;
    }

    public void setArchivoBlob(Blob archivoBlob) {
        this.archivoBlob = archivoBlob;
    }

    public BFILE getArchivoImagen() {
        return archivoImagen;
    }

    public void setArchivoImagen(BFILE archivoImagen) {
        this.archivoImagen = archivoImagen;
    }

    public String getFilename() {
        return filename;
    }

    public void setFilename(String filename) {
        this.filename = filename;
    }

    public String getCodArticuloRef() {
        return codArticuloRef;
    }

    public void setCodArticuloRef(String codArticuloRef) {
        this.codArticuloRef = codArticuloRef;
    }
}

Когда мне нужно получить данные:

package com.inv.services;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.ws.rs.Consumes;
import javax.ws.rs.GET;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.PathParam;
import javax.ws.rs.Produces;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Logger;

import com.inv.entities.ArchivoImagen;
import com.inv.utils.AppUtils;

import oracle.jdbc.driver.OracleResultSet;
import oracle.sql.BFILE;
import oracle.sql.BLOB;
@Path("/WsArchivoImagen")
@Consumes(MediaType.APPLICATION_JSON)
@Produces(MediaType.APPLICATION_JSON)
public class WsArchivoImagen {
    Logger logger  = Logger.getLogger(WsArticulo.class);

    public WsArchivoImagen() {
        BasicConfigurator.configure();
    }

    @GET
    @Path("/{cod_empresa}/{cod_articulo}")
    @Produces(MediaType.APPLICATION_JSON)
    public List<ArchivoImagen> getIt(@PathParam("cod_empresa") String cod_empresa, @PathParam("cod_articulo") String cod_articulo) {
        ArchivoImagen c = null;
        List<ArchivoImagen> lista = new ArrayList<>();

        String sql = "select cod_empresa," +
                     "cod_archivo_imagen," +
                     "cod_usuario_alta," +
                     "fec_alta," +
                     "archivo_blob," +
                     "archivo_imagen," +
                     "filename," +
                     "cod_articulo_ref " + 
                     "from archivos_imagenes "
                     + "where cod_empresa="
                     + cod_empresa
                     + " and cod_articulo_ref='"
                     + cod_articulo + "'";

        logger.debug("consulta "+sql);

        try {
            OracleResultSet rs = AppUtils.realizaConsulta(sql);

            while (rs.next()) {
                c = new ArchivoImagen();
                c.setCodEmpresa(rs.getString("cod_empresa"));
                c.setCodArchivoImagen(rs.getInt("cod_archivo_imagen"));
                c.setCodUsuarioAlta(rs.getString("cod_usuario_alta"));
                c.setFecAlta(rs.getDate("fec_alta"));
                //c.setArchivoBlob(rs.getBlob("archivo_blob"));
                c.setArchivoImagen(rs.getBFILE("archivo_imagen"));
                c.setFilename(rs.getString("filename"));
                c.setCodArticuloRef(rs.getString("cod_articulo_ref"));
                lista.add(c);
            }

        } catch (SQLException e) {
            System.out.println("Error en la consulta ");
            e.printStackTrace();
            logger.error("Error realizando la consulta de las imagenes del articulo " + cod_articulo +". "+sql,e);
            c = null;
        }

        AppUtils.cerrarConsulta();

        return lista;
    }
}

Я получаю эту ошибку в c.setArchivoImagen(rs.getBFILE ("archivo_imagen"));:

GRAVE: El Servlet.service() para el servlet [JAX-RS] en el contexto con ruta [/wsinv] lanzó la excepción [org.glassfish.jersey.server.ContainerException: com.fasterxml.jackson.databind.JsonMappingException: Conexión cerrada (through reference chain: java.util.ArrayList[0]->com.inv.entities.ArchivoImagen["archivoImagen"]->oracle.sql.BFILE["dbaccess"])] con causa raíz
java.sql.SQLException: Conexión cerrada
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:208)
    at oracle.sql.BFILE.getDBAccess(BFILE.java:594)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.lang.reflect.Method.invoke(Unknown Source)
    at com.fasterxml.jackson.databind.ser.BeanPropertyWriter.get(BeanPropertyWriter.java:679)
    at com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:534)
    at com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:597)
    at com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:142)
    at com.fasterxml.jackson.databind.ser.BeanPropertyWriter.serializeAsField(BeanPropertyWriter.java:569)
    at com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:597)
    at com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:142)
    at com.fasterxml.jackson.databind.ser.std.CollectionSerializer.serializeContentsUsing(CollectionSerializer.java:145)
    at com.fasterxml.jackson.databind.ser.std.CollectionSerializer.serializeContents(CollectionSerializer.java:87)
    at com.fasterxml.jackson.databind.ser.std.CollectionSerializer.serializeContents(CollectionSerializer.java:23)
    at com.fasterxml.jackson.databind.ser.std.AsArraySerializerBase.serialize(AsArraySerializerBase.java:186)
    at com.fasterxml.jackson.databind.ser.DefaultSerializerProvider.serializeValue(DefaultSerializerProvider.java:222)
    at com.fasterxml.jackson.databind.ObjectWriter.writeValue(ObjectWriter.java:496)
    at com.fasterxml.jackson.jaxrs.base.ProviderBase.writeTo(ProviderBase.java:542)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.invokeWriteTo(WriterInterceptorExecutor.java:243)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.aroundWriteTo(WriterInterceptorExecutor.java:230)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:149)
    at org.glassfish.jersey.server.internal.JsonWithPaddingInterceptor.aroundWriteTo(JsonWithPaddingInterceptor.java:103)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:149)
    at org.glassfish.jersey.server.internal.MappableExceptionWrapperInterceptor.aroundWriteTo(MappableExceptionWrapperInterceptor.java:88)
    at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:149)
    at org.glassfish.jersey.message.internal.MessageBodyFactory.writeTo(MessageBodyFactory.java:1139)
    at org.glassfish.jersey.server.ServerRuntime$Responder.writeResponse(ServerRuntime.java:574)
    at org.glassfish.jersey.server.ServerRuntime$Responder.processResponse(ServerRuntime.java:381)
    at org.glassfish.jersey.server.ServerRuntime$Responder.process(ServerRuntime.java:371)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:262)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:271)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:267)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:315)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:297)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:267)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:318)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:236)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:1010)
    at org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:373)
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:382)
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:345)
    at org.glassfish.jersey.servlet.ServletContainer.service(ServletContainer.java:220)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199)
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:528)
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)
    at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:678)
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:798)
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:810)
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1500)
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
    at java.lang.Thread.run(Unknown Source)

Утилиты моего приложения:

package com.inv.utils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.apache.log4j.Logger;

import oracle.jdbc.driver.OracleResultSet;

public class AppUtils {
    static Logger logger  = Logger.getLogger(AppUtils.class);

    private static final String DATABASE_URL = "jdbc:oracle:thin:@localhost:1521:ZEBIN";
    //private static final String DATABASE_URL = "jdbc:oracle:thin:@localhost:1521:DISTRIREP";
    private static final String DATABASE_USER = "INV";
    private static final String DATABASE_PASS = "INV";

    private static Connection con;
    private static Statement stmt;

    public static OracleResultSet realizaConsulta(String sql) throws SQLException {
        DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
        con = DriverManager.getConnection(DATABASE_URL, DATABASE_USER, DATABASE_PASS);
        con.setAutoCommit(false);
        stmt = con.createStatement();
        return (OracleResultSet) stmt.executeQuery(sql);
    }

    public static void realizaCarga(String sql) throws SQLException {
        logger.debug("sql inserta "+sql);
        DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
        con = DriverManager.getConnection(DATABASE_URL, DATABASE_USER, DATABASE_PASS);
        con.setAutoCommit(true);
        stmt = con.createStatement();
        stmt.executeUpdate(sql);
        cerrarConsulta();   
    }

    public static void cerrarConsulta(){
        try{
            con.close();
        }
        catch(Exception e){
            logger.error("error al cerrar la conexion de la base de datos",e);
        }

        try{
            stmt.close();
        }
        catch(Exception e){
            logger.error("error al cerrar la conexion de la base de datos",e);
        }
    }
}

Как решить эту ошибку, когда я пытаюсь получить BFILE из базы данных?

...