capytal/comicverse
1
0
Fork 0
Code Issues Pull Requests Activity

fix(repo,project): update queries

Browse Source
This commit is contained in:
Guz
2025-06-10 15:08:32 -03:00
parent db876a9a17
commit 72e227ac40
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
repository/project.go
View File

@@ -15,7 +15,7 @@ type Project struct {
baseRepostiory baseRepostiory
} }
func NewProject(ctx context.Context, db *sql.DB, log *slog.Logger, assert tinyssert.Assertions) (*ProjectRepository, error) { func NewProject(ctx context.Context, db *sql.DB, log *slog.Logger, assert tinyssert.Assertions) (*Project, error) {
b := newBaseRepostiory(ctx, db, log, assert) b := newBaseRepostiory(ctx, db, log, assert)
tx, err := db.BeginTx(ctx, nil) tx, err := db.BeginTx(ctx, nil)
@@ -60,11 +60,11 @@ func (repo Project) Create(p model.Project) error {
VALUES (:id, :title, :created_at, :updated_at) VALUES (:id, :title, :created_at, :updated_at)
` `
log := repo.log.With(slog.String("uuid", p.UUID.String()), slog.String("query", q)) log := repo.log.With(slog.String("id", p.ID.String()), slog.String("query", q))
log.DebugContext(repo.ctx, "Inserting new project") log.DebugContext(repo.ctx, "Inserting new project")
_, err = tx.ExecContext(repo.ctx, q, _, err = tx.ExecContext(repo.ctx, q,
sql.Named("id", p.UUID), sql.Named("id", p.ID),
sql.Named("title", p.Title), sql.Named("title", p.Title),
sql.Named("created_at", p.DateCreated.Format(dateFormat)), sql.Named("created_at", p.DateCreated.Format(dateFormat)),
sql.Named("updated_at", p.DateUpdated.Format(dateFormat)), sql.Named("updated_at", p.DateUpdated.Format(dateFormat)),
@@ -103,7 +103,7 @@ func (repo Project) Update(p model.Project) error {
WHERE id = :id WHERE id = :id
` `
log := repo.log.With(slog.String("id", p.UUID.String()), slog.String("query", q)) log := repo.log.With(slog.String("id", p.ID.String()), slog.String("query", q))
log.DebugContext(repo.ctx, "Updating project") log.DebugContext(repo.ctx, "Updating project")
_, err = tx.ExecContext(repo.ctx, q, _, err = tx.ExecContext(repo.ctx, q,