Database utilities. More...

#include <DbUtil.hpp>

Inheritance diagram for DbUtil:

Collaboration diagram for DbUtil:

Classes
struct	LockQueueInstance
struct	Operation
	Used in execution (contains resultset and buffers for result) More...
struct	Page32
	For storing SimpleProperties objects and similar temporary data. More...
struct	Prepare
	Info regarding prepare request (contains a prepared operation) More...
struct	PreparedOperation
	Contains instantiated TcKeyReq signaldata for operation. More...
struct	Transaction
	Used in execution (contains list of operations) More...

Public Types
typedef DataBuffer< 11 >	KeyInfoBuffer
typedef KeyInfoBuffer::ConstDataBufferIterator	KeyInfoIterator
typedef DataBuffer< 11 >	AttrInfoBuffer
typedef AttrInfoBuffer::ConstDataBufferIterator	AttrInfoIterator
typedef DataBuffer< 11 >	ResultSetBuffer
typedef DataBuffer< 11 >	ResultSetInfoBuffer
typedef DataBuffer< 1 >	AttrMappingBuffer
typedef Ptr< Page32 >	Page32Ptr
typedef Ptr< Prepare >	PreparePtr
typedef Ptr< Transaction >	TransactionPtr
typedef Ptr< Operation >	OperationPtr
typedef Ptr< PreparedOperation >	PreparedOperationPtr
typedef Ptr< LockQueueInstance >	LockQueuePtr
Public Types inherited from SimulatedBlock
typedef void(SimulatedBlock::*	CallbackFunction )(class Signal *, Uint32 callbackData, Uint32 returnCode)

Public Member Functions
	DbUtil (Block_context &ctx)
	BLOCK_DEFINES (DbUtil)
void	getTransId (Transaction *)
void	initResultSet (ResultSetBuffer &, const ResultSetInfoBuffer &)
void	runTransaction (Signal *signal, TransactionPtr)
void	runOperation (Signal *signal, TransactionPtr &, OperationPtr &, Uint32)
void	sendKeyInfo (Signal signal, Uint32 ref, KeyInfo keyInfo, const KeyInfoBuffer &keyBuf, KeyInfoIterator &kit)
void	sendAttrInfo (Signal , Uint32 ref, AttrInfo attrInfo, const AttrInfoBuffer &, AttrInfoIterator &ait)
int	getResultSet (Signal signal, const Transaction transP, struct LinearSectionPtr sectionsPtr[])
void	finishTransaction (Signal *, TransactionPtr)
void	releaseTransaction (TransactionPtr transPtr)
void	get_systab_tableid (Signal *)
void	hardcodedPrepare (Signal *, Uint32 SYSTAB_0)
void	connectTc (Signal *signal)
void	reportSequence (Signal , const Transaction )
void	readPrepareProps (Signal signal, SimpleProperties::Reader reader, PreparePtr)
void	prepareOperation (Signal *, PreparePtr, SegmentedSectionPtr)
void	sendUtilPrepareRef (Signal *, UtilPrepareRef::ErrorCode, Uint32, Uint32, Uint32 extraError=0)
void	sendUtilExecuteRef (Signal *, UtilExecuteRef::ErrorCode, Uint32, Uint32, Uint32)
void	releasePrepare (PreparePtr)
void	releasePreparedOperation (PreparedOperationPtr)
void	execUTIL_CREATE_LOCK_REQ (Signal *signal)
void	execUTIL_DESTORY_LOCK_REQ (Signal *signal)
void	execUTIL_LOCK_REQ (Signal *signal)
void	execUTIL_UNLOCK_REQ (Signal *signal)
void	sendLOCK_REF (Signal , const UtilLockReq req, UtilLockRef::ErrorCode)
void	sendLOCK_CONF (Signal , const UtilLockReq req)
void	sendUNLOCK_REF (Signal , const UtilUnlockReq , UtilUnlockRef::ErrorCode)
void	mutex_created (Signal *signal, Uint32 mutexId, Uint32 retVal)
void	mutex_destroyed (Signal *signal, Uint32 mutexId, Uint32 retVal)
void	mutex_locked (Signal *signal, Uint32 mutexId, Uint32 retVal)
void	mutex_unlocked (Signal *signal, Uint32 mutexId, Uint32 retVal)
	DbUtil (MYSQL *mysql)
	DbUtil (const char dbname="mysql", const char suffix=NULL)
