Compare commits
No commits in common. "da0643ee96bd860dd51ca2ec49cea27b0df4c8b5" and "6b7faf1899e37a8ceedc427ad1666630a4312567" have entirely different histories.
da0643ee96
...
6b7faf1899
6
Makefile
6
Makefile
|
@ -1,3 +1,5 @@
|
||||||
|
export NAME=genityapp
|
||||||
|
|
||||||
build:
|
build:
|
||||||
docker-compose build
|
docker-compose build
|
||||||
|
|
||||||
|
@ -5,6 +7,4 @@ run: build
|
||||||
docker-compose up
|
docker-compose up
|
||||||
|
|
||||||
build-binary:
|
build-binary:
|
||||||
GOOS=linux GOARCH=amd64 go build
|
GOOS=linux GOARCH=amd64 go build
|
||||||
|
|
||||||
.PHONY: build-binary run build
|
|
|
@ -1,8 +0,0 @@
|
||||||
FROM golang:alpine as builder
|
|
||||||
|
|
||||||
RUN mkdir -p /go/src/app
|
|
||||||
WORKDIR /go/src/app
|
|
||||||
|
|
||||||
ADD . /go/src/app
|
|
||||||
|
|
||||||
RUN go get -d -v
|
|
|
@ -6,8 +6,6 @@ import (
|
||||||
_ "github.com/lib/pq"
|
_ "github.com/lib/pq"
|
||||||
"log"
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"genityapi"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var db *sql.DB
|
var db *sql.DB
|
||||||
|
|
|
@ -1,12 +1,13 @@
|
||||||
version: "3.8"
|
version: '3'
|
||||||
services:
|
services:
|
||||||
db:
|
db:
|
||||||
image: postgres
|
image: postgres
|
||||||
env_file: ./configs/db.env
|
env_file:
|
||||||
|
- ./db.env
|
||||||
volumes:
|
volumes:
|
||||||
- ./db_postgres:/var/lib/postgresql/data
|
- ./db_postgres:/var/lib/postgresql/data
|
||||||
- ./scripts/db/ddl_01.sql:/docker-entrypoint-initdb.d/10_schema.sql
|
- ./ddl_01.sql:/docker-entrypoint-initdb.d/10_schema.sql
|
||||||
- ./scripts/db/dml_01.sql:/docker-entrypoint-initdb.d/20_insert.sql
|
- ./dml_01.sql:/docker-entrypoint-initdb.d/20_insert.sql
|
||||||
expose:
|
expose:
|
||||||
- "5432"
|
- "5432"
|
||||||
restart: always
|
restart: always
|
||||||
|
@ -15,7 +16,8 @@ services:
|
||||||
web:
|
web:
|
||||||
build: ""
|
build: ""
|
||||||
command: [ "go", "run", "main.go","api.go"]
|
command: [ "go", "run", "main.go","api.go"]
|
||||||
env_file: ./configs/web.env
|
env_file:
|
||||||
|
- ./web.env
|
||||||
ports:
|
ports:
|
||||||
- "5000:5000"
|
- "5000:5000"
|
||||||
restart: always
|
restart: always
|
||||||
|
|
|
@ -1,100 +0,0 @@
|
||||||
package genityapi
|
|
||||||
|
|
||||||
import (
|
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
|
||||||
"net/http"
|
|
||||||
"time"
|
|
||||||
)
|
|
||||||
|
|
||||||
type User struct {
|
|
||||||
UserID int
|
|
||||||
Title string
|
|
||||||
CreatedOn time.Time
|
|
||||||
}
|
|
||||||
|
|
||||||
type Users struct {
|
|
||||||
users []User
|
|
||||||
}
|
|
||||||
|
|
||||||
func UserGetHandler(w http.ResponseWriter, req *http.Request) {
|
|
||||||
if req.Method == "GET" {
|
|
||||||
users := Users{}
|
|
||||||
|
|
||||||
err := queryRepos(&users)
|
|
||||||
if err != nil {
|
|
||||||
http.Error(w, err.Error(), 500)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
out, err := json.Marshal(users.users)
|
|
||||||
if err != nil {
|
|
||||||
http.Error(w, err.Error(), 500)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Fprintf(w, string(out))
|
|
||||||
} else {
|
|
||||||
fmt.Fprintf(w, "Sorry, only Get methods are supported for thus api.")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func UserPostHandler(w http.ResponseWriter, req *http.Request) {
|
|
||||||
if req.Method == "POST" {
|
|
||||||
if err := req.ParseForm(); err != nil {
|
|
||||||
fmt.Fprintf(w, "ParseForm() err: %v", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
title := req.FormValue("title")
|
|
||||||
sqlInsert := `
|
|
||||||
INSERT INTO users (title, created_on)
|
|
||||||
VALUES ($1, $2)
|
|
||||||
RETURNING user_id`
|
|
||||||
if len(title) > 0 {
|
|
||||||
user_id := 0
|
|
||||||
row := db.QueryRow(sqlInsert, title, time.Now())
|
|
||||||
err := row.Scan(&user_id)
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
fmt.Fprintf(w, "user creted")
|
|
||||||
} else {
|
|
||||||
fmt.Fprintf(w, "Invalid data")
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
fmt.Fprintf(w, "Sorry, only POST methods are supported for thus api.")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func queryRepos(users *Users) error {
|
|
||||||
rows, err := db.Query(`
|
|
||||||
SELECT
|
|
||||||
user_id,
|
|
||||||
title,
|
|
||||||
created_on
|
|
||||||
|
|
||||||
FROM users;
|
|
||||||
`)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
defer rows.Close()
|
|
||||||
for rows.Next() {
|
|
||||||
user := User{}
|
|
||||||
err = rows.Scan(
|
|
||||||
&user.UserID,
|
|
||||||
&user.Title,
|
|
||||||
&user.CreatedOn,
|
|
||||||
)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
users.users = append(users.users, user)
|
|
||||||
}
|
|
||||||
|
|
||||||
err = rows.Err()
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
61
main.go
61
main.go
|
@ -1,61 +0,0 @@
|
||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"database/sql"
|
|
||||||
"fmt"
|
|
||||||
_ "github.com/lib/pq"
|
|
||||||
"log"
|
|
||||||
"net/http"
|
|
||||||
)
|
|
||||||
|
|
||||||
var db *sql.DB
|
|
||||||
|
|
||||||
const (
|
|
||||||
dbhost = "DBHOST"
|
|
||||||
dbport = "DBPORT"
|
|
||||||
dbuser = "DBUSER"
|
|
||||||
dbpass = "DBPASS"
|
|
||||||
dbname = "DBNAME"
|
|
||||||
)
|
|
||||||
|
|
||||||
func main() {
|
|
||||||
initDb()
|
|
||||||
defer db.Close()
|
|
||||||
|
|
||||||
http.HandleFunc("/get-data", UserGetHandler)
|
|
||||||
http.HandleFunc("/post-data", UserPostHandler)
|
|
||||||
|
|
||||||
fmt.Println("Listening on :5000")
|
|
||||||
log.Fatal(http.ListenAndServe(":5000", nil))
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
func initDb() {
|
|
||||||
config := dbConfig()
|
|
||||||
var err error
|
|
||||||
psqlInfo := fmt.Sprintf("postgres://%v:%v@%v:%v/%v?sslmode=disable",
|
|
||||||
config[dbuser], config[dbpass],
|
|
||||||
config[dbhost], config[dbport], config[dbname])
|
|
||||||
|
|
||||||
fmt.Println(psqlInfo)
|
|
||||||
db, err = sql.Open("postgres", psqlInfo)
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
err = db.Ping()
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
fmt.Println("Successfully connected!")
|
|
||||||
}
|
|
||||||
|
|
||||||
func dbConfig() map[string]string {
|
|
||||||
conf := make(map[string]string)
|
|
||||||
conf[dbhost] = "genitywebapp_db_1"
|
|
||||||
conf[dbport] = "5432"
|
|
||||||
conf[dbuser] = "root_user"
|
|
||||||
conf[dbpass] = "shahzad12"
|
|
||||||
conf[dbname] = "db_genity"
|
|
||||||
return conf
|
|
||||||
}
|
|
|
@ -1,5 +1,5 @@
|
||||||
COMPOSE_PROJECT_NAME=genitywebapp
|
COMPOSE_PROJECT_NAME=genitywebapp
|
||||||
dbhost=genityapp_db_1
|
dbhost=genityapp_db_1"
|
||||||
dbport=5432
|
dbport=5432
|
||||||
dbuser=root_user
|
dbuser=root_user
|
||||||
dbpass=shahzad12
|
dbpass=shahzad12
|
Loading…
Reference in a new issue