ntpaddb.c

基于东南大学开发的SEP3203的ARM7中的所有驱动

/*************************************************************************
*
* Copyright  2002 National ASIC Center, All rights Reserved
*
* FILE NAME:			phoneHdb.c
* PROGRAMMER:			xuanhui
* Date of Creation:		2002/09/24
* 
* DESCRIPTION: 			Database operations for the application "notepad".
*
* NOTE:			 		 
*						 
*
* FUNCTIONS LIST:
* -------------------------------------------------------------------------
*InitNotepadDB,
*LinkNotepadDB,
*DetachNotepadDB,
*NotepadDBReadRecord,
*NotepadDBModifyRecord,
*NotepadDBAddRecord,
*NotepadDBDelRecord,
*NotepadDBFindRecord,
*NotepadDBSearchRecord,
*
* GLOBAL VARS LIST:
* 
*
**************************************************************************
*
* MODIFICATION HISTORY
*
*
* 2002/09/24	by xuanhui		Create the file
*								
*************************************************************************/
#include <string.h>
#include "lmalloc.h"

#include "ntpaddb.h"
#include "common.h"

#include "sysdebug.h"

// 字段索引
FIELDINDEX	NotepadParentField[256];			// 父目录索引表
FIELDINDEX	NotepadIDField[256];					// 目录/文件的id索引表
FIELDINDEX	NotepadNameField_I[27];				// 目录/文件的名称一级索引表
FIELDINDEX	NotepadModifyTimeField_I[12];		// 修改时间一级索引表
/*
FIELDINDEXLIST	NotepadDBFList[ NOTEPAD_INDEX_FIELD_NUM ] = 
{
	{	NOTEPAD_PARENT_FIELD,		SINGLE_VALUE_FIELD,	256,	NotepadParentField,			I_LEVEL  },	// 父目录索引表
	{	NOTEPAD_ID_FIELD,			SINGLE_VALUE_FIELD,	256,	NotepadIDField,				I_LEVEL  },	// 目录/文件的id索引表
	{	NOTEPAD_NAME_FIELD,			SINGLE_VALUE_FIELD,	27,		NotepadNameField_I,			II_LEVEL },	// 目录/文件的名称索引表
	{	NOTEPAD_MODIFY_TIME_FIELD,	SINGLE_VALUE_FIELD,	12,		NotepadModifyTimeField_I,	II_LEVEL }	// 修改时间索引表
};
*/
FIELDINDEXLIST	NotepadDBFList[ NOTEPAD_FIELD_NUM ] = 
{
	{	NOTEPAD_PARENT_FIELD,		SINGLE_VALUE_FIELD,	256,	NotepadParentField,			I_LEVEL  },	// 父目录索引表
	{	NOTEPAD_ID_FIELD,			SINGLE_VALUE_FIELD,	256,	NotepadIDField,				I_LEVEL  },	// 目录/文件的id索引表
	{	NOTEPAD_NAME_FIELD,			SINGLE_VALUE_FIELD,	27,		NotepadNameField_I,			II_LEVEL },	// 目录/文件的名称索引表
	{	NOTEPAD_MODIFY_TIME_FIELD,	SINGLE_VALUE_FIELD,	12,		NotepadModifyTimeField_I,	II_LEVEL },	// 修改时间索引表
	{	0,	SINGLE_VALUE_FIELD,	0,		NULL,   0 },		
	{	0,	SINGLE_VALUE_FIELD,	0,		NULL,   0 }		
};
//-------------------- Local Functions List --------------------------------------------//
//初始化一级索引表
static void InitIndexList( void );
// 将字段值加入到字段索引表
static DWORD Add2FieldIndexTbl( DBGACB *gacb, BYTE field, BYTE *value, DWORD id );

//创建新的二级索引表
static FIELDINDEX *CreateIIIndexList( FIELDINDEX *I_index_list, BYTE field );
//分开查找表的目录和文件
static WORD DetachListDirandFile( WORD count, RECORDDATA *record_head, LOCALSEARCHLIST *head );
//获得父目录的各级记录
static DWORD GetParentRecord( DBLACB *lacb, LOCALSEARCHLIST *head, FIELDINDEX *I_index_list, BYTE *data );

