1// Code generated by sqlc. DO NOT EDIT.
2// versions:
3// sqlc v1.22.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.getSessionStatsStmt, err = db.PrepareContext(ctx, getSessionStats); err != nil {
64 return nil, fmt.Errorf("error preparing query GetSessionStats: %w", err)
65 }
66 if q.getSessionStatsByDayStmt, err = db.PrepareContext(ctx, getSessionStatsByDay); err != nil {
67 return nil, fmt.Errorf("error preparing query GetSessionStatsByDay: %w", err)
68 }
69 if q.getSessionStatsByMonthStmt, err = db.PrepareContext(ctx, getSessionStatsByMonth); err != nil {
70 return nil, fmt.Errorf("error preparing query GetSessionStatsByMonth: %w", err)
71 }
72 if q.getSessionStatsByWeekStmt, err = db.PrepareContext(ctx, getSessionStatsByWeek); err != nil {
73 return nil, fmt.Errorf("error preparing query GetSessionStatsByWeek: %w", err)
74 }
75 if q.listAllSessionsStmt, err = db.PrepareContext(ctx, listAllSessions); err != nil {
76 return nil, fmt.Errorf("error preparing query ListAllSessions: %w", err)
77 }
78 if q.listChildSessionsStmt, err = db.PrepareContext(ctx, listChildSessions); err != nil {
79 return nil, fmt.Errorf("error preparing query ListChildSessions: %w", err)
80 }
81 if q.listFilesByPathStmt, err = db.PrepareContext(ctx, listFilesByPath); err != nil {
82 return nil, fmt.Errorf("error preparing query ListFilesByPath: %w", err)
83 }
84 if q.listFilesBySessionStmt, err = db.PrepareContext(ctx, listFilesBySession); err != nil {
85 return nil, fmt.Errorf("error preparing query ListFilesBySession: %w", err)
86 }
87 if q.listLatestSessionFilesStmt, err = db.PrepareContext(ctx, listLatestSessionFiles); err != nil {
88 return nil, fmt.Errorf("error preparing query ListLatestSessionFiles: %w", err)
89 }
90 if q.listMessagesBySessionStmt, err = db.PrepareContext(ctx, listMessagesBySession); err != nil {
91 return nil, fmt.Errorf("error preparing query ListMessagesBySession: %w", err)
92 }
93 if q.listNewFilesStmt, err = db.PrepareContext(ctx, listNewFiles); err != nil {
94 return nil, fmt.Errorf("error preparing query ListNewFiles: %w", err)
95 }
96 if q.listSessionsStmt, err = db.PrepareContext(ctx, listSessions); err != nil {
97 return nil, fmt.Errorf("error preparing query ListSessions: %w", err)
98 }
99 if q.searchSessionsByTextStmt, err = db.PrepareContext(ctx, searchSessionsByText); err != nil {
100 return nil, fmt.Errorf("error preparing query SearchSessionsByText: %w", err)
101 }
102 if q.searchSessionsByTitleStmt, err = db.PrepareContext(ctx, searchSessionsByTitle); err != nil {
103 return nil, fmt.Errorf("error preparing query SearchSessionsByTitle: %w", err)
104 }
105 if q.searchSessionsByTitleAndTextStmt, err = db.PrepareContext(ctx, searchSessionsByTitleAndText); err != nil {
106 return nil, fmt.Errorf("error preparing query SearchSessionsByTitleAndText: %w", err)
107 }
108 if q.updateMessageStmt, err = db.PrepareContext(ctx, updateMessage); err != nil {
109 return nil, fmt.Errorf("error preparing query UpdateMessage: %w", err)
110 }
111 if q.updateSessionStmt, err = db.PrepareContext(ctx, updateSession); err != nil {
112 return nil, fmt.Errorf("error preparing query UpdateSession: %w", err)
113 }
114 return &q, nil
115}
116
117func (q *Queries) Close() error {
118 var err error
119 if q.createFileStmt != nil {
120 if cerr := q.createFileStmt.Close(); cerr != nil {
121 err = fmt.Errorf("error closing createFileStmt: %w", cerr)
122 }
123 }
124 if q.createMessageStmt != nil {
125 if cerr := q.createMessageStmt.Close(); cerr != nil {
126 err = fmt.Errorf("error closing createMessageStmt: %w", cerr)
127 }
128 }
129 if q.createSessionStmt != nil {
130 if cerr := q.createSessionStmt.Close(); cerr != nil {
131 err = fmt.Errorf("error closing createSessionStmt: %w", cerr)
132 }
133 }
134 if q.deleteFileStmt != nil {
135 if cerr := q.deleteFileStmt.Close(); cerr != nil {
136 err = fmt.Errorf("error closing deleteFileStmt: %w", cerr)
137 }
138 }
139 if q.deleteMessageStmt != nil {
140 if cerr := q.deleteMessageStmt.Close(); cerr != nil {
141 err = fmt.Errorf("error closing deleteMessageStmt: %w", cerr)
142 }
143 }
144 if q.deleteSessionStmt != nil {
145 if cerr := q.deleteSessionStmt.Close(); cerr != nil {
146 err = fmt.Errorf("error closing deleteSessionStmt: %w", cerr)
147 }
148 }
149 if q.deleteSessionFilesStmt != nil {
150 if cerr := q.deleteSessionFilesStmt.Close(); cerr != nil {
151 err = fmt.Errorf("error closing deleteSessionFilesStmt: %w", cerr)
152 }
153 }
154 if q.deleteSessionMessagesStmt != nil {
155 if cerr := q.deleteSessionMessagesStmt.Close(); cerr != nil {
156 err = fmt.Errorf("error closing deleteSessionMessagesStmt: %w", cerr)
157 }
158 }
159 if q.getFileStmt != nil {
160 if cerr := q.getFileStmt.Close(); cerr != nil {
161 err = fmt.Errorf("error closing getFileStmt: %w", cerr)
162 }
163 }
164 if q.getFileByPathAndSessionStmt != nil {
165 if cerr := q.getFileByPathAndSessionStmt.Close(); cerr != nil {
166 err = fmt.Errorf("error closing getFileByPathAndSessionStmt: %w", cerr)
167 }
168 }
169 if q.getMessageStmt != nil {
170 if cerr := q.getMessageStmt.Close(); cerr != nil {
171 err = fmt.Errorf("error closing getMessageStmt: %w", cerr)
172 }
173 }
174 if q.getSessionByIDStmt != nil {
175 if cerr := q.getSessionByIDStmt.Close(); cerr != nil {
176 err = fmt.Errorf("error closing getSessionByIDStmt: %w", cerr)
177 }
178 }
179 if q.getSessionStatsStmt != nil {
180 if cerr := q.getSessionStatsStmt.Close(); cerr != nil {
181 err = fmt.Errorf("error closing getSessionStatsStmt: %w", cerr)
182 }
183 }
184 if q.getSessionStatsByDayStmt != nil {
185 if cerr := q.getSessionStatsByDayStmt.Close(); cerr != nil {
186 err = fmt.Errorf("error closing getSessionStatsByDayStmt: %w", cerr)
187 }
188 }
189 if q.getSessionStatsByMonthStmt != nil {
190 if cerr := q.getSessionStatsByMonthStmt.Close(); cerr != nil {
191 err = fmt.Errorf("error closing getSessionStatsByMonthStmt: %w", cerr)
192 }
193 }
194 if q.getSessionStatsByWeekStmt != nil {
195 if cerr := q.getSessionStatsByWeekStmt.Close(); cerr != nil {
196 err = fmt.Errorf("error closing getSessionStatsByWeekStmt: %w", cerr)
197 }
198 }
199 if q.listAllSessionsStmt != nil {
200 if cerr := q.listAllSessionsStmt.Close(); cerr != nil {
201 err = fmt.Errorf("error closing listAllSessionsStmt: %w", cerr)
202 }
203 }
204 if q.listChildSessionsStmt != nil {
205 if cerr := q.listChildSessionsStmt.Close(); cerr != nil {
206 err = fmt.Errorf("error closing listChildSessionsStmt: %w", cerr)
207 }
208 }
209 if q.listFilesByPathStmt != nil {
210 if cerr := q.listFilesByPathStmt.Close(); cerr != nil {
211 err = fmt.Errorf("error closing listFilesByPathStmt: %w", cerr)
212 }
213 }
214 if q.listFilesBySessionStmt != nil {
215 if cerr := q.listFilesBySessionStmt.Close(); cerr != nil {
216 err = fmt.Errorf("error closing listFilesBySessionStmt: %w", cerr)
217 }
218 }
219 if q.listLatestSessionFilesStmt != nil {
220 if cerr := q.listLatestSessionFilesStmt.Close(); cerr != nil {
221 err = fmt.Errorf("error closing listLatestSessionFilesStmt: %w", cerr)
222 }
223 }
224 if q.listMessagesBySessionStmt != nil {
225 if cerr := q.listMessagesBySessionStmt.Close(); cerr != nil {
226 err = fmt.Errorf("error closing listMessagesBySessionStmt: %w", cerr)
227 }
228 }
229 if q.listNewFilesStmt != nil {
230 if cerr := q.listNewFilesStmt.Close(); cerr != nil {
231 err = fmt.Errorf("error closing listNewFilesStmt: %w", cerr)
232 }
233 }
234 if q.listSessionsStmt != nil {
235 if cerr := q.listSessionsStmt.Close(); cerr != nil {
236 err = fmt.Errorf("error closing listSessionsStmt: %w", cerr)
237 }
238 }
239 if q.searchSessionsByTextStmt != nil {
240 if cerr := q.searchSessionsByTextStmt.Close(); cerr != nil {
241 err = fmt.Errorf("error closing searchSessionsByTextStmt: %w", cerr)
242 }
243 }
244 if q.searchSessionsByTitleStmt != nil {
245 if cerr := q.searchSessionsByTitleStmt.Close(); cerr != nil {
246 err = fmt.Errorf("error closing searchSessionsByTitleStmt: %w", cerr)
247 }
248 }
249 if q.searchSessionsByTitleAndTextStmt != nil {
250 if cerr := q.searchSessionsByTitleAndTextStmt.Close(); cerr != nil {
251 err = fmt.Errorf("error closing searchSessionsByTitleAndTextStmt: %w", cerr)
252 }
253 }
254 if q.updateMessageStmt != nil {
255 if cerr := q.updateMessageStmt.Close(); cerr != nil {
256 err = fmt.Errorf("error closing updateMessageStmt: %w", cerr)
257 }
258 }
259 if q.updateSessionStmt != nil {
260 if cerr := q.updateSessionStmt.Close(); cerr != nil {
261 err = fmt.Errorf("error closing updateSessionStmt: %w", cerr)
262 }
263 }
264 return err
265}
266
267func (q *Queries) exec(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (sql.Result, error) {
268 switch {
269 case stmt != nil && q.tx != nil:
270 return q.tx.StmtContext(ctx, stmt).ExecContext(ctx, args...)
271 case stmt != nil:
272 return stmt.ExecContext(ctx, args...)
273 default:
274 return q.db.ExecContext(ctx, query, args...)
275 }
276}
277
278func (q *Queries) query(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (*sql.Rows, error) {
279 switch {
280 case stmt != nil && q.tx != nil:
281 return q.tx.StmtContext(ctx, stmt).QueryContext(ctx, args...)
282 case stmt != nil:
283 return stmt.QueryContext(ctx, args...)
284 default:
285 return q.db.QueryContext(ctx, query, args...)
286 }
287}
288
289func (q *Queries) queryRow(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) *sql.Row {
290 switch {
291 case stmt != nil && q.tx != nil:
292 return q.tx.StmtContext(ctx, stmt).QueryRowContext(ctx, args...)
293 case stmt != nil:
294 return stmt.QueryRowContext(ctx, args...)
295 default:
296 return q.db.QueryRowContext(ctx, query, args...)
297 }
298}
299
300type Queries struct {
301 db DBTX
302 tx *sql.Tx
303 createFileStmt *sql.Stmt
304 createMessageStmt *sql.Stmt
305 createSessionStmt *sql.Stmt
306 deleteFileStmt *sql.Stmt
307 deleteMessageStmt *sql.Stmt
308 deleteSessionStmt *sql.Stmt
309 deleteSessionFilesStmt *sql.Stmt
310 deleteSessionMessagesStmt *sql.Stmt
311 getFileStmt *sql.Stmt
312 getFileByPathAndSessionStmt *sql.Stmt
313 getMessageStmt *sql.Stmt
314 getSessionByIDStmt *sql.Stmt
315 getSessionStatsStmt *sql.Stmt
316 getSessionStatsByDayStmt *sql.Stmt
317 getSessionStatsByMonthStmt *sql.Stmt
318 getSessionStatsByWeekStmt *sql.Stmt
319 listAllSessionsStmt *sql.Stmt
320 listChildSessionsStmt *sql.Stmt
321 listFilesByPathStmt *sql.Stmt
322 listFilesBySessionStmt *sql.Stmt
323 listLatestSessionFilesStmt *sql.Stmt
324 listMessagesBySessionStmt *sql.Stmt
325 listNewFilesStmt *sql.Stmt
326 listSessionsStmt *sql.Stmt
327 searchSessionsByTextStmt *sql.Stmt
328 searchSessionsByTitleStmt *sql.Stmt
329 searchSessionsByTitleAndTextStmt *sql.Stmt
330 updateMessageStmt *sql.Stmt
331 updateSessionStmt *sql.Stmt
332}
333
334func (q *Queries) WithTx(tx *sql.Tx) *Queries {
335 return &Queries{
336 db: tx,
337 tx: tx,
338 createFileStmt: q.createFileStmt,
339 createMessageStmt: q.createMessageStmt,
340 createSessionStmt: q.createSessionStmt,
341 deleteFileStmt: q.deleteFileStmt,
342 deleteMessageStmt: q.deleteMessageStmt,
343 deleteSessionStmt: q.deleteSessionStmt,
344 deleteSessionFilesStmt: q.deleteSessionFilesStmt,
345 deleteSessionMessagesStmt: q.deleteSessionMessagesStmt,
346 getFileStmt: q.getFileStmt,
347 getFileByPathAndSessionStmt: q.getFileByPathAndSessionStmt,
348 getMessageStmt: q.getMessageStmt,
349 getSessionByIDStmt: q.getSessionByIDStmt,
350 getSessionStatsStmt: q.getSessionStatsStmt,
351 getSessionStatsByDayStmt: q.getSessionStatsByDayStmt,
352 getSessionStatsByMonthStmt: q.getSessionStatsByMonthStmt,
353 getSessionStatsByWeekStmt: q.getSessionStatsByWeekStmt,
354 listAllSessionsStmt: q.listAllSessionsStmt,
355 listChildSessionsStmt: q.listChildSessionsStmt,
356 listFilesByPathStmt: q.listFilesByPathStmt,
357 listFilesBySessionStmt: q.listFilesBySessionStmt,
358 listLatestSessionFilesStmt: q.listLatestSessionFilesStmt,
359 listMessagesBySessionStmt: q.listMessagesBySessionStmt,
360 listNewFilesStmt: q.listNewFilesStmt,
361 listSessionsStmt: q.listSessionsStmt,
362 searchSessionsByTextStmt: q.searchSessionsByTextStmt,
363 searchSessionsByTitleStmt: q.searchSessionsByTitleStmt,
364 searchSessionsByTitleAndTextStmt: q.searchSessionsByTitleAndTextStmt,
365 updateMessageStmt: q.updateMessageStmt,
366 updateSessionStmt: q.updateSessionStmt,
367 }
368}