Compare commits

..

2 Commits

Author SHA1 Message Date
fb2ba22f72 Update: 2025-10-27 14:57:21 +01:00
dede386e8b Fixes 2025-10-27 13:54:11 +01:00
2 changed files with 3 additions and 23 deletions

View File

@@ -1,36 +1,14 @@
package postgresql
// Wrapper around jackx/pgx pool
// Jackc/pgx helper
import (
"context"
"errors"
"github.com/jackc/pgx/v5"
"github.com/jackc/pgx/v5/pgconn"
"github.com/jackc/pgx/v5/pgxpool"
)
type Database struct {
*pgxpool.Pool
}
func NewDB(connStr string) *Database {
db := &Database{}
db.Connect(connStr)
return db
}
func (db *Database) 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

View File

@@ -1,5 +1,7 @@
package rabbitmq
// rabbitmq/amqp091-go helper
import (
"bytes"
"encoding/json"