Merge pull request #95 from Niharika0104/Fixes-58

Added update table function

src/tables/table.ts

@@ -64,6 +64,16 @@ export default class Table {
   }
 
    /**
+
+   * Updates a table from its integration.
+   * @param {string} updateQuery - The SQL UPDATE query to run for updating the table.
+   * @throws {MindsDbError} - Something went wrong deleting the table.
+   */
+   async  update(updateQuery: string): Promise<void> {
+    await this.tablesApiClient.updateTable(this.name, this.integration,updateQuery);
+   }
+}
+
    * Insert data into this table.
    * @param {string} select - SELECT query to insert data from.
    * @throws {MindsDbError} - Something went wrong inserting data into the table.
@@ -72,3 +82,4 @@ export default class Table {
     await this.tablesApiClient.insertTable(this.name, this.integration, select);
   }
 }
+

src/tables/tablesApiClient.ts

@@ -41,6 +41,21 @@ export default abstract class TablesApiClient {
    */
   abstract deleteTable(name: string, integration: string): Promise<void>;
 
+
+
+  /**
+   * Updates a table from its integration.
+   * @param {string} name - Name of the table to be updated.
+   * @param {string} integration - Name of the integration the table to be updated is a part of.
+   * @param {string} updateQuery - The SQL UPDATE query to run for updating the table.
+   * @throws {MindsDbError} - Something went wrong deleting the table.
+   */
+  abstract updateTable(
+    name: string,
+    integration: string,
+    updateQuery: string
+  ): Promise<void>;
+
   /**
    * Deletes specific row (or multiple rows) from the table present in the given integration.
    * @param {string} name - Name of the table from which data is to be deleted.
@@ -65,6 +80,7 @@ export default abstract class TablesApiClient {
    * @throws {MindsDbError} - Something went wrong deleting the file.
    */
   abstract deleteFile(name: string): Promise<void>;
+
 }
 
 /**

src/tables/tablesRestApiClient.ts

@@ -88,6 +88,40 @@ export default class TablesRestApiClient extends TablesApiClient {
     }
   }
 
+
+  /**
+   * Updates a table from its integration.
+   * @param {string} name - Name of the table to be updated.
+   * @param {string} integration - Name of the integration the table to be updated is a part of.
+   * @param {string} updateQuery - The SQL UPDATE query to run for updating the table.
+   * @throws {MindsDbError} - Something went wrong deleting the table.
+   */
+  override async updateTable(
+    name: string,
+    integration: string,
+    updateQuery: string
+  ): Promise<void> {
+
+    let keyword="SET";
+    let setPosition = updateQuery.toUpperCase().indexOf(keyword);
+    let result;
+
+    if (setPosition !== -1) {
+    // Extract the substring starting just after "SET"
+     result = updateQuery.substring(setPosition + keyword.length).trim();
+    } 
+
+    // Construct the full SQL query to update the table
+    const sqlQuery = `UPDATE ${mysql.escapeId(integration)}.${mysql.escapeId(name)} SET ${result}`;
+
+    // Execute the SQL query using the sqlClient
+    const sqlQueryResult = await this.sqlClient.runQuery(sqlQuery);
+    if (sqlQueryResult.error_message) {
+      throw new MindsDbError(sqlQueryResult.error_message);
+    }
+  }
+
+
   /**
    * Deletes specific row (or multiple rows) from the table present in the given integration.
    * @param {string} name - Name of the table from which data is to be deleted.