bool	doQuery (const char *query)
bool	doQuery (const char *query, SqlResultSet &result)
bool	doQuery (const char *query, const Properties &args, SqlResultSet &result)
bool	doQuery (const char *query, const Properties &args)
bool	doQuery (BaseString &str)
bool	doQuery (BaseString &str, SqlResultSet &result)
bool	doQuery (BaseString &str, const Properties &args, SqlResultSet &result)
bool	doQuery (BaseString &str, const Properties &args)
bool	waitConnected (int timeout=120)
bool	databaseLogin (const char host, const char user, const char password, unsigned int portIn, const char sockIn, bool transactional)
const char *	getDbName ()
const char *	getUser ()
const char *	getPassword ()
const char *	getHost ()
const char *	getSocket ()
const char *	getServerType ()
const char *	getError ()
MYSQL *	getMysql ()
MYSQL_STMT *STDCALL	mysqlSimplePrepare (const char *query)
void	databaseLogout ()
void	mysqlCloseStmHandle (MYSQL_STMT *my_stmt)
bool	connect ()
void	disconnect ()
bool	selectDb ()
bool	selectDb (const char *)
bool	createDb (BaseString &)
int	getErrorNumber ()
const char *	last_error () const
int	last_errno () const
unsigned long long	selectCountTable (const char *table)
void	silent ()
Public Member Functions inherited from SimulatedBlock
void	executeFunction (GlobalSignalNumber gsn, Signal *signal)
Uint32	instance () const
SimulatedBlock *	getInstance (Uint32 instanceNumber)
void	addInstance (SimulatedBlock *b, Uint32 theInstanceNo)
virtual void	loadWorkers ()
void	assignToThread (ThreadContext ctx)
uint32	getThreadId () const
void	assertOwnThread ()
void	synchronize_threads_for_blocks (Signal *, const Uint32 blocks[], const Callback &, JobBufferLevel=JBB)
void	synchronize_path (Signal *, const Uint32 blocks[], const Callback &, JobBufferLevel=JBB)
virtual const char *	get_filename (Uint32 fd) const
EmulatedJamBuffer *	jamBuffer () const
void	ignoreMutexUnlockCallback (Signal *signal, Uint32 ptrI, Uint32 retVal)
virtual bool	getParam (const char param, Uint32 retVal)

Public Attributes
Uint32	c_transId [2]
ArrayPool< Page32 >	c_pagePool
ArrayPool< Prepare >	c_preparePool
ArrayPool< Operation >	c_operationPool
ArrayPool< PreparedOperation >	c_preparedOperationPool
ArrayPool< Transaction >	c_transactionPool
DataBuffer< 1 >::DataBufferPool	c_attrMappingPool
DataBuffer< 11 >::DataBufferPool	c_dataBufPool
DLList< Prepare >	c_runningPrepares
DLList< Transaction >	c_seizingTransactions
DLList< Transaction >	c_runningTransactions
ArrayPool< LockQueueInstance >	c_lockQueuePool
KeyTable< LockQueueInstance >	c_lockQueues
LockQueue::Pool	c_lockElementPool
Public Attributes inherited from SimulatedBlock
MutexManager	c_mutexMgr
SafeCounterManager	c_counterMgr

