Install library :
go get github.com/go-sql-driver/mysql
go get github.com/gorilla/mux
Main.go
package main
import (
"fmt"
"log"
"net/http"
"encoding/json"
_ "github.com/go-sql-driver/mysql"
"github.com/gorilla/mux"
)
func main() {
router := mux.NewRouter()
router.HandleFunc("/getusers", returnAllUsers).Methods("GET")
router.HandleFunc("/get1user/{id}", return1User).Methods("GET")
router.HandleFunc("/get1user2/{id2}", return1User2).Methods("POST")
router.HandleFunc("/users", insertUsersMultipart).Methods("POST")
router.HandleFunc("/users",updateUsersMultipart).Methods("PUT")
router.HandleFunc("/users",deleteUsersMultipart).Methods("DELETE")
http.Handle("/", router)
fmt.Println("Connected to port 8080")
log.Fatal(http.ListenAndServe(":8080", router))
}
func returnAllUsers(w http.ResponseWriter, r *http.Request) {
var users Users
var arr_user []Users
var response Response
db := connect()
defer db.Close()
rows, err := db.Query("Select id,first_name,last_name from person")
if err != nil {
log.Print(err)
}
for rows.Next() {
if err := rows.Scan(&users.Id, &users.FirstName, &users.LastName); err != nil {
log.Fatal(err.Error())
} else {
arr_user = append(arr_user, users)
}
}
response.Status = 1
response.Message = "Success"
response.Data = arr_user
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
func return1User(w http.ResponseWriter, r *http.Request) {
var users Users
var arr_user []Users
var response Response
db := connect()
defer db.Close()
vars := mux.Vars(r)
id := vars["id"]
rows, err := db.Query("Select id,first_name,last_name from person where id="+id)
if err != nil {
log.Print(err)
}
var status=0
var hasil="gagal"
for rows.Next() {
if err := rows.Scan(&users.Id, &users.FirstName, &users.LastName); err != nil {
log.Fatal(err.Error())
} else {
arr_user = append(arr_user, users)
status=1
hasil="sukses"
}
}
response.Status = status
response.Message = hasil
response.Data = arr_user
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
func return1User2(w http.ResponseWriter, r *http.Request) {
var users Users
var arr_user []Users
var response Response
db := connect()
defer db.Close()
vars := mux.Vars(r)
id := vars["id2"]
rows, err := db.Query("Select id,first_name,last_name from person where id="+id)
if err != nil {
log.Print(err)
}
var status=0
var hasil="gagal"
for rows.Next() {
if err := rows.Scan(&users.Id, &users.FirstName, &users.LastName); err != nil {
log.Fatal(err.Error())
} else {
arr_user = append(arr_user, users)
status=1
hasil="sukses"
}
}
response.Status = status
response.Message = hasil
response.Data = arr_user
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
Mysql.go
package main
import (
"database/sql"
"log"
"fmt"
)
func connect() *sql.DB {
db, err := sql.Open("mysql", "root:password@tcp(host:3306)/namadb")
if err != nil {
log.Fatal(err)
}
fmt.Println("connect db ok !")
return db
}
data.go
package main
import (
"encoding/json"
"log"
"fmt"
"net/http"
)
func insertUsersMultipart(w http.ResponseWriter, r *http.Request) {
var response Response
fmt.Println("insert processing");
db := connect()
defer db.Close()
err := r.ParseForm()
if err != nil {
panic(err)
}
first_name := r.Form.Get("first_name")
last_name := r.Form.Get("last_name")
_, err = db.Exec("INSERT INTO person (first_name, last_name) values (?,?)",
first_name,
last_name,
)
if err != nil {
log.Print(err)
}
response.Status = 1
response.Message = "Success Add"
log.Print("Insert data to database")
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
func updateUsersMultipart(w http.ResponseWriter, r *http.Request) {
var response Response
db := connect()
defer db.Close()
err := r.ParseForm()
if err != nil {
panic(err)
}
id := r.Form.Get("user_id")
first_name := r.Form.Get("first_name")
last_name := r.Form.Get("last_name")
_, err = db.Exec("UPDATE person set first_name = ?, last_name = ? where id = ?",
first_name,
last_name,
id,
)
if err != nil {
log.Print(err)
}
response.Status = 1
response.Message = "Success Update Data"
log.Print("Update data to database")
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
func deleteUsersMultipart(w http.ResponseWriter, r *http.Request) {
var response Response
db := connect()
defer db.Close()
err := r.ParseForm()
if err != nil {
panic(err)
}
id := r.Form.Get("user_id")
_, err = db.Exec("DELETE from person where id = ?",
id,
)
if err != nil {
log.Print(err)
}
response.Status = 1
response.Message = "Success Delete Data"
log.Print("Delete data to database")
w.Header().Set("Content-Type", "application/json")
json.NewEncoder(w).Encode(response)
}
Cek dengan menggunakan postman
Update Data
Add Data
Delete Data
Get all User
Testing insert dengan menggunakan curl:
curl --data "first_name=keke3&last_name=keke3" -X POST http://localhost:8080/users
Sumber : https://kiddyxyz.medium.com
