TableImpl Class Reference

#include <TableImpl.h>

Inheritance diagram for TableImpl:

[legend]Collaboration diagram for TableImpl:

[legend]

Public Member Functions
	TableImpl ()
	~TableImpl ()
void	setDB (Database *db)
void	setSystemDB (Database *db)
void	setLockManager (LockManager *lmgr)
void	setTrans (Transaction **t)
DataType	getFieldType (const char *name)
int	getFieldOffset (const char *name)
size_t	getFieldLength (const char *name)
DbRetVal	getFieldInfo (const char *fieldName, FieldInfo *&info)
List	getFieldNameList ()
void	setCondition (Condition *p)
	sets condition for the select, update and delete operations
DbRetVal	bindFld (const char *name, void *val)
	binds application buffer to the specified field of the table.
void	markFldNull (const char *name)
	marks the specified field to insert null when insert method is called.
void	markFldNull (int colpos)
	marks the specified field to insert null when insert method is called.
bool	isFldNull (const char *name)
	checks whether the field value is null.
bool	isFldNull (int colpos)
	checks whether the field value is null for the specified field position.
void	clearFldNull (const char *name)
	clears the null mark which is set before.
void	clearFldNull (int colpos)
	clears the null mark which is set before.
DbRetVal	insertTuple ()
	insert the tuple into the table.
DbRetVal	updateTuple ()
	update values in the current tuple of the table.
DbRetVal	deleteTuple ()
	deletes the current tuple of the table.
int	deleteWhere ()
	deletes all the records which satisfies the condition set.
int	truncate ()
	deletes the all the records in the table.
DbRetVal	execute ()
	executes the select statement.
void *	fetch ()
	fetches the next tuple in the table which satisfies the condition specified.
void *	fetch (DbRetVal &rv)
void *	fetchNoBind ()
	fetches the next tuple in the table which satisfies the condition specified.
void *	fetchNoBind (DbRetVal &rv)
DbRetVal	close ()
	closes the scan.
long	spaceUsed ()
	Retrieves the total space used for this table in bytes.
long	numTuples ()
	Retrieves the total number of tuples present in this table.
int	pagesUsed ()
void	printInfo ()
DbRetVal	lock (bool shared)
	takes lock on the table if bool shared flag is set, it will take shared lock, or else exclusive lock
DbRetVal	unlock ()
	releases the lock acquired on the table
DbRetVal	setUndoLogging (bool flag)
	sets the undo log flag.
void	printSQLIndexString ()
char *	getName ()
void	setTableInfo (char *name, int tblid, size_t length, int numFld, int numIdx, void *chunk)
Data Fields
FieldList	fldList_
int	numIndexes_
char **	indexPtr_
IndexInfo **	idxInfo
int	useIndex_
bool	isPlanCreated
Database *	db_
Database *	sysDB_
bool	isIntUsedForNULL
int	iNullInfo
char *	cNullInfo
int	iNotNullInfo
char *	cNotNullInfo
Friends
class	DatabaseManagerImpl

---

Detailed Description

Definition at line 65 of file TableImpl.h.

---

Constructor & Destructor Documentation

TableImpl::TableImpl

(

)

[inline]

Definition at line 130 of file TableImpl.h.

References cNotNullInfo, cNullInfo, db_, idxInfo, indexPtr_, iNotNullInfo, iNullInfo, isIntUsedForNULL, isPlanCreated, unknownScan, and useIndex_.

                { db_ = NULL; chunkPtr_ = NULL; iter = NULL;
        idxInfo = NULL; indexPtr_ = NULL; scanType_ = unknownScan; 
        pred_ = NULL; useIndex_ = -1; numFlds_ = 0;
        iNullInfo = 0; cNullInfo = NULL; isIntUsedForNULL = true; 
        iNotNullInfo = 0; cNotNullInfo = NULL;
        isPlanCreated = false; undoFlag = true;}

TableImpl::~TableImpl

(

)

Definition at line 781 of file TableImpl.cxx.

References cNullInfo, fldList_, idxInfo, indexPtr_, and FieldList::removeAll().

{
    if (NULL != iter ) { delete iter; iter = NULL; }
    if (NULL != indexPtr_) { delete[] indexPtr_; indexPtr_ = NULL;  }
    if (NULL != idxInfo) 
    {
        for (int i = 0; i < numIndexes_; i++) delete idxInfo[i];
        delete[] idxInfo; 
        idxInfo = NULL; 
    }
    if (numFlds_ > 31 && cNullInfo != NULL) { free(cNullInfo); cNullInfo = NULL; }

    fldList_.removeAll();

}

Here is the call graph for this function:

---

Member Function Documentation

DbRetVal TableImpl::bindFld	(	const char *	name,
		void *	val
	)			[virtual]

