PSTRESS-157 Add support for ALTER ENGINE DDL in pstress (#97)

ALTER TABLE tbl_name ENGINE=InnoDB, ALGORITHM=INPLACE/COPY/INSTANT/DEFAULT

Author: mohitj1988

src/common.hpp

@@ -68,6 +68,7 @@ struct Option {
     NUMBER_OF_SECONDS_WORKLOAD,
     ALTER_TABLE_ENCRYPTION,
     ALTER_DISCARD_TABLESPACE,
+    ALTER_ENGINE,
     ALTER_TABLE_COMPRESSION,
     ALTER_COLUMN_MODIFY,
     ALTER_INSTANCE_RELOAD_KEYRING,

src/help.cpp

@@ -483,6 +483,13 @@ void add_options() {
   opt->setSQL();
   opt->setDDL();
 
+  /* Alter table Storage Engine to Innodb with different Algorithms */
+  opt = newOption(Option::INT, Option::ALTER_ENGINE, "alter-table-engine");
+  opt->help = "alter table engine";
+  opt->setInt(1);
+  opt->setSQL();
+  opt->setDDL();
+
   /* Add column */
   opt = newOption(Option::INT, Option::ADD_COLUMN, "add-column");
   opt->help = "alter table add some random column";

src/random_test.cpp

@@ -1980,7 +1980,7 @@ bool execute_sql(const std::string &sql, Thd1 *thd) {
 void Table::SetEncryption(Thd1 *thd) {
   std::string sql = "ALTER TABLE " + name_ + " ENCRYPTION = '";
   std::string enc = g_encryption[rand_int(g_encryption.size() - 1)];
-  sql += enc + "'";
+  sql += enc + "'" + "," + pick_algorithm_lock();
   if (execute_sql(sql, thd)) {
     table_mutex.lock();
     encryption = enc;
@@ -1992,14 +1992,19 @@ void Table::SetEncryption(Thd1 *thd) {
 void Table::SetTableCompression(Thd1 *thd) {
   std::string sql = "ALTER TABLE " + name_ + " COMPRESSION= '";
   std::string comp = g_compression[rand_int(g_compression.size() - 1)];
-  sql += comp + "'";
+  sql += comp + "'" + "," + pick_algorithm_lock();
   if (execute_sql(sql, thd)) {
     table_mutex.lock();
     compression = comp;
     table_mutex.unlock();
   }
 }
 
+void Table::SetAlterEngine(Thd1 *thd) {
+  std::string sql = "ALTER TABLE " + name_ + " ENGINE=InnoDB," + pick_algorithm_lock();
+  execute_sql(sql, thd);
+}
+
 // todo pick relevent table//
 void Table::ModifyColumn(Thd1 *thd) {
   std::string sql = "ALTER TABLE " + name_ + " MODIFY COLUMN ";
@@ -3593,6 +3598,9 @@ bool Thd1::run_some_query() {
     case Option::ALTER_TABLE_ENCRYPTION:
       table->SetEncryption(this);
       break;
+    case Option::ALTER_ENGINE:
+      table->SetAlterEngine(this);
+      break;
     case Option::ALTER_TABLE_COMPRESSION:
       table->SetTableCompression(this);
       break;

src/random_test.hpp

@@ -197,6 +197,7 @@ struct Table {
   void SetEncryption(Thd1 *thd);
   void SetEncryptionInplace(Thd1 *thd);
   void SetTableCompression(Thd1 *thd);
+  void SetAlterEngine(Thd1 *thd);
   void ModifyColumn(Thd1 *thd);
   void InsertRandomRow(Thd1 *thd);
   bool InsertBulkRecord(Thd1 *thd, size_t number_of_records);