added change type, changed logic in alter_executor, varchar still not suppport

Author: Dingshilun

src/catalog/catalog.cpp

@@ -1060,6 +1060,7 @@ ResultType Catalog::AlterTable(
                new_column_id < new_schema->GetColumnCount(); new_column_id++) {
             auto it = column_map.find(new_column_id);
             type::Value val;
+            auto cast_flag = false;
             if (it == column_map.end()) {
               // new column, set value to null
               val = type::ValueFactory::GetNullValueByType(
@@ -1070,10 +1071,18 @@ ResultType Catalog::AlterTable(
               val = result_tile->GetValue(i, it->second);
               if (new_schema->GetColumn(new_column_id).GetType() != old_schema->GetColumn(it->second).GetType()) {
                 //change the value's type
-                val = val.CastAs(new_schema->GetColumn(new_column_id).GetType());
+                LOG_TRACE("CASTED: %s TO %s", val.GetInfo().c_str(),new_schema->GetColumn(new_column_id).GetInfo()
+                    .c_str());
+                auto casted_val = val.CastAs(new_schema->GetColumn(new_column_id).GetType());
+                cast_flag = true;
+                tuple->SetValue(new_column_id, casted_val, pool_.get());
               }
             }
-            tuple->SetValue(new_column_id, val, pool_.get());
+            if (!cast_flag) {
+              tuple->SetValue(new_column_id, val, pool_.get());
+            } else {
+              LOG_TRACE("CASTED: %s", val.GetInfo().c_str());
+            }
           }
           // insert new tuple into new table
           planner::InsertPlan node(new_table, std::move(tuple));
@@ -1089,19 +1098,19 @@ ResultType Catalog::AlterTable(
       oid_t column_offset = 0;
       for (auto new_column : new_schema->GetColumns()) {
         catalog::ColumnCatalog::GetInstance()->InsertColumn(
-            table_oid, new_column.GetName(), column_offset,
+            new_table->GetOid(), new_column.GetName(), column_offset,
             new_column.GetOffset(), new_column.GetType(),
             new_column.IsInlined(), new_column.GetConstraints(), pool_.get(),
             txn);
         column_offset++;
       }
+      // Record table drop
+      // txn->RecordDrop(database_oid, old_table->GetOid(), INVALID_OID);
 
       // Final step of physical change should be moved to commit time
       database->ReplaceTableWithOid(table_oid, new_table);
 
-      // Record table drop
-      txn->RecordDrop(database_oid, table_oid, INVALID_OID);
-
+      LOG_TRACE("Alter table with oid %d", new_table->GetOid());
     } catch (CatalogException &e) {
       LOG_TRACE("Alter table failed.");
       return ResultType::FAILURE;

src/executor/alter_executor.cpp

@@ -114,13 +114,13 @@ bool AlterExecutor::AlterTable(const peloton::planner::AlterPlan &node,
   }
   std::unique_ptr<catalog::Schema> temp_schema(
       catalog::Schema::CopySchema(old_schema, column_ids));
-
+  auto columns = temp_schema->GetColumns();
   // Step 2: change column type if exists
   for (auto change_pair : node.GetChangedTypeColumns()) {
     bool is_found = false;
     oid_t i = 0;
-    for (; i < temp_schema->GetColumnCount(); ++i) {
-      if (temp_schema->GetColumn(i).GetName() == change_pair.first) {
+    for (; i < columns.size(); ++i) {
+      if (columns[i].GetName() == change_pair.first) {
         is_found = true;
         break;
       }
@@ -131,7 +131,16 @@ bool AlterExecutor::AlterTable(const peloton::planner::AlterPlan &node,
       txn->SetResult(ResultType::FAILURE);
       return false;
     } else {
-      temp_schema->ChangeColumnType(i, change_pair.second);
+      if (change_pair.second != type::TypeId::VARCHAR) {
+        columns[i].SetType(change_pair.second);
+        columns[i].SetLength(type::VarlenType::GetTypeSize(change_pair.second));
+      } else {
+        //TODO decide VARCHAR's size when change type
+        //It is broken now!
+        columns[i].SetType(change_pair.second);
+        //columns[i].SetLength(type::VarlenType::GetTypeSize(change_pair.second));
+        columns[i].SetInlined();
+      }
     }
   }
 
@@ -143,10 +152,8 @@ bool AlterExecutor::AlterTable(const peloton::planner::AlterPlan &node,
       add_columns.push_back(column);
     }
   }
-  std::unique_ptr<catalog::Schema> add_column_schema(
-      new catalog::Schema(add_columns));
   // Check if added column exists
-  for (auto new_column : add_column_schema->GetColumns()) {
+  for (auto new_column : add_columns) {
     for (auto old_column : old_schema->GetColumns()) {
       if (new_column.GetName() == old_column.GetName()) {
         LOG_TRACE("Add column failed: Column %s already exists",
@@ -156,10 +163,9 @@ bool AlterExecutor::AlterTable(const peloton::planner::AlterPlan &node,
       }
     }
   }
-
+  columns.insert(columns.end(), add_columns.begin(), add_columns.end());
   // Construct new schema
-  std::unique_ptr<catalog::Schema> new_schema(catalog::Schema::AppendSchema(
-      temp_schema.get(), add_column_schema.get()));
+  std::unique_ptr<catalog::Schema> new_schema(new catalog::Schema(columns));
 
   // Copy and replace table content to new schema in catalog
   ResultType result = catalog::Catalog::GetInstance()->AlterTable(

src/parser/postgresparser.cpp

@@ -1855,6 +1855,7 @@ parser::AlterTableStatement *PostgresParser::AlterTransform(Node *root) {
             std::unique_ptr<ColumnDefinition> col_def(
                 new ColumnDefinition(cmd->name, type_id));
             result->changed_type_columns->push_back(std::move(col_def));
+            break;
           }
           default: {
             throw NotImplementedException(StringUtil::Format(

src/storage/database.cpp

@@ -104,6 +104,7 @@ storage::DataTable *Database::ReplaceTableWithOid(
     const oid_t table_oid, storage::DataTable *new_table) {
   {
     std::lock_guard<std::mutex> lock(database_mutex);
+    codegen::QueryCache::Instance().Remove(table_oid);
 
     oid_t table_offset = 0;
     for (auto table : tables) {