@@ -102,11 +102,11 @@ func test_sqlx_DB(db *sqlx.DB) {
102
102
db .Select (& user5 , "SELECT * FROM users WHERE id = 1" ) // $ source
103
103
}
104
104
105
- func test_sqlx_Tx ( tx * sqlx.Tx ) {
106
- example , err := tx .Query ("SELECT * FROM users" ) // $ source
105
+ func test_sqlx_NamedStmt ( stmt * sqlx.NamedStmt ) {
106
+ example , err := stmt .Query ("SELECT * FROM users" ) // $ source
107
107
ignore (example , err )
108
108
109
- rows , err := tx .Queryx ("SELECT * FROM users" ) // $ source
109
+ rows , err := stmt .Queryx ("SELECT * FROM users" ) // $ source
110
110
111
111
if err != nil {
112
112
return
@@ -136,7 +136,7 @@ func test_sqlx_Tx(tx *sqlx.Tx) {
136
136
sink (user ) // $ hasTaintFlow="user"
137
137
}
138
138
139
- row := tx .QueryRowx ("SELECT * FROM users WHERE id = 1" ) // $ source
139
+ row := stmt .QueryRowx ("SELECT * FROM users WHERE id = 1" ) // $ source
140
140
141
141
userMap := make (map [string ]interface {})
142
142
row .MapScan (userMap )
@@ -149,19 +149,13 @@ func test_sqlx_Tx(tx *sqlx.Tx) {
149
149
sink (user ) // $ hasTaintFlow="user"
150
150
151
151
var user2 User
152
- tx .Get (& user2 , "SELECT * FROM users WHERE id = 1" ) // $ source
152
+ stmt .Get (& user2 , "SELECT * FROM users WHERE id = 1" ) // $ source
153
153
154
154
var user3 User
155
- tx .GetContext (nil , & user3 , "SELECT * FROM users WHERE id = 1" ) // $ source
155
+ stmt .GetContext (nil , & user3 , "SELECT * FROM users WHERE id = 1" ) // $ source
156
156
157
157
var user4 User
158
- rows , err = tx .NamedQuery ("SELECT * FROM users WHERE id = :id" , map [string ]any {"id" : 1 }) // $ source
159
- ignore (err )
160
- rows .StructScan (& user4 )
161
- sink (user4 ) // $ hasTaintFlow="user4"
162
-
163
- var user5 User
164
- tx .Select (& user5 , "SELECT * FROM users WHERE id = 1" ) // $ source
158
+ stmt .Select (& user4 , "SELECT * FROM users WHERE id = 1" ) // $ source
165
159
}
166
160
167
161
func test_sqlx_Stmt (stmt * sqlx.Stmt ) {
@@ -220,11 +214,11 @@ func test_sqlx_Stmt(stmt *sqlx.Stmt) {
220
214
stmt .Select (& user4 , "SELECT * FROM users WHERE id = 1" ) // $ source
221
215
}
222
216
223
- func test_sqlx_NamedStmt ( stmt * sqlx.NamedStmt ) {
224
- example , err := stmt .Query ("SELECT * FROM users" ) // $ source
217
+ func test_sqlx_Tx ( tx * sqlx.Tx ) {
218
+ example , err := tx .Query ("SELECT * FROM users" ) // $ source
225
219
ignore (example , err )
226
220
227
- rows , err := stmt .Queryx ("SELECT * FROM users" ) // $ source
221
+ rows , err := tx .Queryx ("SELECT * FROM users" ) // $ source
228
222
229
223
if err != nil {
230
224
return
@@ -254,7 +248,7 @@ func test_sqlx_NamedStmt(stmt *sqlx.NamedStmt) {
254
248
sink (user ) // $ hasTaintFlow="user"
255
249
}
256
250
257
- row := stmt .QueryRowx ("SELECT * FROM users WHERE id = 1" ) // $ source
251
+ row := tx .QueryRowx ("SELECT * FROM users WHERE id = 1" ) // $ source
258
252
259
253
userMap := make (map [string ]interface {})
260
254
row .MapScan (userMap )
@@ -267,11 +261,17 @@ func test_sqlx_NamedStmt(stmt *sqlx.NamedStmt) {
267
261
sink (user ) // $ hasTaintFlow="user"
268
262
269
263
var user2 User
270
- stmt .Get (& user2 , "SELECT * FROM users WHERE id = 1" ) // $ source
264
+ tx .Get (& user2 , "SELECT * FROM users WHERE id = 1" ) // $ source
271
265
272
266
var user3 User
273
- stmt .GetContext (nil , & user3 , "SELECT * FROM users WHERE id = 1" ) // $ source
267
+ tx .GetContext (nil , & user3 , "SELECT * FROM users WHERE id = 1" ) // $ source
274
268
275
269
var user4 User
276
- stmt .Select (& user4 , "SELECT * FROM users WHERE id = 1" ) // $ source
270
+ rows , err = tx .NamedQuery ("SELECT * FROM users WHERE id = :id" , map [string ]any {"id" : 1 }) // $ source
271
+ ignore (err )
272
+ rows .StructScan (& user4 )
273
+ sink (user4 ) // $ hasTaintFlow="user4"
274
+
275
+ var user5 User
276
+ tx .Select (& user5 , "SELECT * FROM users WHERE id = 1" ) // $ source
277
277
}
0 commit comments