diff --git a/storage/dao/postgresql/database_postgresql_games.go b/storage/dao/postgresql/database_postgresql_games.go index cba5660..8d4b90b 100755 --- a/storage/dao/postgresql/database_postgresql_games.go +++ b/storage/dao/postgresql/database_postgresql_games.go @@ -57,12 +57,35 @@ func (db *DatabasePostgreSQL) GetGameById(id string) (*model.Game, error) { return &game, err } -func (db *DatabasePostgreSQL) CreateGame(*model.Game) error { - return nil +func (db *DatabasePostgreSQL) CreateGame(game *model.Game) error { + q := ` + INSERT INTO public.game + (server_id, user_id) + VALUES + ($1, $2) + RETURNING id, created_at + ` + + err := db.session. + QueryRow(q, game.Server.ID, game.User.ID). + Scan(&game.ID, &game.CreatedAt) + if errPq, ok := err.(*pq.Error); ok { + return handlePgError(errPq) + } + return err } -func (db *DatabasePostgreSQL) DeleteGame(string) error { - return nil +func (db *DatabasePostgreSQL) DeleteGame(id string) error { + q := ` + DELETE FROM public.game + WHERE id = $1 + ` + + _, err := db.session.Exec(q, id) + if errPq, ok := err.(*pq.Error); ok { + return handlePgError(errPq) + } + return err } func (db *DatabasePostgreSQL) UpdateGame(*model.Game) error { diff --git a/storage/dao/postgresql/database_postgresql_user.go b/storage/dao/postgresql/database_postgresql_user.go index 6dfea20..961019e 100755 --- a/storage/dao/postgresql/database_postgresql_user.go +++ b/storage/dao/postgresql/database_postgresql_user.go @@ -55,7 +55,7 @@ func (db *DatabasePostgreSQL) CreateUser(user *model.User) error { INSERT INTO public.user (nickname, google_id) VALUES - ($1, $2, $3) + ($1, $2) RETURNING id, created_at `