MySQL 5.6.14 Source Code Document
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
HugoOperations Class Reference
Inheritance diagram for HugoOperations:
Collaboration diagram for HugoOperations:

Classes

struct  RsPair

Public Types

typedef Uint32(* AnyValueCallback )(Ndb *, NdbTransaction *, int rowid, int updVal)

Public Member Functions

 HugoOperations (const NdbDictionary::Table &, const NdbDictionary::Index *idx=0)
int startTransaction (Ndb *, const NdbDictionary::Table *table=0, const char *keyData=0, Uint32 keyLen=0)
int setTransaction (NdbTransaction *, bool not_null_ok=false)
int closeTransaction (Ndb *)
NdbTransactiongetTransaction ()
void refresh ()
void setTransactionId (Uint64)
int pkInsertRecord (Ndb *, int recordNo, int numRecords=1, int updatesValue=0)
int pkWriteRecord (Ndb *, int recordNo, int numRecords=1, int updatesValue=0)
int pkWritePartialRecord (Ndb *, int recordNo, int numRecords=1)
int pkReadRecord (Ndb *, int record, int numRecords=1, NdbOperation::LockMode lm=NdbOperation::LM_Read, NdbOperation::LockMode *lmused=0)
int pkReadRandRecord (Ndb *, int records, int numRecords=1, NdbOperation::LockMode lm=NdbOperation::LM_Read, NdbOperation::LockMode *lmused=0)
int pkReadRecordLockHandle (Ndb *, Vector< const NdbLockHandle * > &lockHandles, int record, int numRecords=1, NdbOperation::LockMode lm=NdbOperation::LM_Read, NdbOperation::LockMode *lmused=0)
int pkUnlockRecord (Ndb *, Vector< const NdbLockHandle * > &lockHandles, int offset=0, int numRecords=~(0), NdbOperation::AbortOption ao=NdbOperation::AbortOnError)
int pkUpdateRecord (Ndb *, int recordNo, int numRecords=1, int updatesValue=0)
int pkDeleteRecord (Ndb *, int recordNo, int numRecords=1)
int pkRefreshRecord (Ndb *, int recordNo, int numRecords=1, int anyValueInfo=0)
int execute_Commit (Ndb *, AbortOption ao=AbortOnError)
int execute_NoCommit (Ndb *, AbortOption ao=AbortOnError)
int execute_Rollback (Ndb *)
int saveCopyOfRecord (int numRecords=1)
int compareRecordToCopy (int numRecords=1)
BaseString getRecordStr (int recordNum)
int getRecordGci (int recordNum)
int setValueForAttr (NdbOperation *, int attrId, int rowId, int updateId)
int equalForAttr (NdbOperation *, int attrId, int rowId)
int equalForRow (NdbOperation *, int rowid)
bool getPartIdForRow (const NdbOperation *pOp, int rowid, Uint32 &partId)
int setValues (NdbOperation *, int rowId, int updateId)
int verifyUpdatesValue (int updatesValue, int _numRows=0)
int indexReadRecords (Ndb *, const char *idxName, int recordNo, bool exclusive=false, int records=1)
int indexUpdateRecord (Ndb *, const char *idxName, int recordNo, int numRecords=1, int updatesValue=0)
int scanReadRecords (Ndb *, NdbScanOperation::LockMode=NdbScanOperation::LM_CommittedRead, int numRecords=1)
NDBT_ResultRowget_row (Uint32 idx)
int execute_async (Ndb *, NdbTransaction::ExecType, NdbOperation::AbortOption=NdbOperation::AbortOnError)
int execute_async_prepare (Ndb *, NdbTransaction::ExecType, NdbOperation::AbortOption=NdbOperation::AbortOnError)
int wait_async (Ndb *, int timeout=-1)
int releaseLockHandles (Ndb *, Vector< const NdbLockHandle * > &lockHandles, int offset=0, int numRecords=~(0))
const NdbErrorgetNdbError () const
void setQuiet ()
void setAnyValueCallback (AnyValueCallback)
- Public Member Functions inherited from UtilTransactions
 UtilTransactions (const NdbDictionary::Table &, const NdbDictionary::Index *idx=0)
 UtilTransactions (Ndb *ndb, const char *tableName, const char *indexName=0)
int clearTable (Ndb *, NdbScanOperation::ScanFlag, int records=0, int parallelism=0)
int clearTable (Ndb *, int records=0, int parallelism=0)
int clearTable1 (Ndb *, int records=0, int parallelism=0)
int clearTable2 (Ndb *, int records=0, int parallelism=0)
int clearTable3 (Ndb *, int records=0, int parallelism=0)
int selectCount (Ndb *, int parallelism=0, int *count_rows=NULL, NdbOperation::LockMode lm=NdbOperation::LM_CommittedRead)
int scanReadRecords (Ndb *, int parallelism, NdbOperation::LockMode lm, int records, int noAttribs, int *attrib_list, ReadCallBackFn *fn=NULL)
int verifyIndex (Ndb *, const char *indexName, int parallelism=0, bool transactional=false)
int copyTableData (Ndb *, const char *destName)
int compare (Ndb *, const char *other_table, int flags)

Public Attributes

NdbIndexScanOperationpIndexScanOp

Protected Member Functions

void allocRows (int rows)
void deallocRows ()
void callback (int res, NdbTransaction *)
Uint32 getAnyValueForRowUpd (int row, int update)
void setNdbError (const NdbError &error)
- Protected Member Functions inherited from UtilTransactions
NdbOperationgetOperation (NdbConnection *, NdbOperation::OperationType)
NdbScanOperationgetScanOperation (NdbConnection *)

Protected Attributes

Vector< NDBT_ResultRow * > rows
Vector< NdbIndexScanOperation * > indexScans
HugoCalculator calc
Vector< BaseStringsavedRecords
Vector< RsPairm_result_sets
Vector< RsPairm_executed_result_sets
int m_async_reply
int m_async_return
NdbError m_error
bool m_quiet
AnyValueCallback avCallback
- Protected Attributes inherited from UtilTransactions
int m_defaultClearMethod
const NdbDictionary::Tabletab
const NdbDictionary::Indexidx
NdbConnectionpTrans

Friends

void HugoOperations_async_callback (int, NdbTransaction *, void *)

Detailed Description

Definition at line 27 of file HugoOperations.hpp.


The documentation for this class was generated from the following files: