Skip to content

Commit 71fefa6

Browse files
committed
fix postgres scanner error
1 parent cad6a9f commit 71fefa6

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

postgres/repo_find.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,9 @@ func (f *finder[T]) Struct(ctx context.Context, args ...any) (*T, error) {
102102
}
103103

104104
result, err := pgx.CollectOneRow(rows, pgx.RowToStructByName[T])
105-
if err != nil {
105+
if errors.Is(err, pgx.ErrNoRows) {
106+
return nil, nil
107+
} else if err != nil {
106108
return nil, err
107109
}
108110

@@ -134,7 +136,9 @@ func (f *finder[T]) Structs(ctx context.Context, args ...any) ([]T, error) {
134136
}
135137

136138
results, err := pgx.CollectRows(rows, pgx.RowToStructByName[T])
137-
if err != nil {
139+
if errors.Is(err, pgx.ErrNoRows) {
140+
return nil, nil
141+
} else if err != nil {
138142
return nil, err
139143
}
140144

0 commit comments

Comments
 (0)