Oracle数据案例 C语言源码 C语言Oracle案例

/*! * @file MemTable_trans.c 事务操作 * <br> copyright (C), 1995-2005, Si-Tech Information Technology Ltd * @author wangjs * @version 1.0 * @date 2008-07-20 */ #include "MemTable.h" /*****************************************************************/ /*! * @brief 设置等值查找时的条件. * @param [out] TC 查询树节点游标 * @param [in] key 待查找的值 * @return 无 */ void Ts_SetEQ(TREE_CURSOR *TC, char *key) { TC->tiPos = 0; TC->tiNum = 0; TC->curTmi = TC->tmi; TC->minKey = key; TC->maxKey = NULL; TC->optSign = 103; /*DATA_TYPE_EQ*/; return; } /*****************************************************************/ /*! * @brief 获取一张表的临时变更记录数. * @param [in] TD 表指针 * @param [in] transBuf 事务指针 * @return 变更记录数 */ int Ts_GetTabChgCount(TABLE_DATA *TD, TRANS_BUF *transBuf) { int i; for(i=0; i<transBuf->tabNum; i++) { if(TD == transBuf->allTab[i]->TD) return transBuf->allTab[i]->change_count; } return 0; } /*****************************************************************/ /*! * @brief 判断一条记录是否在事务缓冲区. * @param [in] TD 表指针 * @param [in] areaPos 内存块序号 * @param [in] recPos 内存块内部记录号 * @param [in] transBuf 事务指针 * @return 对应的事务记录指针，如果为空，表示不存在 */ TRANS_REC *Ts_IsInTransBuf(TABLE_DATA *TD, int areaPos, int recPos, TRANS_BUF *transBuf) { TRANS_TAB *tmpTrans; TRANS_REC *tmpTRec; int tid; tmpTrans = transBuf->transTab; while(NULL != tmpTrans) { if(TD == tmpTrans->TD) break; tmpTrans = tmpTrans->next; } if(NULL == tmpTrans) return NULL; tid = recPos%TRANS_HASH_NUM; tmpTRec = tmpTrans->transRec[tid]; /*判断此hash节点是否应该置空 20081025 wangjs修改*/ if( (NULL != tmpTRec) && (-1 == tmpTRec->area_pos) ) { tmpTrans->transRec[tid] = NULL; tmpTRec = NULL; } while(NULL != tmpTRec) { if( (recPos == tmpTRec->rec_pos)&&(areaPos == tmpTRec->area_pos) ) break; tmpTRec = tmpTRec->next; } return tmpTRec; } /*****************************************************************/ /*! * @brief 为一条记录创建索引. * @param [out] errStr 出错新乡 * @param [in] indexNo 索引序号 * @param [in] TD 表指针 * @param [in] TF 表结构 * @param [in] newP 待插入的记录 * @param [in] areaPos 插入位置(数据块序号) * @param [in] recPos 插入位置(数据块内记录序号) * @return 0 成功， <0 失败 */ int Ts_CreateIndRec(char *errStr, int indexNo, TABLE_DATA *TD, TABLE_DEF *TF, char *newP, int areaPos, int recPos) { INDEX_DEF *IXF = &(TF->index[indexNo]); if(HASH_INDEX == IXF->index_type) { INDEX_RECORD *IR; if(0 != TP_CreateIndex(errStr, &IR, newP, TD, indexNo, 1, 0)) /*不检测主键*/ return ERRNO_SQL; IR->area_pos = areaPos; IR->rec_pos = recPos; IR->useFlag = 0; } else { int flag; TREE_ITEM TI; TI.area_pos = areaPos; TI.rec_pos = recPos; TD->tree[indexNo] = Tree_insert(errStr, TD, TD->tree[indexNo], &TI, &(TF->column[IXF->field_no[0]]), &flag); if(NULL == TD->tree[indexNo]) return ERRNO_SQL; } return 0; } /*****************************************************************/ /*! * @brief 删除表的一条数据的索引 * @param [in] indexNo 索引序号 * @param [in] TD 表指针 * @param [in] TF 表结构 * @param [in] dataP 要删除的记录 * @param [in] areaPos 内存块序号 * @param [in] recPos 记录序号 * @return 无 */ void Ts_DeleteInd(int indexNo, TABLE_DATA *TD, TABLE_DEF *TF, char *dataP, int areaPos, int recPos) { INDEX_DEF *IXF; IXF = &(TF->index[indexNo]); if(HASH_INDEX == IXF->index_type) /*HASH索引*/ { INDEX_RECORD *tmpIR; char indexStr[300]; TP_GetIndexStr(indexStr, dataP, IXF, TF->column); if( TP_GetIndex(&tmpIR, TD->index_p[indexNo], TD->dataArea.dataP, IXF, TF->column, indexStr, TF->data_len) ) { while(NULL != tmpIR) { if( (0 == tmpIR->useFlag) && (tmpIR->area_pos == areaPos) && (tmpIR->rec_pos == recPos) ) { tmpIR->useFlag = 1; /*将此索引置为删除*/ break; } tmpIR = tmpIR->next; } } } else /*Tree索引*/ { int roarFlag, findFlag; TREE_CURSOR TC; COLUMN_DEF *CF = &(TF->column[IXF->field_no[0]]); Ts_SetEQ(&TC, dataP + CF->data_pos); TD->tree[indexNo] = Tree_remove(TD, TD->tree[indexNo], CF, &TC, &findFlag, &roarFlag, areaPos, recPos); } return; } /*****************************************************************/ /*! * @brief 删除表的一条数据的索引，并将数据坐标写入空闲列表. * @param [in] TD 表指针 * @param [in] TF 表结构 * @param [in] DA 数据区首指针 * @param [in] dataP 要删除的记录 * @param [in] areaPos 内存块序号 * @param [in] recPos 记录序号 * @return 无 */ void Ts_DeleteP(TABLE_DATA *TD, TABLE_DEF *TF, DATA_AREA *DA, char *dataP, int areaPos, int recPos) { int i; FREE_AREA *ptmpFree; /*删除索引对应的值*/ for(i=0; i<TF->index_num; i++) { Ts_DeleteInd(i, TD, TF, dataP, areaPos, recPos); } /*将本记录对应的数据区写到空闲列表*/ if((0 == DA->freeNum)||(MAX_REC_NUM_ONCE <= DA->freeNum)) /*一块空闲区被用完了*/ { ptmpFree = (FREE_AREA *)P_MyMalloc(sizeof(FREE_AREA)); /*再申请一块*/ memset(ptmpFree, 0, sizeof(FREE_AREA)); ptmpFree->next = DA->pfree; DA->pfree = ptmpFree; DA->freeNum = 0; } else ptmpFree = DA->pfree; ptmpFree->area_pos[DA->freeNum] = areaPos; ptmpFree->rec_pos[DA->freeNum] = recPos; DA->freeNum++; return; } /*****************************************************************/ /*! * @brief 删除旧索引，重建新索引. * @param [in] upInd 更新的索引序号，每个bit代表一个索引，0～7位。 * @param [in] oldP 旧记录 * @param [in] newP 新记录 * @param [in] opFlag 3位操作标志，0位表示删除、1位表示创建、2位表示是否比较新旧索引 * @param [in] areaPos 内存块序号 * @param [in] recPos 内存块内部记录号 * @param [in] TD 表指针 * @return 更新的索引序号，每个bit代表一个索引，0～7位。 */ char Ts_DelAndCrtIndex(char upInd, char *oldP, char *newP, const char *opFlag, int areaPos, int recPos, TABLE_DATA *TD) { int i; char tmpInd, errStr[100], oldIndStr[256], newIndStr[256]; TABLE_DEF *TF; INDEX_DEF *IXF; if(0 == upInd) return 0; TF = &(TD->table_def); tmpInd = upInd; for(i=0; i<TF->index_num; i++) { if(1 == ((upInd >> i)&1) ) { IXF = &(TF->index[i]); if('1' == opFlag[2]) /*需要做新旧索引比较*/ { TP_GetIndexStr(oldIndStr, oldP, IXF, TF->column); TP_GetIndexStr(newIndStr, newP, IXF, TF->column); if(0 == strcmp(oldIndStr, newIndStr)) /*无需操作*/ { tmpInd&=~(1<<i); /*第i位置0*/ continue; } } if('1' == opFlag[0]) /*删除旧索引*/ Ts_DeleteInd(i, TD, TF, oldP, areaPos, recPos)