+++ /dev/null
-///////////////////////////////////////////////////////////////////////////////\r
-//\r
-// File : $Id: transaction.cpp,v 1.1 2007/05/05 17:00:43 faust Exp $\r
-// Subject : IBPP, Database 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 <algorithm>\r
-\r
-using namespace ibpp_internals;\r
-\r
-// (((((((( OBJECT INTERFACE IMPLEMENTATION ))))))))\r
-\r
-void TransactionImpl::AttachDatabase(IBPP::Database db,\r
- IBPP::TAM am, IBPP::TIL il, IBPP::TLR lr, IBPP::TFF flags)\r
-{\r
- if (db.intf() == 0)\r
- throw LogicExceptionImpl("Transaction::AttachDatabase",\r
- _("Can't attach an unbound Database."));\r
-\r
- AttachDatabaseImpl(dynamic_cast<DatabaseImpl*>(db.intf()), am, il, lr, flags);\r
-}\r
-\r
-void TransactionImpl::DetachDatabase(IBPP::Database db)\r
-{\r
- if (db.intf() == 0)\r
- throw LogicExceptionImpl("Transaction::DetachDatabase",\r
- _("Can't detach an unbound Database."));\r
-\r
- DetachDatabaseImpl(dynamic_cast<DatabaseImpl*>(db.intf()));\r
-}\r
-\r
-void TransactionImpl::AddReservation(IBPP::Database db,\r
- const std::string& table, IBPP::TTR tr)\r
-{\r
- if (mHandle != 0)\r
- throw LogicExceptionImpl("Transaction::AddReservation",\r
- _("Can't add table reservation if Transaction started."));\r
- if (db.intf() == 0)\r
- throw LogicExceptionImpl("Transaction::AddReservation",\r
- _("Can't add table reservation on an unbound Database."));\r
-\r
- // Find the TPB associated with this database\r
- std::vector<DatabaseImpl*>::iterator pos =\r
- std::find(mDatabases.begin(), mDatabases.end(), dynamic_cast<DatabaseImpl*>(db.intf()));\r
- if (pos != mDatabases.end())\r
- {\r
- size_t index = pos - mDatabases.begin();\r
- TPB* tpb = mTPBs[index];\r
- \r
- // Now add the reservations to the TPB\r
- switch (tr)\r
- {\r
- case IBPP::trSharedWrite :\r
- tpb->Insert(isc_tpb_lock_write);\r
- tpb->Insert(table);\r
- tpb->Insert(isc_tpb_shared);\r
- break;\r
- case IBPP::trSharedRead :\r
- tpb->Insert(isc_tpb_lock_read);\r
- tpb->Insert(table);\r
- tpb->Insert(isc_tpb_shared);\r
- break;\r
- case IBPP::trProtectedWrite :\r
- tpb->Insert(isc_tpb_lock_write);\r
- tpb->Insert(table);\r
- tpb->Insert(isc_tpb_protected);\r
- break;\r
- case IBPP::trProtectedRead :\r
- tpb->Insert(isc_tpb_lock_read);\r
- tpb->Insert(table);\r
- tpb->Insert(isc_tpb_protected);\r
- break;\r
- /*default :\r
- throw LogicExceptionImpl("Transaction::AddReservation",\r
- _("Illegal TTR value detected."));*/\r
- }\r
- }\r
- else throw LogicExceptionImpl("Transaction::AddReservation",\r
- _("The database connection you specified is not attached to this transaction."));\r
-}\r
-\r
-void TransactionImpl::Start()\r
-{\r
- if (mHandle != 0) return; // Already started anyway\r
-\r
- if (mDatabases.empty())\r
- throw LogicExceptionImpl("Transaction::Start", _("No Database is attached."));\r
-\r
- struct ISC_TEB\r
- {\r
- ISC_LONG* db_ptr;\r
- ISC_LONG tpb_len;\r
- char* tpb_ptr;\r
- } * teb = new ISC_TEB[mDatabases.size()];\r
-\r
- unsigned i;\r
- for (i = 0; i < mDatabases.size(); i++)\r
- {\r
- if (mDatabases[i]->GetHandle() == 0)\r
- {\r
- // All Databases must be connected to Start the transaction !\r
- delete [] teb;\r
- throw LogicExceptionImpl("Transaction::Start",\r
- _("All attached Database should have been connected."));\r
- }\r
- teb[i].db_ptr = (ISC_LONG*) mDatabases[i]->GetHandlePtr();\r
- teb[i].tpb_len = mTPBs[i]->Size();\r
- teb[i].tpb_ptr = mTPBs[i]->Self();\r
- }\r
-\r
- IBS status;\r
- (*gds.Call()->m_start_multiple)(status.Self(), &mHandle, (short)mDatabases.size(), teb);\r
- delete [] teb;\r
- if (status.Errors())\r
- {\r
- mHandle = 0; // Should be, but better be sure...\r
- throw SQLExceptionImpl(status, "Transaction::Start");\r
- }\r
-}\r
-\r
-void TransactionImpl::Commit()\r
-{\r
- if (mHandle == 0)\r
- throw LogicExceptionImpl("Transaction::Commit", _("Transaction is not started."));\r
- \r
- IBS status;\r
-\r
- (*gds.Call()->m_commit_transaction)(status.Self(), &mHandle);\r
- if (status.Errors())\r
- throw SQLExceptionImpl(status, "Transaction::Commit");\r
- mHandle = 0; // Should be, better be sure\r
-}\r
-\r
-void TransactionImpl::CommitRetain()\r
-{\r
- if (mHandle == 0)\r
- throw LogicExceptionImpl("Transaction::CommitRetain", _("Transaction is not started."));\r
-\r
- IBS status;\r
-\r
- (*gds.Call()->m_commit_retaining)(status.Self(), &mHandle);\r
- if (status.Errors())\r
- throw SQLExceptionImpl(status, "Transaction::CommitRetain");\r
-}\r
-\r
-void TransactionImpl::Rollback()\r
-{\r
- if (mHandle == 0) return; // Transaction not started anyway\r
-\r
- IBS status;\r
-\r
- (*gds.Call()->m_rollback_transaction)(status.Self(), &mHandle);\r
- if (status.Errors())\r
- throw SQLExceptionImpl(status, "Transaction::Rollback");\r
- mHandle = 0; // Should be, better be sure\r
-}\r
-\r
-void TransactionImpl::RollbackRetain()\r
-{\r
- if (mHandle == 0)\r
- throw LogicExceptionImpl("Transaction::RollbackRetain", _("Transaction is not started."));\r
-\r
- IBS status;\r
-\r
- (*gds.Call()->m_rollback_retaining)(status.Self(), &mHandle);\r
- if (status.Errors())\r
- throw SQLExceptionImpl(status, "Transaction::RollbackRetain");\r
-}\r
-\r
-IBPP::ITransaction* TransactionImpl::AddRef()\r
-{\r
- ASSERTION(mRefCount >= 0);\r
- ++mRefCount;\r
- return this;\r
-}\r
-\r
-void TransactionImpl::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 TransactionImpl::Init()\r
-{\r
- mHandle = 0;\r
- mDatabases.clear();\r
- mTPBs.clear();\r
- mStatements.clear();\r
- mBlobs.clear();\r
- mArrays.clear();\r
-}\r
-\r
-void TransactionImpl::AttachStatementImpl(StatementImpl* st)\r
-{\r
- if (st == 0)\r
- throw LogicExceptionImpl("Transaction::AttachStatement",\r
- _("Can't attach a 0 Statement object."));\r
-\r
- mStatements.push_back(st);\r
-}\r
-\r
-void TransactionImpl::DetachStatementImpl(StatementImpl* st)\r
-{\r
- if (st == 0)\r
- throw LogicExceptionImpl("Transaction::DetachStatement",\r
- _("Can't detach a 0 Statement object."));\r
-\r
- mStatements.erase(std::find(mStatements.begin(), mStatements.end(), st));\r
-}\r
-\r
-void TransactionImpl::AttachBlobImpl(BlobImpl* bb)\r
-{\r
- if (bb == 0)\r
- throw LogicExceptionImpl("Transaction::AttachBlob",\r
- _("Can't attach a 0 BlobImpl object."));\r
-\r
- mBlobs.push_back(bb);\r
-}\r
-\r
-void TransactionImpl::DetachBlobImpl(BlobImpl* bb)\r
-{\r
- if (bb == 0)\r
- throw LogicExceptionImpl("Transaction::DetachBlob",\r
- _("Can't detach a 0 BlobImpl object."));\r
-\r
- mBlobs.erase(std::find(mBlobs.begin(), mBlobs.end(), bb));\r
-}\r
-\r
-void TransactionImpl::AttachArrayImpl(ArrayImpl* ar)\r
-{\r
- if (ar == 0)\r
- throw LogicExceptionImpl("Transaction::AttachArray",\r
- _("Can't attach a 0 ArrayImpl object."));\r
-\r
- mArrays.push_back(ar);\r
-}\r
-\r
-void TransactionImpl::DetachArrayImpl(ArrayImpl* ar)\r
-{\r
- if (ar == 0)\r
- throw LogicExceptionImpl("Transaction::DetachArray",\r
- _("Can't detach a 0 ArrayImpl object."));\r
-\r
- mArrays.erase(std::find(mArrays.begin(), mArrays.end(), ar));\r
-}\r
-\r
-void TransactionImpl::AttachDatabaseImpl(DatabaseImpl* dbi,\r
- IBPP::TAM am, IBPP::TIL il, IBPP::TLR lr, IBPP::TFF flags)\r
-{\r
- if (mHandle != 0)\r
- throw LogicExceptionImpl("Transaction::AttachDatabase",\r
- _("Can't attach a Database if Transaction started."));\r
- if (dbi == 0)\r
- throw LogicExceptionImpl("Transaction::AttachDatabase",\r
- _("Can't attach a null Database."));\r
-\r
- mDatabases.push_back(dbi);\r
-\r
- // Prepare a new TPB\r
- TPB* tpb = new TPB;\r
- if (am == IBPP::amRead) tpb->Insert(isc_tpb_read);\r
- else tpb->Insert(isc_tpb_write);\r
-\r
- switch (il)\r
- {\r
- case IBPP::ilConsistency : tpb->Insert(isc_tpb_consistency); break;\r
- case IBPP::ilReadDirty : tpb->Insert(isc_tpb_read_committed);\r
- tpb->Insert(isc_tpb_rec_version); break;\r
- case IBPP::ilReadCommitted : tpb->Insert(isc_tpb_read_committed);\r
- tpb->Insert(isc_tpb_no_rec_version); break;\r
- case IBPP::ilConcurrency : tpb->Insert(isc_tpb_concurrency); break;\r
- }\r
-\r
- if (lr == IBPP::lrNoWait) tpb->Insert(isc_tpb_nowait);\r
- else tpb->Insert(isc_tpb_wait);\r
-\r
- if (flags & IBPP::tfIgnoreLimbo) tpb->Insert(isc_tpb_ignore_limbo);\r
- if (flags & IBPP::tfAutoCommit) tpb->Insert(isc_tpb_autocommit);\r
- if (flags & IBPP::tfNoAutoUndo) tpb->Insert(isc_tpb_no_auto_undo);\r
-\r
- mTPBs.push_back(tpb);\r
-\r
- // Signals the Database object that it has been attached to the Transaction\r
- dbi->AttachTransactionImpl(this);\r
-}\r
-\r
-void TransactionImpl::DetachDatabaseImpl(DatabaseImpl* dbi)\r
-{\r
- if (mHandle != 0)\r
- throw LogicExceptionImpl("Transaction::DetachDatabase",\r
- _("Can't detach a Database if Transaction started."));\r
- if (dbi == 0)\r
- throw LogicExceptionImpl("Transaction::DetachDatabase",\r
- _("Can't detach a null Database."));\r
-\r
- std::vector<DatabaseImpl*>::iterator pos =\r
- std::find(mDatabases.begin(), mDatabases.end(), dbi);\r
- if (pos != mDatabases.end())\r
- {\r
- size_t index = pos - mDatabases.begin();\r
- TPB* tpb = mTPBs[index];\r
- mDatabases.erase(pos);\r
- mTPBs.erase(mTPBs.begin()+index);\r
- delete tpb;\r
- }\r
-\r
- // Signals the Database object that it has been detached from the Transaction\r
- dbi->DetachTransactionImpl(this);\r
-}\r
-\r
-TransactionImpl::TransactionImpl(DatabaseImpl* db,\r
- IBPP::TAM am, IBPP::TIL il, IBPP::TLR lr, IBPP::TFF flags)\r
- : mRefCount(0)\r
-{\r
- Init();\r
- AttachDatabaseImpl(db, am, il, lr, flags);\r
-}\r
-\r
-TransactionImpl::~TransactionImpl()\r
-{\r
- // Rollback the transaction if it was Started\r
- try { if (Started()) Rollback(); }\r
- catch (...) { }\r
-\r
- // Let's detach cleanly all Blobs from this Transaction.\r
- // No Blob object can still maintain pointers to this\r
- // Transaction which is disappearing.\r
- //\r
- // We use a reverse traversal of the array to avoid loops.\r
- // The array shrinks on each loop (mBbCount decreases).\r
- // And during the deletion, there is a packing of the array through a\r
- // copy of elements from the end to the beginning of the array.\r
- try {\r
- while (mBlobs.size() > 0)\r
- mBlobs.back()->DetachTransactionImpl();\r
- } catch (...) { }\r
-\r
- // Let's detach cleanly all Arrays from this Transaction.\r
- // No Array object can still maintain pointers to this\r
- // Transaction which is disappearing.\r
- try {\r
- while (mArrays.size() > 0)\r
- mArrays.back()->DetachTransactionImpl();\r
- } catch (...) { }\r
-\r
- // Let's detach cleanly all Statements from this Transaction.\r
- // No Statement object can still maintain pointers to this\r
- // Transaction which is disappearing.\r
- try {\r
- while (mStatements.size() > 0)\r
- mStatements.back()->DetachTransactionImpl();\r
- } catch (...) { }\r
-\r
- // Very important : let's detach cleanly all Databases from this\r
- // Transaction. No Database object can still maintain pointers to this\r
- // Transaction which is disappearing.\r
- try {\r
- while (mDatabases.size() > 0)\r
- {\r
- size_t i = mDatabases.size()-1;\r
- DetachDatabaseImpl(mDatabases[i]); // <-- remove link to database from mTPBs\r
- // array and destroy TPB object\r
- // Fixed : Maxim Abrashkin on 12 Jun 2002\r
- //mDatabases.back()->DetachTransaction(this);\r
- }\r
- } catch (...) { }\r
-}\r
-\r
-//\r
-// EOF\r
-//\r
git.stg.codes / stg.git / blobdiff