Skip to content

Commit 36ae3db

Browse files
committed
Add single statement prepared query
Uses forked sqlc with sqlc-dev/sqlc#3136
1 parent daf288d commit 36ae3db

File tree

3 files changed

+204
-2
lines changed

3 files changed

+204
-2
lines changed

‎internal/fileid/pattern.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,8 @@ func RefreshFiles(db *sql.DB, files []string) error {
5858
}
5959
l.Info("start inserting files")
6060
ctx := context.Background()
61-
q, err := sqlc.Prepare(ctx, db)
62-
if err != nil {
61+
q := sqlc.New(db)
62+
if err := q.PrepareInsertEpisodeFile(ctx); err != nil {
6363
return fmt.Errorf("refresh files: %w", err)
6464
}
6565
defer q.Close()

‎internal/query/episodefile.go‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,8 @@ type EpisodeFile struct {
2929
}
3030

3131
// InsertEpisodeFile inserts episode files into the database.
32+
// The caller should pre-emptively prepare
33+
// [sqlc.Queries.PrepareInsertEpisodeFile] for performance.
3234
func InsertEpisodeFiles(ctx context.Context, q *sqlc.Queries, l *slog.Logger, efs []EpisodeFile) error {
3335
for _, ef := range efs {
3436
p := sqlc.InsertEpisodeFileParams{

‎internal/sqlc/db.go‎

Lines changed: 200 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)