57 lines
1.4 KiB
Go
57 lines
1.4 KiB
Go
|
package postgres
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"git.snrd.de/Spaenny/goddit"
|
||
|
|
"github.com/google/uuid"
|
||
|
|
"github.com/jmoiron/sqlx"
|
||
|
|
)
|
||
|
|
|
||
|
|
type ThreadStore struct {
|
||
|
|
*sqlx.DB
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *ThreadStore) Thread(id uuid.UUID) (goddit.Thread, error) {
|
||
|
|
var t goddit.Thread
|
||
|
|
if err := s.Get(&t, `SELECT * FROM threads WHERE id = $1`, id); err != nil {
|
||
|
|
return goddit.Thread{}, fmt.Errorf("error getting thread: %w", err)
|
||
|
|
}
|
||
|
|
return t, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *ThreadStore) Threads() ([]goddit.Thread, error) {
|
||
|
|
var tt []goddit.Thread
|
||
|
|
if err := s.Select(&tt, `SELECT * FROM threads`); err != nil {
|
||
|
|
return []goddit.Thread{}, fmt.Errorf("error getting threads: %w", err)
|
||
|
|
}
|
||
|
|
return tt, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *ThreadStore) CreateThread(t *goddit.Thread) error {
|
||
|
|
if err := s.Get(t, `INSERT INTO threads VALUES($1, $2, $3) RETURNING *`,
|
||
|
|
t.ID,
|
||
|
|
t.Title,
|
||
|
|
t.Description); err != nil {
|
||
|
|
return fmt.Errorf("error creating thread: %w", err)
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *ThreadStore) UpdateThread(t *goddit.Thread) error {
|
||
|
|
if err := s.Get(t, `UPDATE INTO threads SET title = $1,description = $2 WHERE id = $3) RETURNING *`,
|
||
|
|
t.Title,
|
||
|
|
t.Description,
|
||
|
|
t.ID); err != nil {
|
||
|
|
return fmt.Errorf("error updating thread: %w", err)
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (s *ThreadStore) DeleteThread(id uuid.UUID) error {
|
||
|
|
if _, err := s.Exec(`DELETE FROM threads WHERE id = $1`, id); err != nil {
|
||
|
|
return fmt.Errorf("error deleteing thread: %w", err)
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|