@@ -3,6 +3,7 @@ package cmd
3
3
import (
4
4
"context"
5
5
"database/sql"
6
+ "errors"
6
7
"fmt"
7
8
"log/slog"
8
9
"os"
@@ -75,6 +76,7 @@ func Verify(ctx context.Context, dir, filename string, opts *Options) error {
75
76
existing [qs .Name ] = qs
76
77
}
77
78
79
+ var verr error
78
80
for _ , qs := range previous .QuerySets {
79
81
// TODO: Create a function for this so that we can return early on errors
80
82
@@ -121,30 +123,31 @@ func Verify(ctx context.Context, dir, filename string, opts *Options) error {
121
123
}
122
124
defer db .Close ()
123
125
126
+ var qerr error
124
127
for _ , query := range codegen .Queries {
125
128
stmt , err := db .PrepareContext (ctx , query .Text )
126
129
if err != nil {
127
130
fmt .Fprintf (stderr , "Failed to prepare the following query:\n " )
128
131
fmt .Fprintf (stderr , "%s\n " , query .Text )
129
132
fmt .Fprintf (stderr , "Error was: %s\n " , err )
133
+ qerr = err
130
134
continue
131
135
}
132
136
if err := stmt .Close (); err != nil {
133
137
slog .Error ("stmt.Close failed" , "err" , err )
134
138
}
135
139
}
136
140
137
- return nil
141
+ return qerr
138
142
}
139
143
140
144
if err := check (); err != nil {
145
+ verr = errors .New ("errored" )
141
146
fmt .Fprintf (stderr , "FAIL\t %s\n " , qs .Name )
142
147
} else {
143
148
fmt .Fprintf (stderr , "ok\t %s\n " , qs .Name )
144
149
}
145
150
}
146
151
147
- // return fmt.Errorf("BREAKING CHANGES DETECTED")
148
-
149
- return nil
152
+ return verr
150
153
}
0 commit comments