// Code generated by sqlc. DO NOT EDIT. // versions: // sqlc v1.29.0 // source: favourites.sql package sqlc import ( "context" "github.com/jackc/pgx/v5/pgtype" ) const createFavourite = `-- name: CreateFavourite :one INSERT INTO favourites ( user_id, event_guid, event_id ) VALUES ( $1, $2, $3 ) RETURNING id, user_id, event_guid, event_id ` type CreateFavouriteParams struct { UserID int32 `json:"user_id"` EventGuid pgtype.UUID `json:"event_guid"` EventID pgtype.Int4 `json:"event_id"` } func (q *Queries) CreateFavourite(ctx context.Context, arg CreateFavouriteParams) (Favourite, error) { row := q.db.QueryRow(ctx, createFavourite, arg.UserID, arg.EventGuid, arg.EventID) var i Favourite err := row.Scan( &i.ID, &i.UserID, &i.EventGuid, &i.EventID, ) return i, err } const deleteFavourite = `-- name: DeleteFavourite :exec DELETE FROM favourites WHERE id = $1 ` func (q *Queries) DeleteFavourite(ctx context.Context, id int32) error { _, err := q.db.Exec(ctx, deleteFavourite, id) return err } const deleteFavouriteByEventDetails = `-- name: DeleteFavouriteByEventDetails :execrows DELETE FROM favourites WHERE (event_guid = $1 OR event_id = $2) AND user_id = $3 ` type DeleteFavouriteByEventDetailsParams struct { EventGuid pgtype.UUID `json:"event_guid"` EventID pgtype.Int4 `json:"event_id"` UserID int32 `json:"user_id"` } func (q *Queries) DeleteFavouriteByEventDetails(ctx context.Context, arg DeleteFavouriteByEventDetailsParams) (int64, error) { result, err := q.db.Exec(ctx, deleteFavouriteByEventDetails, arg.EventGuid, arg.EventID, arg.UserID) if err != nil { return 0, err } return result.RowsAffected(), nil } const getFavouritesForUser = `-- name: GetFavouritesForUser :many SELECT id, user_id, event_guid, event_id FROM favourites WHERE user_id = $1 ` func (q *Queries) GetFavouritesForUser(ctx context.Context, userID int32) ([]Favourite, error) { rows, err := q.db.Query(ctx, getFavouritesForUser, userID) if err != nil { return nil, err } defer rows.Close() var items []Favourite for rows.Next() { var i Favourite if err := rows.Scan( &i.ID, &i.UserID, &i.EventGuid, &i.EventID, ); err != nil { return nil, err } items = append(items, i) } if err := rows.Err(); err != nil { return nil, err } return items, nil }