MySQL 5.6.14 Source Code Document
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
Public Member Functions | Public Attributes | Protected Attributes | List of all members
HugoTransactions Class Reference
Inheritance diagram for HugoTransactions:
Inheritance graph
[legend]
Collaboration diagram for HugoTransactions:
Collaboration graph
[legend]

Public Member Functions

 HugoTransactions (const NdbDictionary::Table &, const NdbDictionary::Index *idx=0)
int loadTable (Ndb *, int records, int batch=512, bool allowConstraintViolation=true, int doSleep=0, bool oneTrans=false, int updateValue=0, bool abort=false)
int loadTableStartFrom (Ndb *, int startFrom, int records, int batch=512, bool allowConstraintViolation=true, int doSleep=0, bool oneTrans=false, int updateValue=0, bool abort=false)
int scanReadRecords (Ndb *, int records, int abort=0, int parallelism=0, NdbOperation::LockMode=NdbOperation::LM_Read, int scan_flags=0)
int scanReadRecords (Ndb *, const NdbDictionary::Index *, int records, int abort=0, int parallelism=0, NdbOperation::LockMode=NdbOperation::LM_Read, int scan_flags=0)
int pkReadRecords (Ndb *, int records, int batchsize=1, NdbOperation::LockMode=NdbOperation::LM_Read, int rand=0)
int pkReadUnlockRecords (Ndb *, int records, int batchsize=1, NdbOperation::LockMode=NdbOperation::LM_Read)
int scanUpdateRecords (Ndb *, NdbScanOperation::ScanFlag, int records, int abort=0, int parallelism=0)
int scanUpdateRecords (Ndb *, int records, int abort=0, int parallelism=0)
int scanUpdateRecords1 (Ndb *, int records, int abort=0, int parallelism=0)
int scanUpdateRecords2 (Ndb *, int records, int abort=0, int parallelism=0)
int scanUpdateRecords3 (Ndb *, int records, int abort=0, int parallelism=0)
int pkUpdateRecords (Ndb *, int records, int batchsize=1, int doSleep=0)
int pkInterpretedUpdateRecords (Ndb *, int records, int batchsize=1)
int pkDelRecords (Ndb *, int records=0, int batch=1, bool allowConstraintViolation=true, int doSleep=0)
int pkRefreshRecords (Ndb *, int startFrom, int count=1, int batch=1)
int lockRecords (Ndb *, int records, int percentToLock=1, int lockTime=1000)
int fillTable (Ndb *, int batch=512)
int fillTableStartFrom (Ndb *, int startFrom, int batch=512)
int indexReadRecords (Ndb *, const char *idxName, int records, int batchsize=1)
int indexUpdateRecords (Ndb *, const char *idxName, int records, int batchsize=1)
void setRetryMax (int retryMax=100)
void setStatsLatency (NDBT_Stats *stats)
void setThrInfo (int thr_count, int thr_no)
- Public Member Functions inherited from HugoOperations
 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 *)
NdbTransaction * getTransaction ()
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_ResultRow & get_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 NdbError & getNdbError () 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

Uint64 m_latest_gci
- Public Attributes inherited from HugoOperations
NdbIndexScanOperation * pIndexScanOp

Protected Attributes

NDBT_ResultRow row
int m_defaultScanUpdateMethod
int m_retryMax
NDBT_Stats * m_stats_latency
int m_thr_count
int m_thr_no
- Protected Attributes inherited from HugoOperations
Vector< NDBT_ResultRow * > rows
Vector< NdbIndexScanOperation * > indexScans
HugoCalculator calc
Vector< BaseString > savedRecords
Vector< RsPair > m_result_sets
Vector< RsPair > m_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::Table & tab
const NdbDictionary::Index * idx
NdbConnection * pTrans

Additional Inherited Members

- Public Types inherited from HugoOperations
typedef Uint32(* AnyValueCallback )(Ndb *, NdbTransaction *, int rowid, int updVal)
- Protected Member Functions inherited from HugoOperations
void allocRows (int rows)
void deallocRows ()
void callback (int res, NdbTransaction *)
Uint32 getAnyValueForRowUpd (int row, int update)
void setNdbError (const NdbError &error)

Detailed Description

Definition at line 28 of file HugoTransactions.hpp.

Member Function Documentation

int HugoTransactions::indexReadRecords ( Ndb *  pNdb,
const char *  idxName,
int  records,
int  batchsize = 1 
)

Reading using UniqHashIndex with key = pk

Definition at line 1842 of file HugoTransactions.cpp.

Here is the call graph for this function:

int HugoTransactions::pkReadRecords ( Ndb *  pNdb,
int  records,
int  batchsize = 1,
NdbOperation::LockMode  lm = NdbOperation::LM_Read,
int  rand = 0 
)

LM_CommittedRead will not abort transaction even if doing execute(AbortOnError); so also check pTrans->getNdbError() in this case

Definition at line 854 of file HugoTransactions.cpp.

Here is the call graph for this function:

int HugoTransactions::scanReadRecords ( Ndb *  pNdb,
int  records,
int  abort = 0,
int  parallelism = 0,
NdbOperation::LockMode  lm = NdbOperation::LM_Read,
int  scan_flags = 0 
)

decrease parallelism

Definition at line 42 of file HugoTransactions.cpp.

Here is the call graph for this function:

int HugoTransactions::scanReadRecords ( Ndb *  pNdb,
const NdbDictionary::Index *  pIdx,
int  records,
int  abort = 0,
int  parallelism = 0,
NdbOperation::LockMode  lm = NdbOperation::LM_Read,
int  scan_flags = 0 
)

decrease parallelism

Definition at line 197 of file HugoTransactions.cpp.

Here is the call graph for this function:

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