Skip to content

Commit 3ef7ee0

Browse files
GabrielNat1GabrielNat1
committed
implement database connection and product repository for product use case
1 parent 91e99c4 commit 3ef7ee0

File tree

7 files changed

+133
-12
lines changed

7 files changed

+133
-12
lines changed

‎cmd/main.go‎

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@ package main
22

33
import (
44
"api-go/controller"
5+
"api-go/db"
6+
"api-go/repository"
7+
"api-go/usecase"
58

69
"github.com/gin-gonic/gin"
710
)
@@ -10,7 +13,16 @@ func main() {
1013

1114
server := gin.Default()
1215

13-
ProductController := controller.NewProductController()
16+
dbConnection, err := db.ConnectDb()
17+
if err != nil {
18+
panic(err)
19+
}
20+
21+
ProductRepository := repository.NewProductRepository(dbConnection)
22+
23+
ProductUseCase := usecase.NewProductUseCase(ProductRepository)
24+
25+
ProductController := controller.NewProductController(*ProductUseCase)
1426

1527
server.GET("/ping", func(ctx *gin.Context) {
1628
ctx.JSON(200, gin.H{

‎controller/product_controller.go‎

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package controller
22

33
import (
4-
"api-go/model"
4+
"api-go/usecase"
55
"net/http"
66

77
"github.com/gin-gonic/gin"
@@ -11,13 +11,18 @@ type productController struct {
1111
productUseCase usecase.ProductUseCase
1212
}
1313

14-
func NewProductController() *productController {
15-
return &productController{}
14+
func NewProductController(usecase usecase.ProductUseCase) *productController {
15+
return &productController{
16+
productUseCase: usecase,
17+
}
1618
}
1719

1820
func (p *productController) GetProducts(ctx *gin.Context) {
19-
products := []model.Product{
20-
{ID: 1, Name: "Produto 1", Price: 100.00},
21+
products, err := p.productUseCase.GetProducts()
22+
if err != nil {
23+
ctx.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
24+
return
2125
}
26+
2227
ctx.JSON(http.StatusOK, products)
2328
}

‎db/conn.go‎

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
package db
2+
3+
import (
4+
"database/sql"
5+
"fmt"
6+
7+
_ "github.com/lib/pq"
8+
)
9+
10+
const (
11+
host = "localhost"
12+
port = 5432
13+
user = "postgres"
14+
password = "1234"
15+
dbname = "postgres"
16+
)
17+
18+
func ConnectDb() (*sql.DB, error) {
19+
psqlInfo := fmt.Sprintf("host=%s port=%d user=%s "+
20+
"password=%s dbname=%s sslmode=disable",
21+
host, port, user, password, dbname)
22+
db, err := sql.Open("postgres", psqlInfo)
23+
if err != nil {
24+
panic(err)
25+
}
26+
27+
err = db.Ping()
28+
if err != nil {
29+
panic(err)
30+
}
31+
32+
fmt.Println("connected to" + dbname)
33+
34+
return db, nil
35+
}

‎go.mod‎

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,18 @@ module api-go
22

33
go 1.23.4
44

5+
require (
6+
github.com/gin-gonic/gin v1.10.0
7+
github.com/lib/pq v1.10.9
8+
)
9+
510
require (
611
github.com/bytedance/sonic v1.11.6 // indirect
712
github.com/bytedance/sonic/loader v0.1.1 // indirect
813
github.com/cloudwego/base64x v0.1.4 // indirect
914
github.com/cloudwego/iasm v0.2.0 // indirect
1015
github.com/gabriel-vasile/mimetype v1.4.3 // indirect
1116
github.com/gin-contrib/sse v0.1.0 // indirect
12-
github.com/gin-gonic/gin v1.10.0 // indirect
1317
github.com/go-playground/locales v0.14.1 // indirect
1418
github.com/go-playground/universal-translator v0.18.1 // indirect
1519
github.com/go-playground/validator/v10 v10.20.0 // indirect

‎go.sum‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,16 @@ github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJ
77
github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
88
github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
99
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
10+
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
1011
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
1112
github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0=
1213
github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk=
1314
github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE=
1415
github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI=
1516
github.com/gin-gonic/gin v1.10.0 h1:nTuyha1TYqgedzytsKYqna+DfLos46nTv2ygFy86HFU=
1617
github.com/gin-gonic/gin v1.10.0/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
18+
github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
19+
github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
1720
github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
1821
github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
1922
github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
@@ -22,6 +25,8 @@ github.com/go-playground/validator/v10 v10.20.0 h1:K9ISHbSaI0lyB2eWMPJo+kOS/FBEx
2225
github.com/go-playground/validator/v10 v10.20.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM=
2326
github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU=
2427
github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
28+
github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
29+
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
2530
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
2631
github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
2732
github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
@@ -31,6 +36,8 @@ github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZY
3136
github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M=
3237
github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
3338
github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
39+
github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
40+
github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
3441
github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
3542
github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
3643
github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -40,6 +47,7 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
4047
github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
4148
github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
4249
github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
50+
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
4351
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
4452
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
4553
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
@@ -51,6 +59,7 @@ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
5159
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
5260
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
5361
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
62+
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
5463
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
5564
github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
5665
github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
@@ -69,8 +78,11 @@ golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y=
6978
golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
7079
golang.org/x/text v0.15.0 h1:h1V/4gjBv8v9cjcR6+AR5+/cIYK5N/WAgiv4xlsEtAk=
7180
golang.org/x/text v0.15.0/go.mod h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
81+
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
82+
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
7283
google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg=
7384
google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
85+
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
7486
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
7587
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
7688
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

‎repository/product_repository.go‎

Lines changed: 47 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,47 @@
1+
package repository
2+
3+
import (
4+
"api-go/model"
5+
"database/sql"
6+
"fmt"
7+
)
8+
9+
type ProductRepository struct {
10+
connection *sql.DB
11+
}
12+
13+
func NewProductRepository(connection *sql.DB) ProductRepository {
14+
return ProductRepository{
15+
connection: connection,
16+
}
17+
}
18+
19+
func (pr *ProductRepository) GetProducts() ([]model.Product, error) {
20+
query := "SELECT id, product_name, price FROM product"
21+
rows, err := pr.connection.Query(query)
22+
if err != nil {
23+
fmt.Println(err)
24+
return []model.Product{}, err
25+
}
26+
27+
var productList []model.Product
28+
var productObj model.Product
29+
30+
for rows.Next() {
31+
err = rows.Scan(
32+
&productObj.ID,
33+
&productObj.Name,
34+
&productObj.Price)
35+
36+
if err != nil {
37+
fmt.Println(err)
38+
return []model.Product{}, err
39+
}
40+
41+
productList = append(productList, productObj)
42+
}
43+
44+
rows.Close()
45+
46+
return productList, nil
47+
}

‎usecase/product_usecase.go‎

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,20 @@
11
package usecase
22

3-
import "api-go/model"
3+
import (
4+
"api-go/model"
5+
"api-go/repository"
6+
)
47

58
type ProductUseCase struct {
9+
repository repository.ProductRepository
610
}
711

8-
func NewProductuUseCase() *productUseCase {
9-
return &productUseCase{}
12+
func NewProductUseCase(repo repository.ProductRepository) *ProductUseCase {
13+
return &ProductUseCase{
14+
repository: repo,
15+
}
1016
}
1117

12-
func (pu *productUseCase) GetProducts([]model.Product, error) {
13-
return []model.Product{}, nil
18+
func (pu *ProductUseCase) GetProducts() ([]model.Product, error) {
19+
return pu.repository.GetProducts()
1420
}

0 commit comments

Comments
 (0)