binds application buffer to the specified field of the table.

Before doing any DML operations required fields are binded first. Below are the candidates for this:
1.All the fields in the projection list of select statement.
2.Field list in the insert statement.
3.Fields in the assignment list of update statement.

Parameters:

	name	field name in the table
	val	address of the application buffer. Memory should be allocated by the application before binding the buffer.

Implements Table.

Definition at line 27 of file TableImpl.cxx.

References ErrNotExists, fldList_, OK, printError, and FieldList::updateBindVal().

{
    //set it in the field list
    DbRetVal rv = fldList_.updateBindVal(name, val);
    if (OK != rv) {
        printError(ErrNotExists, "Field %s does not exist", name);
        return  rv;
    }
    return OK;
}

Here is the call graph for this function:

void TableImpl::clearFldNull

(

int

colpos

)

[virtual]

clears the null mark which is set before.

Parameters:

colpos

field position

Implements Table.

Definition at line 98 of file TableImpl.cxx.

References CLEARBIT, cNullInfo, iNullInfo, and isIntUsedForNULL.

{
    if (colpos <1 || colpos > numFlds_) return;
    if (isIntUsedForNULL) { 
        CLEARBIT(iNullInfo, colpos);
    }
    else
        cNullInfo[colpos-1] = 0;
    return;
}

void TableImpl::clearFldNull

(

const char *

name

)

[virtual]

clears the null mark which is set before.

Parameters:

name

field name

Implements Table.

Definition at line 86 of file TableImpl.cxx.

References ErrNotExists, fldList_, FieldList::getFieldPosition(), and printError.

{
    int colpos = fldList_.getFieldPosition(name);
    if (-1 == colpos)
    {
        printError(ErrNotExists, "Field %s does not exist", name);
        return;
    }

    clearFldNull(colpos);
}

Here is the call graph for this function:

DbRetVal TableImpl::close

(

)

[virtual]

closes the scan.

Needs to be called before calling execute again on the same table handle. It releases the resources acquired during the scan.

Returns:

DbRetVal

Implements Table.

Definition at line 733 of file TableImpl.cxx.

References TupleIterator::close(), ErrNotOpen, OK, and printError.

Referenced by deleteWhere().

