ifdef'd unused table reorg code

parent 07859756
...@@ -239,7 +239,11 @@ Dbdict::packTableIntoPagesImpl(SimpleProperties::Writer & w, ...@@ -239,7 +239,11 @@ Dbdict::packTableIntoPagesImpl(SimpleProperties::Writer & w,
w.add(DictTabInfo::TableName, tablePtr.p->tableName); w.add(DictTabInfo::TableName, tablePtr.p->tableName);
w.add(DictTabInfo::TableId, tablePtr.i); w.add(DictTabInfo::TableId, tablePtr.i);
#ifdef HAVE_TABLE_REORG
w.add(DictTabInfo::SecondTableId, tablePtr.p->secondTable); w.add(DictTabInfo::SecondTableId, tablePtr.p->secondTable);
#else
w.add(DictTabInfo::SecondTableId, (Uint32)0);
#endif
w.add(DictTabInfo::TableVersion, tablePtr.p->tableVersion); w.add(DictTabInfo::TableVersion, tablePtr.p->tableVersion);
w.add(DictTabInfo::NoOfKeyAttr, tablePtr.p->noOfPrimkey); w.add(DictTabInfo::NoOfKeyAttr, tablePtr.p->noOfPrimkey);
w.add(DictTabInfo::NoOfAttributes, tablePtr.p->noOfAttributes); w.add(DictTabInfo::NoOfAttributes, tablePtr.p->noOfAttributes);
...@@ -1436,6 +1440,7 @@ Uint32 Dbdict::getFreeTableRecord(Uint32 primaryTableId) ...@@ -1436,6 +1440,7 @@ Uint32 Dbdict::getFreeTableRecord(Uint32 primaryTableId)
jam(); jam();
return RNIL; return RNIL;
}//if }//if
#ifdef HAVE_TABLE_REORG
bool secondFound = false; bool secondFound = false;
for (tablePtr.i = firstTablePtr.i + 1; tablePtr.i < tabSize ; tablePtr.i++) { for (tablePtr.i = firstTablePtr.i + 1; tablePtr.i < tabSize ; tablePtr.i++) {
jam(); jam();
...@@ -1455,6 +1460,7 @@ Uint32 Dbdict::getFreeTableRecord(Uint32 primaryTableId) ...@@ -1455,6 +1460,7 @@ Uint32 Dbdict::getFreeTableRecord(Uint32 primaryTableId)
firstTablePtr.p->tabState = TableRecord::NOT_DEFINED; firstTablePtr.p->tabState = TableRecord::NOT_DEFINED;
return RNIL; return RNIL;
}//if }//if
#endif
return firstTablePtr.i; return firstTablePtr.i;
}//Dbdict::getFreeTableRecord() }//Dbdict::getFreeTableRecord()
...@@ -4623,7 +4629,7 @@ void Dbdict::handleTabInfoInit(SimpleProperties::Reader & it, ...@@ -4623,7 +4629,7 @@ void Dbdict::handleTabInfoInit(SimpleProperties::Reader & it,
jam(); jam();
tablePtr.p->tabState = TableRecord::DEFINING; tablePtr.p->tabState = TableRecord::DEFINING;
}//if }//if
#ifdef HAVE_TABLE_REORG
/* ---------------------------------------------------------------- */ /* ---------------------------------------------------------------- */
// Get id of second table id and check that table doesn't already exist // Get id of second table id and check that table doesn't already exist
// and set up links between first and second table. // and set up links between first and second table.
...@@ -4637,7 +4643,7 @@ void Dbdict::handleTabInfoInit(SimpleProperties::Reader & it, ...@@ -4637,7 +4643,7 @@ void Dbdict::handleTabInfoInit(SimpleProperties::Reader & it,
secondTablePtr.p->tabState = TableRecord::REORG_TABLE_PREPARED; secondTablePtr.p->tabState = TableRecord::REORG_TABLE_PREPARED;
secondTablePtr.p->secondTable = tablePtr.i; secondTablePtr.p->secondTable = tablePtr.i;
tablePtr.p->secondTable = secondTablePtr.i; tablePtr.p->secondTable = secondTablePtr.i;
#endif
/* ---------------------------------------------------------------- */ /* ---------------------------------------------------------------- */
// Set table version // Set table version
/* ---------------------------------------------------------------- */ /* ---------------------------------------------------------------- */
...@@ -5535,10 +5541,12 @@ void Dbdict::releaseTableObject(Uint32 tableId, bool removeFromHash) ...@@ -5535,10 +5541,12 @@ void Dbdict::releaseTableObject(Uint32 tableId, bool removeFromHash)
nextAttrRecord = attrPtr.p->nextAttrInTable; nextAttrRecord = attrPtr.p->nextAttrInTable;
c_attributeRecordPool.release(attrPtr); c_attributeRecordPool.release(attrPtr);
}//if }//if
#ifdef HAVE_TABLE_REORG
Uint32 secondTableId = tablePtr.p->secondTable; Uint32 secondTableId = tablePtr.p->secondTable;
initialiseTableRecord(tablePtr); initialiseTableRecord(tablePtr);
c_tableRecordPool.getPtr(tablePtr, secondTableId); c_tableRecordPool.getPtr(tablePtr, secondTableId);
initialiseTableRecord(tablePtr); initialiseTableRecord(tablePtr);
#endif
return; return;
}//releaseTableObject() }//releaseTableObject()
......
...@@ -151,10 +151,10 @@ public: ...@@ -151,10 +151,10 @@ public:
/* Temporary record used during add/drop table */ /* Temporary record used during add/drop table */
Uint32 myConnect; Uint32 myConnect;
#ifdef HAVE_TABLE_REORG
/* Second table used by this table (for table reorg) */ /* Second table used by this table (for table reorg) */
Uint32 secondTable; Uint32 secondTable;
#endif
/* Next record in Pool */ /* Next record in Pool */
Uint32 nextPool; Uint32 nextPool;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment