fix: ignore close errors in tests and queries
This commit is contained in:
@@ -12,7 +12,7 @@ func TestRunMigrationsCreatesHotPathIndexes(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("open sqlite: %v", err)
|
t.Fatalf("open sqlite: %v", err)
|
||||||
}
|
}
|
||||||
defer sqlDB.Close()
|
defer func() { _ = sqlDB.Close() }()
|
||||||
sqlDB.SetMaxOpenConns(1)
|
sqlDB.SetMaxOpenConns(1)
|
||||||
|
|
||||||
if err := RunMigrations(sqlDB); err != nil {
|
if err := RunMigrations(sqlDB); err != nil {
|
||||||
|
|||||||
@@ -41,10 +41,10 @@ WHERE c.user_id = ?
|
|||||||
)
|
)
|
||||||
ORDER BY c.updated_at DESC
|
ORDER BY c.updated_at DESC
|
||||||
LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
|
LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer rows.Close()
|
defer func() { _ = rows.Close() }()
|
||||||
|
|
||||||
items := make([]GetContinueWatchingEntriesRow, 0, int(limit))
|
items := make([]GetContinueWatchingEntriesRow, 0, int(limit))
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
@@ -119,10 +119,10 @@ ORDER BY
|
|||||||
END,
|
END,
|
||||||
e.updated_at DESC
|
e.updated_at DESC
|
||||||
LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
|
LIMIT ?`, userID, needle, pattern, pattern, pattern, pattern, limit)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer rows.Close()
|
defer func() { _ = rows.Close() }()
|
||||||
|
|
||||||
items := make([]GetUserWatchListRow, 0, int(limit))
|
items := make([]GetUserWatchListRow, 0, int(limit))
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
|
|||||||
@@ -24,7 +24,7 @@ func (q *Queries) GetUserWatchlistAnimeIDs(ctx context.Context, userID string, a
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
defer rows.Close()
|
defer func() { _ = rows.Close() }()
|
||||||
|
|
||||||
matches := make([]int64, 0, len(animeIDs))
|
matches := make([]int64, 0, len(animeIDs))
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ func TestGetUserWatchlistAnimeIDsFiltersRequestedIDs(t *testing.T) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("open sqlite: %v", err)
|
t.Fatalf("open sqlite: %v", err)
|
||||||
}
|
}
|
||||||
defer sqlDB.Close()
|
defer func() { _ = sqlDB.Close() }()
|
||||||
|
|
||||||
_, err = sqlDB.Exec(`
|
_, err = sqlDB.Exec(`
|
||||||
CREATE TABLE watch_list_entry (
|
CREATE TABLE watch_list_entry (
|
||||||
|
|||||||
Reference in New Issue
Block a user