Protected Member Functions
void	execREAD_CONFIG_REQ (Signal *signal)
void	execSTTOR (Signal *signal)
void	execNDB_STTOR (Signal *signal)
void	execDUMP_STATE_ORD (Signal *signal)
void	execDBINFO_SCANREQ (Signal *signal)
void	execCONTINUEB (Signal *signal)
void	execNODE_FAILREP (Signal *signal)
void	execUTIL_SEQUENCE_REQ (Signal *signal)
void	execUTIL_SEQUENCE_REF (Signal *signal)
void	execUTIL_SEQUENCE_CONF (Signal *signal)
void	execUTIL_PREPARE_REQ (Signal *signal)
void	execUTIL_PREPARE_CONF (Signal *signal)
void	execUTIL_PREPARE_REF (Signal *signal)
void	execUTIL_DELETE_REQ (Signal *signal)
void	execUTIL_DELETE_REF (Signal *signal)
void	execUTIL_DELETE_CONF (Signal *signal)
void	execUTIL_EXECUTE_REQ (Signal *signal)
void	execUTIL_EXECUTE_REF (Signal *signal)
void	execUTIL_EXECUTE_CONF (Signal *signal)
void	execUTIL_RELEASE_REQ (Signal *signal)
void	execUTIL_RELEASE_CONF (Signal *signal)
void	execUTIL_RELEASE_REF (Signal *signal)
void	execTCSEIZECONF (Signal *signal)
void	execTCKEYCONF (Signal *signal)
void	execTCKEYREF (Signal *signal)
void	execTCROLLBACKREP (Signal *signal)
void	execTCKEY_FAILCONF (Signal *signal)
void	execTCKEY_FAILREF (Signal *signal)
void	execTRANSID_AI (Signal *signal)
void	execGET_TABINFOREF (Signal *)
void	execGET_TABINFO_CONF (Signal *signal)
bool	runQuery (const char *query, const Properties &args, SqlResultSet &rows)
bool	isConnected ()
Protected Member Functions inherited from SimulatedBlock
	SimulatedBlock (BlockNumber blockNumber, struct Block_context &ctx, Uint32 instanceNumber=0)
void	addRecSignalImpl (GlobalSignalNumber g, ExecFunction fun, bool f=false)
void	installSimulatedBlockFunctions ()
void	initCommon ()
void	TheNULLCallbackFunction (class Signal *, Uint32, Uint32)
void	execute (Signal *signal, Callback &c, Uint32 returnCode)
void	sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf) const
void	sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf) const
void	sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections) const
void	sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections) const
void	sendSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections) const
void	sendSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections) const
void	sendSignalNoRelease (BlockReference ref, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections) const
void	sendSignalNoRelease (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections) const
void	sendSignalWithDelay (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 delayInMilliSeconds, Uint32 length) const
void	sendSignalWithDelay (BlockReference ref, GlobalSignalNumber gsn, Signal signal, Uint32 delayInMilliSeconds, Uint32 length, SectionHandle sections) const
void	EXECUTE_DIRECT (Uint32 block, Uint32 gsn, Signal *signal, Uint32 len, Uint32 givenInstanceNo=ZNIL)
class SectionSegmentPool &	getSectionSegmentPool ()
void	release (SegmentedSectionPtr &ptr)
void	release (SegmentedSectionPtrPOD &ptr)
void	releaseSection (Uint32 firstSegmentIVal)
void	releaseSections (struct SectionHandle &)
bool	import (Ptr< SectionSegment > &first, const Uint32 *src, Uint32 len)
bool	import (SegmentedSectionPtr &ptr, const Uint32 *src, Uint32 len)
bool	appendToSection (Uint32 &firstSegmentIVal, const Uint32 *src, Uint32 len)
bool	dupSection (Uint32 &copyFirstIVal, Uint32 srcFirstIVal)
bool	writeToSection (Uint32 firstSegmentIVal, Uint32 offset, const Uint32 *src, Uint32 len)
void	handle_invalid_sections_in_send_signal (Signal *) const
void	handle_lingering_sections_after_execute (Signal *) const
void	handle_lingering_sections_after_execute (SectionHandle *) const
void	handle_invalid_fragmentInfo (Signal *) const
void	handle_send_failed (SendStatus, Signal *) const
void	handle_out_of_longsignal_memory (Signal *) const
void	sendRoutedSignal (RoutePath path[], Uint32 pathcnt, Uint32 dst[], Uint32 dstcnt, Uint32 gsn, Signal , Uint32 len, JobBufferLevel prio, SectionHandle handle=0)
bool	checkNodeFailSequence (Signal *)
bool	assembleFragments (Signal *signal)
bool	assembleDroppedFragments (Signal *signal)
	STATIC_CONST (FRAGMENT_WORD_SIZE=240)
