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