开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > 其他数据库 > 查看源码
Record.cpp
资源名称：minisqlc.rar　[点击查看]
上传用户：lkd6667
上传日期：2015-05-13
资源大小：1448k
文件大小：13k
源码类别：

其他数据库

开发平台：

C/C++

Record.cpp：源码内容
  1. #include"Buffer.h"
  2. #include"Glob_Var.h"
  3. #include"Record.h"
  4. #include <string.h>
  6. extern _M_Buffer Buffer;
  7. /////////////////////////////////////////////////////////////////////////////////////
  8. //构建　Record 
  9. Record::Record()
  10. {
  11. char address[256];  //存放文件地址
  12. strcpy(address,CurLocation);
  13.     strcat(address,CurRelationName);
  14.     strcat(address,".dbf");     //扩展名
  15. _M_File TargetF = Buffer[address];
  16. this->m_DbfFile=&TargetF;
  17.   this->m_DelList = (_F_DELLIST*)(TargetF.GetDelListCond().MemAddr());
  18. }
  20. ////////////////////////////////////////////////////////////////////////////////////
  21. //函数
  22. //插入一个TUPLE语句
  23. _F_FileAddr Record::Insert(Rec_Info& RecInfo)
  24. {
  25. //将Buffer指针指向当前文件
  26. char address[256];
  27. strcpy(address,CurLocation);
  28. strcat(address,CurRelationName);
  29. strcat(address,".dbf");
  30. _M_File targettb = Buffer[address];
  32. Cell_Info* temp = RecInfo.head;               //存改指向单个Column 的信息
  33. _F_FileAddr InsertPlace,TargetPlace;          //存放临时头信息
  34. if(this->m_DelList->DelFirst.uiOffset==0)     //Have no DelList 
  35. {
  36. TargetPlace=InsertPlace=this->m_DelList->NewInsert;  //取头地址
  37. this->m_DelList->NewInsert = MemWriteTest(RecInfo.RecordLength + sizeof(_F_FileAddr),&InsertPlace);
  38. }
  39. else if(this->m_DelList->DelFirst==this->m_DelList->DelLast)//Just have one tuple have being delete 
  40. {
  41. TargetPlace=InsertPlace=this->m_DelList->DelFirst;   //取头地址
  42. this->m_DelList->DelFirst.Initialize();              
  43. this->m_DelList->DelLast.Initialize();
  44. }
  45. else
  46. {
  47. TargetPlace=InsertPlace=this->m_DelList->DelFirst;   //取头地址
  48. this->m_DelList->DelFirst=*(_F_FileAddr*)(this->m_DelList->DelFirst.MemAddr());
  49. }
  50. //InsertPlace.Status='u';TargetPlace=InsertPlace;如果有遍历整个文件功能　
  51. InsertPlace = MemWrite((void*)&InsertPlace,sizeof(_F_FileAddr),&TargetPlace);//Write the head of one tuple
  52. //Write the cell information插入数据
  53. while(temp)                       
  54. {
  56. switch(temp->ColType)
  57.    {
  58. case  I:     //int 型数据  写信息
  59. InsertPlace = MemWrite((void*)&temp->value.IntValue,temp->ColLength,&InsertPlace);
  60. break;
  61.         case  F: //float 型数据  写信息
  62. InsertPlace = MemWrite((void*)&temp->value.FloatValue,temp->ColLength,&InsertPlace);
  63. break;
  64.         case  C: //char 型数据  写信息
  65. InsertPlace = MemWrite((void*)temp->value.pCharValue,temp->ColLength,&InsertPlace);
  66. break;
  67. }
  68. temp = temp->next;//到下一个Column
  69. }
  70. return TargetPlace;//返回地址合INDEXT
  71. }
  73. //删除一个tuple语句
  74. void Record::Delete(_F_FileAddr& DFAddr)
  75. {
  76. //将Buffer指针指向当前文件
  77. char address[256];
  78. strcpy(address,CurLocation);
  79. strcat(address,CurRelationName);
  80. strcat(address,".dbf");
  81. _M_File targettb = Buffer[address];
  83. _F_FileAddr * FPTemp;
  84. //DFAddr.Status='l';如果有遍历整个文件功能
  85. FPTemp = (_F_FileAddr*)DFAddr.MemAddr();//取得文件中的单语句头信息
  86. if(*FPTemp!= DFAddr )//信息与所要Delete的不一样
  87. {
  88. cout<<"Already deleted or Required record does not exsit.n";
  89. return;
  90. }
  91. _F_FileAddr ZPtr;
  92. ZPtr.Initialize();
  93. //ZPtr.Status='l';如果有遍历整个文件功能
  94. MemWrite(&ZPtr,sizeof(_F_FileAddr),FPTemp);//将被删除处的头信息写空
  95.     if(this->m_DelList->DelFirst.uiOffset==0)//如果Dellist为空
  96. {
  97. this->m_DelList->DelFirst=DFAddr;
  98. this->m_DelList->DelLast=DFAddr;  
  99. }
  100. else
  101. {//将当前删除语句的头信息写入前一删除语句的头地址以使删除空间链在一起
  102. MemWrite((void*)&DFAddr,sizeof(_F_FileAddr),&this->m_DelList->DelLast);
  103. this->m_DelList->DelLast = DFAddr;
  104. }
  105. }
  107. //查找一个TUPLE语句
  108. Rec_Info* Record::Select(_F_FileAddr& FAddr,Select_Rec_Info& SelRecInfo) const
  109. {
  110. //将Buffer指针指向当前文件
  111. char address[256];
  112. strcpy(address,CurLocation);
  113. strcat(address,CurRelationName);
  114. strcat(address,".dbf");
  115. _M_File targettb = Buffer[address];
  117.     Rec_Info* RPRecInfo = new class Rec_Info;//存放Select出来的信息
  118. TCell_Info* CPTemp =NULL;
  119. TCell_Info* CPTemp1= NULL;
  120. RPRecInfo->head=NULL;
  121. //向Rec_Info 写信息
  122. RPRecInfo->ColNum=SelRecInfo.ColumnNum;//所选Column（列数）number
  123. RPRecInfo->RecordLength=SelRecInfo.RecordLength;//所选记录长度
  124. Select_Cell* SPTemp=SelRecInfo.head;
  125. _F_FileAddr temp=*(_F_FileAddr*)FAddr.MemAddr();//取该语句存放地址
  126. if(temp!=FAddr)//与要选择的信息不一致，返回
  127. return 0;
  128.     temp.ShiftOffset(sizeof(_F_FileAddr));
  129. while(SPTemp)
  130. {
  131. CPTemp = new Cell_Info;
  132. if(SPTemp == SelRecInfo.head)//第一个Column要链到整条信息的头信息
  133.    RPRecInfo->head=CPTemp;
  134. else 
  135. {
  136.    CPTemp1->next = CPTemp;
  137. }
  138. //对Cell_Info符值
  139. CPTemp1=CPTemp;
  140. CPTemp->ColLength = SPTemp->ColLength;
  141. CPTemp->next = NULL;
  142. CPTemp->ColType = SPTemp->ColType;
  143. CPTemp->PriorLength = SPTemp->PriorLength;
  144. temp.ShiftOffset(SPTemp->PriorLength);//移动OFFSET指针到要读的数据位置
  145. //不同类数据的读取
  146. switch(SPTemp->ColType)
  147. {
  148. case I: CPTemp->value.IntValue = * (int*) temp.MemAddr();
  149.       break;
  150. case C: CPTemp->value.pCharValue = new char(SPTemp->ColLength+1);
  151.         strcpy(CPTemp->value.pCharValue,(char*)temp.MemAddr());
  152.   break;
  153. case F: CPTemp->value.FloatValue = * (float*) temp.MemAddr();
  154.   break;
  155. }
  156. temp.ShiftOffset( -SPTemp->PriorLength);//将OFFSET指返回初始值，以便下次便用
  157. SPTemp=SPTemp->next;
  158. }
  159. return RPRecInfo;
  161. }
  163. //更新数据
  164. void Record::Update(_F_FileAddr& UpdateFAddr,Rec_Info& UpdateInfo)
  165. {
  166. //将Buffer指针指向当前文件
  167. char address[256];
  168. strcpy(address,CurLocation);
  169. strcat(address,CurRelationName);
  170. strcat(address,".dbf");
  171. _M_File targettb = Buffer[address];
  173. Cell_Info* temp = UpdateInfo.head;
  174. _F_FileAddr UFATemp = UpdateFAddr;
  175. UFATemp.ShiftOffset(sizeof(_F_FileAddr));
  176. while(temp)                       //Write the cell information
  177. {
  178. UFATemp.ShiftOffset(temp->PriorLength);
  179. switch(temp->ColType)
  180.    {
  181. case  I:
  182. MemWrite((void*)&temp->value.IntValue,temp->ColLength,&UFATemp);
  183. break;
  184.         case  F: 
  185.     MemWrite((void*)&temp->value.FloatValue,temp->ColLength,&UFATemp);
  186. break;
  187.         case  C: 
  188. MemWrite((void*)temp->value.pCharValue,temp->ColLength,&UFATemp);
  189. break;
  190. }
  191. UFATemp.ShiftOffset(-temp->PriorLength);
  192. temp = temp->next;
  193. }
  194. }
  196. //打印头信息
  197. void Record::PrintHead(Select_Rec_Info& SelRecInfo) const
  198. {
  199. Select_Cell* SPTemp = SelRecInfo.head;
  200. int k = 0;
  201. cout.setf(ios::left,ios::adjustfield);//调整打印宽度
  202. for(k=0;k<SelRecInfo.RecordLength + SelRecInfo.ColumnNum*4;k++)
  203. cout<<"*";
  204. cout<<"*n* ";
  205. cout.width(SPTemp->ColLength +2);
  206.     cout<<SPTemp->ColumnName;
  207.     SPTemp = SPTemp->next;
  208.     while(SPTemp)
  209.     {
  210. cout<<"| ";
  211. cout.width(SPTemp->ColLength +2);//调整打印宽度
  212. cout<<SPTemp->ColumnName;//打印属性名
  213. SPTemp = SPTemp->next;
  214.     }
  215. cout<<"*n";
  216. }
  218. //打印所查到的记录（RECORD）
  219. void Record::Print(_F_FileAddr& pritarget,Select_Rec_Info& prilist) const
  220. {
  221.     Rec_Info* temp = this->Select(pritarget,prilist);//调用Select
  222. if(!temp)   throw 1030;
  223.     Cell_Info* node = temp->head;
  224. cout.setf(ios::left,ios::adjustfield);
  225. cout<<"*";
  226. for(int k=0;k<prilist.RecordLength + prilist.ColumnNum*4 -1;k++)
  227. cout<<"-";
  228. cout<<"*n* ";
  229.     while( node )//打印值　
  230.     {
  231.         switch( node->ColType )
  232.         {
  233.             
  234.             case I:
  235. if(node!=temp->head)
  236.     cout<<"| ";
  237. cout.width(node->ColLength+2);
  238.                 cout<<node->value.IntValue;
  239.                 break;
  240.             
  241.             case C:
  242. if(node!=temp->head)
  243.     cout<<"| ";
  244. cout.width(node->ColLength+2);
  245.                 cout<<node->value.pCharValue;
  246.                 break;
  247.             
  248.             case F:
  249. if(node!=temp->head)
  250.     cout<<"| ";
  251. cout.width(node->ColLength+2);
  252.                 cout<<node->value.FloatValue;
  253.                 break;
  254.         }
  255.         node = node->next;
  256.     }
  257. cout<<"*n";
  258. return;
  259. }
  261. //打印表末尾
  262. void Record::PrintEnd(Select_Rec_Info& SelRecInfo) const
  263. {
  264. cout.setf(ios::left,ios::adjustfield);
  265. for(int k=0;k<SelRecInfo.RecordLength + SelRecInfo.ColumnNum*4;k++)
  266. cout<<"*";
  267. cout<<"*n";
  268. }
  270. /*　　表的形式
  271. **********************************************************************
  272. *          |                |              |            |            *
  273. *--------------------------------------------------------------------*
  274. *          |                |              |            |            *
  275. **********************************************************************
  277. //下面是遍历整个文件的代码
  278. int Record::Print(Select_Rec_Info& prilist,Select_Cond_Info &SelCondInfo)
  279. {
  280. //将Buffer指针指向当前文件
  281. char address[256];
  282. strcpy(address,CurLocation);
  283. strcat(address,CurRelationName);
  284. strcat(address,".dbf");
  285. _M_File targettb = Buffer[address];
  287. _F_FileAddr *pFile;
  288. _F_FileAddr  FileAddr;
  289. int TotalLength=sizeof(_F_FileAddr)+SelCondInfo.RecordLength;//每条记录的总长度
  290. //所有页进行查找
  291. for(unsigned long i=0;i<targettb.GetPageTotal();i++)
  292. {
  293. //设置每页第一条语句的页数人ID和偏移地址以取得文件指针
  294. if(i==0)
  295. {
  296. //第一页包含了一个文件头信息和一个页头信息
  297. FileAddr.ShiftOffset(sizeof(_TB_FILECOND)+sizeof(_TB_PAGEHEAD));
  298. FileAddr.ulFilePageID=0;
  299. pFile =(_F_FileAddr*)FileAddr.MemAddr();
  300. }
  301. else 
  302. {//其它页只有一个页头信息
  303. FileAddr.ShiftOffset(sizeof(_TB_PAGEHEAD));
  304. FileAddr.ulFilePageID=i;
  305. pFile =(_F_FileAddr*) FileAddr.MemAddr();
  306. }
  307. //页内搜索，
  308. while((pFile->uiOffset+TotalLength)<FILE_PAGESIZE)//记录是否溢出，溢出则跳出循环
  309. {
  310. int IfCatch=0;//标记该语句是否为所要找的语句
  311. FileAddr = *pFile;
  312. if(pFile==&this->m_DelList->NewInsert)//到文件尾结整搜索
  313. return 1;
  314. pFile=(_F_FileAddr *)((char*)pFile+TotalLength);//指到下一语句地址
  315. if(FileAddr.Status=='l')//判断该语句是否已删除
  316. continue;
  317. TSelect_Cond_Cell* SCCT=SelCondInfo.head;//搜索条件
  318. Column_Value TempVal;//用于存放临时读取的数据　
  319. while(SCCT)//多条件循环
  320. {
  321. FileAddr.ShiftOffset(sizeof(_F_FileAddr)+SCCT->PriorLength);//文件指针移到要读取值的位置
  322. switch(SCCT->ColType)//类型判断
  323. {
  324. case I:TempVal.IntValue=*(int*)FileAddr.MemAddr();
  325. switch(SCCT->OperType)//操作符判断
  326. {
  327. case E:if((TempVal.IntValue-SCCT->ColSelValue.IntValue)==0)
  328.    IfCatch=1;
  329. else IfCatch=0;
  330. break;
  331. case B:if((TempVal.IntValue-SCCT->ColSelValue.IntValue)>0)
  332.    IfCatch=1;
  333. else IfCatch=0;
  334. break;
  335. case BE:
  336. if((TempVal.IntValue-SCCT->ColSelValue.IntValue)>=0)
  337.    IfCatch=1;
  338. else IfCatch=0;
  339. break;
  340. case L:if((TempVal.IntValue-SCCT->ColSelValue.IntValue)<0)
  341.    IfCatch=1;
  342. else IfCatch=0;
  343. break;
  344. case LE:if((TempVal.IntValue-SCCT->ColSelValue.IntValue)<=0)
  345.    IfCatch=1;
  346. else IfCatch=0;
  347. break;
  348.     //default
  349. }break;
  350. case F:TempVal.FloatValue=*(float*)FileAddr.MemAddr();
  351. switch(SCCT->OperType)//操作符判断
  352. {
  353. case E:if((TempVal.FloatValue-SCCT->ColSelValue.FloatValue)==0)
  354.    IfCatch=1;
  355. else IfCatch=0;
  356. break;
  357. case B:if((TempVal.FloatValue-SCCT->ColSelValue.FloatValue)>0)
  358.    IfCatch=1;
  359. else IfCatch=0;
  360. break;
  361. case BE:
  362. if((TempVal.FloatValue-SCCT->ColSelValue.FloatValue)>=0)
  363.    IfCatch=1;
  364. else IfCatch=0;
  365. break;
  366. case L:if((TempVal.FloatValue-SCCT->ColSelValue.FloatValue)<0)
  367.    IfCatch=1;
  368. else IfCatch=0;
  369. break;
  370. case LE:if((TempVal.FloatValue-SCCT->ColSelValue.FloatValue)<=0)
  371.    IfCatch=1;
  372. else IfCatch=0;
  373. break;
  374.     //default
  375. }break;
  376. case C:TempVal.pCharValue=(char*)FileAddr.MemAddr();
  377. switch(SCCT->OperType)//操作符判断
  378. {
  379. case E:
  380. if(strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==0)
  381.    IfCatch=1;
  382. else IfCatch=0;
  383. break;
  384. case B:
  385. if(strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==1)
  386.    IfCatch=1;
  387. else IfCatch=0;
  388. break;
  389. case BE:
  390. if((strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==0)||(strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==1))
  391.    IfCatch=1;
  392. else IfCatch=0;
  393. break;
  394. case L:
  395. if(strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==-1)
  396.    IfCatch=1;
  397. else IfCatch=0;
  398. break;
  399. case LE:
  400. if((strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==0)||(strcmp(TempVal.pCharValue,SCCT->ColSelValue.pCharValue)==-1))
  401.    IfCatch=1;
  402. else IfCatch=0;
  403. break;
  404.     //default
  405. }break;
  406. //default
  407. }
  408. FileAddr.ShiftOffset(-(sizeof(_F_FileAddr)+SCCT->PriorLength));//文件指针回复到初始状态　
  409. SCCT=SCCT->next;//下一个条件
  410. }
  411. if(IfCatch)//如果找到符合条件的语句
  412. {
  413. this->Print(FileAddr,prilist);
  414. }
  415. }
  416. }
  417. return 1;
  418. }
  422. */