diff --git a/sqlite3.go b/sqlite3.go
index f5699e4..cbe3964 100644
--- a/sqlite3.go
+++ b/sqlite3.go
@@ -772,7 +772,7 @@ func (s *SQLiteStmt) query(ctx context.Context, args []namedValue) (driver.Rows,
 			select {
 			case <-rows.done:
 			default:
-				C.sqlite3_interrupt(s.c.db)
+				C.sqlite3_interrupt(db)
 				rows.Close()
 			}
 		case <-rows.done: