1// Code generated by sqlc. DO NOT EDIT.
2// versions:
3// sqlc v1.27.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.createMessageStmt, err = db.PrepareContext(ctx, createMessage); err != nil {
28 return nil, fmt.Errorf("error preparing query CreateMessage: %w", err)
29 }
30 if q.createSessionStmt, err = db.PrepareContext(ctx, createSession); err != nil {
31 return nil, fmt.Errorf("error preparing query CreateSession: %w", err)
32 }
33 if q.deleteMessageStmt, err = db.PrepareContext(ctx, deleteMessage); err != nil {
34 return nil, fmt.Errorf("error preparing query DeleteMessage: %w", err)
35 }
36 if q.deleteSessionStmt, err = db.PrepareContext(ctx, deleteSession); err != nil {
37 return nil, fmt.Errorf("error preparing query DeleteSession: %w", err)
38 }
39 if q.deleteSessionMessagesStmt, err = db.PrepareContext(ctx, deleteSessionMessages); err != nil {
40 return nil, fmt.Errorf("error preparing query DeleteSessionMessages: %w", err)
41 }
42 if q.getMessageStmt, err = db.PrepareContext(ctx, getMessage); err != nil {
43 return nil, fmt.Errorf("error preparing query GetMessage: %w", err)
44 }
45 if q.getSessionByIDStmt, err = db.PrepareContext(ctx, getSessionByID); err != nil {
46 return nil, fmt.Errorf("error preparing query GetSessionByID: %w", err)
47 }
48 if q.listMessagesBySessionStmt, err = db.PrepareContext(ctx, listMessagesBySession); err != nil {
49 return nil, fmt.Errorf("error preparing query ListMessagesBySession: %w", err)
50 }
51 if q.listSessionsStmt, err = db.PrepareContext(ctx, listSessions); err != nil {
52 return nil, fmt.Errorf("error preparing query ListSessions: %w", err)
53 }
54 if q.updateMessageStmt, err = db.PrepareContext(ctx, updateMessage); err != nil {
55 return nil, fmt.Errorf("error preparing query UpdateMessage: %w", err)
56 }
57 if q.updateSessionStmt, err = db.PrepareContext(ctx, updateSession); err != nil {
58 return nil, fmt.Errorf("error preparing query UpdateSession: %w", err)
59 }
60 return &q, nil
61}
62
63func (q *Queries) Close() error {
64 var err error
65 if q.createMessageStmt != nil {
66 if cerr := q.createMessageStmt.Close(); cerr != nil {
67 err = fmt.Errorf("error closing createMessageStmt: %w", cerr)
68 }
69 }
70 if q.createSessionStmt != nil {
71 if cerr := q.createSessionStmt.Close(); cerr != nil {
72 err = fmt.Errorf("error closing createSessionStmt: %w", cerr)
73 }
74 }
75 if q.deleteMessageStmt != nil {
76 if cerr := q.deleteMessageStmt.Close(); cerr != nil {
77 err = fmt.Errorf("error closing deleteMessageStmt: %w", cerr)
78 }
79 }
80 if q.deleteSessionStmt != nil {
81 if cerr := q.deleteSessionStmt.Close(); cerr != nil {
82 err = fmt.Errorf("error closing deleteSessionStmt: %w", cerr)
83 }
84 }
85 if q.deleteSessionMessagesStmt != nil {
86 if cerr := q.deleteSessionMessagesStmt.Close(); cerr != nil {
87 err = fmt.Errorf("error closing deleteSessionMessagesStmt: %w", cerr)
88 }
89 }
90 if q.getMessageStmt != nil {
91 if cerr := q.getMessageStmt.Close(); cerr != nil {
92 err = fmt.Errorf("error closing getMessageStmt: %w", cerr)
93 }
94 }
95 if q.getSessionByIDStmt != nil {
96 if cerr := q.getSessionByIDStmt.Close(); cerr != nil {
97 err = fmt.Errorf("error closing getSessionByIDStmt: %w", cerr)
98 }
99 }
100 if q.listMessagesBySessionStmt != nil {
101 if cerr := q.listMessagesBySessionStmt.Close(); cerr != nil {
102 err = fmt.Errorf("error closing listMessagesBySessionStmt: %w", cerr)
103 }
104 }
105 if q.listSessionsStmt != nil {
106 if cerr := q.listSessionsStmt.Close(); cerr != nil {
107 err = fmt.Errorf("error closing listSessionsStmt: %w", cerr)
108 }
109 }
110 if q.updateMessageStmt != nil {
111 if cerr := q.updateMessageStmt.Close(); cerr != nil {
112 err = fmt.Errorf("error closing updateMessageStmt: %w", cerr)
113 }
114 }
115 if q.updateSessionStmt != nil {
116 if cerr := q.updateSessionStmt.Close(); cerr != nil {
117 err = fmt.Errorf("error closing updateSessionStmt: %w", cerr)
118 }
119 }
120 return err
121}
122
123func (q *Queries) exec(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (sql.Result, error) {
124 switch {
125 case stmt != nil && q.tx != nil:
126 return q.tx.StmtContext(ctx, stmt).ExecContext(ctx, args...)
127 case stmt != nil:
128 return stmt.ExecContext(ctx, args...)
129 default:
130 return q.db.ExecContext(ctx, query, args...)
131 }
132}
133
134func (q *Queries) query(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) (*sql.Rows, error) {
135 switch {
136 case stmt != nil && q.tx != nil:
137 return q.tx.StmtContext(ctx, stmt).QueryContext(ctx, args...)
138 case stmt != nil:
139 return stmt.QueryContext(ctx, args...)
140 default:
141 return q.db.QueryContext(ctx, query, args...)
142 }
143}
144
145func (q *Queries) queryRow(ctx context.Context, stmt *sql.Stmt, query string, args ...interface{}) *sql.Row {
146 switch {
147 case stmt != nil && q.tx != nil:
148 return q.tx.StmtContext(ctx, stmt).QueryRowContext(ctx, args...)
149 case stmt != nil:
150 return stmt.QueryRowContext(ctx, args...)
151 default:
152 return q.db.QueryRowContext(ctx, query, args...)
153 }
154}
155
156type Queries struct {
157 db DBTX
158 tx *sql.Tx
159 createMessageStmt *sql.Stmt
160 createSessionStmt *sql.Stmt
161 deleteMessageStmt *sql.Stmt
162 deleteSessionStmt *sql.Stmt
163 deleteSessionMessagesStmt *sql.Stmt
164 getMessageStmt *sql.Stmt
165 getSessionByIDStmt *sql.Stmt
166 listMessagesBySessionStmt *sql.Stmt
167 listSessionsStmt *sql.Stmt
168 updateMessageStmt *sql.Stmt
169 updateSessionStmt *sql.Stmt
170}
171
172func (q *Queries) WithTx(tx *sql.Tx) *Queries {
173 return &Queries{
174 db: tx,
175 tx: tx,
176 createMessageStmt: q.createMessageStmt,
177 createSessionStmt: q.createSessionStmt,
178 deleteMessageStmt: q.deleteMessageStmt,
179 deleteSessionStmt: q.deleteSessionStmt,
180 deleteSessionMessagesStmt: q.deleteSessionMessagesStmt,
181 getMessageStmt: q.getMessageStmt,
182 getSessionByIDStmt: q.getSessionByIDStmt,
183 listMessagesBySessionStmt: q.listMessagesBySessionStmt,
184 listSessionsStmt: q.listSessionsStmt,
185 updateMessageStmt: q.updateMessageStmt,
186 updateSessionStmt: q.updateSessionStmt,
187 }
188}