76 lines
1.8 KiB
Go
76 lines
1.8 KiB
Go
|
// Code generated by sqlc. DO NOT EDIT.
|
||
|
// source: team_member.sql
|
||
|
|
||
|
package pg
|
||
|
|
||
|
import (
|
||
|
"context"
|
||
|
"time"
|
||
|
|
||
|
"github.com/google/uuid"
|
||
|
)
|
||
|
|
||
|
const createTeamMember = `-- name: CreateTeamMember :one
|
||
|
INSERT INTO team_member (team_id, user_id, addedDate) VALUES ($1, $2, $3)
|
||
|
RETURNING team_member_id, team_id, user_id, addeddate
|
||
|
`
|
||
|
|
||
|
type CreateTeamMemberParams struct {
|
||
|
TeamID uuid.UUID `json:"team_id"`
|
||
|
UserID uuid.UUID `json:"user_id"`
|
||
|
Addeddate time.Time `json:"addeddate"`
|
||
|
}
|
||
|
|
||
|
func (q *Queries) CreateTeamMember(ctx context.Context, arg CreateTeamMemberParams) (TeamMember, error) {
|
||
|
row := q.db.QueryRowContext(ctx, createTeamMember, arg.TeamID, arg.UserID, arg.Addeddate)
|
||
|
var i TeamMember
|
||
|
err := row.Scan(
|
||
|
&i.TeamMemberID,
|
||
|
&i.TeamID,
|
||
|
&i.UserID,
|
||
|
&i.Addeddate,
|
||
|
)
|
||
|
return i, err
|
||
|
}
|
||
|
|
||
|
const deleteTeamMemberByUserID = `-- name: DeleteTeamMemberByUserID :exec
|
||
|
DELETE FROM team_member WHERE user_id = $1
|
||
|
`
|
||
|
|
||
|
func (q *Queries) DeleteTeamMemberByUserID(ctx context.Context, userID uuid.UUID) error {
|
||
|
_, err := q.db.ExecContext(ctx, deleteTeamMemberByUserID, userID)
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
const getTeamMembersForTeamID = `-- name: GetTeamMembersForTeamID :many
|
||
|
SELECT team_member_id, team_id, user_id, addeddate FROM team_member WHERE team_id = $1
|
||
|
`
|
||
|
|
||
|
func (q *Queries) GetTeamMembersForTeamID(ctx context.Context, teamID uuid.UUID) ([]TeamMember, error) {
|
||
|
rows, err := q.db.QueryContext(ctx, getTeamMembersForTeamID, teamID)
|
||
|
if err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
defer rows.Close()
|
||
|
var items []TeamMember
|
||
|
for rows.Next() {
|
||
|
var i TeamMember
|
||
|
if err := rows.Scan(
|
||
|
&i.TeamMemberID,
|
||
|
&i.TeamID,
|
||
|
&i.UserID,
|
||
|
&i.Addeddate,
|
||
|
); err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
items = append(items, i)
|
||
|
}
|
||
|
if err := rows.Close(); err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
if err := rows.Err(); err != nil {
|
||
|
return nil, err
|
||
|
}
|
||
|
return items, nil
|
||
|
}
|