void	sendFragmentedSignal (BlockReference ref, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void	sendFragmentedSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void	sendFragmentedSignal (BlockReference ref, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void	sendFragmentedSignal (NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Callback &=TheEmptyCallback, Uint32 messageSize=FRAGMENT_WORD_SIZE)
Uint32	simBlockNodeFailure (Signal *signal, Uint32 failedNodeId, Callback &cb=TheEmptyCallback)
bool	sendFirstFragment (FragmentSendInfo &info, NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal signal, Uint32 length, JobBufferLevel jbuf, SectionHandle sections, bool noRelease, Uint32 messageSize=FRAGMENT_WORD_SIZE)
bool	sendFirstFragment (FragmentSendInfo &info, NodeReceiverGroup rg, GlobalSignalNumber gsn, Signal *signal, Uint32 length, JobBufferLevel jbuf, LinearSectionPtr ptr[3], Uint32 noOfSections, Uint32 messageSize=FRAGMENT_WORD_SIZE)
void	sendNextSegmentedFragment (Signal *signal, FragmentSendInfo &info)
void	sendNextLinearFragment (Signal *signal, FragmentSendInfo &info)
BlockNumber	number () const
BlockReference	reference () const
NodeId	getOwnNodeId () const
void	refresh_watch_dog (Uint32 place=1)
void	update_watch_dog_timer (Uint32 interval)
void	progError (int line, int err_code, const char *extradata=NULL) const ATTRIBUTE_NORETURN
NewVARIABLE *	allocateBat (int batSize)
void	freeBat ()
BlockReference	calcInstanceBlockRef (BlockNumber aBlock)
BlockReference	calcInstanceBlockRef (BlockNumber aBlock, NodeId aNode)
void *	allocRecord (const char *type, size_t s, size_t n, bool clear=true, Uint32 paramId=0)
void *	allocRecordAligned (const char type, size_t s, size_t n, void *unaligned_buffer, Uint32 align=NDB_O_DIRECT_WRITE_ALIGNMENT, bool clear=true, Uint32 paramId=0)
void	deallocRecord (void *, const char type, size_t s, size_t n)
Uint32	allocChunks (AllocChunk dst[], Uint32arraysize, Uint32rg, Uint32pages, Uint32 paramId)
void	infoEvent (const char *msg,...) const ATTRIBUTE_FORMAT(printf
void void	warningEvent (const char *msg,...) const ATTRIBUTE_FORMAT(printf
void void const NodeState &	getNodeState () const
const NodeInfo &	getNodeInfo (NodeId nodeId) const
NodeInfo &	setNodeInfo (NodeId)
const NodeVersionInfo &	getNodeVersionInfo () const
NodeVersionInfo &	setNodeVersionInfo ()
Uint32	xfrm_key (Uint32 tab, const Uint32 src, Uint32 dst, Uint32 dstSize, Uint32 keyPartLen[MAX_ATTRIBUTES_IN_INDEX]) const
Uint32	xfrm_attr (Uint32 attrDesc, CHARSET_INFO cs, const Uint32 src, Uint32 &srcPos, Uint32 *dst, Uint32 &dstPos, Uint32 dstSize) const
Uint32	create_distr_key (Uint32 tableId, const Uint32 src, Uint32 dst, const Uint32 keyPaLen[MAX_ATTRIBUTES_IN_INDEX]) const
void	wakeup ()
void	setup_wakeup ()
void	execNDB_TAMPER (Signal *signal)
void	execNODE_STATE_REP (Signal *signal)
void	execCHANGE_NODE_STATE_REQ (Signal *signal)
void	execSIGNAL_DROPPED_REP (Signal *signal)
void	execCONTINUE_FRAGMENTED (Signal *signal)
void	execSTOP_FOR_CRASH (Signal *signal)
void	execAPI_START_REP (Signal *signal)
void	execNODE_START_REP (Signal *signal)
void	execSEND_PACKED (Signal *signal)
void	execLOCAL_ROUTE_ORD (Signal *)
Uint32	debugPrintFragmentCounts ()
void	fsRefError (Signal signal, Uint32 line, const char msg)
void	execFSWRITEREF (Signal *signal)
void	execFSREADREF (Signal *signal)
void	execFSOPENREF (Signal *signal)
void	execFSCLOSEREF (Signal *signal)
void	execFSREMOVEREF (Signal *signal)
void	execFSSYNCREF (Signal *signal)
void	execFSAPPENDREF (Signal *signal)
void	execute (Signal *signal, CallbackPtr &cptr, Uint32 returnCode)
const CallbackEntry &	getCallbackEntry (Uint32 ci)
void	sendCallbackConf (Signal *signal, Uint32 fullBlockNo, CallbackPtr &cptr, Uint32 returnCode)
void	execCALLBACK_CONF (Signal *signal)
void	ndbinfo_send_row (Signal *signal, const DbinfoScanReq &req, const Ndbinfo::Row &row, Ndbinfo::Ratelimit &rl) const
void	ndbinfo_send_scan_break (Signal *signal, DbinfoScanReq &req, const Ndbinfo::Ratelimit &rl, Uint32 data1, Uint32 data2=0, Uint32 data3=0, Uint32 data4=0) const
void	ndbinfo_send_scan_conf (Signal *signal, DbinfoScanReq &req, const Ndbinfo::Ratelimit &rl) const

Protected Attributes
MYSQL *	m_mysql
bool	m_free_mysql
Protected Attributes inherited from SimulatedBlock
ExecFunction	theExecArray [MAX_GSN+1]
Block_context	m_ctx
SafeArrayPool< GlobalPage > &	m_global_page_pool
ArrayPool< GlobalPage > &	m_shared_page_pool
CallbackTable *	m_callbackTableAddr
	ERROR_INSERT_VARIABLE

Additional Inherited Members
Static Public Member Functions inherited from SimulatedBlock
static bool	isMultiThreaded ()
static bool	isNdbMt ()
static bool	isNdbMtLqh ()
static Uint32	getLqhWorkers ()
static Uint32	getInstanceKey (Uint32 tabId, Uint32 fragId)
static Uint32	getInstanceFromKey (Uint32 instanceKey)
Protected Types inherited from SimulatedBlock
enum	CallbackFlags { CALLBACK_DIRECT = 0x0001, CALLBACK_ACK = 0x0002 }
enum	{ THE_NULL_CALLBACK = 0 }
typedef void(SimulatedBlock::*	ExecFunction )(Signal *signal)
Static Protected Member Functions inherited from SimulatedBlock
static const NewVARIABLE *	getBat (BlockNumber blockNo, Uint32 instanceNo)
static Uint16	getBatSize (BlockNumber blockNo, Uint32 instanceNo)
static BlockReference	calcTcBlockRef (NodeId aNode)
static BlockReference	calcLqhBlockRef (NodeId aNode)
static BlockReference	calcAccBlockRef (NodeId aNode)
static BlockReference	calcTupBlockRef (NodeId aNode)
static BlockReference	calcTuxBlockRef (NodeId aNode)
static BlockReference	calcDihBlockRef (NodeId aNode)
static BlockReference	calcQmgrBlockRef (NodeId aNode)
static BlockReference	calcDictBlockRef (NodeId aNode)
static BlockReference	calcNdbCntrBlockRef (NodeId aNode)
static BlockReference	calcTrixBlockRef (NodeId aNode)
static BlockReference	calcBackupBlockRef (NodeId aNode)
static BlockReference	calcSumaBlockRef (NodeId aNode)
static BlockReference	calcApiClusterMgrBlockRef (NodeId aNode)
static int	sortchunks (const void , const void )
Static Protected Attributes inherited from SimulatedBlock
static Callback	TheEmptyCallback = {0, 0}
static Callback	TheNULLCallback

Detailed Description

Database utilities.

This block implements transactional services which can be used by other blocks.

Module: The Sequence Service

A sequence is a varaible stored in the database. Each time it is requested with "NextVal" it returns a unique number. If requested with "CurrVal" it returns the current number.

Request: SEQUENCE_REQ Requests the 'NextVal' or 'CurrVal' for sequence variable 'sequenceId'.

Response: SEQUENCE_CONF / REF (if failure) Returns value requested.

Definition at line 64 of file DbUtil.hpp.

Constructor & Destructor Documentation

DbUtil::DbUtil ( Block_context & ctx )

Sequence Service

Locking

Backend towards Dict

Prepare / Execute / Release Services

Definition at line 56 of file DbUtil.cpp.

Here is the call graph for this function:

Member Function Documentation

void DbUtil::execGET_TABINFO_CONF ( Signal * signal )

protected

Note: We assume that this signal comes due to a request related to a Prepare struct. DictTabInfo:s 'senderData' denotes the Prepare struct related to the request.

Definition at line 1122 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execGET_TABINFOREF ( Signal * signal )

protected

Backend interface to a used DICT service

Definition at line 1162 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execREAD_CONFIG_REQ ( Signal * signal )

protected

Startup & Misc

Definition at line 166 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execSTTOR ( Signal * signal )

protected

1) get systab_0 table-id 2) run hardcodedPrepare (for sequences) 3) connectTc() 4) STTORRY

