blob.getBinaryStream самостоятельно закрывается

Question

У меня есть метод Java, который извлекает BLOB-объектов из базы данных Oracle (я использую ojdbc8.jar). Этот метод записывает BLOB-объект в OutputStream (для клиента):

// OutputStream os = response.getOutputStream();  // earlier
// Blob blob = resultSet.getBlob("data_binary");  // earlier

    int length;
    int bufSize = 4096;
    byte buffer[] = new byte[bufSize];
    try (InputStream is = blob.getBinaryStream()) {
        while ((length = is.read(buffer, 0, bufSize)) != -1) {
            out.write(buffer, 0, length);
            out.flush();
        }
        out.flush();
    }

и возвращает InputStream (для кеша):

return blob.getBinaryStream();

И когда я пытаюсь (в другом классе) записать этот InputStream на диск:

    try (OutputStream os = new FileOutputStream(fileOnTheDisk)) {
        IOUtils.copy(blobIS, os);
    } catch (IOException e) {
        e.printStackTrace();
    }

Я получаю исключения:

java.io.IOException: Closed Connection
at oracle.jdbc.driver.OracleBlobInputStream.needBytes(OracleBlobInputStream.java:204)
at oracle.jdbc.driver.OracleBufferedStream.readInternal(OracleBufferedStream.java:169)
at oracle.jdbc.driver.OracleBufferedStream.read(OracleBufferedStream.java:143)
at oracle.jdbc.driver.OracleBufferedStream.read(OracleBufferedStream.java:132)
at org.apache.commons.io.IOUtils.copyLarge(IOUtils.java:1025)
at org.apache.commons.io.IOUtils.copy(IOUtils.java:999)
at ru.miit.databasereader.OracleDatabaseReader.getbo(OracleDatabaseReader.java:262)
at ru.miit.contentservlet.ContentGetter.getObject(ContentGetter.java:85)
at ru.miit.contentservlet.ContentServlet.doGet(ContentServlet.java:131)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
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:53)
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.core.StandardHostValve.invoke(StandardHostValve.java:137)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81)
at org.apache.catalina.valves.AbstractAccessLogValve.invoke(AbstractAccessLogValve.java:651)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:87)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342)
at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:409)
at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:754)
at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1376)
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)
Caused by: java.sql.SQLRecoverableException: Closed Connection
at oracle.sql.BLOB.getDBAccess(BLOB.java:1122)
at oracle.sql.BLOB.getBytes(BLOB.java:348)
at oracle.jdbc.driver.OracleBlobInputStream.needBytes(OracleBlobInputStream.java:181)
... 31 more

Мне нужно решение, как написать это blob.getBinaryStream() на диск другого класса и узнать, в чем проблема.

Я пытался записать этот поток больших двоичных объектов на диск этим (извлекающим) методом, но я не получил исключений. И только когда я возвращаю этот поток другому классу, у меня есть исключения.

ОБНОВЛЕНО

Полный код DiskCache:

public class DiskCache {

public void put(final String location, final String name, final InputStream blobIS, OutpuStream servletOS) {

    DatabaseReader databaseReader = new DatabaseReader ();

    BinaryObject binaryobject = databaseReader.getBinaryDataByImageId(imageId, servletOS);

    File fileOnTheDisk = new File(location + name);

    try (OutputStream os = new FileOutputStream(fileOnTheDisk)) {
        IOUtils.copy(binaryobject.getIS(), os);
    } catch (IOException e) {
        e.printStackTrace();
    }

}

DatabaseReader:

public class DatabaseReader{

public Connection getConnection() throws NamingException, SQLException {

    Context initialContext = null;
    try {
        initialContext = new InitialContext();
        DataSource dataSource = (DataSource) initialContext.lookup(DATASOURCE_NAME);
        OracleConnection connection = (OracleConnection) dataSource.getConnection().unwrap(OracleConnection.class);
        return connection;
    } finally {
        if (initialContext != null){
            initialContext.close();
        }
    }

}
    public BinaryObject getBinaryDataByImageId(final String imageId, OutputStream osServlet) throws SQLException, NamingException, IOException{

     String sqlQuery = "***";

     BinaryObject binaryObject = null;
     try (Connection connection = getConnection();
            OraclePreparedStatement preparedStatement = (OraclePreparedStatement) connection
                    .prepareStatement(sqlQuery)) {
        try (ResultSet resultSet = preparedStatement.executeQuery()) {

            resultSet.next();
            Blob blob = resultSet.getBlob("blob_data");
            writeToStream(blob, osServlet); 
            binaryObject = new BinaryObject(imageId, blob.getBinaryStream());

        }
      }
      return binaryObject;
    }


    public void writeToStream(Blob blobData, OutputStream out) throws IOException, SQLException {

    int length;
    int bufSize = 4096;
    byte buffer[] = new byte[bufSize];
    try (InputStream is = blobData.getBinaryStream()) {
        while ((length = is.read(buffer, 0, bufSize)) != -1) {
            out.write(buffer, 0, length);
            out.flush();
        }
        out.flush();

    }

}
}

JNDI:

    <Resource name="jdbc/database" auth="Container"
    type="javax.sql.DataSource" maxActive="100" 
    maxIdle="30" maxWait="1000"
    username="***" 
    password="***"
    driverClassName="oracle.jdbc.OracleDriver"
    url="jdbc:oracle:thin***"/>

Answer 1

BLOB-объект должен быть прочитан только один раз, в каждом ResultSet.next шаг. После того, как набор результатов закрыт (и он должен быть закрыт), и после того, как прочитан входной поток большого двоичного объекта (также закрывая поток), вам не повезло.

Если вы хотите быстро обслуживать клиента и хранить дубликаты в кэше, вам нужно будет выполнить оба действия одновременно:

// OutputStream os = response.getOutputStream();  // earlier
// Blob blob = resultSet.getBlob("data_binary");  // earlier
// OutputStream cacheOut
final int bufSize = 4096;
byte[] buffer = new byte[bufSize];
int length;
try (InputStream is = blob.getBinaryStream()) {
    while ((length = is.read(buffer, 0, bufSize)) != -1) {
        out.write(buffer, 0, length);
        out.flush();
        cacheOut.write(buffer, 0, length);
    }
    out.flush();
    cacheOut.close();
}

Все остальное было бы требованием к памяти.

Answer 2

    BinaryObject binaryObject = null;
    try (ResultSet resultSet = preparedStatement.executeQuery()) {
        resultSet.next();
        Blob blob = resultSet.getBlob("data_binary");
        writeToStream(blob, osServlet); 
        binaryObject = new BinaryObject(imageId, blob.getBinaryStream());

    }
    return binaryObject;

Используя try-with-resources, ваш ResultSet закрывается, как только область остается, поэтому пытается прочитать с BLOB InputStream приводит к ошибке. В любом случае вы записываете данные в какой-то другой поток, поэтому, если это где-то временный файл, вы можете использовать FileInputStream вместо этого временного файла.