diff options
Diffstat (limited to 'ndb/src/ndbapi/NdbOperation.cpp')
| -rw-r--r-- | ndb/src/ndbapi/NdbOperation.cpp | 432 |
1 files changed, 432 insertions, 0 deletions
diff --git a/ndb/src/ndbapi/NdbOperation.cpp b/ndb/src/ndbapi/NdbOperation.cpp new file mode 100644 index 00000000000..eaa2b35965b --- /dev/null +++ b/ndb/src/ndbapi/NdbOperation.cpp @@ -0,0 +1,432 @@ +/* Copyright (C) 2003 MySQL AB + + This program is free software; you can redistribute it and/or modify + it under the terms of the GNU General Public License as published by + the Free Software Foundation; either version 2 of the License, or + (at your option) any later version. + + This program is distributed in the hope that it will be useful, + but WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + GNU General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ + + +/***************************************************************************** + * Name: NdbOperation.C + * Include: + * Link: + * Author: UABMNST Mona Natterkvist UAB/B/SD + * Date: 970829 + * Version: 0.1 + * Description: Interface between TIS and NDB + * Documentation: + * Adjust: 971022 UABMNST First version. + ****************************************************************************/ +#include "NdbConnection.hpp" +#include "NdbOperation.hpp" +#include "NdbApiSignal.hpp" +#include "NdbRecAttr.hpp" +#include "NdbUtil.hpp" + +#include <signaldata/TcKeyReq.hpp> +#include "NdbDictionaryImpl.hpp" + +#include "API.hpp" +#include <NdbOut.hpp> +#include <assert.h> + + +/****************************************************************************** + * NdbOperation(Ndb* aNdb, Table* aTable); + * + * Return Value: None + * Parameters: aNdb: Pointers to the Ndb object. + * aTable: Pointers to the Table object + * Remark: Creat an object of NdbOperation. + ****************************************************************************/ +NdbOperation::NdbOperation(Ndb* aNdb) : + theReceiver(aNdb), + theErrorLine(0), + theNdb(aNdb), + //theTable(aTable), + theNdbCon(NULL), + theNext(NULL), + theNextScanOp(NULL), + theTCREQ(NULL), + theFirstATTRINFO(NULL), + theCurrentATTRINFO(NULL), + theTotalCurrAI_Len(0), + theAI_LenInCurrAI(0), + theFirstKEYINFO(NULL), + theLastKEYINFO(NULL), + theFirstRecAttr(NULL), + theCurrentRecAttr(NULL), + + theFirstLabel(NULL), + theLastLabel(NULL), + theFirstBranch(NULL), + theLastBranch(NULL), + theFirstCall(NULL), + theLastCall(NULL), + theFirstSubroutine(NULL), + theLastSubroutine(NULL), + theNoOfLabels(0), + theNoOfSubroutines(0), + + theTotalRecAI_Len(0), + theCurrRecAI_Len(0), + theAI_ElementLen(0), + theCurrElemPtr(NULL), + m_currentTable(NULL), //theTableId(0xFFFF), + m_accessTable(NULL), //theAccessTableId(0xFFFF), + //theSchemaVersion(0), + theTotalNrOfKeyWordInSignal(8), + theTupKeyLen(0), + theNoOfTupKeyDefined(0), + theOperationType(NotDefined), + theStatus(Init), + theMagicNumber(0xFE11D0), + theScanInfo(0), + theDistrKeySize(0), + theDistributionGroup(0), + m_tcReqGSN(GSN_TCKEYREQ), + m_keyInfoGSN(GSN_KEYINFO), + m_attrInfoGSN(GSN_ATTRINFO), + theParallelism(0), + theScanReceiversArray(NULL), + theSCAN_TABREQ(NULL), + theFirstSCAN_TABINFO_Send(NULL), + theLastSCAN_TABINFO_Send(NULL), + theFirstSCAN_TABINFO_Recv(NULL), + theLastSCAN_TABINFO_Recv(NULL), + theSCAN_TABCONF_Recv(NULL), + theBoundATTRINFO(NULL) +{ + theReceiver.init(NdbReceiver::NDB_OPERATION, this); + theError.code = 0; +} +/***************************************************************************** + * ~NdbOperation(); + * + * Remark: Delete tables for connection pointers (id). + *****************************************************************************/ +NdbOperation::~NdbOperation( ) +{ +} +/****************************************************************************** + *void setErrorCode(int anErrorCode); + * + * Remark: Set an Error Code on operation and + * on connection set an error status. + *****************************************************************************/ +void +NdbOperation::setErrorCode(int anErrorCode) +{ + theError.code = anErrorCode; + theNdbCon->theErrorLine = theErrorLine; + theNdbCon->theErrorOperation = this; + theNdbCon->setOperationErrorCode(anErrorCode); +} + +/****************************************************************************** + * void setErrorCodeAbort(int anErrorCode); + * + * Remark: Set an Error Code on operation and on connection set + * an error status. + *****************************************************************************/ +void +NdbOperation::setErrorCodeAbort(int anErrorCode) +{ + theError.code = anErrorCode; + theNdbCon->theErrorLine = theErrorLine; + theNdbCon->theErrorOperation = this; + theNdbCon->setOperationErrorCodeAbort(anErrorCode); +} + +/***************************************************************************** + * int init(); + * + * Return Value: Return 0 : init was successful. + * Return -1: In all other case. + * Remark: Initiates operation record after allocation. + *****************************************************************************/ + +int +NdbOperation::init(NdbTableImpl* tab, NdbConnection* myConnection){ + NdbApiSignal* tSignal; + theStatus = Init; + theError.code = 0; + theErrorLine = 1; + m_currentTable = m_accessTable = tab; + + theNdbCon = myConnection; + for (Uint32 i=0; i<MAXNROFTUPLEKEY; i++) + for (int j=0; j<3; j++) + theTupleKeyDefined[i][j] = false; + + theFirstATTRINFO = NULL; + theCurrentATTRINFO = NULL; + theFirstKEYINFO = NULL; + theLastKEYINFO = NULL; + + + theTupKeyLen = 0; + theNoOfTupKeyDefined = 0; + theTotalCurrAI_Len = 0; + theAI_LenInCurrAI = 0; + theTotalRecAI_Len = 0; + theDistrKeySize = 0; + theDistributionGroup = 0; + theCurrRecAI_Len = 0; + theAI_ElementLen = 0; + theStartIndicator = 0; + theCommitIndicator = 0; + theSimpleIndicator = 0; + theDirtyIndicator = 0; + theInterpretIndicator = 0; + theDistrGroupIndicator= 0; + theDistrGroupType = 0; + theDistrKeyIndicator = 0; + theScanInfo = 0; + theFirstRecAttr = NULL; + theCurrentRecAttr = NULL; + theCurrElemPtr = NULL; + theTotalNrOfKeyWordInSignal = 8; + theMagicNumber = 0xABCDEF01; + theBoundATTRINFO = NULL; + + tSignal = theNdb->getSignal(); + if (tSignal == NULL) + { + setErrorCode(4000); + return -1; + } + theTCREQ = tSignal; + theTCREQ->setSignal(m_tcReqGSN); + + theAI_LenInCurrAI = 20; + TcKeyReq * const tcKeyReq = CAST_PTR(TcKeyReq, theTCREQ->getDataPtrSend()); + tcKeyReq->scanInfo = 0; + theKEYINFOptr = &tcKeyReq->keyInfo[0]; + theATTRINFOptr = &tcKeyReq->attrInfo[0]; + return 0; +} + + +/****************************************************************************** + * void release(); + * + * Remark: Release all objects connected to the operation object. + *****************************************************************************/ +void +NdbOperation::release() +{ + NdbApiSignal* tSignal; + NdbApiSignal* tSaveSignal; + NdbRecAttr* tRecAttr; + NdbRecAttr* tSaveRecAttr; + NdbBranch* tBranch; + NdbBranch* tSaveBranch; + NdbLabel* tLabel; + NdbLabel* tSaveLabel; + NdbCall* tCall; + NdbCall* tSaveCall; + NdbSubroutine* tSubroutine; + NdbSubroutine* tSaveSubroutine; + + if (theTCREQ != NULL) + { + theNdb->releaseSignal(theTCREQ); + } + theTCREQ = NULL; + tSignal = theFirstATTRINFO; + while (tSignal != NULL) + { + tSaveSignal = tSignal; + tSignal = tSignal->next(); + theNdb->releaseSignal(tSaveSignal); + } + theFirstATTRINFO = NULL; + theCurrentATTRINFO = NULL; + tSignal = theFirstKEYINFO; + while (tSignal != NULL) + { + tSaveSignal = tSignal; + tSignal = tSignal->next(); + theNdb->releaseSignal(tSaveSignal); + } + theFirstKEYINFO = NULL; + theLastKEYINFO = NULL; + tRecAttr = theFirstRecAttr; + while (tRecAttr != NULL) + { + tSaveRecAttr = tRecAttr; + tRecAttr = tRecAttr->next(); + theNdb->releaseRecAttr(tSaveRecAttr); + } + theFirstRecAttr = NULL; + theCurrentRecAttr = NULL; + if (theInterpretIndicator == 1) + { + tBranch = theFirstBranch; + while (tBranch != NULL) + { + tSaveBranch = tBranch; + tBranch = tBranch->theNext; + theNdb->releaseNdbBranch(tSaveBranch); + } + tLabel = theFirstLabel; + while (tLabel != NULL) + { + tSaveLabel = tLabel; + tLabel = tLabel->theNext; + theNdb->releaseNdbLabel(tSaveLabel); + } + tCall = theFirstCall; + while (tCall != NULL) + { + tSaveCall = tCall; + tCall = tCall->theNext; + theNdb->releaseNdbCall(tSaveCall); + } + tSubroutine = theFirstSubroutine; + while (tSubroutine != NULL) + { + tSaveSubroutine = tSubroutine; + tSubroutine = tSubroutine->theNext; + theNdb->releaseNdbSubroutine(tSaveSubroutine); + } + tSignal = theBoundATTRINFO; + while (tSignal != NULL) + { + tSaveSignal = tSignal; + tSignal = tSignal->next(); + theNdb->releaseSignal(tSaveSignal); + } + theBoundATTRINFO = NULL; + } + releaseScan(); +} + +NdbRecAttr* +NdbOperation::getValue(const char* anAttrName, char* aValue) +{ + return getValue(m_currentTable->getColumn(anAttrName), aValue); +} + +NdbRecAttr* +NdbOperation::getValue(Uint32 anAttrId, char* aValue) +{ + return getValue(m_currentTable->getColumn(anAttrId), aValue); +} + +int +NdbOperation::equal(const char* anAttrName, + const char* aValuePassed, + Uint32 aVariableKeyLen) +{ + return equal_impl(m_accessTable->getColumn(anAttrName), aValuePassed, aVariableKeyLen); +} + +int +NdbOperation::equal(Uint32 anAttrId, + const char* aValuePassed, + Uint32 aVariableKeyLen) +{ + return equal_impl(m_accessTable->getColumn(anAttrId), aValuePassed, aVariableKeyLen); +} + +int +NdbOperation::setValue( const char* anAttrName, + const char* aValuePassed, + Uint32 len) +{ + return setValue(m_currentTable->getColumn(anAttrName), aValuePassed, len); +} + + +int +NdbOperation::setValue( Uint32 anAttrId, + const char* aValuePassed, + Uint32 len) +{ + return setValue(m_currentTable->getColumn(anAttrId), aValuePassed, len); +} + +int +NdbOperation::incValue(const char* anAttrName, Uint32 aValue) +{ + return incValue(m_currentTable->getColumn(anAttrName), aValue); +} + +int +NdbOperation::incValue(const char* anAttrName, Uint64 aValue) +{ + return incValue(m_currentTable->getColumn(anAttrName), aValue); +} + +int +NdbOperation::incValue(Uint32 anAttrId, Uint32 aValue) +{ + return incValue(m_currentTable->getColumn(anAttrId), aValue); +} + +int +NdbOperation::incValue(Uint32 anAttrId, Uint64 aValue) +{ + return incValue(m_currentTable->getColumn(anAttrId), aValue); +} + +int +NdbOperation::subValue( const char* anAttrName, Uint32 aValue) +{ + return subValue(m_currentTable->getColumn(anAttrName), aValue); +} + +int +NdbOperation::subValue(Uint32 anAttrId, Uint32 aValue) +{ + return subValue(m_currentTable->getColumn(anAttrId), aValue); +} + +int +NdbOperation::read_attr(const char* anAttrName, Uint32 RegDest) +{ + return read_attr(m_currentTable->getColumn(anAttrName), RegDest); +} + +int +NdbOperation::read_attr(Uint32 anAttrId, Uint32 RegDest) +{ + return read_attr(m_currentTable->getColumn(anAttrId), RegDest); +} + +int +NdbOperation::write_attr(const char* anAttrName, Uint32 RegDest) +{ + return write_attr(m_currentTable->getColumn(anAttrName), RegDest); +} + +int +NdbOperation::write_attr(Uint32 anAttrId, Uint32 RegDest) +{ + return write_attr(m_currentTable->getColumn(anAttrId), RegDest); +} + +int +NdbOperation::setBound(const char* anAttrName, int type, const void* aValue, Uint32 len) +{ + return setBound(m_accessTable->getColumn(anAttrName), type, aValue, len); +} + +int +NdbOperation::setBound(Uint32 anAttrId, int type, const void* aValue, Uint32 len) +{ + return setBound(m_accessTable->getColumn(anAttrId), type, aValue, len); +} + + |