--- /dev/null
+///////////////////////////////////////////////////////////////////////////////\r
+//\r
+// File : $Id: blob.cpp,v 1.2 2009/03/19 20:00:28 faust Exp $\r
+// Subject : IBPP, Blob class implementation\r
+//\r
+///////////////////////////////////////////////////////////////////////////////\r
+//\r
+// (C) Copyright 2000-2006 T.I.P. Group S.A. and the IBPP Team (www.ibpp.org)\r
+//\r
+// The contents of this file are subject to the IBPP License (the "License");\r
+// you may not use this file except in compliance with the License. You may\r
+// obtain a copy of the License at http://www.ibpp.org or in the 'license.txt'\r
+// file which must have been distributed along with this file.\r
+//\r
+// This software, distributed under the License, is distributed on an "AS IS"\r
+// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the\r
+// License for the specific language governing rights and limitations\r
+// under the License.\r
+//\r
+///////////////////////////////////////////////////////////////////////////////\r
+//\r
+// COMMENTS\r
+// * Tabulations should be set every four characters when editing this file.\r
+//\r
+///////////////////////////////////////////////////////////////////////////////\r
+\r
+#ifdef _MSC_VER\r
+#pragma warning(disable: 4786 4996)\r
+#ifndef _DEBUG\r
+#pragma warning(disable: 4702)\r
+#endif\r
+#endif\r
+\r
+#include "_ibpp.h"\r
+\r
+#ifdef HAS_HDRSTOP\r
+#pragma hdrstop\r
+#endif\r
+\r
+#include <cstring>\r
+\r
+using namespace ibpp_internals;\r
+\r
+// (((((((( OBJECT INTERFACE IMPLEMENTATION ))))))))\r
+\r
+void BlobImpl::Open()\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("Blob::Open", _("Blob already opened."));\r
+ if (mDatabase == 0)\r
+ throw LogicExceptionImpl("Blob::Open", _("No Database is attached."));\r
+ if (mTransaction == 0)\r
+ throw LogicExceptionImpl("Blob::Open", _("No Transaction is attached."));\r
+ if (! mIdAssigned)\r
+ throw LogicExceptionImpl("Blob::Open", _("Blob Id is not assigned."));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_open_blob2)(status.Self(), mDatabase->GetHandlePtr(),\r
+ mTransaction->GetHandlePtr(), &mHandle, &mId, 0, 0);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Open", _("isc_open_blob2 failed."));\r
+ mWriteMode = false;\r
+}\r
+\r
+void BlobImpl::Create()\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("Blob::Create", _("Blob already opened."));\r
+ if (mDatabase == 0)\r
+ throw LogicExceptionImpl("Blob::Create", _("No Database is attached."));\r
+ if (mTransaction == 0)\r
+ throw LogicExceptionImpl("Blob::Create", _("No Transaction is attached."));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_create_blob2)(status.Self(), mDatabase->GetHandlePtr(),\r
+ mTransaction->GetHandlePtr(), &mHandle, &mId, 0, 0);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Create",\r
+ _("isc_create_blob failed."));\r
+ mIdAssigned = true;\r
+ mWriteMode = true;\r
+}\r
+\r
+void BlobImpl::Close()\r
+{\r
+ if (mHandle == 0) return; // Not opened anyway\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_close_blob)(status.Self(), &mHandle);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Close", _("isc_close_blob failed."));\r
+ mHandle = 0;\r
+}\r
+\r
+void BlobImpl::Cancel()\r
+{\r
+ if (mHandle == 0) return; // Not opened anyway\r
+\r
+ if (! mWriteMode)\r
+ throw LogicExceptionImpl("Blob::Cancel", _("Can't cancel a Blob opened for read"));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_cancel_blob)(status.Self(), &mHandle);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Cancel", _("isc_cancel_blob failed."));\r
+ mHandle = 0;\r
+ mIdAssigned = false;\r
+}\r
+\r
+int BlobImpl::Read(void* buffer, int size)\r
+{\r
+ if (mHandle == 0)\r
+ throw LogicExceptionImpl("Blob::Read", _("The Blob is not opened"));\r
+ if (mWriteMode)\r
+ throw LogicExceptionImpl("Blob::Read", _("Can't read from Blob opened for write"));\r
+ if (size < 1 || size > (64*1024-1))\r
+ throw LogicExceptionImpl("Blob::Read", _("Invalid segment size (max 64Kb-1)"));\r
+\r
+ IBS status;\r
+ unsigned short bytesread;\r
+ ISC_STATUS result = (*gds.Call()->m_get_segment)(status.Self(), &mHandle, &bytesread,\r
+ (unsigned short)size, (char*)buffer);\r
+ if (result == isc_segstr_eof) return 0; // Fin du blob\r
+ if (result != isc_segment && status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Read", _("isc_get_segment failed."));\r
+ return (int)bytesread;\r
+}\r
+\r
+void BlobImpl::Write(const void* buffer, int size)\r
+{\r
+ if (mHandle == 0)\r
+ throw LogicExceptionImpl("Blob::Write", _("The Blob is not opened"));\r
+ if (! mWriteMode)\r
+ throw LogicExceptionImpl("Blob::Write", _("Can't write to Blob opened for read"));\r
+ if (size < 1 || size > (64*1024-1))\r
+ throw LogicExceptionImpl("Blob::Write", _("Invalid segment size (max 64Kb-1)"));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_put_segment)(status.Self(), &mHandle,\r
+ (unsigned short)size, (char*)buffer);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Write", _("isc_put_segment failed."));\r
+}\r
+\r
+void BlobImpl::Info(int* Size, int* Largest, int* Segments)\r
+{\r
+ char items[] = {isc_info_blob_total_length,\r
+ isc_info_blob_max_segment,\r
+ isc_info_blob_num_segments};\r
+\r
+ if (mHandle == 0)\r
+ throw LogicExceptionImpl("Blob::GetInfo", _("The Blob is not opened"));\r
+\r
+ IBS status;\r
+ RB result(100);\r
+ (*gds.Call()->m_blob_info)(status.Self(), &mHandle, sizeof(items), items,\r
+ (short)result.Size(), result.Self());\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::GetInfo", _("isc_blob_info failed."));\r
+\r
+ if (Size != 0) *Size = result.GetValue(isc_info_blob_total_length);\r
+ if (Largest != 0) *Largest = result.GetValue(isc_info_blob_max_segment);\r
+ if (Segments != 0) *Segments = result.GetValue(isc_info_blob_num_segments);\r
+}\r
+\r
+void BlobImpl::Save(const std::string& data)\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("Blob::Save", _("Blob already opened."));\r
+ if (mDatabase == 0)\r
+ throw LogicExceptionImpl("Blob::Save", _("No Database is attached."));\r
+ if (mTransaction == 0)\r
+ throw LogicExceptionImpl("Blob::Save", _("No Transaction is attached."));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_create_blob2)(status.Self(), mDatabase->GetHandlePtr(),\r
+ mTransaction->GetHandlePtr(), &mHandle, &mId, 0, 0);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Save",\r
+ _("isc_create_blob failed."));\r
+ mIdAssigned = true;\r
+ mWriteMode = true;\r
+\r
+ size_t pos = 0;\r
+ size_t len = data.size();\r
+ while (len != 0)\r
+ {\r
+ size_t blklen = (len < 32*1024-1) ? len : 32*1024-1;\r
+ status.Reset();\r
+ (*gds.Call()->m_put_segment)(status.Self(), &mHandle,\r
+ (unsigned short)blklen, const_cast<char*>(data.data()+pos));\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Save",\r
+ _("isc_put_segment failed."));\r
+ pos += blklen;\r
+ len -= blklen;\r
+ }\r
+ \r
+ status.Reset();\r
+ (*gds.Call()->m_close_blob)(status.Self(), &mHandle);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Save", _("isc_close_blob failed."));\r
+ mHandle = 0;\r
+}\r
+\r
+void BlobImpl::Load(std::string& data)\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("Blob::Load", _("Blob already opened."));\r
+ if (mDatabase == 0)\r
+ throw LogicExceptionImpl("Blob::Load", _("No Database is attached."));\r
+ if (mTransaction == 0)\r
+ throw LogicExceptionImpl("Blob::Load", _("No Transaction is attached."));\r
+ if (! mIdAssigned)\r
+ throw LogicExceptionImpl("Blob::Load", _("Blob Id is not assigned."));\r
+\r
+ IBS status;\r
+ (*gds.Call()->m_open_blob2)(status.Self(), mDatabase->GetHandlePtr(),\r
+ mTransaction->GetHandlePtr(), &mHandle, &mId, 0, 0);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Load", _("isc_open_blob2 failed."));\r
+ mWriteMode = false;\r
+\r
+ size_t blklen = 32*1024-1;\r
+ data.resize(blklen);\r
+\r
+ size_t size = 0;\r
+ size_t pos = 0;\r
+ for (;;)\r
+ {\r
+ status.Reset();\r
+ unsigned short bytesread;\r
+ ISC_STATUS result = (*gds.Call()->m_get_segment)(status.Self(), &mHandle,\r
+ &bytesread, (unsigned short)blklen,\r
+ const_cast<char*>(data.data()+pos));\r
+ if (result == isc_segstr_eof) break; // End of blob\r
+ if (result != isc_segment && status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Load", _("isc_get_segment failed."));\r
+\r
+ pos += bytesread;\r
+ size += bytesread;\r
+ data.resize(size + blklen);\r
+ }\r
+ data.resize(size);\r
+ \r
+ status.Reset();\r
+ (*gds.Call()->m_close_blob)(status.Self(), &mHandle);\r
+ if (status.Errors())\r
+ throw SQLExceptionImpl(status, "Blob::Load", _("isc_close_blob failed."));\r
+ mHandle = 0;\r
+}\r
+\r
+IBPP::Database BlobImpl::DatabasePtr() const\r
+{\r
+ if (mDatabase == 0) throw LogicExceptionImpl("Blob::DatabasePtr",\r
+ _("No Database is attached."));\r
+ return mDatabase;\r
+}\r
+\r
+IBPP::Transaction BlobImpl::TransactionPtr() const\r
+{\r
+ if (mTransaction == 0) throw LogicExceptionImpl("Blob::TransactionPtr",\r
+ _("No Transaction is attached."));\r
+ return mTransaction;\r
+}\r
+\r
+IBPP::IBlob* BlobImpl::AddRef()\r
+{\r
+ ASSERTION(mRefCount >= 0);\r
+ ++mRefCount;\r
+ return this;\r
+}\r
+\r
+void BlobImpl::Release()\r
+{\r
+ // Release cannot throw, except in DEBUG builds on assertion\r
+ ASSERTION(mRefCount >= 0);\r
+ --mRefCount;\r
+ try { if (mRefCount <= 0) delete this; }\r
+ catch (...) { }\r
+}\r
+\r
+// (((((((( OBJECT INTERNAL METHODS ))))))))\r
+\r
+void BlobImpl::Init()\r
+{\r
+ mIdAssigned = false;\r
+ mWriteMode = false;\r
+ mHandle = 0;\r
+ mDatabase = 0;\r
+ mTransaction = 0;\r
+}\r
+\r
+void BlobImpl::SetId(ISC_QUAD* quad)\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("BlobImpl::SetId", _("Can't set Id on an opened BlobImpl."));\r
+ if (quad == 0)\r
+ throw LogicExceptionImpl("BlobImpl::SetId", _("Null Id reference detected."));\r
+\r
+ memcpy(&mId, quad, sizeof(mId));\r
+ mIdAssigned = true;\r
+}\r
+\r
+void BlobImpl::GetId(ISC_QUAD* quad)\r
+{\r
+ if (mHandle != 0)\r
+ throw LogicExceptionImpl("BlobImpl::GetId", _("Can't get Id on an opened BlobImpl."));\r
+ if (! mWriteMode)\r
+ throw LogicExceptionImpl("BlobImpl::GetId", _("Can only get Id of a newly created Blob."));\r
+ if (quad == 0)\r
+ throw LogicExceptionImpl("BlobImpl::GetId", _("Null Id reference detected."));\r
+\r
+ memcpy(quad, &mId, sizeof(mId));\r
+}\r
+\r
+void BlobImpl::AttachDatabaseImpl(DatabaseImpl* database)\r
+{\r
+ if (database == 0) throw LogicExceptionImpl("Blob::AttachDatabase",\r
+ _("Can't attach a NULL Database object."));\r
+\r
+ if (mDatabase != 0) mDatabase->DetachBlobImpl(this);\r
+ mDatabase = database;\r
+ mDatabase->AttachBlobImpl(this);\r
+}\r
+\r
+void BlobImpl::AttachTransactionImpl(TransactionImpl* transaction)\r
+{\r
+ if (transaction == 0) throw LogicExceptionImpl("Blob::AttachTransaction",\r
+ _("Can't attach a NULL Transaction object."));\r
+\r
+ if (mTransaction != 0) mTransaction->DetachBlobImpl(this);\r
+ mTransaction = transaction;\r
+ mTransaction->AttachBlobImpl(this);\r
+}\r
+\r
+void BlobImpl::DetachDatabaseImpl()\r
+{\r
+ if (mDatabase == 0) return;\r
+\r
+ mDatabase->DetachBlobImpl(this);\r
+ mDatabase = 0;\r
+}\r
+\r
+void BlobImpl::DetachTransactionImpl()\r
+{\r
+ if (mTransaction == 0) return;\r
+\r
+ mTransaction->DetachBlobImpl(this);\r
+ mTransaction = 0;\r
+}\r
+\r
+BlobImpl::BlobImpl(DatabaseImpl* database, TransactionImpl* transaction)\r
+ : mRefCount(0)\r
+{\r
+ Init();\r
+ AttachDatabaseImpl(database);\r
+ if (transaction != 0) AttachTransactionImpl(transaction);\r
+}\r
+\r
+BlobImpl::~BlobImpl()\r
+{\r
+ try\r
+ {\r
+ if (mHandle != 0)\r
+ {\r
+ if (mWriteMode) Cancel();\r
+ else Close();\r
+ }\r
+ }\r
+ catch (...) { }\r
+ \r
+ try { if (mTransaction != 0) mTransaction->DetachBlobImpl(this); }\r
+ catch (...) { }\r
+ try { if (mDatabase != 0) mDatabase->DetachBlobImpl(this); }\r
+ catch (...) { }\r
+}\r
+\r
+//\r
+// EOF\r
+//\r
git.stg.codes / stg.git / blobdiff