schemedb.c

一个操作系统源代码 用于嵌入式设备 在Vc++环境下仿真 成功移植到多款处理器上

	if( ( mode != PRECISE_FULL_MATCH ) && ( mode != PRECISE_PART_MATCH ) && ( mode != GLOBAL_SEARCH ) )
		return NULL;

	//验证字段值的有效性
	if( data == NULL )
		return NULL;

	//申请局部查找表
	if( ( lacb->head = SysLmalloc( sizeof(LOCALSEARCHLIST) ) ) == NULL )	
		return NULL;
	lacb->head->num = 0;
	lacb->head->head = NULL;

	list = lacb->gacb->FList;
	I_index_list = list[field].head;//找到相符的一级字段索引表

	switch( field )	//获取关键字的一二级索引
	{
		case SCHEME_NAME_FIELD:	// 名称字段
			GetNameFieldIandIIIndex( data, field_I_index, field_II_index, &PY_num);	//将关键字转化为索引
			I_index_list += ( *field_I_index - 'a' );
			if( I_index_list->num == 0 )
			{
				goto endrv;
			}else{
				II_index_list = I_index_list->sub;
				II_index_list += ( *field_II_index );//确定二级索引表
			}
			break;
		case SCHEME_ALARM_TYPE_FIELD:	// 提醒方式(不提醒、开闹铃或提示窗)
		case SCHEME_TYPE_FIELD:			// 到期标志
		case SCHEME_ALARM_MODE_FIELD:	// 定期提醒模式(按月或按年等)
			*field_I_index = (WORD)(*data & 0x0f);
			I_index_list += ( *field_I_index );	//确定一级索引表
			break;
	}
			
	switch( field )	//得到查找的链表
	{
		case SCHEME_TIME_FIELD:	// 时间字段
			lacb->head = SearchTimeRange( lacb, data, I_index_list, SCHEME_TIME_FIELD );
			break;
		case SCHEME_NAME_FIELD:	// 名称字段
			if( II_index_list->num == 0 )	
				goto	endrv;
			
			read_rv = SearchPreciseRecord( II_index_list, lacb, field, data, mode );
			if( read_rv != DB_OK )
			{
				SysLfree( lacb->head );
				return NULL;
			}
			if( lacb->head->num != 0 )
			{
				if( ( record_data_head = (RECORDDATA *)SysLmalloc( sizeof(RECORDDATA) * lacb->head->num ) ) == NULL ) 
				{
					SysLfree( lacb->head );
					return NULL;
				}
				memcpy( record_data_head, lacb->head->head, ( sizeof(RECORDDATA) * lacb->head->num ) );
				SysLfree( lacb->head->head );
				lacb->head->head = record_data_head;
			}
			break;
		case SCHEME_ALARM_TYPE_FIELD:	// 提醒方式(不提醒、开闹铃或提示窗)
		case SCHEME_TYPE_FIELD:			// 到期标志
		case SCHEME_ALARM_MODE_FIELD:	// 定期提醒模式(按月或按年等)
			lacb->head->num = I_index_list->num;
			if( I_index_list->num != 0 )
				lacb->head->head = ObtainSearchList( lacb->gacb->PLInfo, I_index_list->next, lacb->head->num );
			break;
	}

	SchemeDBSortList( lacb, lacb->head, SCHEME_TIME_FIELD, 0 );
endrv:
	return ( lacb->head );
}
/**********************************************************************/
//在指定数据库中查找与指定字段索引匹配（完全匹配/部分匹配）的记录（模糊查找）
 LOCALSEARCHLIST* SchemeDBSortRecord( DBLACB *lacb, BYTE field, BYTE *data, BYTE reserved )
{
	return NULL;
}

