Skip to content

Chore: Optimize MySql Recipe #3333

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 4 commits into
base: master
Choose a base branch
from
Open

Chore: Optimize MySql Recipe #3333

Changes from 3 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
edf9fd3
Chore: Optimize MySql Recipe
stewartmbofana Oct 14, 2025
fc88e83
Review Changes
stewartmbofana Oct 14, 2025
97b27ae
Review change
stewartmbofana Oct 14, 2025
c67bd8f
Merge branch 'master' into feature/optimize-mysql-recipe
stewartmbofana Oct 16, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
130 changes: 66 additions & 64 deletions mysql/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@ import (
"database/sql"
"fmt"
"log"
"net/http"
"strconv"

_ "github.com/go-sql-driver/mysql"
"github.com/gofiber/fiber/v2"
Expand All @@ -17,8 +19,6 @@ var db *sql.DB

// Database settings
const (
host = "localhost"
port = 5432 // Default port
user = "root"
password = "password"
dbname = "fiber_demo"
Expand All @@ -32,11 +32,6 @@ type Employee struct {
Age int `json:"age"`
}

// Employees struct
type Employees struct {
Employees []Employee `json:"employees"`
}

// Connect function
func Connect() error {
var err error
Expand All @@ -60,96 +55,103 @@ func main() {
// Create a Fiber app
app := fiber.New()

// Get all records from MySQL
app.Get("/employee", func(c *fiber.Ctx) error {
// Get Employee list from database
rows, err := db.Query("SELECT id, name, salary, age FROM employees order by id")
rows, err := db.Query("SELECT id, name, salary, age FROM employees ORDER BY id")
if err != nil {
return c.Status(500).SendString(err.Error())
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}
defer rows.Close()
result := Employees{}

var employees []Employee
for rows.Next() {
employee := Employee{}
if err := rows.Scan(&employee.ID, &employee.Name, &employee.Salary, &employee.Age); err != nil {
return err // Exit if we get an error
var emp Employee
if err := rows.Scan(&emp.ID, &emp.Name, &emp.Salary, &emp.Age); err != nil {
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}
employees = append(employees, emp)
}
if err := rows.Err(); err != nil {
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}
return c.JSON(employees)
})

// Append Employee to Employees
result.Employees = append(result.Employees, employee)
app.Get("/employee/:id", func(c *fiber.Ctx) error {
idParam := c.Params("id")
id, err := strconv.Atoi(idParam)
if err != nil {
return c.Status(http.StatusBadRequest).SendString("invalid employee id")
}
// Return Employees in JSON format
return c.JSON(result)
var emp Employee
err = db.QueryRow("SELECT id, name, salary, age FROM employees WHERE id = ?", id).Scan(&emp.ID, &emp.Name, &emp.Salary, &emp.Age)
if err != nil {
if err == sql.ErrNoRows {
return c.SendStatus(http.StatusNotFound)
}
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}

return c.JSON(emp)
})

// Add record into MySQL
app.Post("/employee", func(c *fiber.Ctx) error {
// New Employee struct
u := new(Employee)

// Parse body into struct
if err := c.BodyParser(u); err != nil {
return c.Status(400).SendString(err.Error())
var emp Employee
if err := c.BodyParser(&emp); err != nil {
return c.Status(http.StatusBadRequest).SendString(err.Error())
}

// Insert Employee into database
res, err := db.Query("INSERT INTO employees (NAME, SALARY, AGE) VALUES (?, ?, ?)", u.Name, u.Salary, u.Age)
result, err := db.Exec("INSERT INTO employees (name, salary, age) VALUES (?, ?, ?)", emp.Name, emp.Salary, emp.Age)
if err != nil {
return err
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}

// Print result
log.Println(res)
id, _ := result.LastInsertId()
emp.ID = int(id)

// Return Employee in JSON format
return c.JSON(u)
return c.Status(http.StatusCreated).JSON(emp)
})

// Update record into MySQL
app.Put("/employee", func(c *fiber.Ctx) error {
// New Employee struct
u := new(Employee)

// Parse body into struct
if err := c.BodyParser(u); err != nil {
return c.Status(400).SendString(err.Error())
app.Put("/employee/:id", func(c *fiber.Ctx) error {
idParam := c.Params("id")
id, err := strconv.Atoi(idParam)
if err != nil {
return c.Status(http.StatusBadRequest).SendString("invalid employee id")
}
var emp Employee
if err := c.BodyParser(&emp); err != nil {
return c.Status(http.StatusBadRequest).SendString(err.Error())
}

// Update Employee record in database
res, err := db.Query("UPDATE employees SET name=?,salary=?,age=? WHERE id=?", u.Name, u.Salary, u.Age, u.ID)
result, err := db.Exec("UPDATE employees SET name=?, salary=?, age=? WHERE id=?", emp.Name, emp.Salary, emp.Age, id)
if err != nil {
return err
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}

// Print result
log.Println(res)
rowsAffected, _ := result.RowsAffected()
if rowsAffected == 0 {
return c.SendStatus(http.StatusNotFound)
}

// Return Employee in JSON format
return c.Status(201).JSON(u)
return c.JSON(emp)
})

// Delete record from MySQL
app.Delete("/employee", func(c *fiber.Ctx) error {
// New Employee struct
u := new(Employee)

// Parse body into struct
if err := c.BodyParser(u); err != nil {
return c.Status(400).SendString(err.Error())
app.Delete("/employee/:id", func(c *fiber.Ctx) error {
idParam := c.Params("id")
id, err := strconv.Atoi(idParam)
if err != nil {
return c.Status(http.StatusBadRequest).SendString("invalid employee id")
}

// Delete Employee from database
res, err := db.Query("DELETE FROM employees WHERE id = ?", u.ID)
result, err := db.Exec("DELETE FROM employees WHERE id = ?", id)
if err != nil {
return err
return c.Status(http.StatusInternalServerError).SendString(err.Error())
}

// Print result
log.Println(res)
rowsAffected, _ := result.RowsAffected()
if rowsAffected == 0 {
return c.SendStatus(http.StatusNotFound)
}

// Return Employee in JSON format
return c.JSON("Deleted")
return c.SendStatus(http.StatusNoContent)
})

log.Fatal(app.Listen(":3000"))
Expand Down