Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dede386e8b | |||
| 7fa00f323f |
@@ -1,23 +1,14 @@
|
|||||||
package postgresql
|
package postgresql
|
||||||
|
|
||||||
|
// DB Operations helper
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
|
||||||
"errors"
|
"errors"
|
||||||
|
|
||||||
"github.com/jackc/pgx/v5"
|
"github.com/jackc/pgx/v5"
|
||||||
"github.com/jackc/pgx/v5/pgconn"
|
"github.com/jackc/pgx/v5/pgconn"
|
||||||
"github.com/jackc/pgx/v5/pgxpool"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func Connect(connStr string) (*pgxpool.Pool, error) {
|
|
||||||
pool, err := pgxpool.New(context.Background(), connStr)
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return pool, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func IsDuplicatedRow(err error) error {
|
func IsDuplicatedRow(err error) error {
|
||||||
var pgErr *pgconn.PgError
|
var pgErr *pgconn.PgError
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user