From 0377c585131a3e2e28f4b3eb1ada07441a21477a Mon Sep 17 00:00:00 2001 From: bvandeusen Date: Sun, 19 Apr 2026 02:31:58 +0000 Subject: [PATCH] M1/#292: sqlc-generated artists queries --- internal/db/dbq/artists.sql.go | 112 +++++++++++++++++++++++++++++++++ 1 file changed, 112 insertions(+) create mode 100644 internal/db/dbq/artists.sql.go diff --git a/internal/db/dbq/artists.sql.go b/internal/db/dbq/artists.sql.go new file mode 100644 index 00000000..17750aa1 --- /dev/null +++ b/internal/db/dbq/artists.sql.go @@ -0,0 +1,112 @@ +// Code generated by sqlc. DO NOT EDIT. +// versions: +// sqlc v1.27.0 +// source: artists.sql + +package dbq + +import ( + "context" + + "github.com/jackc/pgx/v5/pgtype" +) + +const getArtistByID = `-- name: GetArtistByID :one +SELECT id, name, sort_name, mbid, created_at, updated_at FROM artists WHERE id = $1 +` + +func (q *Queries) GetArtistByID(ctx context.Context, id pgtype.UUID) (Artist, error) { + row := q.db.QueryRow(ctx, getArtistByID, id) + var i Artist + err := row.Scan( + &i.ID, + &i.Name, + &i.SortName, + &i.Mbid, + &i.CreatedAt, + &i.UpdatedAt, + ) + return i, err +} + +const getArtistByName = `-- name: GetArtistByName :one +SELECT id, name, sort_name, mbid, created_at, updated_at FROM artists WHERE name = $1 LIMIT 1 +` + +func (q *Queries) GetArtistByName(ctx context.Context, name string) (Artist, error) { + row := q.db.QueryRow(ctx, getArtistByName, name) + var i Artist + err := row.Scan( + &i.ID, + &i.Name, + &i.SortName, + &i.Mbid, + &i.CreatedAt, + &i.UpdatedAt, + ) + return i, err +} + +const listArtists = `-- name: ListArtists :many +SELECT id, name, sort_name, mbid, created_at, updated_at FROM artists ORDER BY sort_name +` + +func (q *Queries) ListArtists(ctx context.Context) ([]Artist, error) { + rows, err := q.db.Query(ctx, listArtists) + if err != nil { + return nil, err + } + defer rows.Close() + var items []Artist + for rows.Next() { + var i Artist + if err := rows.Scan( + &i.ID, + &i.Name, + &i.SortName, + &i.Mbid, + &i.CreatedAt, + &i.UpdatedAt, + ); err != nil { + return nil, err + } + items = append(items, i) + } + if err := rows.Err(); err != nil { + return nil, err + } + return items, nil +} + +const upsertArtist = `-- name: UpsertArtist :one +INSERT INTO artists (name, sort_name, mbid) +VALUES ($1, $2, $3) +ON CONFLICT (mbid) WHERE mbid IS NOT NULL +DO UPDATE SET + name = EXCLUDED.name, + sort_name = EXCLUDED.sort_name, + updated_at = now() +RETURNING id, name, sort_name, mbid, created_at, updated_at +` + +type UpsertArtistParams struct { + Name string + SortName string + Mbid *string +} + +// Insert or update by mbid when present; otherwise by (name, sort_name). +// Callers pass the canonical sort_name; scanner is responsible for derivation. +func (q *Queries) UpsertArtist(ctx context.Context, arg UpsertArtistParams) (Artist, error) { + row := q.db.QueryRow(ctx, upsertArtist, arg.Name, arg.SortName, arg.Mbid) + var i Artist + err := row.Scan( + &i.ID, + &i.Name, + &i.SortName, + &i.Mbid, + &i.CreatedAt, + &i.UpdatedAt, + ) + return i, err +}