pgbase

Documentation

Index

• Variables
• func CreateAndMigrateTestDatabase(t *testing.T, ctx context.Context) *pgxpool.Pool
• func GenerateFakeUser(t *testing.T, fake *faker.Faker) user.User
• type Repository
  • func NewRepository(pool *pgxpool.Pool) *Repository
  • func (r *Repository) QueryTx(domain string, operation string, query string, args pgx.NamedArgs) error
  • func (r *Repository) Rollback(ctx context.Context, tx pgx.Tx, domain string, operation string)
  • func (r *Repository) RowExistsByQuery(query string, queryParams ...any) (bool, error)

Variables

var (
	FullTextSearchReplacer = strings.NewReplacer("/", " ", ".", " ")
)

Functions

func CreateAndMigrateTestDatabase

func CreateAndMigrateTestDatabase(t *testing.T, ctx context.Context) *pgxpool.Pool

func GenerateFakeUser

func GenerateFakeUser(t *testing.T, fake *faker.Faker) user.User

Types

type Repository

type Repository struct {
	Pool *pgxpool.Pool
}

Repository provides a PostgreSQL persistence layer.

func NewRepository

func NewRepository(pool *pgxpool.Pool) *Repository

NewRepository initializes and returns a PostgreSQL Repository.

func (*Repository) QueryTx

func (r *Repository) QueryTx(domain string, operation string, query string, args pgx.NamedArgs) error

func (*Repository) Rollback

func (r *Repository) Rollback(ctx context.Context, tx pgx.Tx, domain string, operation string)

func (*Repository) RowExistsByQuery

func (r *Repository) RowExistsByQuery(query string, queryParams ...any) (bool, error)