/**********************************************************************/
//对指定列表进行排序
LOCALSEARCHLIST* SchemeDBSortList( DBLACB *lacb, LOCALSEARCHLIST *searchlist, BYTE field, BYTE reserved )
{
	WORD				i, count;
	CHAR				rv;			//字段值比较结果
	DBRECORDHEAD		*head_info, *tmp_head_info;
	BYTE				*record_data, *field_value, *tmp_data, *tmp_field_value;
#ifdef SIM_ON_PC
	WORD				*field_head, *tmp_field_head;
#else
	WORD				field_head, tmp_field_head;
#endif
	RECORDDATA			*next_record_data;

	//验证字段的有效性
	if( ( field != SCHEME_NAME_FIELD ) && ( field != SCHEME_TIME_FIELD) )
		return NULL;
	
	if(  searchlist->num != 0 )
	{
		count = searchlist->num;
		if( ( next_record_data = (RECORDDATA *)SysLmalloc(sizeof(RECORDDATA)) ) == NULL )
			return NULL;
		while( count != 1 )	//冒泡算法
		{
			for( i = 0; i < (WORD)( count - 1 ) ; i++ )
			{
				head_info = (DBRECORDHEAD *)( searchlist->head[i].data );
				record_data = (BYTE *)(&head_info->data);
#ifdef SIM_ON_PC
				field_head = (WORD *)record_data;
				if( field_head[field] != 0 )
					field_value = record_data + field_head[field];
#else
				Bytes2Word( &field_head, record_data+(field*sizeof(WORD)) );
				if( field_head != 0 )
					field_value = record_data + field_head;
#endif

				tmp_head_info = (DBRECORDHEAD *)( searchlist->head[i+1].data );
				tmp_data = (BYTE *)(&tmp_head_info->data);
#ifdef SIM_ON_PC
				tmp_field_head = (WORD *)tmp_data;
				if( tmp_field_head[field] != 0 )
					tmp_field_value =  tmp_data + tmp_field_head[field];
#else
				Bytes2Word( &tmp_field_head, tmp_data+(field*sizeof(WORD)) );
				if( tmp_field_head != 0 )
					tmp_field_value =  tmp_data + tmp_field_head;
#endif

				switch( field )
				{
					case SCHEME_NAME_FIELD:
						rv = CompareChar( field_value, tmp_field_value );
						break;
					case SCHEME_TIME_FIELD:
						rv = strcmp( field_value, tmp_field_value );
						break;
				}
//				if( ( ( rv > 0 ) && ( field == SCHEME_NAME_FIELD ) )	//名字按拼音和长度排列(大的放后面),交换;时间按新的放在后面
//				  || ( ( rv < 0 ) && ( field == SCHEME_TIME_FIELD ) ) )	
				if( rv > 0 )	//名字按拼音和长度排列(大的放后面),交换;时间按新的放在后面
				{
					//暂存前一个数据
					next_record_data->index = searchlist->head[i].index;
					next_record_data->data = searchlist->head[i].data;
					next_record_data->datalen = searchlist->head[i].datalen;

					//重新写入前一个数据
					searchlist->head[i].index = searchlist->head[i+1].index;
					searchlist->head[i].data = searchlist->head[i+1].data;
					searchlist->head[i].datalen = searchlist->head[i+1].datalen;

					//重新写入后一个数据
					searchlist->head[i+1].index = next_record_data->index;
					searchlist->head[i+1].data = next_record_data->data;
					searchlist->head[i+1].datalen = next_record_data->datalen;
				}
			}
			count--;
		}
		SysLfree(next_record_data);
	}
	return searchlist;
}

/*************** Local Functions ********************/
//初始化一级索引表
void InitIndexList( void )
{
	BYTE i;

	// 时间字段一级索引表
	for( i = 0; i < 12; i++ )
	{
		SchemeTimeField_I[i].next = NULL;
		SchemeTimeField_I[i].prev = NULL;
		SchemeTimeField_I[i].sub = NULL;
		SchemeTimeField_I[i].index = i;			// 0 to 11
		SchemeTimeField_I[i].num = 0;
	}

	// 姓名一级索引表   //	for( i = 0; i < 26; i++ )
	for( i = 0; i < 27; i++ )
	{
		SchemeNameField_I[i].next = NULL;
		SchemeNameField_I[i].prev = NULL;
		SchemeNameField_I[i].sub = NULL;
		SchemeNameField_I[i].index = (WORD)(97+i);	// 'a' to 'z'
		SchemeNameField_I[i].num = 0;
	}

	// 提醒方式索引表
	for( i = 0; i < 3; i++ )
	{
		SchemeAlarmTypeField[i].next = NULL;
		SchemeAlarmTypeField[i].prev = NULL;
		SchemeAlarmTypeField[i].sub = NULL;
		SchemeAlarmTypeField[i].index = i;		// 0 to 2
		SchemeAlarmTypeField[i].num = 0;
	}

	// 到期标志索引表
	for( i = 0; i < 2; i++ )
	{
		SchemeTypeField[i].next = NULL;
		SchemeTypeField[i].prev = NULL;
		SchemeTypeField[i].sub = NULL;
		SchemeTypeField[i].index = i;			// 0 to 1
		SchemeTypeField[i].num = 0;
	}

	// 定期提醒模式索引表
	for( i = 0; i < 10; i++ )
	{
		SchemeAlarmModeField[i].next = NULL;
		SchemeAlarmModeField[i].prev = NULL;
		SchemeAlarmModeField[i].sub = NULL;
		SchemeAlarmModeField[i].index = i;		// 0 to 9
		SchemeAlarmModeField[i].num = 0;
	}
}

