Merge pull request #67 from sanketshinde3001/four

Added a function to remove a table

src/tables/table.ts

@@ -29,7 +29,13 @@ export default class Table {
     this.name = name;
     this.integration = integration;
   }
-
+  /**
+   * Removes this table from its integration.
+   * @throws {MindsDbError} - Something went wrong removing this table.
+   */
+  async removeTable(): Promise<void> {
+    await this.tablesApiClient.removeTable(this.name, this.integration);
+  }
   /**
    * Creates a table in an integration from a given SELECT statement.
    * @param {string} select - SELECT statement to use for populating the new table with data.

src/tables/tablesApiClient.ts

@@ -56,3 +56,13 @@ export default abstract class TablesApiClient {
    */
   abstract deleteFile(name: string): Promise<void>;
 }
+
+/**
+ * Removes a table from its integration.
+ * @param {string} name - Name of the table to be removed.
+ * @param {string} integration - Name of the integration the table belongs to.
+ * @returns {Promise<void>} - Resolves when the table is successfully removed.
+ * @throws {MindsDbError} - Something went wrong removing the table.
+ */
+abstract removeTable(name: string, integration: string): Promise<void>;
+

src/tables/tablesRestApiClient.ts

@@ -119,3 +119,27 @@ export default class TablesRestApiClient extends TablesApiClient {
     }
   }
 }
+
+/**
+ * Removes a table from its integration.
+ * @param {string} name - Name of the table to be removed.
+ * @param {string} integration - Name of the integration the table belongs to.
+ * @returns {Promise<void>} - Resolves when the table is successfully removed.
+ * @throws {MindsDbError} - Something went wrong removing the table.
+ */
+override async removeTable(
+  name: string,
+  integration: string
+): Promise<void> {
+  // Construct the SQL query to drop the table
+  const sqlQuery = `DROP TABLE ${mysql.escapeId(integration)}.${mysql.escapeId(name)}`;
+
+  // Execute the SQL query using the sqlClient
+  const sqlQueryResult = await this.sqlClient.runQuery(sqlQuery);
+
+  // Check for errors
+  if (sqlQueryResult.error_message) {
+    throw new MindsDbError(sqlQueryResult.error_message);
+  }
+}
+