Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| fb2ba22f72 | |||
| dede386e8b | |||
| 7fa00f323f |
@@ -1,23 +1,14 @@
|
||||
package postgresql
|
||||
|
||||
// Jackc/pgx helper
|
||||
|
||||
import (
|
||||
"context"
|
||||
"errors"
|
||||
|
||||
"github.com/jackc/pgx/v5"
|
||||
"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 {
|
||||
var pgErr *pgconn.PgError
|
||||
|
||||
|
||||
@@ -1,5 +1,7 @@
|
||||
package rabbitmq
|
||||
|
||||
// rabbitmq/amqp091-go helper
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
"encoding/json"
|
||||
|
||||
Reference in New Issue
Block a user