/**********************************************************************/
// 将字段值加入到字段索引表	
DWORD Add2FieldIndexTbl( DBGACB *gacb, BYTE field, BYTE *value, DWORD id )
{
	FIELDINDEXLIST		*list;
	BYTE				*temp;		//指向字段的暂存指针
	BYTE				i;
	FIELDINDEX			*I_index_list, *II_index_list;	//一、二级索引表
	WORD				field_I_index[PY_MAX_NUM], field_II_index[PY_MAX_NUM];//字段一二级索引值
	RECORDINDEX			*new_record_head;	//新纪录的地址
	BYTE				PY_num = 0;		//存放汉字的多音字的个数

	if( value == NULL )
		return DB_ERROR;
	
	temp = value;
	list = gacb->FList;
	I_index_list = list[field].head;//链接一级索引表

	switch( field )
	{
		case SCHEME_TIME_FIELD:	// 时间字段
			GetTimeFieldIandIIIndex( temp, field_I_index, field_II_index );	//将字段值转化为索引
			
			I_index_list += ( *field_I_index );//确定一级索引表
			II_index_list = CreateIIIndexList( I_index_list, field );// 新建二级索引表
			II_index_list += ( *field_II_index );//确定二级索引表

			new_record_head = Add2RecordIndexTbl( II_index_list, id );
			Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
			break;
		case SCHEME_NAME_FIELD:	// 名称字段
			GetNameFieldIandIIIndex( temp, field_I_index, field_II_index, &PY_num);	//将字段值转化为索引
			for( i = 0; i <= PY_num; i++ )			//把单音字/多音字逐个添加到字段索引表中
			{
				I_index_list += ( field_I_index[i] - 'a' );
				II_index_list = CreateIIIndexList( I_index_list, field );// 新建姓名二级索引表
				II_index_list += ( field_II_index[i] );//确定二级索引表
				
				new_record_head = Add2RecordIndexTbl( II_index_list, id );
				Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
					 
				I_index_list = list[field].head;
//				field_I_index++;
//				field_II_index++;
			}
//			field_I_index -= (PY_num+1);
//			field_II_index -= (PY_num+1);
			break;
		case SCHEME_ALARM_TYPE_FIELD: // 提醒方式(不提醒、开闹铃或提示窗)
		case SCHEME_TYPE_FIELD: // 到期标志
		case SCHEME_ALARM_MODE_FIELD: // 定期提醒模式（按月或按年等）
			*field_I_index = (WORD)( *value & 0x0f );
			
			I_index_list += ( *field_I_index );//确定一级索引表

			new_record_head = Add2RecordIndexTbl( I_index_list, id );
			Add2RecordIndex( gacb->RFList, id, new_record_head );// 将字段索引加入到记录字段表
			break;
		default:
			break;
	}

	return DB_OK;
}

/**********************************************************************/
//创建新的二级索引表
FIELDINDEX *CreateIIIndexList( FIELDINDEX *I_index_list, BYTE field )
{
	BYTE			k;
	FIELDINDEX		*II_index_list;

	II_index_list = I_index_list->sub;		//链接二级索引表
	if( II_index_list == NULL )	 //二级索引表为空,则动态申请二级索引表
	{
		switch( field )
		{		
			case SCHEME_TIME_FIELD:	// 时间字段
				I_index_list->num = 31;				//更新一级索引表的索引数
				break;
			case SCHEME_NAME_FIELD:	// 名称字段
				I_index_list->num = 54;				//更新一级索引表的索引数
				break;
			default:
				return NULL;
		}

		if( ( II_index_list = (FIELDINDEX *)SysLmalloc( sizeof(FIELDINDEX) * ( I_index_list->num ) ) ) == NULL )
			return NULL;
		I_index_list->sub = II_index_list;	//链接二级索引表
		
		// 新建二级索引表
		for( k = 0; k < I_index_list->num; k++ )
		{
			II_index_list[k].next = NULL;		
			II_index_list[k].prev = NULL;
			II_index_list[k].sub = NULL;
			II_index_list[k].index = k;	
			II_index_list[k].num = 0;
		}
	}
	return ( II_index_list );
}