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

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

其他数据库

开发平台：

C/C++

Catalog.cpp：源码内容
  1. #include <iostream>
  2. #include <stdio.h>
  3. #include "Catalog.h"
  6. extern char CurLocation[256];//<---存有当前正在使用的表的相对路径
  7. extern char CurRelationName[33];//<---存当前表的表名
  8. extern _M_Buffer Buffer;
  9. extern unsigned int BTreeNodeSize;
  11. using namespace std;
  13. //找出给定列的位置
  14. Column_Info* HCatalog::Find_Column(char* Name) const
  15. {
  16. char temp[289];
  17. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  18. _M_File CurrentTable = Buffer[temp];
  20. _F_FileAddr head;
  21. head = CurrentTable.GetCataPoint();     //指向文件的头指针
  23. Table_Info* TableHead;
  24. TableHead = (Table_Info*)head.MemAddr(); //指向内存的头指针
  26. Column_Info* column;
  27. column = (Column_Info*)TableHead->KeyPtr.FileKey.MemAddr(); //内存中指向列的信息
  29. while (column != NULL)
  30. {
  31. if(strcmp(column->ColumnName,Name) == 0)
  32. return column;
  33. else
  34. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  35. }
  37. return NULL;
  38. }
  41. //判断列是否存在
  42. bool HCatalog::Exist_Column(char* Name) const
  43. {
  44. if(Find_Column(Name) == NULL)
  45. return false;
  46. else
  47. return true;
  48. } 
  51. //判断列的类型是否正确
  52. bool HCatalog::Check_Type(Column_Info* column, Column_Type type) const
  53. {
  54. if(column->ColType == type)
  55. return true;
  56. else
  57. return false;
  58. }
  61. //判断此列是否为主键
  62. bool HCatalog::Check_Key(Column_Info* column) const
  63. {
  64. if(column->IsPrimary == 1)
  65. return true;
  66. else
  67. return false;
  68. }
  71. //判断约束条件是否成立
  72. bool HCatalog::Check_Value(Column_Info* column,Column_Value* val) const
  73. {
  74. Column_Type ColType = column->ColType; 
  75. int integer;
  76. float fl;
  77. char* ch;
  78.     switch(ColType){
  79.     case I:       //int
  80.     integer = val->IntValue;
  81. break;
  82. case F:       //float
  83. fl = val->FloatValue;
  84. break;
  85. case C:       //char
  86. ch = val->pCharValue;
  87. break;
  88. default:
  89. throw 1010; //Error code 1010----错误的类型;
  90. }
  92. //此列上的约束条件
  93.     Constraint_Info* constraint = (Constraint_Info*)column->ConstraintPtr.FileConstraint.MemAddr(); 
  95. //没有约束
  96.     if(constraint == NULL)
  97. return true;
  98.     if(ColType == I)    
  99. switch(constraint->OperType){
  100. case L:   // <
  101. if(integer >= constraint->max.IntValue)
  102. return false;
  103. break;
  104. case LE:   // <=
  105. if(integer > constraint->max.IntValue)
  106. return false;
  107. break;
  108. case B:    // >
  109. if(integer <= constraint->min.IntValue)
  110. return false;
  111. break;
  112. case BE:   // >=
  113. if(integer < constraint->min.IntValue)
  114. return false;
  115. break;
  116. case E:    // =
  117. if(integer != constraint->max.IntValue)
  118. return false;
  119. break;
  120. case NE:   // !=
  121. if(integer == constraint->max.IntValue)
  122. return false;
  123. break;
  124. case BETWEEN:   // between...and...
  125. if((integer < constraint->min.IntValue) || (integer > constraint->max.IntValue))
  126. return false;
  127. break;
  128. default:
  129. throw 1009; //error code 1009----错误的关系运算符
  130. }
  132.        else if (ColType == F)
  133. switch(constraint->OperType){
  134. case L:   // >
  135. if(fl >= constraint->max.FloatValue)
  136. return false;
  137. break;
  138. case LE:   // >=
  139. if(fl > constraint->max.FloatValue)
  140. return false;
  141. break;
  142. case B:     // <
  143. if(fl <= constraint->min.FloatValue)
  144. return false;
  145. break;
  146. case BE:    // <=
  147. if(fl < constraint->min.FloatValue)
  148. return false;
  149. break;
  150. case E:     // ==
  151. if(fl != constraint->max.FloatValue)
  152. return false;
  153. break;
  154. case NE:    // !=
  155. if(fl == constraint->max.FloatValue)
  156. return false;
  157. break;
  158. case BETWEEN:   // between...and...
  159. if((fl < constraint->min.FloatValue) || (fl > constraint->max.FloatValue))
  160. return false;
  161. break;
  162. default:
  163. throw 1009; //error code 1009----错误的关系运算符
  164. }
  166.       else{ 
  167. if(strlen(ch) > column->RequiredLength)
  168. throw 1013; //Error1013: 长度不符合
  169. switch(constraint->OperType){
  170. case L:   // >
  171. if(strcmp(ch,constraint->max.CharValue) >= 0)
  172. return false;
  173. break;
  174. case LE:  // >=
  175. if(strcmp(ch,constraint->max.CharValue) > 0)
  176. return false;
  177. break;
  178. case B:   // <
  179. if(strcmp(ch,constraint->min.CharValue) <= 0)
  180. return false;
  181. break;
  182. case BE:   // <=
  183. if(strcmp(ch,constraint->min.CharValue) < 0)
  184. return false;
  185. break;
  186. case E:   // ==
  187. if(strcmp(ch,constraint->max.CharValue) != 0)
  188. return false;
  189. break;
  190. case NE:  // !=
  191. if(strcmp(ch,constraint->max.CharValue) == 0)
  192. return false;
  193. break;
  194. case BETWEEN:   // between...and...
  195. if((strcmp(ch,constraint->min.CharValue) < 0) || (strcmp(ch,constraint->max.CharValue)) > 0)
  196. return false;
  197. break;
  198. default:
  199. throw 1009; //error code 1009-----错误的关系运算符
  200. }
  201. }
  203. return true;
  204. }
  206. //检查char的长度是否合法
  207. bool HCatalog::Check_Length(Column_Info* column, Column_Value* val) const
  208. {
  209. if((column->ColType==C) && (strlen(val->pCharValue) > column->RequiredLength))
  210. return false;
  211. else 
  212. return true;
  213. }
  216. //检查键是否合法
  217. bool HCatalog::Check_Key_Validation(Column_Type ColType, Column_Value* max, Column_Value* min) const
  218. {
  219.   switch(ColType){
  220.   case I:  
  221.     if(max->IntValue < min->IntValue)
  222.       return false;
  223.     else 
  224.       return true;
  225.   case F:   
  226.     if(max->FloatValue < min->FloatValue)
  227.       return false;
  228.     else 
  229.       return true;
  230.   case C:   
  231.     if(strcmp(max->pCharValue,min->pCharValue) < 0)
  232.       return false;
  233.     else
  234.       return true;
  235.   default:
  236.     throw 1010;   //Error1010: 错误的数据类型
  237.   }
  238. }
  241. //表的信息
  242. TTable_Info::TTable_Info()
  243. {
  244. KeyPtr.FileKey.Initialize();
  245. KeyPtr.Key = NULL;
  246. strcpy(TableName,"");
  247. TotalColumn = 0;
  248. RecordLength = 0;
  249. KeyAttrNum = 0;
  250. }
  253. //生成链表节点
  254. Column_Info* HCatalog::Form_ListNode(Create_Column* ptr,int id) const
  255. {
  256. Column_Info* pcolumn = new Column_Info;
  257. Constraint_Info* constraint;
  258. pcolumn->ID = id;
  259. strcpy(pcolumn->ColumnName,ptr->ColumnName);
  260. pcolumn->ColType = ptr->ColType;
  261. pcolumn->IsPrimary = ptr->IsPrimary;
  262. pcolumn->ColumnPtr.next = NULL;
  263. if(ptr->IsPrimary == true)
  264. pcolumn->IsNull = 0;
  265. else if (ptr->IsNull == true)
  266. pcolumn->IsNull = 1;
  267. else if (ptr->IsNull == false)
  268. pcolumn->IsNull = 0;
  269. switch(pcolumn->ColType){
  270. case I:   
  271. pcolumn->RequiredLength = sizeof(int);
  272. pcolumn->StoredLength = pcolumn->RequiredLength;
  273. break;
  274. case F:   
  275. pcolumn->RequiredLength = sizeof(float);
  276. pcolumn->StoredLength = pcolumn->RequiredLength;
  277. break;
  278. case C:   
  279. pcolumn->RequiredLength = ptr->length;
  280. pcolumn->StoredLength = pcolumn->RequiredLength+1;
  281. break;
  282. default:
  283. throw 1010; //error 1010: 错误的数据类型
  284. }
  286. //是否有约束
  287. bool flag=false;
  288. if((ptr->ColType==I) && (ptr->min.IntValue<=ptr->max.IntValue))
  289. flag=true;
  290. else if((ptr->ColType==F) && (ptr->min.FloatValue<=ptr->max.FloatValue))
  291. flag=true;
  292. else if((ptr->ColType==C) && (strcmp(ptr->min.pCharValue,ptr->max.pCharValue)<=0))
  293. flag=true;
  295. if(flag){ //有约束，连接入节点
  296. constraint = new Constraint_Info;
  297. constraint->OperType = ptr->OperType;
  298. switch(pcolumn->ColType){
  299. case I:
  300. constraint->min.IntValue = ptr->min.IntValue;
  301. constraint->max.IntValue = ptr->max.IntValue;
  302. break;
  303. case F:
  304. constraint->min.FloatValue = ptr->min.FloatValue;
  305. constraint->max.FloatValue = ptr->max.FloatValue;
  306. break;
  307. case C:
  308. strcpy(constraint->min.CharValue, ptr->min.pCharValue);
  309. strcpy(constraint->max.CharValue, ptr->max.pCharValue);
  310. break;
  311. }
  312. pcolumn->ConstraintPtr.constraint = constraint;
  313. }
  314. else //没约束，指针设为空
  315. pcolumn->ConstraintPtr.constraint = NULL;
  317. return pcolumn;
  318. }
  321. //创建
  322. void HCatalog::Create(TB_Create_Info& info, char* KeyInfo)
  323. {
  324. Create_Column* ptr;
  325. ptr = info.head;
  326. Table_Info TableNode;
  327. strcpy(TableNode.TableName,info.TableName);
  328. TableNode.TotalColumn = info.TotalColumn;
  330. Column_Info* column1;
  331. Column_Info* head;
  332. Column_Info* column2;
  333. int count=0; //主键数
  334. int length=0; //记录长度
  335. int j=0;
  336.     int keylen=0;
  337. for(int i=0 ;ptr!=NULL ;ptr=ptr->next,i++){
  338. column1 = this->Form_ListNode(ptr,i);   
  339. length += column1->StoredLength;        
  340. if(column1->IsPrimary == 1){
  341. count++;      
  342. keylen += column1->StoredLength;  
  343.             if(column1->ColType == C)
  344. j += sprintf(KeyInfo+j,"c%d",column1->RequiredLength);
  345. else if(column1->ColType == F)
  346. j += sprintf(KeyInfo+j,"f");
  347. else 
  348. j += sprintf(KeyInfo+j,"i");
  349. }
  350. if(i == 0)
  351. head = column1;
  352. else
  353. column2->ColumnPtr.next = column1;
  354. column2 = column1;
  355. }
  356.     if(( BTreeNodeSize - 2*sizeof(_F_FileAddr) - sizeof(bool) - sizeof(int) ) 
  357.                        / ( sizeof(_F_FileAddr) + keylen) < 4)
  358.                        throw 1034;      //Error 1034: Primary Key is too long!
  359. TableNode.KeyPtr.Key = head;
  360. TableNode.KeyAttrNum = count;
  361. TableNode.RecordLength = length;
  363.     //定位到当前表
  364. char temp[289];
  365. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  366. _M_File CurrentTable = Buffer[temp];
  368. //写入文件
  369. _F_FileAddr pFile,pFile1,pFile2;
  371. pFile = CurrentTable.GetCataPoint();
  373. pFile1 = MemWrite((void*)&TableNode,sizeof(Table_Info),&pFile);
  375. column1 = head;
  377. if(column1 != NULL){
  378. ((Table_Info*)pFile.MemAddr())->KeyPtr.FileKey = pFile1; //移动文件指针
  379. pFile = MemWrite((void*)column1,sizeof(Column_Info),&pFile1);
  380. ((Column_Info*)pFile1.MemAddr())->ColumnPtr.FileNext.Initialize();
  381. pFile2 = pFile1;
  382. if(column1->ConstraintPtr.constraint != NULL){
  383. ((Column_Info*)pFile1.MemAddr())->ConstraintPtr.FileConstraint = pFile;
  384. pFile1 = MemWrite((void*)column1->ConstraintPtr.constraint,sizeof(Constraint_Info),&pFile);
  385. }
  386. else{
  387. ((Column_Info*)pFile1.MemAddr())->ConstraintPtr.FileConstraint.Initialize();
  388. pFile1 = pFile;   //记录上次的写入点 
  389. }
  390. column1 = column1->ColumnPtr.next;
  391. }
  392. while(column1 != NULL){
  393. ((Column_Info*)pFile2.MemAddr())->ColumnPtr.FileNext = pFile1;
  394. pFile = MemWrite((void*)column1,sizeof(Column_Info),&pFile1);
  395. ((Column_Info*)pFile1.MemAddr())->ColumnPtr.FileNext.Initialize();
  396. pFile2 = pFile1;
  397. if(column1->ConstraintPtr.constraint != NULL){
  398. ((Column_Info*)pFile1.MemAddr())->ConstraintPtr.FileConstraint = pFile;
  399. pFile1 = MemWrite((void*)column1->ConstraintPtr.constraint,sizeof(Constraint_Info),&pFile);
  400.     }
  401. else{
  402. ((Column_Info*)pFile1.MemAddr())->ConstraintPtr.FileConstraint.Initialize();
  403. pFile1 = pFile;   
  404. }
  405. column1 = column1->ColumnPtr.next;
  406. }
  408. //删除列表
  409. column1 = head;
  410. column2 = column1->ColumnPtr.next;
  411. while(column1 != NULL){
  412. if(column1->ConstraintPtr.constraint != NULL)
  413. delete column1->ConstraintPtr.constraint;
  414. delete column1;
  415. column1 = column2;
  416. if(column1 != NULL)
  417. column2 = column1->ColumnPtr.next;
  418. }
  419. return;
  420. }
  422. //选择
  423. void HCatalog::Select(TB_Select_Info& info,Condition_Info& index,Select_Rec_Info& record)
  424. {
  426.     char temp[289];
  427. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  428. _M_File CurrentTable = Buffer[temp];
  430. Select_Column* pcolumn = info.ColumnHead;
  431. Select_Condition* pcondition = info.ConditionHead;
  433. //检查约束条件列是否存在
  434.     Column_Info* column;
  435. int l=0;   
  436. if(strcmp(pcolumn->ColumnName,"*") != 0){
  437.         for(; pcolumn!=NULL; pcolumn=pcolumn->next){
  438. if(!this->Exist_Column(pcolumn->ColumnName))
  439. throw 1008; //Error1008: Column demanded has not existed yet!  
  440.             column = this->Find_Column(pcolumn->ColumnName);
  441.             l += column->StoredLength;
  442.         }
  443.     }
  444.     _F_FileAddr pFile = CurrentTable.GetCataPoint();
  445. Table_Info* TbInfo = (Table_Info*)pFile.MemAddr();
  446.     if((info.ConditionNum!=0) && (TbInfo->KeyAttrNum!=info.ConditionNum))
  447. throw 1019; //Error1019: Information Inadequate for selection(Every attribute should be included)!
  448. for(; pcondition!=NULL; pcondition=pcondition->next){
  449. column = this->Find_Column(pcondition->PrimaryKey); //find the demanded column
  450. if(column == NULL)
  451. throw 1007; //Error1007: Primary Key demanded has not existed yet!
  452. if(!this->Check_Key(column))
  453. throw 1011; //Error1011: Not a select based on primary key!
  454. if(!this->Check_Type(column,pcondition->ColType))
  455. throw 1012; //Error1012: Type mismatch!
  456.         if(pcondition->OperType == BETWEEN){
  457.             if(!Check_Key_Validation(pcondition->ColType,&(pcondition->max),&(pcondition->min)))
  458.                 throw 1020;       //Error1020: Result is null!
  459.         }
  460.         if(pcondition->ColType == C){
  461. switch(pcondition->OperType){
  462. case L:
  463. case LE:
  464. if(!Check_Length(column,&(pcondition->max)))
  465. throw 1013; //Error1013: Length Invalid for type char!
  466. else 
  467. break;
  468. case B:
  469. case BE:
  470. if(!Check_Length(column,&(pcondition->min)))
  471. throw 1013; //Error1013: Length Invalid for type char!
  472. else
  473. break;
  474. case BETWEEN:
  475. case E:
  476. case NE:
  477. if(!Check_Length(column,&(pcondition->max)) || !Check_Length(column,&(pcondition->min)))
  478. throw 1013; //Error1013: Length Invalid for type char!
  479. else 
  480. break;
  481. default:
  482. throw 1009; //Error1009: Unknown relation operator!
  483. }
  484. }
  485. }
  486. Column_Info* head;
  487. head = (Column_Info*)TbInfo->KeyPtr.FileKey.MemAddr();
  488. column = head;
  489. pKey_Attr pkey1,pkey2,pminkey,pmaxkey,pkey3,pkey4;
  490. pminkey = new Key_Attr;
  491. pkey1 = pminkey;  
  492. pkey3 = pkey1;    
  493. pmaxkey = new Key_Attr;
  494. pkey2 = pmaxkey; 
  495. pkey4 = pkey2;    
  496. int count = TbInfo->KeyAttrNum;
  497.     if(info.ConditionHead != NULL){
  498.       while((column!=NULL) && (count!=0)){
  499.         if(column->IsPrimary == 1){
  500. //找寻选择条件
  501.             for(pcondition = info.ConditionHead; pcondition!=NULL; pcondition=pcondition->next){
  502.                 if(strcmp(pcondition->PrimaryKey,column->ColumnName)==0){  
  503. switch (pcondition->ColType){
  504. case I:
  505. pkey1->value.IntValue = pcondition->min.IntValue;
  506. pkey2->value.IntValue = pcondition->max.IntValue;
  507. break;
  508. case F:
  509. pkey1->value.FloatValue = pcondition->min.FloatValue;
  510. pkey2->value.FloatValue = pcondition->max.FloatValue;
  511. break;
  512. case C:
  513. pkey1->value.pCharValue = pcondition->min.pCharValue;
  514. pkey2->value.pCharValue = pcondition->max.pCharValue;
  515. break;
  516. default:
  517. throw 1010; //Error1010: 错误的数据类型
  518. }
  519. break;
  520. }
  521. }
  523. pkey3 = pkey1;  
  524. pkey4 = pkey2;  
  525. pkey1->next = new Key_Attr; 
  526. pkey1 = pkey1->next;   
  527. pkey2->next = new Key_Attr; 
  528. pkey2 = pkey2->next;   
  529. count--;  
  530. }
  532. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  533. }
  534.   
  535. pkey3->next = NULL;
  536. pkey4->next = NULL;
  537. delete pkey1;
  538. delete pkey2;
  540. index.max = pmaxkey;
  541. index.min = pminkey;
  542.     index.OperType = info.ConditionHead->OperType;
  543.   }
  544.   
  545.   else{
  546.     index.max = NULL;
  547.     index.min = NULL;
  548.     index.OperType = ALL;
  549.   }
  552. //为record准备的数据
  553. Select_Cell* cell = new Select_Cell;
  554. Select_Cell* cell1 = cell;
  555. record.head = cell;
  556. pcolumn = info.ColumnHead;
  557. column = head;
  558. int len=0;    
  559.     if(strcmp(pcolumn->ColumnName,"*")!=0){
  560.         while(pcolumn != NULL){
  561. for(column = head; column!=NULL; len+=column->StoredLength,column=(Column_Info*)column->ColumnPtr.FileNext.MemAddr()){
  562. if(strcmp(pcolumn->ColumnName,column->ColumnName)==0){
  563. strcpy(cell->ColumnName,column->ColumnName);
  564. cell->ColType = column->ColType;
  565. cell->ColLength = column->StoredLength;
  566. cell->PriorLength = len;
  567. if(pcolumn->next != NULL){
  568. cell1 = cell;
  569. cell->next = new Select_Cell;
  570. cell = cell->next;
  571. }
  572. break;
  573. }
  574. }
  575. pcolumn = pcolumn->next;
  576. len = 0;
  577. }
  579. record.ColumnNum = info.ColumnNum;
  580.         record.RecordLength = l;
  581. }
  582.     else{
  583. while(column!=NULL){
  584. strcpy(cell->ColumnName,column->ColumnName);
  585. cell->ColType = column->ColType;
  586. cell->ColLength = column->StoredLength;
  587. cell->PriorLength = len;
  588. len += column->StoredLength;
  589. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  590. if(column!=NULL){
  591. cell->next = new Select_Cell;
  592. cell = cell->next;
  593. }
  594. }
  595. record.ColumnNum = TbInfo->TotalColumn;
  596.         record.RecordLength = TbInfo->RecordLength;
  597. }
  599. return;
  600. }
  602. //插入
  603. void HCatalog::Insert(TB_Insert_Info& info, Key_Attr& index, Rec_Info& record)
  604. {
  605.     char temp[289];
  606. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  607. _M_File CurrentTable = Buffer[temp];
  609. Insert_Column *raw;
  610. raw = info.head;
  612. Column_Info* column = NULL;
  613. Column_Info* head;
  614. Table_Info* table;
  615. table = (Table_Info*)CurrentTable.GetCataPoint().MemAddr();
  616. head = (Column_Info*)table->KeyPtr.FileKey.MemAddr();
  617. int count=0;
  618. //检查插入的信息
  619.     while (raw != NULL){
  620.         if(strcmp(raw->ColumnName,"*") != 0){
  621. if(!Exist_Column(raw->ColumnName))
  622. throw 1008; //Error1008: Column demanded has not existed yet!
  623. column = this->Find_Column(raw->ColumnName);
  624. if(Check_Key(column))
  625. count++;
  626. } 
  627.         else{
  628. if(column == NULL)
  629. column = head;
  630. else
  631. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  632. }
  633. if(!Check_Type(column,raw->ColType))
  634. throw 1012; //Error1012: Type mismatch!
  635. if(!Check_Length(column,&(raw->value)))
  636. throw 1013; //Error1013: Length Invalid for type char!
  637. if(!Check_Value(column,&(raw->value)))
  638. throw 1014; //Error1014: Invalid Value!
  639. raw = raw->next;
  640. }
  642. raw = info.head;
  643. if(strcmp(raw->ColumnName,"*") != 0){
  644. if(count != table->KeyAttrNum)
  645. throw 1015; //Error1015: Value of Primary Key can not be null!
  646. }
  647. else{
  648. if(info.ColumnNum != table->TotalColumn)
  649. throw 1016; //Error1016: Inadequate value for every column! 
  650. count = table->KeyAttrNum;
  651. }
  653. column = head;
  654.     if(strcmp(info.head->ColumnName,"*") != 0){
  655. while(column != NULL){
  656. if(column->IsNull == 0){
  657. for(raw=info.head; raw!=NULL; raw=raw->next)
  658. if(strcmp(raw->ColumnName,column->ColumnName) == 0)
  659. break;
  660. if(raw == NULL)
  661. throw 1017; //Error1017: No value for some not null column!
  662. }
  663. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  664. }
  665. }
  667. //为index insertion 的信息
  668. Key_Attr* key = &index;
  669. column = head;
  670. raw = info.head;
  671. while(count!=0 && column!=NULL){
  672.         if(strcmp(info.head->ColumnName,"*") != 0){
  673.             if(column->IsPrimary == 0){   
  674. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  675. continue;
  676. }
  677. for(raw=info.head; raw!=NULL; raw=raw->next){
  678.                 if(strcmp(raw->ColumnName,column->ColumnName)==0){
  679. switch(column->ColType){
  680. case I:
  681. key->value.IntValue = raw->value.IntValue;
  682. break;
  683. case F:
  684. key->value.FloatValue = raw->value.FloatValue;
  685. break;
  686. case C:
  687. key->value.pCharValue = raw->value.pCharValue;
  688. break;
  689. default:
  690. throw 1010; //Error1010: 错误的数据类型
  691. }
  692. count--;
  693. break;
  694. }
  695. }
  696. }
  697. //i插入所有列
  698.         else{
  699.             if(column->IsPrimary == 0){
  700. raw = raw->next;
  701. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  702. continue;
  703. }
  704. switch(column->ColType){
  705. case I:
  706. key->value.IntValue = raw->value.IntValue;
  707. break;
  708. case F:
  709. key->value.FloatValue = raw->value.FloatValue;
  710. break;
  711. case C:
  712. key->value.pCharValue = raw->value.pCharValue;
  713. break;
  714. default:
  715. throw 1010; //Error1010: 错误的数据类型
  716. }
  717. count--;
  718. raw = raw->next;
  719. }
  720. if(count!=0){
  721. key->next = new Key_Attr;
  722. key = key->next;
  723. }
  724. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  725. }
  727. //为 record insert的信息
  728. Cell_Info* cell = new Cell_Info;
  729. record.ColNum = table->TotalColumn;
  730. record.head = cell;
  731.     record.RecordLength = table->RecordLength;
  732. column = head;
  733. raw = info.head;
  734. int len=0;  
  735. if(strcmp(info.head->ColumnName,"*") == 0){
  736. while(column != NULL){
  737. cell->ColLength = column->StoredLength;
  738. cell->ColType = column->ColType;
  739. cell->PriorLength = len;
  740. switch(column->ColType){
  741. case I:
  742. cell->value.IntValue = raw->value.IntValue;
  743. break;
  744. case F:
  745. cell->value.FloatValue = raw->value.FloatValue;
  746. break;
  747. case C:
  748. cell->value.pCharValue = raw->value.pCharValue;
  749. break;
  750. default:
  751. throw 1010; //Error1010: 错误的数据类型
  752. }
  753. len += column->StoredLength;
  754. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  755. raw = raw->next;
  756. if(column != NULL){
  757. cell->next = new Cell_Info;
  758. cell = cell->next;
  759. }
  760. }
  761. }
  763. else{
  764. column = head;
  765. len = 0;
  766. while(column!=NULL){
  767. raw = info.head;
  768. while(raw != NULL){
  769. if(strcmp(raw->ColumnName,column->ColumnName) == 0){
  770. cell->ColLength = column->StoredLength;
  771. cell->ColType = column->ColType;
  772. cell->PriorLength = len;
  773. switch(column->ColType){
  774. case I:
  775. cell->value.IntValue = raw->value.IntValue;
  776. break;
  777. case F:
  778. cell->value.FloatValue = raw->value.FloatValue;
  779. break;
  780. case C:
  781. cell->value.pCharValue = raw->value.pCharValue;
  782. break;
  783. default:
  784. throw 1010; //Error1010: 错误的数据类型
  785. }
  786. break;
  787. }
  788. raw = raw->next;
  789. }
  790. if(raw == NULL){
  791. cell->ColLength = column->StoredLength;
  792. cell->ColType = column->ColType;
  793. cell->PriorLength = len;
  794. switch(column->ColType){
  795. case I:
  796. cell->value.IntValue = 0;
  797. break;
  798. case F:
  799. cell->value.FloatValue = 0.0;
  800. break;
  801. case C:
  802. cell->value.pCharValue = NULL;
  803. break;
  804. default:
  805. throw 1010; //Error1010: 错误的数据类型
  806. }
  807. }
  808. len += column->StoredLength;
  809. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  811. if(column != NULL){
  812. cell->next = new Cell_Info;
  813. cell = cell->next;
  814. }
  815. }
  816. }
  818. return;
  819. }
  822. //更新
  823. void HCatalog::Update(TB_Update_Info& info, Condition_Info& index, Rec_Info& record)
  824. {
  825.     char temp[289];
  826. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  827. _M_File CurrentTable = Buffer[temp];
  829. Update_Column* col;
  830. Update_Condition* cond;
  831. col = info.ColumnHead;
  832. cond = info.ConditionHead;
  833. cout<<"text1";
  834. Column_Info* column;
  835. while(col != NULL){
  836. if(!Exist_Column(col->ColumnName))
  837. throw 1008; //Error1008: Column demanded has not existed yet!
  838. column = Find_Column(col->ColumnName);
  839. if(column->IsPrimary == 1)
  840. throw 1018; //Error1018: Update denied on primary key!
  841. if(!Check_Type(column,col->ColType))
  842. throw 1012; //Error1012: Type mismatch!
  843. if(col->ColType == C)
  844. if(!Check_Length(column,&col->value))
  845. throw 1013; //Error1013: Length Invalid for type char!
  846. if(!Check_Value(column,&col->value))
  847. throw 1014; //Error1014: Invalid Value!
  848. col = col->next;
  849. }
  850. cout<<"text1";
  851. Table_Info* table;
  852. table = (Table_Info*)CurrentTable.GetCataPoint().MemAddr();
  853. if(info.ConditionNum != table->KeyAttrNum)
  854. throw 1019; //Error1019: Information Inadequate for selection(Every attribute should be included)!
  855. for(; cond!=NULL; cond=cond->next){
  856. column = this->Find_Column(cond->PrimaryKey);
  857. if(column == NULL)
  858. throw 1007; //Error1007: Primary Key demanded has not existed yet!
  859. if(!this->Check_Key(column))
  860. throw 1011; //Error1011: Not a select based on primary key!
  861. if(!this->Check_Type(column,cond->ColType))
  862. throw 1012; //Error1012: Type mismatch!
  863.     if(cond->OperType == BETWEEN){
  864.       if(!Check_Key_Validation(cond->ColType,&(cond->max),&(cond->min)))
  865.         throw 1020;       //Error1020: Result is null!
  866.     }
  867. if(cond->ColType == C){ //check if the length is correct if the column is char type
  868. switch(cond->OperType){
  869. case L:
  870. case LE:
  871. if(!Check_Length(column,&(cond->max)))
  872. throw 1013; //Error1013: Length Invalid for type char!
  873. else 
  874. break;
  875. case B:
  876. case BE:
  877. if(!Check_Length(column,&(cond->min)))
  878. throw 1013; //Error1013: Length Invalid for type char!
  879. else
  880. break;
  881. case E:
  882. case NE:
  883. case BETWEEN:
  884. if(!Check_Length(column,&(cond->max)) || !Check_Length(column,&(cond->min)))
  885. throw 1013; //Error1013: Length Invalid for type char!
  886. else 
  887. break;
  888. default:
  889. throw 1009; //Error1009: Unknown relation operator!
  890. }
  891. }
  892. }
  893. cout<<"text1";
  894. //为 index select的信息
  895. Column_Info* head; 
  896. head = (Column_Info*)table->KeyPtr.FileKey.MemAddr();
  897. column = head;
  898. int count = table->KeyAttrNum;
  899. pKey_Attr pkey1,pkey2,pminkey,pmaxkey,pkey3,pkey4;
  900. pminkey = new Key_Attr;
  901. pkey1 = pminkey;  
  902. pkey3 = pkey1;   
  903. pmaxkey = new Key_Attr;
  904. pkey2 = pmaxkey;  
  905. pkey4 = pkey2;    
  906.     while((column!=NULL) && (count!=0)){
  907.         if(column->IsPrimary == 1){
  908.             for(cond = info.ConditionHead; cond!=NULL; cond=cond->next){
  909. if(strcmp(cond->PrimaryKey,column->ColumnName)==0){  
  910. switch (cond->ColType){
  911. case I:
  912. pkey1->value.IntValue = cond->min.IntValue;
  913. pkey2->value.IntValue = cond->max.IntValue;
  914. break;
  915. case F:
  916. pkey1->value.FloatValue = cond->min.FloatValue;
  917. pkey2->value.FloatValue = cond->max.FloatValue;
  918. break;
  919. case C:
  920. pkey1->value.pCharValue = cond->min.pCharValue;
  921. pkey2->value.pCharValue = cond->max.pCharValue;
  922. break;
  923. default:
  924. throw 1010; //Error1010: 错误的数据类型
  925. }
  926. break;
  927. }
  928. }
  930. if(cond==NULL)
  931. switch(column->ColType){
  932. case I:
  933. pkey1->value.IntValue = 1;
  934. pkey2->value.IntValue = 0;
  935. break;
  936. case F:
  937. pkey1->value.FloatValue = 1.0;
  938. pkey2->value.FloatValue = 0.0;
  939. break;
  940. case C:
  941. strcpy(pkey1->value.pCharValue,"b");
  942. strcpy(pkey2->value.pCharValue,"a");
  943. break;
  944. default:
  945. throw 1010; //Error1010: 错误的数据类型
  946. }
  948. pkey3 = pkey1;
  949. pkey4 = pkey2;
  950. pkey1->next = new Key_Attr;
  951. pkey1 = pkey1->next;
  952. pkey2->next = new Key_Attr;
  953. pkey2 = pkey2->next;
  954. count--;
  955. }
  957. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  958. }
  960. pkey3->next = NULL;
  961. pkey4->next = NULL;
  962. delete pkey1;
  963. delete pkey2;
  965. index.max = pmaxkey;
  966. index.min = pminkey;
  967. if(info.ConditionHead == NULL)
  968.         index.OperType = ALL;
  969.     else
  970.         index.OperType = info.ConditionHead->OperType;
  971. cout<<"text1";
  973. //为 record update的信息
  974. Cell_Info* cell = new Cell_Info;
  975. Cell_Info* cell1 = cell;
  976. record.head = cell;
  977. record.ColNum = info.ColumnNum;
  978.     record.RecordLength = table->RecordLength;
  979. column = head;
  980. int len = 0;    
  981. while(column!=NULL){
  982. col = info.ColumnHead;
  983.         for(;col!=NULL;col=col->next){
  984. if(strcmp(col->ColumnName,column->ColumnName)==0){
  985. cell->ColLength = column->StoredLength;
  986. cell->ColType = column->ColType;
  987. cell->PriorLength = len;
  988. switch(column->ColType){
  989. case I:
  990. cell->value.IntValue = col->value.IntValue;
  991. break;
  992. case F:
  993. cell->value.FloatValue = col->value.FloatValue;
  994. break;
  995. case C:
  996. cell->value.pCharValue = col->value.pCharValue;
  997. break;
  998. default:
  999. throw 1010; //Error1010:错误的数据类型
  1000. }
  1001. cell->next = new Cell_Info;
  1002. cell1 = cell;
  1003. cell = cell->next;
  1004. break;
  1005. }
  1006. }
  1007. len += column->StoredLength;
  1008. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  1009. }
  1010. cell1->next = NULL;
  1011. delete cell;
  1013. return;
  1014. }
  1017. //删除
  1018. void HCatalog::Delete(TB_Delete_Info& info, Condition_Info& index)
  1019. {
  1020.     char temp[289];
  1021. sprintf(temp,"%s%s.dbf",CurLocation,CurRelationName);
  1022. _M_File CurrentTable = Buffer[temp];
  1024. Delete_Condition* cond=info.head;
  1025. Column_Info* column;
  1027. Table_Info* table;
  1028. table = (Table_Info*)CurrentTable.GetCataPoint().MemAddr();
  1029.     if(info.ConditionNum != table->KeyAttrNum)
  1030. throw 1019; //Error1019: Information Inadequate for selection(Every attribute should be included)!
  1032. for(; cond!=NULL; cond=cond->next){
  1033. column = this->Find_Column(cond->PrimaryKey);
  1034. if(column == NULL)
  1035. throw 1007; //Error1007: Primary Key demanded has not existed yet!
  1036. if(!this->Check_Key(column))
  1037. throw 1011; //Error1011: Not a select based on primary key!
  1038. if(!this->Check_Type(column,cond->ColType))
  1039. throw 1012; //Error1012: Type mismatch!
  1040.         if(cond->OperType == BETWEEN){
  1041.             if(!Check_Key_Validation(cond->ColType,&(cond->max),&(cond->min)))
  1042.                 throw 1020;       //Error1020: Result is null!
  1043.         }
  1044. if(cond->ColType == C){
  1045. switch(cond->OperType){
  1046. case L:
  1047. case LE:
  1048. if(!Check_Length(column,&(cond->max)))
  1049. throw 1013; //Error1013: Length Invalid for type char!
  1050. else 
  1051. break;
  1052. case B:
  1053. case BE:
  1054. if(!Check_Length(column,&(cond->min)))
  1055. throw 1013; //Error1013: Length Invalid for type char!
  1056. else
  1057. break;
  1058. case E:
  1059. case NE:
  1060. case BETWEEN:
  1061. if(!Check_Length(column,&(cond->max)) || !Check_Length(column,&(cond->min)))
  1062. throw 1013; //Error1013: Length Invalid for type char!
  1063. else 
  1064. break;
  1065. default:
  1066. throw 1009; //Error1009: 错误的关系运算符
  1067. }
  1068. }
  1069. }
  1071. //给index的信息
  1072.     Column_Info* head; 
  1073. head = (Column_Info*)table->KeyPtr.FileKey.MemAddr();
  1074. column = head;
  1075. int count = table->KeyAttrNum;
  1076. pKey_Attr pkey1,pkey2,pminkey,pmaxkey,pkey3,pkey4;
  1077. pminkey = new Key_Attr;
  1078. pkey1 = pminkey;   
  1079. pkey3 = pkey1;     
  1080. pmaxkey = new Key_Attr;
  1081. pkey2 = pmaxkey;    
  1082. pkey4 = pkey2;     
  1083.     while((column!=NULL) && (count!=0)){
  1084.         if(column->IsPrimary == 1){
  1085.             for(cond = info.head; cond!=NULL; cond=cond->next){
  1086. if(strcmp(cond->PrimaryKey,column->ColumnName)==0){  
  1087. switch (cond->ColType){
  1088. case I:
  1089. pkey1->value.IntValue = cond->min.IntValue;
  1090. pkey2->value.IntValue = cond->max.IntValue;
  1091. break;
  1092. case F:
  1093. pkey1->value.FloatValue = cond->min.FloatValue;
  1094. pkey2->value.FloatValue = cond->max.FloatValue;
  1095. break;
  1096. case C:
  1097. pkey1->value.pCharValue = cond->min.pCharValue;
  1098. pkey2->value.pCharValue = cond->max.pCharValue;
  1099. break;
  1100. default:
  1101. throw 1010; //Error1010: 错误的数据类型
  1102. }
  1103. break;
  1104. }
  1105. }
  1108.             if(cond==NULL)
  1109. switch(column->ColType){
  1110. case I:
  1111. pkey1->value.IntValue = 1;
  1112. pkey2->value.IntValue = 0;
  1113. break;
  1114. case F:
  1115. pkey1->value.FloatValue = 1.0;
  1116. pkey2->value.FloatValue = 0.0;
  1117. break;
  1118. case C:
  1119. strcpy(pkey1->value.pCharValue,"b");
  1120. strcpy(pkey2->value.pCharValue,"a");
  1121. break;
  1122. default:
  1123. throw 1010; //Error1010: 错误的数据类型
  1124. }
  1126. pkey3 = pkey1;
  1127. pkey4 = pkey2;
  1128. pkey1->next = new Key_Attr;
  1129. pkey1 = pkey1->next;
  1130. pkey2->next = new Key_Attr;
  1131. pkey2 = pkey2->next;
  1132. count--;
  1133. }
  1135. column = (Column_Info*)column->ColumnPtr.FileNext.MemAddr();
  1136. }
  1138. pkey3->next = NULL;
  1139. pkey4->next = NULL;
  1140. delete pkey1;
  1141. delete pkey2;
  1143. index.max = pmaxkey;
  1144. index.min = pminkey;
  1145. if(info.head == NULL)
  1146.         index.OperType = ALL;
  1147.     else
  1148.         index.OperType = info.head->OperType;
  1151. return;
  1152. }