{
    if (NULL == iter)
    {
         printError(ErrNotOpen,"Scan not open");
         return ErrNotOpen;
    }
    iter->close();
    delete iter;
    iter = NULL;
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal TableImpl::deleteTuple

(

)

[virtual]

deletes the current tuple of the table.

It works only on top of select. using fetch first go to the tuple to be deleted, then call this method to delete.
To delete all the tuples, do not set any condition and call fetch followed by delete in a loop till fetch exhausts.

Returns:

DbRetVal

Implements Table.

Definition at line 398 of file TableImpl.cxx.

References db_, DeleteOperation, ErrLockTimeOut, ErrNotOpen, LockManager::getExclusiveLock(), idxInfo, indexPtr_, OK, printError, LockManager::releaseLock(), and sysDB_.

Referenced by deleteWhere().

{
    if (NULL == curTuple_)
    {
        printError(ErrNotOpen, "Scan not open: No Current tuple");
        return ErrNotOpen;
    }
    DbRetVal ret = lMgr_->getExclusiveLock(curTuple_, trans);
    if (OK != ret)
    {
        printError(ret, "Could not get lock for the delete tuple %x", curTuple_);
        return ErrLockTimeOut;
    }

    if (NULL != indexPtr_)
    {
        int i;
        //it has index
        for (i = 0; i < numIndexes_ ; i++)
        {
            ret = deleteIndexNode(*trans, indexPtr_[i], idxInfo[i], curTuple_);
            if (ret != OK) break;
        }
        if (i != numIndexes_ )
        {
            for (int j = 0; j < i ; j++)
                insertIndexNode(*trans, indexPtr_[j], idxInfo[j], curTuple_);
            lMgr_->releaseLock(curTuple_);
            (*trans)->removeFromHasList(db_, curTuple_);
            printError(ret, "Unable to insert index node for tuple %x", curTuple_);
            return ret;
        }
    }
    ((Chunk*)chunkPtr_)->free(db_, curTuple_);
    if (undoFlag)
        ret = (*trans)->appendUndoLog(sysDB_, DeleteOperation, curTuple_, length_);
    return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int TableImpl::deleteWhere

(

)

[virtual]

deletes all the records which satisfies the condition set.

Returns:

int totalTuples deleted

Implements Table.

Definition at line 437 of file TableImpl.cxx.

References close(), deleteTuple(), execute(), fetchNoBind(), OK, and printError.

Referenced by truncate().

{
    int tuplesDeleted = 0;
    DbRetVal rv  = OK;
    rv =  execute();
    if (rv !=OK) return (int) rv;
    while(true){
        fetchNoBind( rv);
        if (rv != OK) { tuplesDeleted = (int)rv; break; }
        if (NULL == curTuple_) break;
        rv = deleteTuple();
        if (rv != OK) {
            printError(rv, "Error: Could only delete %d tuples", tuplesDeleted);
            close();
            return (int) rv;
        }
        tuplesDeleted++;
    }
    close();
    return tuplesDeleted;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal TableImpl::execute

(

)

[virtual]

executes the select statement.

Based on the predicate(condition), respective index is chosen for the select. Application should call execute before they start fetching the values from the table.This starts scan on the table.

Returns:

DbRetVal

Implements Table.

Definition at line 110 of file TableImpl.cxx.

References ErrAlready, ErrSysFatal, ErrSysInternal, fullTableScan, idxInfo, OK, TupleIterator::open(), printError, Database::procSlot, PredicateImpl::setTable(), sysDB_, and useIndex_.

Referenced by deleteWhere().

{
    if (NULL != iter)
    {
         printError(ErrAlready,"Scan already open:Close and re execute");
         return ErrAlready;
    }
    //table ptr is set in predicate because it needs to access the
    //type and length to evaluate
    if( NULL != pred_)
    {
        PredicateImpl *pred = (PredicateImpl*) pred_;
        pred->setTable(this);
    }
    DbRetVal ret = OK;

    ret = createPlan();
    if (OK != ret)
    {
        printError(ErrSysInternal,"Unable to create the plan");
        return ErrSysInternal;
    }
    if (useIndex_ >= 0) 
        iter = new TupleIterator(pred_, scanType_, idxInfo[useIndex_], chunkPtr_, sysDB_->procSlot);
    else if (scanType_ == fullTableScan)
        iter = new TupleIterator(pred_, scanType_, NULL, chunkPtr_, sysDB_->procSlot);
    else
    {
        printError(ErrSysFatal,"Unable to create tuple iterator");//should never happen
        return ErrSysFatal;
    }
    ret = iter->open();
    if (OK != ret)
    {
        printError(ret,"Unable to open the iterator");
        return ret;
    }
    return OK;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void * TableImpl::fetch

(

DbRetVal &

rv

)

[virtual]

Implements Table.

Definition at line 200 of file TableImpl.cxx.

References fetchNoBind().

{
    fetchNoBind(rv);
    if (NULL == curTuple_) return curTuple_;
    copyValuesToBindBuffer(curTuple_);
    return curTuple_;
}

Here is the call graph for this function:

void * TableImpl::fetch

(

)

[virtual]

fetches the next tuple in the table which satisfies the condition specified.

execute should be called before calling this method. Application buffer should be binded to get the tuple values.

Returns:

void* NULL if there is no tuple.

Implements Table.

Definition at line 193 of file TableImpl.cxx.

References fetchNoBind().

{
    fetchNoBind();
    if (NULL == curTuple_) return curTuple_;
    copyValuesToBindBuffer(curTuple_);
    return curTuple_;
}

Here is the call graph for this function:

void * TableImpl::fetchNoBind

(

DbRetVal &

rv

)

[virtual]

Implements Table.

Definition at line 266 of file TableImpl.cxx.

References Conf::config, ErrLockTimeOut, ErrNotOpen, Config::getMutexSecs(), Config::getMutexUSecs(), LockManager::getSharedLock(), LockManager::isExclusiveLocked(), TupleIterator::next(), OK, printError, READ_COMMITTED, READ_REPEATABLE, and os::select().

{
    rv = OK;
    if (NULL == iter)
    {
        printError(ErrNotOpen,"Scan not open or Scan is closed\n");
        rv = ErrNotOpen;
        return NULL;
    }
    void *prevTuple = curTuple_;
    curTuple_ = iter->next();
    if (NULL == curTuple_)
    {
        return NULL;
    }
    DbRetVal lockRet = OK;
    if ((*trans)->isoLevel_ == READ_REPEATABLE) {
        lockRet = lMgr_->getSharedLock(curTuple_, trans);
        if (OK != lockRet)
        {
            printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
            rv = ErrLockTimeOut;
            curTuple_ = prevTuple;
            return NULL;
        }

    }
    else if ((*trans)->isoLevel_ == READ_COMMITTED)
    {
        //if iso level is read committed, operation duration lock is sufficent
        //so release it here itself.
        int tries = 5;
        struct timeval timeout;
        timeout.tv_sec = Conf::config.getMutexSecs();
        timeout.tv_usec = Conf::config.getMutexUSecs();

        bool status = false;
        while(true) {
            lockRet = lMgr_->isExclusiveLocked( curTuple_, trans, status);
            if (OK != lockRet)
            {
                printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
                curTuple_ = prevTuple;
                rv = ErrLockTimeOut;
                return NULL;
            }
            if (!status) break;
            tries--;
            if (tries == 0) break;
            os::select(0, 0, 0, 0, &timeout);

        }
        if (tries == 0)
        {
            printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
            curTuple_ = prevTuple;
            rv = ErrLockTimeOut;
            return NULL;
        }
    }
    return curTuple_;
}

Here is the call graph for this function:

void * TableImpl::fetchNoBind

(

)

[virtual]

fetches the next tuple in the table which satisfies the condition specified.

execute should be called before calling this method. Application buffer need not be binded to call this method.

Returns:

void* NULL if there is no tuple.

Implements Table.

Definition at line 208 of file TableImpl.cxx.

References Conf::config, ErrNotOpen, Config::getMutexSecs(), Config::getMutexUSecs(), LockManager::getSharedLock(), LockManager::isExclusiveLocked(), TupleIterator::next(), OK, printError, READ_COMMITTED, READ_REPEATABLE, and os::select().

Referenced by deleteWhere(), and fetch().

{
    if (NULL == iter)
    {
        printError(ErrNotOpen,"Scan not open or Scan is closed\n");
        return NULL;
    }
    void *prevTuple = curTuple_;
    curTuple_ = iter->next();
    if (NULL == curTuple_)
    {
        return NULL;
    }
    DbRetVal lockRet = OK;
    if ((*trans)->isoLevel_ == READ_REPEATABLE) {
        lockRet = lMgr_->getSharedLock(curTuple_, trans);
        if (OK != lockRet)
        { 
            printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
            curTuple_ = prevTuple;
            return NULL;
        }

    }
    else if ((*trans)->isoLevel_ == READ_COMMITTED)
    {
        //if iso level is read committed, operation duration lock is sufficent 
        //so release it here itself.
        int tries = 5;
        struct timeval timeout;
        timeout.tv_sec = Conf::config.getMutexSecs();
        timeout.tv_usec = Conf::config.getMutexUSecs();

        bool status = false;
        while(true) { 
            lockRet = lMgr_->isExclusiveLocked( curTuple_, trans, status);
            if (OK != lockRet)
            { 
                printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
                curTuple_ = prevTuple;
                return NULL;
            }
            if (!status) break; 
            tries--;
            if (tries == 0) break;
            os::select(0, 0, 0, 0, &timeout);

        }
        if (tries == 0) 
        { 
            printError(lockRet, "Unable to get the lock for the tuple %x", curTuple_);
            curTuple_ = prevTuple;
            return NULL;
        }
    }
    return curTuple_;
}

Here is the call graph for this function:

Here is the caller graph for this function:

DbRetVal TableImpl::getFieldInfo	(	const char *	fieldName,
		FieldInfo *&	info
	)			[inline, virtual]

Implements Table.

Definition at line 150 of file TableImpl.h.

References fldList_, and FieldList::getFieldInfo().

        { return fldList_.getFieldInfo(fieldName, info); }

Here is the call graph for this function:

size_t TableImpl::getFieldLength

(

const char *

name

)

[inline]

Definition at line 147 of file TableImpl.h.

References fldList_, and FieldList::getFieldLength().

Referenced by PredicateImpl::evaluate().

        { return fldList_.getFieldLength(name); }

Here is the call graph for this function:

Here is the caller graph for this function:

List TableImpl::getFieldNameList

(

)

[virtual]

Implements Table.

Definition at line 720 of file TableImpl.cxx.

References List::append(), fldList_, FieldList::getIterator(), FieldIterator::hasElement(), Identifier::name, and FieldIterator::nextElement().

{
    List fldNameList;
    FieldIterator fIter = fldList_.getIterator();
    while (fIter.hasElement())
    {
        FieldDef def = fIter.nextElement();
        Identifier *elem = new Identifier();
        strcpy(elem->name, def.fldName_);
        fldNameList.append(elem);
    } 
    return fldNameList;
}

Here is the call graph for this function:

int TableImpl::getFieldOffset

(

const char *

name

)

[inline]

Definition at line 145 of file TableImpl.h.

References fldList_, and FieldList::getFieldOffset().

Referenced by PredicateImpl::evaluate().

        { return fldList_.getFieldOffset(name); }

Here is the call graph for this function:

Here is the caller graph for this function:

DataType TableImpl::getFieldType

(

const char *

name

)

[inline]

Definition at line 143 of file TableImpl.h.

References fldList_, and FieldList::getFieldType().

Referenced by PredicateImpl::evaluate().

        { return fldList_.getFieldType(name);   }

Here is the call graph for this function:

Here is the caller graph for this function:

char* TableImpl::getName

(

)

[inline, virtual]

Implements Table.

Definition at line 200 of file TableImpl.h.

Referenced by printSQLIndexString().

{ return tblName_; }

Here is the caller graph for this function:

DbRetVal TableImpl::insertTuple

(

)

[virtual]

insert the tuple into the table.

Prior to this, the binded buffer should be updated Values present in the binded buffers of all the fields are taken and stored in the table.

Returns:

DbRetVal

Implements Table.

Definition at line 329 of file TableImpl.cxx.

References os::align(), cNullInfo, db_, ErrLockTimeOut, ErrWarning, LockManager::getExclusiveLock(), idxInfo, indexPtr_, InsertOperation, iNullInfo, os::memcpy(), OK, printError, LockManager::releaseLock(), and sysDB_.

{
    DbRetVal ret =OK;
    void *tptr = ((Chunk*)chunkPtr_)->allocate(db_, &ret);
    if (NULL == tptr)
    {
        printError(ret, "Unable to allocate record from chunk");
        return ret;
    }
    ret = lMgr_->getExclusiveLock(tptr, trans);
    if (OK != ret)
    {
        ((Chunk*)chunkPtr_)->free(db_, tptr);
        printError(ret, "Could not get lock for the insert tuple %x", tptr);
        return ErrLockTimeOut;
    }


    ret = copyValuesFromBindBuffer(tptr);
    if (ret != OK)
    {
        printError(ret, "Unable to copy values from bind buffer");
        (*trans)->removeFromHasList(db_, tptr);
        lMgr_->releaseLock(tptr);
        ((Chunk*)chunkPtr_)->free(db_, tptr);
        return ret;
    }

    int addSize = 0;
    if (numFlds_ < 31) 
    {
        addSize = 4; 
        *(int*)((char*)(tptr) + (length_-addSize)) = iNullInfo;
    }
    else 
    {
        addSize = os::align(numFlds_);
        os::memcpy(((char*)(tptr) + (length_-addSize)), cNullInfo, addSize);

    }
    //int tupleSize = length_ + addSize;
    if (NULL != indexPtr_)
    {
        int i;
        //it has index
        for (i = 0; i < numIndexes_ ; i++)
        {
            ret = insertIndexNode(*trans, indexPtr_[i], idxInfo[i], tptr);
            if (ret != OK) { printError(ret, "Error in inserting to index"); break;}
        }
        if (i != numIndexes_ )
        {
            for (int j = 0; j < i ; j++) {
                printError(ErrWarning, "Deleting index node");
                deleteIndexNode(*trans, indexPtr_[j], idxInfo[j], tptr);
            }
            lMgr_->releaseLock(tptr);
            (*trans)->removeFromHasList(db_, tptr);
            ((Chunk*)chunkPtr_)->free(db_, tptr);
            //TMP::remove int derefernce
            printError(ret, "PRABA:::Unable to insert index node for tuple %x %d", tptr, *(int*)tptr);
            return ret;
        }
    }
    if (undoFlag)
        ret = (*trans)->appendUndoLog(sysDB_, InsertOperation, tptr, length_);
    return ret;
}

Here is the call graph for this function:

bool TableImpl::isFldNull

(

int

colpos

)

[virtual]

checks whether the field value is null for the specified field position.

Parameters:

colpos

field position

Implements Table.

Definition at line 49 of file TableImpl.cxx.

References os::align(), BITSET, and isIntUsedForNULL.

{
    if (!curTuple_) return false;
    if (colpos <1 || colpos > numFlds_) return false;
    char *nullOffset = (char*)curTuple_ - 4;
    if (isIntUsedForNULL) {
        int nullVal = *(int*)((char*)curTuple_ + (length_ - 4));
        if (BITSET(nullVal, colpos)) return true;
    }
    else {
        char *nullOffset = (char*)curTuple_ - os::align(numFlds_);
        if (nullOffset[colpos-1]) return true;
    }
    return false;
}

Here is the call graph for this function:

bool TableImpl::isFldNull

(

const char *

name

)

[virtual]

checks whether the field value is null.

Parameters:

name

field name

Implements Table.

Definition at line 38 of file TableImpl.cxx.

References ErrNotExists, fldList_, FieldList::getFieldPosition(), and printError.

                                         {
    int colpos = fldList_.getFieldPosition(name);
    if (-1 == colpos)
    {
        printError(ErrNotExists, "Field %s does not exist", name);
        return false;
    }

    return isFldNull(colpos);
}

Here is the call graph for this function:

DbRetVal TableImpl::lock

(

bool

shared

)

[virtual]

takes lock on the table if bool shared flag is set, it will take shared lock, or else exclusive lock

Returns:

DbRetVal

Implements Table.

Definition at line 745 of file TableImpl.cxx.

References OK.

{

    DbRetVal ret = OK;
/*
    if (shared) 
        ret = lMgr_->getSharedLock(chunkPtr_, NULL);
    else 
        ret = lMgr_->getExclusiveLock(chunkPtr_, NULL);
    if (OK != ret)
    {
        printError(ret, "Could not exclusive lock on the table %x", chunkPtr_);
    }else {
        //do not append for S to X upgrade
        if (!ProcessManager::hasLockList.exists(chunkPtr_)) 
            ProcessManager::hasLockList.append(chunkPtr_);
    }
*/
    return ret;
}

void TableImpl::markFldNull

(

int

colpos

)

[virtual]

marks the specified field to insert null when insert method is called.

Parameters:

colpos

field position

Implements Table.

Definition at line 75 of file TableImpl.cxx.

References BITSET, cNullInfo, iNotNullInfo, iNullInfo, isIntUsedForNULL, and SETBIT.

{
    if (fldpos <1 || fldpos > numFlds_) return;
    if (isIntUsedForNULL) {
        if (!BITSET(iNotNullInfo, fldpos)) SETBIT(iNullInfo, fldpos);
    }
    else
        if (!BITSET(iNotNullInfo, fldpos)) cNullInfo[fldpos-1] = 1;
    return;
}

void TableImpl::markFldNull

(

const char *

name

)

[virtual]

marks the specified field to insert null when insert method is called.

Parameters:

name

field name in the table

Implements Table.

Definition at line 64 of file TableImpl.cxx.

References ErrNotExists, fldList_, FieldList::getFieldPosition(), and printError.

{
    int colpos = fldList_.getFieldPosition(name);
    if (-1 == colpos)
    {
        printError(ErrNotExists, "Field %s does not exist", name);
        return;
    }
    markFldNull(colpos);
}

Here is the call graph for this function:

long TableImpl::numTuples

(

)

[virtual]

Retrieves the total number of tuples present in this table.

Returns:

DbRetVal

Implements Table.

Definition at line 715 of file TableImpl.cxx.

Referenced by printInfo().

{
    return ((Chunk*)chunkPtr_)->getTotalDataNodes();
}

Here is the caller graph for this function:

int TableImpl::pagesUsed

(

)

Definition at line 709 of file TableImpl.cxx.

References Chunk::totalPages().

Referenced by printInfo().

{
    Chunk *chk = (Chunk*)chunkPtr_;
    return chk->totalPages();
}

Here is the call graph for this function:

Here is the caller graph for this function:

void TableImpl::printInfo

(

)

Definition at line 536 of file TableImpl.cxx.

References CatalogTableINDEX::getName(), indexPtr_, numTuples(), pagesUsed(), and spaceUsed().

Referenced by main().

{
    printf("  <TableName> %s </TableName>\n", tblName_);
    printf("  <TupleCount> %d </TupleCount>\n", numTuples());
    printf("  <PagesUsed> %d </PagesUsed>\n", pagesUsed());
    printf("  <SpaceUsed> %d </SpaceUsed>\n", spaceUsed());
    printf("  <Indexes> %d <Indexes>\n", numIndexes_);
    printf("  <TupleLength> %d </TupleLength>\n", length_);
    printf("  <Fields> %d </Fields>\n", numFlds_);
    printf("  <Indexes>\n");
    for (int i =0; i<numIndexes_; i++)
        printf("<IndexName> %s </IndexName>\n", CatalogTableINDEX::getName(indexPtr_[i]));
    printf("  </Indexes>\n");

}

Here is the call graph for this function:

Here is the caller graph for this function:

void TableImpl::printSQLIndexString

(

)

[virtual]

Implements Table.

Definition at line 660 of file TableImpl.cxx.

References CatalogTableINDEXFIELD::getFieldNameAndType(), getName(), IDENTIFIER_LENGTH, idxInfo, indexPtr_, and sysDB_.

{
    CatalogTableINDEXFIELD cIndexField(sysDB_);
    char fName[IDENTIFIER_LENGTH];
    char *fldName = fName; 
    DataType type;
    for (int i = 0; i < numIndexes_ ; i++)
    {
        INDEX *iptr = (INDEX*) indexPtr_[i];
        cIndexField.getFieldNameAndType((void*)iptr, fldName, type);
        printf("CREATE INDEX %s on %s ( %s ) ", iptr->indName_, getName(), fldName);
        if (((SingleFieldHashIndexInfo*) idxInfo[i])->isUnique) printf(" UNIQUE;\n"); else printf(";\n");
    }
}

Here is the call graph for this function:

void TableImpl::setCondition

(

Condition *

p

)

[inline, virtual]

sets condition for the select, update and delete operations

Parameters:

c

condition

Implements Table.

Definition at line 156 of file TableImpl.h.

References Condition::getPredicate(), and isPlanCreated.

     { isPlanCreated = false; if (p) pred_ = p->getPredicate(); else pred_ = NULL;}

Here is the call graph for this function:

void TableImpl::setDB

(

Database *

db

)

[inline]

Definition at line 138 of file TableImpl.h.

References db_.

Referenced by DatabaseManagerImpl::openTable().

{ db_ = db; }

Here is the caller graph for this function:

void TableImpl::setLockManager

(

LockManager *

lmgr

)

[inline]

Definition at line 140 of file TableImpl.h.

Referenced by DatabaseManagerImpl::openTable().

{ lMgr_ = lmgr; }

Here is the caller graph for this function:

void TableImpl::setSystemDB

(

Database *

db

)

[inline]

Definition at line 139 of file TableImpl.h.

References sysDB_.

Referenced by DatabaseManagerImpl::openTable().

{ sysDB_ = db; }

Here is the caller graph for this function:

void TableImpl::setTableInfo	(	char *	name,
		int	tblid,
		size_t	length,
		int	numFld,
		int	numIdx,
		void *	chunk
	)

Definition at line 690 of file TableImpl.cxx.

Referenced by DatabaseManagerImpl::openTable().

{
    strcpy(tblName_, name);
    tblID_ = tblid;
    length_ = length;
    numFlds_ = numFld;
    numIndexes_ = numIdx;
    chunkPtr_ = chunk;
}

Here is the caller graph for this function:

void TableImpl::setTrans

(

Transaction **

t

)

[inline]

Definition at line 141 of file TableImpl.h.

Referenced by DatabaseManagerImpl::openTable().

{ trans = t; }

Here is the caller graph for this function:

DbRetVal TableImpl::setUndoLogging

(

bool

flag

)

[inline, virtual]

sets the undo log flag.

If this flag is unset then undo logs will not be generated

Returns:

DbRetVal

Implements Table.

Definition at line 197 of file TableImpl.h.

{ undoFlag = flag; }

long TableImpl::spaceUsed

(

)

[virtual]

Retrieves the total space used for this table in bytes.

Returns:

DbRetVal

Implements Table.

Definition at line 701 of file TableImpl.cxx.

References Chunk::getSize(), Chunk::getTotalDataNodes(), and Chunk::totalPages().

Referenced by printInfo().

{
    Chunk *chk = (Chunk*)chunkPtr_;
    long totSize = chk->getTotalDataNodes() * chk->getSize();
    totSize = totSize + (chk->totalPages() * sizeof (PageInfo));
    return totSize;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int TableImpl::truncate

(

)

[virtual]

deletes the all the records in the table.

No transaction required to call this. It takes table level lock.

Returns:

DbRetVal

Implements Table.

Definition at line 459 of file TableImpl.cxx.

References deleteWhere(), isPlanCreated, and OK.

{
    //take exclusive lock on the table
    //get the chunk ptr of the table
    //traverse the tablechunks and free all the pages except the first one
    //get the chunk ptr of all its indexes
    //traverse the indexchunks and free all the pages except the first one
    //release table lock

    //TEMPORARY FIX
    DbRetVal rv = OK;
    Predicate* tmpPred = pred_;
    pred_ = NULL;
    isPlanCreated = false;
    int tuplesDeleted = deleteWhere();
    isPlanCreated = false;
    pred_ = tmpPred;
    return tuplesDeleted;
}

Here is the call graph for this function:

DbRetVal TableImpl::unlock

(

)

[virtual]

releases the lock acquired on the table

Returns:

DbRetVal

Implements Table.

Definition at line 765 of file TableImpl.cxx.

References OK.

{
/*
    if (!ProcessManager::hasLockList.exists(chunkPtr_)) return OK;
    DbRetVal ret = lMgr_->releaseLock(chunkPtr_);
    if (OK != ret)
    {
        printError(ret, "Could not release exclusive lock on the table %x", chunkPtr_);
    }else
    {
        ProcessManager::hasLockList.remove(chunkPtr_);
    }
*/
    return OK;
}

DbRetVal TableImpl::updateTuple

(

)

[virtual]

update values in the current tuple of the table.

It works only on top of select using fetch go to the tuple to be updated, then update the binded buffer value and then call this method to updates the field values in the tuple.

Returns:

DbRetVal

Implements Table.

Definition at line 479 of file TableImpl.cxx.

References os::align(), db_, ErrLockTimeOut, ErrNotOpen, LockManager::getExclusiveLock(), idxInfo, indexPtr_, iNullInfo, OK, printError, LockManager::releaseLock(), sysDB_, and UpdateOperation.

{
    if (NULL == curTuple_)
    {
        printError(ErrNotOpen, "Scan not open: No Current tuple");
        return ErrNotOpen;
    }
    DbRetVal ret = lMgr_->getExclusiveLock(curTuple_, trans);
    if (OK != ret)
    {
        printError(ret, "Could not get lock for the update tuple %x", curTuple_);
        return ErrLockTimeOut;
    }
    if (NULL != indexPtr_)
    {
        //it has index
        //TODO::If it fails while updating index node, we have to undo all the updates 
        //on other indexes on the table.Currently it will leave the database in an 
        //inconsistent state.
        for (int i = 0; i < numIndexes_ ; i++)
        {
            ret = updateIndexNode(*trans, indexPtr_[i], idxInfo[i], curTuple_);
            if (ret != OK)
            {
                lMgr_->releaseLock(curTuple_);
                (*trans)->removeFromHasList(db_, curTuple_);
                printError(ret, "Unable to update index node for tuple %x", curTuple_);
                return ret;
            }
        }
    }
    if (undoFlag)
        ret = (*trans)->appendUndoLog(sysDB_, UpdateOperation, curTuple_, length_);
    if (ret != OK) return ret;
    int addSize = 0;
    if (numFlds_ < 31) 
    {
        addSize = 4; 
        *(int*)((char*)(curTuple_) + (length_-addSize)) |= iNullInfo;
    }
    else 
    {
        addSize = os::align(numFlds_);
        //TODO::Do not do blind memcpy. It should OR each and every char
        //os::memcpy(((char*)(curTuple_) + (length_-addSize)), cNullInfo, addSize);

    }

    DbRetVal rv = copyValuesFromBindBuffer(curTuple_, false);
    if (rv != OK) { 
        lMgr_->releaseLock(curTuple_); 
        (*trans)->removeFromHasList(db_, curTuple_); 
        return rv; 
    }
    return OK;
}

Here is the call graph for this function:

---

Friends And Related Function Documentation

friend class DatabaseManagerImpl [friend]

Definition at line 203 of file TableImpl.h.

---

Field Documentation

char* TableImpl::cNotNullInfo

Definition at line 110 of file TableImpl.h.

Referenced by DatabaseManagerImpl::openTable(), and TableImpl().

char* TableImpl::cNullInfo

Definition at line 108 of file TableImpl.h.

Referenced by clearFldNull(), insertTuple(), markFldNull(), DatabaseManagerImpl::openTable(), TableImpl(), and ~TableImpl().

Database* TableImpl::db_

Definition at line 101 of file TableImpl.h.

Referenced by deleteTuple(), HashIndex::insert(), insertTuple(), HashIndex::remove(), setDB(), TableImpl(), HashIndex::update(), and updateTuple().

FieldList TableImpl::fldList_

Definition at line 94 of file TableImpl.h.

Referenced by bindFld(), clearFldNull(), getFieldInfo(), getFieldLength(), getFieldNameList(), getFieldOffset(), getFieldType(), isFldNull(), markFldNull(), DatabaseManagerImpl::openTable(), HashIndex::update(), and ~TableImpl().

IndexInfo** TableImpl::idxInfo

Definition at line 97 of file TableImpl.h.

Referenced by deleteTuple(), execute(), insertTuple(), DatabaseManagerImpl::openTable(), printSQLIndexString(), TableImpl(), updateTuple(), and ~TableImpl().

char** TableImpl::indexPtr_

Definition at line 96 of file TableImpl.h.

Referenced by deleteTuple(), insertTuple(), DatabaseManagerImpl::openTable(), printInfo(), printSQLIndexString(), TableImpl(), updateTuple(), and ~TableImpl().

int TableImpl::iNotNullInfo

Definition at line 109 of file TableImpl.h.

Referenced by markFldNull(), DatabaseManagerImpl::openTable(), and TableImpl().

int TableImpl::iNullInfo

Definition at line 107 of file TableImpl.h.

Referenced by clearFldNull(), insertTuple(), markFldNull(), DatabaseManagerImpl::openTable(), TableImpl(), and updateTuple().

bool TableImpl::isIntUsedForNULL

Definition at line 106 of file TableImpl.h.

Referenced by clearFldNull(), isFldNull(), markFldNull(), DatabaseManagerImpl::openTable(), and TableImpl().

bool TableImpl::isPlanCreated

Definition at line 99 of file TableImpl.h.

Referenced by setCondition(), TableImpl(), and truncate().

int TableImpl::numIndexes_

Definition at line 95 of file TableImpl.h.

Referenced by DatabaseManagerImpl::openTable().

Database* TableImpl::sysDB_

Definition at line 102 of file TableImpl.h.

Referenced by deleteTuple(), execute(), HashIndex::insert(), insertTuple(), printSQLIndexString(), HashIndex::remove(), setSystemDB(), HashIndex::update(), and updateTuple().

int TableImpl::useIndex_

Definition at line 98 of file TableImpl.h.

Referenced by execute(), and TableImpl().

---

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

• include/TableImpl.h
• src/server/TableImpl.cxx

---