lab1

Author: 15197580192

src/observer/storage/record/record_manager.cpp

@@ -414,7 +414,7 @@ PageNum RecordPageHandler::get_page_num() const
 
 bool RecordPageHandler::is_full() const { return page_header_->record_num >= page_header_->record_capacity; }
 
-RC PaxRecordPageHandler::insert_record(const char *data, RID *rid)
+/*RC PaxRecordPageHandler::insert_record(const char *data, RID *rid)
 {
   // your code here
   // exit(-1);
@@ -451,6 +451,43 @@ RC PaxRecordPageHandler::insert_record(const char *data, RID *rid)
     rid->slot_num = index;
   }
   return RC::SUCCESS;
+}*/
+RC PaxRecordPageHandler::insert_record(const char *data, RID *rid)
+{
+  // your code here
+    ASSERT(rw_mode_ != ReadWriteMode::READ_ONLY, 
+         "cannot insert record into page while the page is readonly");
+
+  if (page_header_->record_num == page_header_->record_capacity) {
+    LOG_WARN("Page is full, page_num %d:%d.", disk_buffer_pool_->file_desc(), frame_->page_num());
+    return RC::RECORD_NOMEM;
+  }
+
+  // 找到空闲位置
+  Bitmap bitmap(bitmap_, page_header_->record_capacity);
+  int    index = bitmap.next_unsetted_bit(0);
+  bitmap.set_bit(index);
+  page_header_->record_num++;
+
+  RC rc = log_handler_.insert_record(frame_, RID(get_page_num(), index), data);
+  if (OB_FAIL(rc)) {
+    LOG_ERROR("Failed to insert record. page_num %d:%d. rc=%s", disk_buffer_pool_->file_desc(), frame_->page_num(), strrc(rc));
+    // return rc; // ignore errors
+  }
+  int offset = 0;
+  for(int i=0;i<page_header_->column_num;i++)
+  {
+    char* _data = get_field_data(index,i);
+    memcpy(_data,data+offset,get_field_len(i));
+    offset+=get_field_len(i);
+  }
+  frame_->mark_dirty();
+  if(rid)
+  {
+    rid->page_num = get_page_num();
+    rid->slot_num = index;
+  }
+  return RC::SUCCESS;
 }
 
 RC PaxRecordPageHandler::delete_record(const RID *rid)
@@ -477,7 +514,7 @@ RC PaxRecordPageHandler::delete_record(const RID *rid)
   }
 }
 
-RC PaxRecordPageHandler::get_record(const RID &rid, Record &record)
+/*RC PaxRecordPageHandler::get_record(const RID &rid, Record &record)
 {
   // your code here
   // exit(-1);
@@ -504,6 +541,34 @@ RC PaxRecordPageHandler::get_record(const RID &rid, Record &record)
   }
   record.copy_data(data,page_header_->record_real_size);
   return RC::SUCCESS;
+}*/
+RC PaxRecordPageHandler::get_record(const RID &rid, Record &record)
+{
+  // your code here
+  if (rid.slot_num >= page_header_->record_capacity) {
+    LOG_ERROR("Invalid slot_num %d, exceed page's record capacity, frame=%s, page_header=%s",
+              rid.slot_num, frame_->to_string().c_str(), page_header_->to_string().c_str());
+    return RC::RECORD_INVALID_RID;
+  }
+
+  Bitmap bitmap(bitmap_, page_header_->record_capacity);
+  if (!bitmap.get_bit(rid.slot_num)) {
+    LOG_ERROR("Invalid slot_num:%d, slot is empty, page_num %d.", rid.slot_num, frame_->page_num());
+    return RC::RECORD_NOT_EXIST;
+  }
+  record.set_rid(rid);
+  
+  char* data = new char[page_header_->record_real_size];
+  int offset = 0;
+  for(int i=0;i<page_header_->column_num;i++)
+  {
+    char* _data = get_field_data(rid.slot_num,i);
+    memcpy(data+offset,_data,get_field_len(i));
+    offset+=get_field_len(i);
+  }
+  record.copy_data(data,page_header_->record_real_size);
+  delete[] data;
+  return RC::SUCCESS;
 }
 /*
 // TODO: specify the column_ids that chunk needed. currenly we get all columns