This repository has been archived by the owner on Jul 17, 2024. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 22
/
deployment_events.sql.go
119 lines (108 loc) · 2.7 KB
/
deployment_events.sql.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
// Code generated by sqlc. DO NOT EDIT.
// versions:
// sqlc v1.18.0
// source: deployment_events.sql
package query
import (
"context"
"database/sql"
"github.com/google/uuid"
)
const createDeploymentEvent = `-- name: CreateDeploymentEvent :one
INSERT INTO deployment_events (
user_id, deployment_id, event_type, message
) VALUES (
$1, $2, $3, $4
)
RETURNING id, created_at, user_id, deployment_id, message, event_type
`
type CreateDeploymentEventParams struct {
UserID uuid.NullUUID `json:"user_id"`
DeploymentID uuid.NullUUID `json:"deployment_id"`
EventType sql.NullString `json:"event_type"`
Message sql.NullString `json:"message"`
}
func (q *Queries) CreateDeploymentEvent(ctx context.Context, arg CreateDeploymentEventParams) (DeploymentEvent, error) {
row := q.db.QueryRow(ctx, createDeploymentEvent,
arg.UserID,
arg.DeploymentID,
arg.EventType,
arg.Message,
)
var i DeploymentEvent
err := row.Scan(
&i.ID,
&i.CreatedAt,
&i.UserID,
&i.DeploymentID,
&i.Message,
&i.EventType,
)
return i, err
}
const listDeploymentEvents = `-- name: ListDeploymentEvents :many
SELECT id, created_at, user_id, deployment_id, message, event_type FROM deployment_events
WHERE user_id = $1 and deployment_id = $2
ORDER BY created_at
`
type ListDeploymentEventsParams struct {
UserID uuid.NullUUID `json:"user_id"`
DeploymentID uuid.NullUUID `json:"deployment_id"`
}
func (q *Queries) ListDeploymentEvents(ctx context.Context, arg ListDeploymentEventsParams) ([]DeploymentEvent, error) {
rows, err := q.db.Query(ctx, listDeploymentEvents, arg.UserID, arg.DeploymentID)
if err != nil {
return nil, err
}
defer rows.Close()
var items []DeploymentEvent
for rows.Next() {
var i DeploymentEvent
if err := rows.Scan(
&i.ID,
&i.CreatedAt,
&i.UserID,
&i.DeploymentID,
&i.Message,
&i.EventType,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}
const listUserEvents = `-- name: ListUserEvents :many
SELECT id, created_at, user_id, deployment_id, message, event_type FROM deployment_events
WHERE user_id = $1
ORDER BY created_at
`
func (q *Queries) ListUserEvents(ctx context.Context, userID uuid.NullUUID) ([]DeploymentEvent, error) {
rows, err := q.db.Query(ctx, listUserEvents, userID)
if err != nil {
return nil, err
}
defer rows.Close()
var items []DeploymentEvent
for rows.Next() {
var i DeploymentEvent
if err := rows.Scan(
&i.ID,
&i.CreatedAt,
&i.UserID,
&i.DeploymentID,
&i.Message,
&i.EventType,
); err != nil {
return nil, err
}
items = append(items, i)
}
if err := rows.Err(); err != nil {
return nil, err
}
return items, nil
}