connectivity/source/drivers/firebird/Blob.hxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; fill-column: 100 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  */
   9
  10 #pragma once
  11
  12 #include <ibase.h>
  13
  14 #include <cppuhelper/compbase.hxx>
  15
  16 #include <com/sun/star/io/XInputStream.hpp>
  17 #include <com/sun/star/sdbc/XBlob.hpp>
  18
  19 namespace connectivity::firebird
  20     {
  21         typedef ::cppu::WeakComponentImplHelper< css::sdbc::XBlob,
  22                                                  css::io::XInputStream >
  23             Blob_BASE;
  24
  25         class Blob :
  26             public Blob_BASE
  27         {
  28         protected:
  29             ::osl::Mutex                    m_aMutex;
  30
  31             isc_db_handle*      m_pDatabaseHandle;
  32             isc_tr_handle*      m_pTransactionHandle;
  33             // We store our own copy of the blob id as typically the statement
  34             // manages its own blob id, and blobs are independent of a statement
  35             // in firebird.
  36             ISC_QUAD            m_blobID;
  37             isc_blob_handle     m_blobHandle;
  38
  39             bool                m_bBlobOpened;
  40             sal_Int64           m_nBlobLength;
  41             sal_uInt16          m_nMaxSegmentSize;
  42             sal_Int64           m_nBlobPosition;
  43
  44             ISC_STATUS_ARRAY    m_statusVector;
  45
  46             /// @throws css::sdbc::SQLException
  47             void ensureBlobIsOpened();
  48             /**
  49              * Closes the blob and cleans up resources -- can be used to reset
  50              * the blob if we e.g. want to read from the beginning again.
  51              *
  52              * @throws css::sdbc::SQLException
  53              */
  54             void closeBlob();
  55             sal_uInt16 getMaximumSegmentSize();
  56
  57         public:
  58             Blob(isc_db_handle* pDatabaseHandle,
  59                  isc_tr_handle* pTransactionHandle,
  60                  ISC_QUAD const & aBlobID);
  61
  62             bool readOneSegment(css::uno::Sequence< sal_Int8 >& rDataOut);
  63
  64             // ---- XBlob ----------------------------------------------------
  65             virtual sal_Int64 SAL_CALL
  66                 length() override;
  67             virtual css::uno::Sequence< sal_Int8 > SAL_CALL
  68                 getBytes(sal_Int64 aPosition, sal_Int32 aLength) override;
  69             virtual css::uno::Reference< css::io::XInputStream > SAL_CALL
  70                 getBinaryStream() override;
  71             virtual sal_Int64 SAL_CALL
  72                 position(const css::uno::Sequence< sal_Int8 >& rPattern,
  73                          sal_Int64 aStart) override;
  74             virtual sal_Int64 SAL_CALL
  75                 positionOfBlob(const css::uno::Reference< css::sdbc::XBlob >& rPattern,
  76                                sal_Int64 aStart) override;
  77
  78             // ---- XInputStream ----------------------------------------------
  79             virtual sal_Int32 SAL_CALL
  80                 readBytes(css::uno::Sequence< sal_Int8 >& rDataOut,
  81                           sal_Int32 nBytes) override;
  82             virtual sal_Int32 SAL_CALL
  83                 readSomeBytes(css::uno::Sequence< sal_Int8 >& rDataOut,
  84                               sal_Int32 nMaximumBytes) override;
  85             virtual void SAL_CALL
  86                 skipBytes(sal_Int32 nBytes) override;
  87             virtual sal_Int32 SAL_CALL
  88                 available() override;
  89             virtual void SAL_CALL
  90                 closeInput() override;
  91
  92             // ---- OComponentHelper ------------------------------------------
  93             virtual void SAL_CALL disposing() override;
  94         };
  95
  96 }
  97
  98 /* vim:set shiftwidth=4 softtabstop=4 expandtab cinoptions=b1,g0,N-s cinkeys+=0=break: */