Merge pull request #83 from HahaBill/f/mindsdb-insert-table

[Hacktoberfest] Insert data into a table functionality

Author: mpacheco12

src/tables/table.ts

@@ -47,4 +47,13 @@ export default class Table {
   async delete(): Promise<void> {
     await this.tablesApiClient.deleteTable(this.name, this.integration);
   }
+
+   /**
+   * Insert data into this table.
+   * @param {string} select - SELECT query to insert data from.
+   * @throws {MindsDbError} - Something went wrong inserting data into the table.
+   */
+   async insert(select: string): Promise<void> {
+    await this.tablesApiClient.insertTable(this.name, this.integration, select);
+  }
 }

src/tables/tablesApiClient.ts

@@ -41,6 +41,14 @@ export default abstract class TablesApiClient {
    */
   abstract deleteTable(name: string, integration: string): Promise<void>;
 
+  /**
+  * Insert data into this table.
+  * @param {string} name - Name of the table to be deleted.
+  * @param {string} integration - Name of the integration the table to be deleted is a part of.
+  * @param {string} select -  SELECT query to insert data from.
+  * @throws {MindsDbError} - Something went wrong inserting data into the table.
+  */
+  abstract insertTable(name: string, integration: string, select: string): Promise<void>;
   /**
    * Deletes a file from the files integration.
    * @param {string} name - Name of the file to be deleted.

src/tables/tablesRestApiClient.ts

@@ -88,6 +88,23 @@ export default class TablesRestApiClient extends TablesApiClient {
     }
   }
 
+  /**
+  * Insert data into this table.
+  * @param {Array<Array<any>> | string} data - A 2D array of values to insert, or a SELECT query to insert data from.
+  * @throws {MindsDbError} - Something went wrong inserting data into the table.
+  */
+  override async insertTable(name: string, integration: string, select: string): Promise<void> {
+    try {
+      const sqlQuery = `INSERT INTO ${mysql.escapeId(integration)}.${mysql.escapeId(name)} (${select})`;
+      const sqlQueryResult = await this.sqlClient.runQuery(sqlQuery);
+      if (sqlQueryResult.error_message) {
+        throw new MindsDbError(sqlQueryResult.error_message);
+      }
+    } catch(error) {
+      throw new MindsDbError(`Insert into a table failed: ${error}`);
+    }
+  }
+  
   /**
    * Deletes a file from the files integration.
    * @param {string} name - Name of the file to be deleted.