Added NoRowsInQuerySet func
This commit is contained in:
@@ -4,6 +4,7 @@ import (
|
|||||||
"context"
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
|
|
||||||
|
"github.com/jackc/pgx/v5"
|
||||||
"github.com/jackc/pgx/v5/pgconn"
|
"github.com/jackc/pgx/v5/pgconn"
|
||||||
"github.com/jackc/pgx/v5/pgxpool"
|
"github.com/jackc/pgx/v5/pgxpool"
|
||||||
)
|
)
|
||||||
@@ -27,17 +28,10 @@ func IsDuplicatedRow(err error) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// FIXME get an idea how this func should work
|
func NoRowsInQuerySet(err error) error {
|
||||||
// func NoRowsInQuerySet(err error) error {
|
if err == pgx.ErrNoRows {
|
||||||
// var pgErr *pgconn.PgError
|
return errors.New("no rows found")
|
||||||
|
}
|
||||||
|
|
||||||
// if errors.As(err, &pgErr) {
|
return nil
|
||||||
// fmt.Println("pgerr:", pgErr.Code)
|
}
|
||||||
// return errors.New("no rows selected")
|
|
||||||
// }
|
|
||||||
// // if err == pgconn. {
|
|
||||||
// // fmt.Println("No rows were found.")
|
|
||||||
// // }
|
|
||||||
|
|
||||||
// return nil
|
|
||||||
// }
|
|
||||||
|
|||||||
Reference in New Issue
Block a user