1// Code generated by sqlc. DO NOT EDIT.
2// versions:
3// sqlc v1.29.0
4
5package db
6
7import (
8 "context"
9 "database/sql"
10 "fmt"
11)
12
13type DBTX interface {
14 ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
15 PrepareContext(context.Context, string) (*sql.Stmt, error)
16 QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
17 QueryRowContext(context.Context, string, ...interface{}) *sql.Row
18}
19
20func New(db DBTX) *Queries {
21 return &Queries{db: db}
22}
23
24func Prepare(ctx context.Context, db DBTX) (*Queries, error) {
25 q := Queries{db: db}
26 var err error
27 if q.createFileStmt, err = db.PrepareContext(ctx, createFile); err != nil {
28 return nil, fmt.Errorf("error preparing query CreateFile: %w", err)
29 }
30 if q.createMessageStmt, err = db.PrepareContext(ctx, createMessage); err != nil {
31 return nil, fmt.Errorf("error preparing query CreateMessage: %w", err)
32 }
33 if q.createSessionStmt, err = db.PrepareContext(ctx, createSession); err != nil {
34 return nil, fmt.Errorf("error preparing query CreateSession: %w", err)
35 }
36 if q.deleteFileStmt, err = db.PrepareContext(ctx, deleteFile); err != nil {
37 return nil, fmt.Errorf("error preparing query DeleteFile: %w", err)
38 }
39 if q.deleteMessageStmt, err = db.PrepareContext(ctx, deleteMessage); err != nil {
40 return nil, fmt.Errorf("error preparing query DeleteMessage: %w", err)
41 }
42 if q.deleteSessionStmt, err = db.PrepareContext(ctx, deleteSession); err != nil {
43 return nil, fmt.Errorf("error preparing query DeleteSession: %w", err)
44 }
45 if q.deleteSessionFilesStmt, err = db.PrepareContext(ctx, deleteSessionFiles); err != nil {
46 return nil, fmt.Errorf("error preparing query DeleteSessionFiles: %w", err)
47 }
48 if q.deleteSessionMessagesStmt, err = db.PrepareContext(ctx, deleteSessionMessages); err != nil {
49 return nil, fmt.Errorf("error preparing query DeleteSessionMessages: %w", err)
50 }
51 if q.getFileStmt, err = db.PrepareContext(ctx, getFile); err != nil {
52 return nil, fmt.Errorf("error preparing query GetFile: %w", err)
53 }
54 if q.getFileByPathAndSessionStmt, err = db.PrepareContext(ctx, getFileByPathAndSession); err != nil {
55 return nil, fmt.Errorf("error preparing query GetFileByPathAndSession: %w", err)
56 }
57 if q.getMessageStmt, err = db.PrepareContext(ctx, getMessage); err != nil {
58 return nil, fmt.Errorf("error preparing query GetMessage: %w", err)
59 }
60 if q.getSessionByIDStmt, err = db.PrepareContext(ctx, getSessionByID); err != nil {
61 return nil, fmt.Errorf("error preparing query GetSessionByID: %w", err)
62 }
63 if q.listFilesByPathStmt, err = db.PrepareContext(ctx, listFilesByPath); err != nil {
64 return nil, fmt.Errorf("error preparing query ListFilesByPath: %w", err)
65 }
66 if q.listFilesBySessionStmt, err = db.PrepareContext(ctx, listFilesBySession); err != nil {
67 return nil, fmt.Errorf("error preparing query ListFilesBySession: %w", err)
68 }
69 if q.listLatestSessionFilesStmt, err = db.PrepareContext(ctx, listLatestSessionFiles); err != nil {
70 return nil, fmt.Errorf("error preparing query ListLatestSessionFiles: %w", err)
71 }
72 if q.listMessagesBySessionStmt, err = db.PrepareContext(ctx, listMessagesBySession); err != nil {
73 return nil, fmt.Errorf("error preparing query ListMessagesBySession: %w", err)
74 }
75 if q.listNewFilesStmt, err = db.PrepareContext(ctx, listNewFiles); err != nil {
76 return nil, fmt.Errorf("error preparing query ListNewFiles: %w", err)
77 }
78 if q.listSessionsStmt, err = db.PrepareContext(ctx, listSessions); err != nil {
79 return nil, fmt.Errorf("error preparing query ListSessions: %w", err)
80 }
81 if q.updateFileStmt, err = db.PrepareContext(ctx, updateFile); err != nil {
82 return nil, fmt.Errorf("error preparing query UpdateFile: %w", err)
83 }
84 if q.updateMessageStmt, err = db.PrepareContext(ctx, updateMessage); err != nil {
85 return nil, fmt.Errorf("error preparing query UpdateMessage: %w", err)
86 }
87 if q.updateSessionStmt, err = db.PrepareContext(ctx, updateSession); err != nil {
88 return nil, fmt.Errorf("error preparing query UpdateSession: %w", err)
89 }
90 return &q, nil
91}
92
93func (q *Queries) Close() error {
94 var err error
95 if q.createFileStmt != nil {
96 if cerr := q.createFileStmt.Close(); cerr != nil {
97 err = fmt.Errorf("error closing createFileStmt: %w", cerr)
98 }
99 }
100 if q.createMessageStmt != nil {
101 if cerr := q.createMessageStmt.Close(); cerr != nil {
102 err = fmt.Errorf("error closing createMessageStmt: %w", cerr)
103 }
104 }
105 if q.createSessionStmt != nil {
106 if cerr := q.createSessionStmt.Close(); cerr != nil {
107 err = fmt.Errorf("error closing createSessionStmt: %w", cerr)
108 }
109 }
110 if q.deleteFileStmt != nil {
111 if cerr := q.deleteFileStmt.Close(); cerr != nil {
112 err = fmt.Errorf("error closing deleteFileStmt: %w", cerr)
113 }
114 }
115 if q.deleteMessageStmt != nil {
116 if cerr := q.deleteMessageStmt.Close(); cerr != nil {
117 err = fmt.Errorf("error closing deleteMessageStmt: %w", cerr)
118 }
119 }
120 if q.deleteSessionStmt != nil {
121 if cerr := q.deleteSessionStmt.Close(); cerr != nil {
122 err = fmt.Errorf("error closing deleteSessionStmt: %w", cerr)
123 }
124 }
125 if q.deleteSessionFilesStmt != nil {
126 if cerr := q.deleteSessionFilesStmt.Close(); cerr != nil {
127 err = fmt.Errorf("error closing deleteSessionFilesStmt: %w", cerr)
128 }
129 }
130 if q.deleteSessionMessagesStmt != nil {
131 if cerr := q.deleteSessionMessagesStmt.Close(); cerr != nil {
132 err = fmt.Errorf("error closing deleteSessionMessagesStmt: %w", cerr)
133 }
134 }
135 if q.getFileStmt != nil {
136 if cerr := q.getFileStmt.Close(); cerr != nil {
137 err = fmt.Errorf("error closing getFileStmt: %w", cerr)
138 }
139 }
140 if q.getFileByPathAndSessionStmt != nil {
141 if cerr := q.getFileByPathAndSessionStmt.Close(); cerr != nil {
142 err = fmt.Errorf("error closing getFileByPathAndSessionStmt: %w", cerr)
143 }
144 }
145 if q.getMessageStmt != nil {
146 if cerr := q.getMessageStmt.Close(); cerr != nil {
147 err = fmt.Errorf("error closing getMessageStmt: %w", cerr)
148 }
149 }
150 if q.getSessionByIDStmt != nil {
151 if cerr := q.getSessionByIDStmt.Close(); cerr != nil {
152 err = fmt.Errorf("error closing getSessionByIDStmt: %w", cerr)
153 }
154 }
155 if q.listFilesByPathStmt != nil {
156 if cerr := q.listFilesByPathStmt.Close(); cerr != nil {
157 err = fmt.Errorf("error closing listFilesByPathStmt: %w", cerr)
158 }
159 }
160 if q.listFilesBySessionStmt != nil {
161 if cerr := q.listFilesBySessionStmt.Close(); cerr != nil {
162 err = fmt.Errorf("error closing listFilesBySessionStmt: %w", cerr)
163 }
164 }
165 if q.listLatestSessionFilesStmt != nil {
166 if cerr := q.listLatestSessionFilesStmt.Close(); cerr != nil {
167 err = fmt.Errorf("error closing listLatestSessionFilesStmt: %w", cerr)
168 }
169 }
170 if q.listMessagesBySessionStmt != nil {
171 if cerr := q.listMessagesBySessionStmt.Close(); cerr != nil {
172 err = fmt.Errorf("error closing listMessagesBySessionStmt: %w", cerr)
173 }
174 }
175 if q.listNewFilesStmt != nil {
176 if cerr := q.listNewFilesStmt.Close(); cerr != nil {
177 err = fmt.Errorf("error closing listNewFilesStmt: %w", cerr)
178 }
179 }
180 if q.listSessionsStmt != nil {
181 if cerr := q.listSessionsStmt.Close(); cerr != nil {
182 err = fmt.Errorf("error closing listSessionsStmt: %w", cerr)
183 }
184 }
185 if q.updateFileStmt != nil {
186 if cerr := q.updateFileStmt.Close(); cerr != nil {
187 err = fmt.Errorf("error closing updateFileStmt: %w", cerr)
188 }
189 }
190 if q.updateMessageStmt != nil {
191 if cerr := q.updateMessageStmt.Close(); cerr != nil {
192 err = fmt.Errorf("error closing updateMessageStmt: %w", cerr)
193 }
194 }
195 if q.updateSessionStmt != nil {
196 if cerr := q.updateSessionStmt.Close(); cerr != nil {
197 err = fmt.Errorf("error closing updateSessionStmt: %w", cerr)
198 }
199 }
200 return err
201}
202
203func (q *Queries) exec(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (sql.Result, error) {
204 switch {
205 case stmt != nil && q.tx != nil:
206 return q.tx.StmtContext(ctx, stmt).ExecContext(ctx, args...)
207 case stmt != nil:
208 return stmt.ExecContext(ctx, args...)
209 default:
210 return q.db.ExecContext(ctx, query, args...)
211 }
212}
213
214func (q *Queries) query(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (*sql.Rows, error) {
215 switch {
216 case stmt != nil && q.tx != nil:
217 return q.tx.StmtContext(ctx, stmt).QueryContext(ctx, args...)
218 case stmt != nil:
219 return stmt.QueryContext(ctx, args...)
220 default:
221 return q.db.QueryContext(ctx, query, args...)
222 }
223}
224
225func (q *Queries) queryRow(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) *sql.Row {
226 switch {
227 case stmt != nil && q.tx != nil:
228 return q.tx.StmtContext(ctx, stmt).QueryRowContext(ctx, args...)
229 case stmt != nil:
230 return stmt.QueryRowContext(ctx, args...)
231 default:
232 return q.db.QueryRowContext(ctx, query, args...)
233 }
234}
235
236type Queries struct {
237 db DBTX
238 tx *sql.Tx
239 createFileStmt *sql.Stmt
240 createMessageStmt *sql.Stmt
241 createSessionStmt *sql.Stmt
242 deleteFileStmt *sql.Stmt
243 deleteMessageStmt *sql.Stmt
244 deleteSessionStmt *sql.Stmt
245 deleteSessionFilesStmt *sql.Stmt
246 deleteSessionMessagesStmt *sql.Stmt
247 getFileStmt *sql.Stmt
248 getFileByPathAndSessionStmt *sql.Stmt
249 getMessageStmt *sql.Stmt
250 getSessionByIDStmt *sql.Stmt
251 listFilesByPathStmt *sql.Stmt
252 listFilesBySessionStmt *sql.Stmt
253 listLatestSessionFilesStmt *sql.Stmt
254 listMessagesBySessionStmt *sql.Stmt
255 listNewFilesStmt *sql.Stmt
256 listSessionsStmt *sql.Stmt
257 updateFileStmt *sql.Stmt
258 updateMessageStmt *sql.Stmt
259 updateSessionStmt *sql.Stmt
260}
261
262func (q *Queries) WithTx(tx *sql.Tx) *Queries {
263 return &Queries{
264 db: tx,
265 tx: tx,
266 createFileStmt: q.createFileStmt,
267 createMessageStmt: q.createMessageStmt,
268 createSessionStmt: q.createSessionStmt,
269 deleteFileStmt: q.deleteFileStmt,
270 deleteMessageStmt: q.deleteMessageStmt,
271 deleteSessionStmt: q.deleteSessionStmt,
272 deleteSessionFilesStmt: q.deleteSessionFilesStmt,
273 deleteSessionMessagesStmt: q.deleteSessionMessagesStmt,
274 getFileStmt: q.getFileStmt,
275 getFileByPathAndSessionStmt: q.getFileByPathAndSessionStmt,
276 getMessageStmt: q.getMessageStmt,
277 getSessionByIDStmt: q.getSessionByIDStmt,
278 listFilesByPathStmt: q.listFilesByPathStmt,
279 listFilesBySessionStmt: q.listFilesBySessionStmt,
280 listLatestSessionFilesStmt: q.listLatestSessionFilesStmt,
281 listMessagesBySessionStmt: q.listMessagesBySessionStmt,
282 listNewFilesStmt: q.listNewFilesStmt,
283 listSessionsStmt: q.listSessionsStmt,
284 updateFileStmt: q.updateFileStmt,
285 updateMessageStmt: q.updateMessageStmt,
286 updateSessionStmt: q.updateSessionStmt,
287 }
288}