Add delete row

components/ResultsTable.go

@@ -336,18 +336,31 @@ func (table *ResultsTable) tableInputCapture(event *tcell.EventKey) *tcell.Event
 		go table.Select(1, selectedColumnIndex)
 	} else if event.Rune() == 71 { // G Key
 		go table.Select(rowCount-1, selectedColumnIndex)
-	} else if event.Rune() == 100 { // d Key
+	} else if event.Rune() == 4 { // Ctrl + D
 		if selectedRowIndex+7 > rowCount-1 {
 			go table.Select(rowCount-1, selectedColumnIndex)
 		} else {
 			go table.Select(selectedRowIndex+7, selectedColumnIndex)
 		}
-	} else if event.Rune() == 117 { // u Key
+	} else if event.Rune() == 21 { // Ctrl + U
 		if selectedRowIndex-7 < 1 {
 			go table.Select(1, selectedColumnIndex)
 		} else {
 			go table.Select(selectedRowIndex-7, selectedColumnIndex)
 		}
+	} else if event.Rune() == 'd' {
+		id := table.GetCell(selectedRowIndex, 0).Text
+		error := drivers.MySQL.DeleteRecord(table.GetDBReference(), id)
+
+		if error != nil {
+			table.SetError(error.Error(), nil)
+		} else {
+			records := table.GetRecords()
+
+			newRecords := append(records[:selectedRowIndex], records[selectedRowIndex+1:]...)
+
+			table.SetRecords(newRecords)
+		}
 	}
 
 	if len(table.GetRecords()) > 0 {

drivers/mysql.go

@@ -63,10 +63,6 @@ func (db *MySql) Connect() error {
 	return nil
 }
 
-func (db *MySql) Disconnect() error {
-	return db.conn.Close()
-}
-
 func (db *MySql) SetConnectionString(connectionString string) {
 	db.connectionString = connectionString
 }
@@ -75,10 +71,6 @@ func (db *MySql) GetConnectionString() string {
 	return db.connectionString
 }
 
-func (db *MySql) GetConnection() *sql.DB {
-	return db.conn
-}
-
 func (db *MySql) GetDatabases() ([]string, error) {
 	var databases []string
 
@@ -297,9 +289,7 @@ func (db *MySql) GetPaginatedRecords(table string, where string, sort string, of
 }
 
 func (db *MySql) QueryPaginatedRecords(query string) (results [][]string, err error) {
-
 	rows, err := db.conn.Query(query)
-
 	if err != nil {
 		return results, err
 	}
@@ -337,6 +327,13 @@ func (db *MySql) UpdateRecord(table string, column string, value string, id stri
 	return err
 }
 
+func (db *MySql) DeleteRecord(table string, id string) error {
+	query := fmt.Sprintf("DELETE FROM %s WHERE id = \"%s\"", table, id)
+	_, err := db.conn.Exec(query)
+
+	return err
+}
+
 func (db *MySql) GetLastExecutedQuery() string {
 	return db.lastExecutedQuery
 }