db.go

  1// Code generated by sqlc. DO NOT EDIT.
  2// versions:
  3//   sqlc v1.30.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.getAverageResponseTimeStmt, err = db.PrepareContext(ctx, getAverageResponseTime); err != nil {
 52		return nil, fmt.Errorf("error preparing query GetAverageResponseTime: %w", err)
 53	}
 54	if q.getFileStmt, err = db.PrepareContext(ctx, getFile); err != nil {
 55		return nil, fmt.Errorf("error preparing query GetFile: %w", err)
 56	}
 57	if q.getFileByPathAndSessionStmt, err = db.PrepareContext(ctx, getFileByPathAndSession); err != nil {
 58		return nil, fmt.Errorf("error preparing query GetFileByPathAndSession: %w", err)
 59	}
 60	if q.getFileReadStmt, err = db.PrepareContext(ctx, getFileRead); err != nil {
 61		return nil, fmt.Errorf("error preparing query GetFileRead: %w", err)
 62	}
 63	if q.getHourDayHeatmapStmt, err = db.PrepareContext(ctx, getHourDayHeatmap); err != nil {
 64		return nil, fmt.Errorf("error preparing query GetHourDayHeatmap: %w", err)
 65	}
 66	if q.getLastSessionStmt, err = db.PrepareContext(ctx, getLastSession); err != nil {
 67		return nil, fmt.Errorf("error preparing query GetLastSession: %w", err)
 68	}
 69	if q.getMessageStmt, err = db.PrepareContext(ctx, getMessage); err != nil {
 70		return nil, fmt.Errorf("error preparing query GetMessage: %w", err)
 71	}
 72	if q.getRecentActivityStmt, err = db.PrepareContext(ctx, getRecentActivity); err != nil {
 73		return nil, fmt.Errorf("error preparing query GetRecentActivity: %w", err)
 74	}
 75	if q.getSessionByIDStmt, err = db.PrepareContext(ctx, getSessionByID); err != nil {
 76		return nil, fmt.Errorf("error preparing query GetSessionByID: %w", err)
 77	}
 78	if q.getToolUsageStmt, err = db.PrepareContext(ctx, getToolUsage); err != nil {
 79		return nil, fmt.Errorf("error preparing query GetToolUsage: %w", err)
 80	}
 81	if q.getTotalStatsStmt, err = db.PrepareContext(ctx, getTotalStats); err != nil {
 82		return nil, fmt.Errorf("error preparing query GetTotalStats: %w", err)
 83	}
 84	if q.getUsageByDayStmt, err = db.PrepareContext(ctx, getUsageByDay); err != nil {
 85		return nil, fmt.Errorf("error preparing query GetUsageByDay: %w", err)
 86	}
 87	if q.getUsageByDayOfWeekStmt, err = db.PrepareContext(ctx, getUsageByDayOfWeek); err != nil {
 88		return nil, fmt.Errorf("error preparing query GetUsageByDayOfWeek: %w", err)
 89	}
 90	if q.getUsageByHourStmt, err = db.PrepareContext(ctx, getUsageByHour); err != nil {
 91		return nil, fmt.Errorf("error preparing query GetUsageByHour: %w", err)
 92	}
 93	if q.getUsageByModelStmt, err = db.PrepareContext(ctx, getUsageByModel); err != nil {
 94		return nil, fmt.Errorf("error preparing query GetUsageByModel: %w", err)
 95	}
 96	if q.listAllUserMessagesStmt, err = db.PrepareContext(ctx, listAllUserMessages); err != nil {
 97		return nil, fmt.Errorf("error preparing query ListAllUserMessages: %w", err)
 98	}
 99	if q.listFilesByPathStmt, err = db.PrepareContext(ctx, listFilesByPath); err != nil {
100		return nil, fmt.Errorf("error preparing query ListFilesByPath: %w", err)
101	}
102	if q.listFilesBySessionStmt, err = db.PrepareContext(ctx, listFilesBySession); err != nil {
103		return nil, fmt.Errorf("error preparing query ListFilesBySession: %w", err)
104	}
105	if q.listLatestSessionFilesStmt, err = db.PrepareContext(ctx, listLatestSessionFiles); err != nil {
106		return nil, fmt.Errorf("error preparing query ListLatestSessionFiles: %w", err)
107	}
108	if q.listMessagesBySessionStmt, err = db.PrepareContext(ctx, listMessagesBySession); err != nil {
109		return nil, fmt.Errorf("error preparing query ListMessagesBySession: %w", err)
110	}
111	if q.listNewFilesStmt, err = db.PrepareContext(ctx, listNewFiles); err != nil {
112		return nil, fmt.Errorf("error preparing query ListNewFiles: %w", err)
113	}
114	if q.listSessionReadFilesStmt, err = db.PrepareContext(ctx, listSessionReadFiles); err != nil {
115		return nil, fmt.Errorf("error preparing query ListSessionReadFiles: %w", err)
116	}
117	if q.listSessionsStmt, err = db.PrepareContext(ctx, listSessions); err != nil {
118		return nil, fmt.Errorf("error preparing query ListSessions: %w", err)
119	}
120	if q.listUserMessagesBySessionStmt, err = db.PrepareContext(ctx, listUserMessagesBySession); err != nil {
121		return nil, fmt.Errorf("error preparing query ListUserMessagesBySession: %w", err)
122	}
123	if q.recordFileReadStmt, err = db.PrepareContext(ctx, recordFileRead); err != nil {
124		return nil, fmt.Errorf("error preparing query RecordFileRead: %w", err)
125	}
126	if q.renameSessionStmt, err = db.PrepareContext(ctx, renameSession); err != nil {
127		return nil, fmt.Errorf("error preparing query RenameSession: %w", err)
128	}
129	if q.updateMessageStmt, err = db.PrepareContext(ctx, updateMessage); err != nil {
130		return nil, fmt.Errorf("error preparing query UpdateMessage: %w", err)
131	}
132	if q.updateSessionStmt, err = db.PrepareContext(ctx, updateSession); err != nil {
133		return nil, fmt.Errorf("error preparing query UpdateSession: %w", err)
134	}
135	if q.updateSessionModelsStmt, err = db.PrepareContext(ctx, updateSessionModels); err != nil {
136		return nil, fmt.Errorf("error preparing query UpdateSessionModels: %w", err)
137	}
138	if q.updateSessionTitleAndUsageStmt, err = db.PrepareContext(ctx, updateSessionTitleAndUsage); err != nil {
139		return nil, fmt.Errorf("error preparing query UpdateSessionTitleAndUsage: %w", err)
140	}
141	return &q, nil
142}
143
144func (q *Queries) Close() error {
145	var err error
146	if q.createFileStmt != nil {
147		if cerr := q.createFileStmt.Close(); cerr != nil {
148			err = fmt.Errorf("error closing createFileStmt: %w", cerr)
149		}
150	}
151	if q.createMessageStmt != nil {
152		if cerr := q.createMessageStmt.Close(); cerr != nil {
153			err = fmt.Errorf("error closing createMessageStmt: %w", cerr)
154		}
155	}
156	if q.createSessionStmt != nil {
157		if cerr := q.createSessionStmt.Close(); cerr != nil {
158			err = fmt.Errorf("error closing createSessionStmt: %w", cerr)
159		}
160	}
161	if q.deleteFileStmt != nil {
162		if cerr := q.deleteFileStmt.Close(); cerr != nil {
163			err = fmt.Errorf("error closing deleteFileStmt: %w", cerr)
164		}
165	}
166	if q.deleteMessageStmt != nil {
167		if cerr := q.deleteMessageStmt.Close(); cerr != nil {
168			err = fmt.Errorf("error closing deleteMessageStmt: %w", cerr)
169		}
170	}
171	if q.deleteSessionStmt != nil {
172		if cerr := q.deleteSessionStmt.Close(); cerr != nil {
173			err = fmt.Errorf("error closing deleteSessionStmt: %w", cerr)
174		}
175	}
176	if q.deleteSessionFilesStmt != nil {
177		if cerr := q.deleteSessionFilesStmt.Close(); cerr != nil {
178			err = fmt.Errorf("error closing deleteSessionFilesStmt: %w", cerr)
179		}
180	}
181	if q.deleteSessionMessagesStmt != nil {
182		if cerr := q.deleteSessionMessagesStmt.Close(); cerr != nil {
183			err = fmt.Errorf("error closing deleteSessionMessagesStmt: %w", cerr)
184		}
185	}
186	if q.getAverageResponseTimeStmt != nil {
187		if cerr := q.getAverageResponseTimeStmt.Close(); cerr != nil {
188			err = fmt.Errorf("error closing getAverageResponseTimeStmt: %w", cerr)
189		}
190	}
191	if q.getFileStmt != nil {
192		if cerr := q.getFileStmt.Close(); cerr != nil {
193			err = fmt.Errorf("error closing getFileStmt: %w", cerr)
194		}
195	}
196	if q.getFileByPathAndSessionStmt != nil {
197		if cerr := q.getFileByPathAndSessionStmt.Close(); cerr != nil {
198			err = fmt.Errorf("error closing getFileByPathAndSessionStmt: %w", cerr)
199		}
200	}
201	if q.getFileReadStmt != nil {
202		if cerr := q.getFileReadStmt.Close(); cerr != nil {
203			err = fmt.Errorf("error closing getFileReadStmt: %w", cerr)
204		}
205	}
206	if q.getHourDayHeatmapStmt != nil {
207		if cerr := q.getHourDayHeatmapStmt.Close(); cerr != nil {
208			err = fmt.Errorf("error closing getHourDayHeatmapStmt: %w", cerr)
209		}
210	}
211	if q.getLastSessionStmt != nil {
212		if cerr := q.getLastSessionStmt.Close(); cerr != nil {
213			err = fmt.Errorf("error closing getLastSessionStmt: %w", cerr)
214		}
215	}
216	if q.getMessageStmt != nil {
217		if cerr := q.getMessageStmt.Close(); cerr != nil {
218			err = fmt.Errorf("error closing getMessageStmt: %w", cerr)
219		}
220	}
221	if q.getRecentActivityStmt != nil {
222		if cerr := q.getRecentActivityStmt.Close(); cerr != nil {
223			err = fmt.Errorf("error closing getRecentActivityStmt: %w", cerr)
224		}
225	}
226	if q.getSessionByIDStmt != nil {
227		if cerr := q.getSessionByIDStmt.Close(); cerr != nil {
228			err = fmt.Errorf("error closing getSessionByIDStmt: %w", cerr)
229		}
230	}
231	if q.getToolUsageStmt != nil {
232		if cerr := q.getToolUsageStmt.Close(); cerr != nil {
233			err = fmt.Errorf("error closing getToolUsageStmt: %w", cerr)
234		}
235	}
236	if q.getTotalStatsStmt != nil {
237		if cerr := q.getTotalStatsStmt.Close(); cerr != nil {
238			err = fmt.Errorf("error closing getTotalStatsStmt: %w", cerr)
239		}
240	}
241	if q.getUsageByDayStmt != nil {
242		if cerr := q.getUsageByDayStmt.Close(); cerr != nil {
243			err = fmt.Errorf("error closing getUsageByDayStmt: %w", cerr)
244		}
245	}
246	if q.getUsageByDayOfWeekStmt != nil {
247		if cerr := q.getUsageByDayOfWeekStmt.Close(); cerr != nil {
248			err = fmt.Errorf("error closing getUsageByDayOfWeekStmt: %w", cerr)
249		}
250	}
251	if q.getUsageByHourStmt != nil {
252		if cerr := q.getUsageByHourStmt.Close(); cerr != nil {
253			err = fmt.Errorf("error closing getUsageByHourStmt: %w", cerr)
254		}
255	}
256	if q.getUsageByModelStmt != nil {
257		if cerr := q.getUsageByModelStmt.Close(); cerr != nil {
258			err = fmt.Errorf("error closing getUsageByModelStmt: %w", cerr)
259		}
260	}
261	if q.listAllUserMessagesStmt != nil {
262		if cerr := q.listAllUserMessagesStmt.Close(); cerr != nil {
263			err = fmt.Errorf("error closing listAllUserMessagesStmt: %w", cerr)
264		}
265	}
266	if q.listFilesByPathStmt != nil {
267		if cerr := q.listFilesByPathStmt.Close(); cerr != nil {
268			err = fmt.Errorf("error closing listFilesByPathStmt: %w", cerr)
269		}
270	}
271	if q.listFilesBySessionStmt != nil {
272		if cerr := q.listFilesBySessionStmt.Close(); cerr != nil {
273			err = fmt.Errorf("error closing listFilesBySessionStmt: %w", cerr)
274		}
275	}
276	if q.listLatestSessionFilesStmt != nil {
277		if cerr := q.listLatestSessionFilesStmt.Close(); cerr != nil {
278			err = fmt.Errorf("error closing listLatestSessionFilesStmt: %w", cerr)
279		}
280	}
281	if q.listMessagesBySessionStmt != nil {
282		if cerr := q.listMessagesBySessionStmt.Close(); cerr != nil {
283			err = fmt.Errorf("error closing listMessagesBySessionStmt: %w", cerr)
284		}
285	}
286	if q.listNewFilesStmt != nil {
287		if cerr := q.listNewFilesStmt.Close(); cerr != nil {
288			err = fmt.Errorf("error closing listNewFilesStmt: %w", cerr)
289		}
290	}
291	if q.listSessionReadFilesStmt != nil {
292		if cerr := q.listSessionReadFilesStmt.Close(); cerr != nil {
293			err = fmt.Errorf("error closing listSessionReadFilesStmt: %w", cerr)
294		}
295	}
296	if q.listSessionsStmt != nil {
297		if cerr := q.listSessionsStmt.Close(); cerr != nil {
298			err = fmt.Errorf("error closing listSessionsStmt: %w", cerr)
299		}
300	}
301	if q.listUserMessagesBySessionStmt != nil {
302		if cerr := q.listUserMessagesBySessionStmt.Close(); cerr != nil {
303			err = fmt.Errorf("error closing listUserMessagesBySessionStmt: %w", cerr)
304		}
305	}
306	if q.recordFileReadStmt != nil {
307		if cerr := q.recordFileReadStmt.Close(); cerr != nil {
308			err = fmt.Errorf("error closing recordFileReadStmt: %w", cerr)
309		}
310	}
311	if q.renameSessionStmt != nil {
312		if cerr := q.renameSessionStmt.Close(); cerr != nil {
313			err = fmt.Errorf("error closing renameSessionStmt: %w", cerr)
314		}
315	}
316	if q.updateMessageStmt != nil {
317		if cerr := q.updateMessageStmt.Close(); cerr != nil {
318			err = fmt.Errorf("error closing updateMessageStmt: %w", cerr)
319		}
320	}
321	if q.updateSessionStmt != nil {
322		if cerr := q.updateSessionStmt.Close(); cerr != nil {
323			err = fmt.Errorf("error closing updateSessionStmt: %w", cerr)
324		}
325	}
326	if q.updateSessionModelsStmt != nil {
327		if cerr := q.updateSessionModelsStmt.Close(); cerr != nil {
328			err = fmt.Errorf("error closing updateSessionModelsStmt: %w", cerr)
329		}
330	}
331	if q.updateSessionTitleAndUsageStmt != nil {
332		if cerr := q.updateSessionTitleAndUsageStmt.Close(); cerr != nil {
333			err = fmt.Errorf("error closing updateSessionTitleAndUsageStmt: %w", cerr)
334		}
335	}
336	return err
337}
338
339func (q *Queries) exec(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (sql.Result, error) {
340	switch {
341	case stmt != nil && q.tx != nil:
342		return q.tx.StmtContext(ctx, stmt).ExecContext(ctx, args...)
343	case stmt != nil:
344		return stmt.ExecContext(ctx, args...)
345	default:
346		return q.db.ExecContext(ctx, query, args...)
347	}
348}
349
350func (q *Queries) query(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (*sql.Rows, error) {
351	switch {
352	case stmt != nil && q.tx != nil:
353		return q.tx.StmtContext(ctx, stmt).QueryContext(ctx, args...)
354	case stmt != nil:
355		return stmt.QueryContext(ctx, args...)
356	default:
357		return q.db.QueryContext(ctx, query, args...)
358	}
359}
360
361func (q *Queries) queryRow(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) *sql.Row {
362	switch {
363	case stmt != nil && q.tx != nil:
364		return q.tx.StmtContext(ctx, stmt).QueryRowContext(ctx, args...)
365	case stmt != nil:
366		return stmt.QueryRowContext(ctx, args...)
367	default:
368		return q.db.QueryRowContext(ctx, query, args...)
369	}
370}
371
372type Queries struct {
373	db                             DBTX
374	tx                             *sql.Tx
375	createFileStmt                 *sql.Stmt
376	createMessageStmt              *sql.Stmt
377	createSessionStmt              *sql.Stmt
378	deleteFileStmt                 *sql.Stmt
379	deleteMessageStmt              *sql.Stmt
380	deleteSessionStmt              *sql.Stmt
381	deleteSessionFilesStmt         *sql.Stmt
382	deleteSessionMessagesStmt      *sql.Stmt
383	getAverageResponseTimeStmt     *sql.Stmt
384	getFileStmt                    *sql.Stmt
385	getFileByPathAndSessionStmt    *sql.Stmt
386	getFileReadStmt                *sql.Stmt
387	getHourDayHeatmapStmt          *sql.Stmt
388	getLastSessionStmt             *sql.Stmt
389	getMessageStmt                 *sql.Stmt
390	getRecentActivityStmt          *sql.Stmt
391	getSessionByIDStmt             *sql.Stmt
392	getToolUsageStmt               *sql.Stmt
393	getTotalStatsStmt              *sql.Stmt
394	getUsageByDayStmt              *sql.Stmt
395	getUsageByDayOfWeekStmt        *sql.Stmt
396	getUsageByHourStmt             *sql.Stmt
397	getUsageByModelStmt            *sql.Stmt
398	listAllUserMessagesStmt        *sql.Stmt
399	listFilesByPathStmt            *sql.Stmt
400	listFilesBySessionStmt         *sql.Stmt
401	listLatestSessionFilesStmt     *sql.Stmt
402	listMessagesBySessionStmt      *sql.Stmt
403	listNewFilesStmt               *sql.Stmt
404	listSessionReadFilesStmt       *sql.Stmt
405	listSessionsStmt               *sql.Stmt
406	listUserMessagesBySessionStmt  *sql.Stmt
407	recordFileReadStmt             *sql.Stmt
408	renameSessionStmt              *sql.Stmt
409	updateMessageStmt              *sql.Stmt
410	updateSessionStmt              *sql.Stmt
411	updateSessionModelsStmt        *sql.Stmt
412	updateSessionTitleAndUsageStmt *sql.Stmt
413}
414
415func (q *Queries) WithTx(tx *sql.Tx) *Queries {
416	return &Queries{
417		db:                             tx,
418		tx:                             tx,
419		createFileStmt:                 q.createFileStmt,
420		createMessageStmt:              q.createMessageStmt,
421		createSessionStmt:              q.createSessionStmt,
422		deleteFileStmt:                 q.deleteFileStmt,
423		deleteMessageStmt:              q.deleteMessageStmt,
424		deleteSessionStmt:              q.deleteSessionStmt,
425		deleteSessionFilesStmt:         q.deleteSessionFilesStmt,
426		deleteSessionMessagesStmt:      q.deleteSessionMessagesStmt,
427		getAverageResponseTimeStmt:     q.getAverageResponseTimeStmt,
428		getFileStmt:                    q.getFileStmt,
429		getFileByPathAndSessionStmt:    q.getFileByPathAndSessionStmt,
430		getFileReadStmt:                q.getFileReadStmt,
431		getHourDayHeatmapStmt:          q.getHourDayHeatmapStmt,
432		getLastSessionStmt:             q.getLastSessionStmt,
433		getMessageStmt:                 q.getMessageStmt,
434		getRecentActivityStmt:          q.getRecentActivityStmt,
435		getSessionByIDStmt:             q.getSessionByIDStmt,
436		getToolUsageStmt:               q.getToolUsageStmt,
437		getTotalStatsStmt:              q.getTotalStatsStmt,
438		getUsageByDayStmt:              q.getUsageByDayStmt,
439		getUsageByDayOfWeekStmt:        q.getUsageByDayOfWeekStmt,
440		getUsageByHourStmt:             q.getUsageByHourStmt,
441		getUsageByModelStmt:            q.getUsageByModelStmt,
442		listAllUserMessagesStmt:        q.listAllUserMessagesStmt,
443		listFilesByPathStmt:            q.listFilesByPathStmt,
444		listFilesBySessionStmt:         q.listFilesBySessionStmt,
445		listLatestSessionFilesStmt:     q.listLatestSessionFilesStmt,
446		listMessagesBySessionStmt:      q.listMessagesBySessionStmt,
447		listNewFilesStmt:               q.listNewFilesStmt,
448		listSessionReadFilesStmt:       q.listSessionReadFilesStmt,
449		listSessionsStmt:               q.listSessionsStmt,
450		listUserMessagesBySessionStmt:  q.listUserMessagesBySessionStmt,
451		recordFileReadStmt:             q.recordFileReadStmt,
452		renameSessionStmt:              q.renameSessionStmt,
453		updateMessageStmt:              q.updateMessageStmt,
454		updateSessionStmt:              q.updateSessionStmt,
455		updateSessionModelsStmt:        q.updateSessionModelsStmt,
456		updateSessionTitleAndUsageStmt: q.updateSessionTitleAndUsageStmt,
457	}
458}