We need to find table-id of SYSTAB_0, as it can be after upgrade we don't know what it will be...

Definition at line 228 of file DbUtil.cpp.

Here is the caller graph for this function:

void DbUtil::execTCKEYCONF ( Signal * signal )

protected

Check commit ack marker flag

Definition at line 2465 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execTCSEIZECONF ( Signal * signal )

protected

Backend interface to a used TC service

Definition at line 323 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execTRANSID_AI ( Signal * signal )

protected

execTRANSID_AI

Receive result from transaction

NOTE: This codes assumes that TransidAI::DataLength = ResultSetBuffer::getSegmentSize() * n

Save result

Definition at line 2396 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_DELETE_REQ ( Signal * signal )

protected

Delete Service : Public interface

void DbUtil::execUTIL_DESTORY_LOCK_REQ ( Signal * signal )

OK

Definition at line 2887 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_EXECUTE_REQ ( Signal * signal )

protected

Execute Service : Public interface

Definition at line 2020 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_PREPARE_REQ ( Signal * signal )

protected

Prepare Service : Public interface

Definition at line 984 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_RELEASE_REQ ( Signal * signal )

protected

Prepare Release Service : Public interface

Definition at line 1598 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_SEQUENCE_REQ ( Signal * signal )

protected

Sequence Service : Public interface

1 Transaction with 1 operation

Definition at line 1776 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::execUTIL_UNLOCK_REQ ( Signal * signal )

Unlock can make other(s) acquie lock

Definition at line 2720 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::hardcodedPrepare	(	Signal *	signal,
		Uint32	SYSTAB_0
	)

Prepare SequenceCurrVal (READ)

Prepare SequenceNextVal (UPDATE)

Prepare CreateSequence (INSERT)

Prepare SetSequence (UPDATE)

Definition at line 1638 of file DbUtil.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

void DbUtil::runOperation	(	Signal *	signal,
		TransactionPtr &	transPtr,
		OperationPtr &	opPtr,
		Uint32	start
	)

Init operation w.r.t result set

Key Info

More the 8 words of key info not implemented

KeyInfo

AttrInfo

Definition at line 2207 of file DbUtil.cpp.

Here is the call graph for this function:

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

storage/ndb/src/kernel/blocks/dbutil/DbUtil.hpp
storage/ndb/test/include/DbUtil.hpp
storage/ndb/src/kernel/blocks/dbutil/DbUtil.cpp
storage/ndb/test/src/DbUtil.cpp

Classes

Public Types

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Module: The Sequence Service

Constructor & Destructor Documentation

Member Function Documentation