mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-25 05:07:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

freaking sql types

Browse source
This commit is contained in:
Andre Medeiros 2022-05-08 21:02:59 -04:00
parent 3803fea055
commit 132374fb6b
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
internal/repository/postgres_watcher.go
View file

@ -211,16 +211,19 @@ func (p *postgresWatcherRepository) Create(ctx context.Context, watcher *domain.
return err return err
} }
now := time.Now()
query := ` query := `
INSERT INTO watchers INSERT INTO watchers
(created_at, last_notified_at, label, device_id, account_id, type, watchee_id, author, subreddit, upvotes, keyword, flair, domain) (created_at, last_notified_at, label, device_id, account_id, type, watchee_id, author, subreddit, upvotes, keyword, flair, domain)
VALUES ($1, 0, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)
RETURNING id` RETURNING id`
return p.conn.QueryRow( return p.conn.QueryRow(
ctx, ctx,
query, query,
time.Now(), now,
now,
watcher.Label, watcher.Label,
watcher.DeviceID, watcher.DeviceID,
watcher.AccountID, watcher.AccountID,
@ -271,9 +274,8 @@ func (p *postgresWatcherRepository) Update(ctx context.Context, watcher *domain.
} }
func (p *postgresWatcherRepository) IncrementHits(ctx context.Context, id int64) error { func (p *postgresWatcherRepository) IncrementHits(ctx context.Context, id int64) error {
now := time.Now().Unix()
query := `UPDATE watchers SET hits = hits + 1, last_notified_at = $2 WHERE id = $1` query := `UPDATE watchers SET hits = hits + 1, last_notified_at = $2 WHERE id = $1`
res, err := p.conn.Exec(ctx, query, id, now) res, err := p.conn.Exec(ctx, query, id, time.Now())
if res.RowsAffected() != 1 { if res.RowsAffected() != 1 {
return fmt.Errorf("weird behaviour, total rows affected: %d", res.RowsAffected()) return fmt.Errorf("weird behaviour, total rows affected: %d", res.RowsAffected())