/**********************************************************************/
DBGACB* InitNotepadDB( DBGACB *gacb )
{
	DWORD	id = gacb->PLInfo->info.usedBlockHead;
	BYTE	i;

	// 初始化一级字段索引表
	InitIndexList();

	gacb->IFNum = NOTEPAD_INDEX_FIELD_NUM;
	gacb->FList = NotepadDBFList;
	gacb->fieldNum = NOTEPAD_FIELD_NUM;
	
	for( i = 0; i < RECORD_FIELD_LIST_LEN; i++)
		gacb->RFList[i] = 0;

	// 构建物理模式信息
	gacb->PLInfo->info.usedBlockTail = 0;
	gacb->PLInfo->info.freeBlockHead = 0;
	gacb->PLInfo->info.usedBlockNum = 0;
	gacb->PLInfo->info.freeBlockNum = 0;

	if( id != 0 )	// 判断记录是否为空
	{
		// 记录不为空
		DBRECORDHEAD	*head_info = NULL;
		BYTE	*record = NULL, *data, *field_value;
#ifdef SIM_ON_PC
		WORD	*field;
#else
		WORD	field;
#endif
		WORD	record_size = 0;
		DWORD	record_num = 0;
		DWORD	rv = DB_OK;

		// 逐条读取记录，建立字段索引表和记录字段表
		do
		{
			rv = GlobalReadRecord( gacb->PLInfo, id, &record );
			if( rv == DB_FREE_RECORD )	//空闲记录
				record = NULL;
			if( ( rv == DB_NO_MEM ) || ( rv == DB_ERROR ) )		
				return NULL;

			if( record == NULL )//空闲记录块
			{
				if( ( head_info = (DBRECORDHEAD *)SysLmalloc(sizeof(DBRECORDHEAD)) ) == NULL )
					return NULL;
				gacb->PLInfo->info.freeBlockHead = id;
				//初始化空闲块数目
				fseek( gacb->PLInfo->fp, id+ADDRESS_BYTE_NUM, SEEK_SET );
				fread( &record_size, SIZE_BYTE_NUM, 1, gacb->PLInfo->fp );
				record_num = (DWORD)( ( record_size + BLOCK_DATA_SIZE - 1 ) / BLOCK_DATA_SIZE );
				gacb->PLInfo->info.freeBlockNum += record_num;
				//初始化尾记录地址
				fseek( gacb->PLInfo->fp, id+ADDRESS_BYTE_NUM+SIZE_BYTE_NUM+FLAG_BYTE_NUM+NEXT_BYTE_NUM, SEEK_SET );
				fread( &head_info->prev, PREV_BYTE_NUM, 1, gacb->PLInfo->fp );
				gacb->PLInfo->info.usedBlockTail = head_info->prev;
				SysLfree( head_info );
				break;
			}else{	//有效记录块
				head_info = (DBRECORDHEAD *)record;

				record_size = head_info->size;
				record_num = (DWORD)( ( record_size + BLOCK_DATA_SIZE - 1 ) / BLOCK_DATA_SIZE );

				gacb->PLInfo->info.usedBlockTail = id;//初始化尾记录地址
				gacb->PLInfo->info.usedBlockNum += record_num;

				data = (BYTE *)(&head_info->data);
#ifdef SIM_ON_PC
				field = (WORD *)data;
#endif

				for( i = 0; i < gacb->IFNum; i++ )
				{
#ifdef SIM_ON_PC
					if( field[i] != 0 )	// 字段有字段值
					{
						field_value = data + field[i];
#else
					ByteReversal( &field, data+i*sizeof(WORD) );
					if( field != 0 )	// 字段有字段值
					{
						field_value = data + field;
#endif
						Add2FieldIndexTbl( gacb, i, field_value, id );// 将字段值加入到字段索引表	
					}
				}
				id = head_info->next;
				SysLfree( record );
			}
		}while( id != 0 );

	}
	return gacb;
}

/**********************************************************************/
DBLACB* LinkNotepadDB( DBGACB *gacb )
{
	return LinkDB( gacb );
}

/**********************************************************************/
void DetachNotepadDB( DBLACB *lacb )
{
	RECORDDATA		*prev_record_data, *next_record_data;

	next_record_data = lacb->head->head;
	while( ( next_record_data != NULL ) && ( lacb->head->num != 0 ) )
	{
		prev_record_data = next_record_data;
		next_record_data++;
		if( prev_record_data->data != NULL )
			SysLfree( prev_record_data->data );
		lacb->head->num--;
	}

	SysLfree( lacb->head->head );
	SysLfree( lacb->head );
	return;
}

/**********************************************************************/
BYTE* NotepadDBReadRecord( DBLACB *lacb, DWORD id )
{
	return ReadDBRecord( lacb, id );
}

/**********************************************************************/
DWORD NotepadDBModifyRecord( DBLACB *lacb, DWORD id, BYTE *data, WORD dataLen )
{	
	BYTE			i;
	BYTE			*field_value, *record;
#ifdef SIM_ON_PC
	WORD			*field;
#else
	WORD			field;
#endif
	DWORD			rv = DB_OK;

	//读出修改前的数据
	rv = GlobalReadRecord( lacb->gacb->PLInfo, id, &record );
	if( rv != DB_OK )
		return DB_ERROR;

	DelRecordIndexTbl( lacb, id );
	//填充修改后的数据
	id = AddModifiedRecordData( lacb->gacb->PLInfo, id, data, dataLen, record );
	if( id == DB_ERROR )
		return DB_ERROR;

	//把修改后的记录添加大字段索引表和记录字段索引表中
#ifdef SIM_ON_PC
	field = (WORD *)data;
#endif
			
	for( i = 0; i < lacb->gacb->IFNum; i++ )
	{
#ifdef SIM_ON_PC
		if( field[i] != 0 )	// 字段有字段值
		{
			field_value = data + field[i];
#else
		ByteReversal( &field, data+i*sizeof(WORD) );
		if( field != 0 )	// 字段有字段值
		{
			field_value = data + field;
#endif
			Add2FieldIndexTbl( lacb->gacb, i, field_value, id );// 将字段值加入到字段索引表	
		}
	}
	
	return id;
}

/**********************************************************************/
DWORD NotepadDBAddRecord( DBLACB *lacb, BYTE *data, WORD dataLen )
{
	BYTE			i;
	BYTE			*field_value;
#ifdef SIM_ON_PC
	WORD			*field;
#else
	WORD			field;
#endif
	DWORD			id = 0;

	//填充新添加的数据
	id = AddNewRecordData( lacb->gacb->PLInfo, data, dataLen );
	if( id == DB_ERROR )
		return DB_ERROR;
	
	//把修改后的记录添加大字段索引表和记录字段索引表中
#ifdef SIM_ON_PC
	field = (WORD *)data;
#endif
	
	for( i = 0; i < lacb->gacb->IFNum; i++ )
	{
#ifdef SIM_ON_PC
		if( field[i] != 0 )	// 字段有字段值
		{
			field_value = data + field[i];
#else
		ByteReversal( &field, data+i*sizeof(WORD) );
		if( field != 0 )	// 字段有字段值
		{
			field_value = data + field;
#endif
			Add2FieldIndexTbl( lacb->gacb, i, field_value, id );// 将字段值加入到字段索引表	
		}
	}
	
	return id;
}

/**********************************************************************/
DWORD NotepadDBDelRecord( DBLACB *lacb, DWORD id )
{
	id = GlobalDelRecord( lacb->gacb->PLInfo, id );			//在数据库中删除指定的记录
	if( ( id == DB_ERROR ) || ( id == DB_FREE_RECORD ) )
		return DB_ERROR;
		
	DelRecordIndexTbl( lacb, id );
		
	return id;
}

/**********************************************************************/
//在指定数据库中查找与指定字段匹配(完全匹配/部分匹配)的记录(精确查找)
LOCALSEARCHLIST* NotepadDBFindRecord( DBLACB *lacb, BYTE field, BYTE *data, BYTE mode )
{	
	FIELDINDEXLIST		*list;		//字段索引表	
	FIELDINDEX			*I_index_list, *II_index_list, *temp_I_index_list;	//一、二级索引表
	DBRECORDHEAD		*head_info;
	RECORDINDEX			*next_record_index; 
	RECORDINDEX			*local_search_list = NULL;
	RECORDDATA			*record_head, *record_data_head, *next_record_data;
	BYTE				PY_num = 0;
	BYTE				*record;	//记录数据
	BYTE				*record_data, *field_value, *tmp_field_value;
	WORD				i, j, count = 0;
#ifdef SIM_ON_PC
	WORD				*field_head;
#else
	WORD				field_head;
#endif
	WORD				field_I_index[PY_MAX_NUM], field_II_index[PY_MAX_NUM];//字段一二级索引值
	WORD				cmp_data_size;
	WORD				num = 0;
	DWORD				tmp_id;		//记录地址
	DWORD				read_rv = DB_OK;
	CHAR				rv;			//字段值比较结果

	//验证字段的有效性
	if( ( field < 0 ) || ( field >= NOTEPAD_INDEX_FIELD_NUM ) )
		return NULL;
	
	list = lacb->gacb->FList;
	I_index_list = list[field].head;//找到相符的一级字段索引表

	//申请局部查找表
	if( ( lacb->head = (LOCALSEARCHLIST *)SysLmalloc( sizeof(LOCALSEARCHLIST) ) ) == NULL )	
		return NULL;
	lacb->head->num = 0;
	lacb->head->head = NULL;
	
	//验证字段值的有效性
	if( data == NULL )
		return NULL;

	switch( field )	//获取关键字的一二级索引
	{
		case NOTEPAD_PARENT_FIELD:
			if( strlen(data) == 0 )	//根目录
			{
//				field_I_index = 0;
				field_I_index[0] = 0;
				num = list[field].num;
			}else{				//子目录
				*field_I_index = (WORD)(*data);
				num = 1;
			}
			I_index_list += ( *field_I_index );			//确定一级索引表
			if( I_index_list->num == 0 )