sqlite added with user creation

Author: krishkumar84

.gitignore

@@ -24,4 +24,4 @@ go.work.sum
 # env file
 .env
 
-storage
+/storage

cmd/api/main.go

@@ -13,15 +13,23 @@ import (
 
 	"github.com/krishkumar84/golang-project/pkg/config"
 	"github.com/krishkumar84/golang-project/pkg/http/handler/users"
+	"github.com/krishkumar84/golang-project/pkg/storage/sqlite"
+	_ "github.com/mattn/go-sqlite3"
 )
 
 func main() {
+
 	// load config
 
 	cfg := config.MustLoad()
 
-	//database
 
+	//database
+    storage,err := sqlite.New(cfg)
+	if err != nil {
+		log.Fatal(err)
+	}
+	slog.Info("Database connected",cfg.Env)
 
 	//setup router
 
@@ -31,7 +39,7 @@ func main() {
 		w.Write([]byte("Hello from krish and cicd and server grace full kill is running"))
 	})
 
-	router.HandleFunc("POST /api/users",users.New())
+	router.HandleFunc("POST /api/users",users.New(storage))
 
 	//start server
 

go.mod

@@ -16,6 +16,7 @@ require (
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mattn/go-sqlite3 v1.14.24 // indirect
 	github.com/radovskyb/watcher v1.0.7 // indirect
 	golang.org/x/crypto v0.19.0 // indirect
 	golang.org/x/net v0.21.0 // indirect

go.sum

@@ -31,6 +31,8 @@ github.com/mattn/go-isatty v0.0.11/go.mod h1:PhnuNfih5lzO57/f3n+odYbM4JtupLOxQOA
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
+github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
 github.com/radovskyb/watcher v1.0.7 h1:AYePLih6dpmS32vlHfhCeli8127LzkIgwJGcwwe8tUE=
 github.com/radovskyb/watcher v1.0.7/go.mod h1:78okwvY5wPdzcb1UYnip1pvrZNIVEIh/Cm+ZuvsUYIg=
 golang.org/x/crypto v0.19.0 h1:ENy+Az/9Y1vSrlrvBSyna3PITt4tiZLf7sgCjZBX7Wo=

pkg/http/handler/users/users.go

@@ -9,13 +9,14 @@ import (
 	"net/http"
 
 	"github.com/go-playground/validator/v10"
+	"github.com/krishkumar84/golang-project/pkg/storage"
 	"github.com/krishkumar84/golang-project/pkg/types"
 	"github.com/krishkumar84/golang-project/pkg/utils/response"
 )
 
 
 
-func New() http.HandlerFunc{
+func New(storage storage.Storage) http.HandlerFunc{
 	return func(w http.ResponseWriter, r *http.Request) {
 		slog.Info("New User Handler")
         var user types.User
@@ -37,7 +38,20 @@ func New() http.HandlerFunc{
 			return
 		}
 
-		response.WriteJson(w, http.StatusCreated, map[string]string{"status":"ok"})
+		lastId, err := storage.CreateUser(
+			user.Name,
+			user.Email,
+			user.Age,
+		)
+
+		slog.Info("User created sucessfully",slog.String("userId",fmt.Sprint(lastId)))
+
+		if err != nil {
+			response.WriteJson(w, http.StatusInternalServerError, response.GeneralError(err))
+			return
+		}
+
+		response.WriteJson(w, http.StatusCreated, map[string]int64{"id":lastId})
 	}
 }
 

pkg/storage/sqlite/sqlite.go

@@ -0,0 +1,50 @@
+package sqlite
+
+import (
+	"database/sql"
+
+	"github.com/krishkumar84/golang-project/pkg/config"
+	_"github.com/mattn/go-sqlite3"
+
+)
+
+type Sqlite struct {
+	Db *sql.DB
+}
+
+func New(cfg *config.Config) (*Sqlite, error) {
+	db, err := sql.Open("sqlite3", cfg.StoragePath)
+	if err != nil {
+		return nil, err
+	}
+
+	_,err =db.Exec(`CREATE TABLE IF NOT EXISTS users (
+		id INTEGER PRIMARY KEY AUTOINCREMENT,
+		name TEXT NOT NULL UNIQUE,
+		email TEXT NOT NULL UNIQUE,
+		age INTEGER NOT NULL 
+	)`)
+    if err != nil {
+		return nil, err
+	}
+
+	return &Sqlite{Db: db}, nil 
+}
+
+func (s *Sqlite) CreateUser(name string, email string, age int) (int64, error) {
+	stmt, err := s.Db.Prepare("INSERT INTO users (name, email, age) VALUES (?, ?, ?)")
+	if err != nil {
+		return 0, err
+	}
+	defer stmt.Close()
+
+	result, err := stmt.Exec(name, email, age)
+	if err != nil {
+		return 0, err
+	}
+	lastId, err := result.LastInsertId()
+	if err != nil {
+		return 0, err
+	}
+	return lastId, nil
+}

pkg/storage/storage.go

@@ -0,0 +1,5 @@
+package storage
+
+type Storage interface {
+	CreateUser(name string, email string, age int)(int64, error)
+}

pkg/types/types.go

@@ -1,7 +1,7 @@
 package types
 
 type User struct {
-	Id   int
+	Id   int64
 	Name string  `validate:"required"`
 	Email string `validate:"required"`
 	Age  int     `validate:"required"`