db

func DSN ¶

func DSN(cfg config.PostgresConfig) string

DSN builds a PostgreSQL connection string from config.

func IsUniqueViolation ¶

func IsUniqueViolation(err error) bool

IsUniqueViolation reports whether err is a PostgreSQL unique constraint violation (SQLSTATE 23505).

func Open ¶

func Open(ctx context.Context, cfg config.PostgresConfig) (*pgxpool.Pool, error)

func ParseUUID ¶

func ParseUUID(id string) (pgtype.UUID, error)

ParseUUID converts a string UUID to pgtype.UUID.

func RunMigrate ¶

func RunMigrate(logger *slog.Logger, cfg config.PostgresConfig, migrationsFS fs.FS, command string, args []string) error

RunMigrate applies or rolls back database migrations. The migrationsFS should contain .sql files at its root (not in a subdirectory). Supported commands: "up", "down", "version", "force N".

func TextToString ¶

func TextToString(value pgtype.Text) string

TextToString returns the string value of pgtype.Text, or "" when invalid.

func TimeFromPg ¶

func TimeFromPg(value pgtype.Timestamptz) time.Time

TimeFromPg converts a pgtype.Timestamptz to time.Time.