pg

func (GorpMigrationQ) Delete ¶

func (q GorpMigrationQ) Delete(gm *data.GorpMigration) error

Delete deletes the GorpMigration from the database.

func (GorpMigrationQ) DeleteCtx ¶

func (q GorpMigrationQ) DeleteCtx(ctx context.Context, gm *data.GorpMigration) error

DeleteCtx deletes the GorpMigration from the database.

func (GorpMigrationQ) GorpMigrationByID ¶

func (q GorpMigrationQ) GorpMigrationByID(id string, isForUpdate bool) (*data.GorpMigration, error)

GorpMigrationByID retrieves a row from 'public.gorp_migrations' as a GorpMigration.

Generated from index 'gorp_migrations_pkey'.

func (GorpMigrationQ) GorpMigrationByIDCtx ¶

func (q GorpMigrationQ) GorpMigrationByIDCtx(ctx context.Context, id string, isForUpdate bool) (*data.GorpMigration, error)

GorpMigrationByIDCtx retrieves a row from 'public.gorp_migrations' as a GorpMigration.

Generated from index 'gorp_migrations_pkey'.

func (GorpMigrationQ) Insert ¶

func (q GorpMigrationQ) Insert(gm *data.GorpMigration) error

Insert insert a GorpMigration to the database.

func (GorpMigrationQ) InsertCtx ¶

func (q GorpMigrationQ) InsertCtx(ctx context.Context, gm *data.GorpMigration) error

InsertCtx inserts a GorpMigration to the database.

func (GorpMigrationQ) Update ¶

func (q GorpMigrationQ) Update(gm *data.GorpMigration) error

Update updates a GorpMigration in the database.

func (GorpMigrationQ) UpdateCtx ¶

func (q GorpMigrationQ) UpdateCtx(ctx context.Context, gm *data.GorpMigration) error

UpdateCtx updates a GorpMigration in the database.

func (GorpMigrationQ) Upsert ¶

func (q GorpMigrationQ) Upsert(gm *data.GorpMigration) error

Upsert performs an upsert for GorpMigration.

func (GorpMigrationQ) UpsertCtx ¶

func (q GorpMigrationQ) UpsertCtx(ctx context.Context, gm *data.GorpMigration) error

UpsertCtx performs an upsert for GorpMigration.

func (*Storage) Clone ¶

func (s *Storage) Clone() data.Storage

Clone - returns new storage with clone of db

func (*Storage) DB ¶

func (s *Storage) DB() *pgdb.DB

DB - returns db used by Storage

func (Storage) GorpMigrationQ ¶

func (s Storage) GorpMigrationQ() data.GorpMigrationQ

GorpMigrationQ - creates new instance of GorpMigrationQ

func (*Storage) Transaction ¶

func (s *Storage) Transaction(tx func() error) error

Transaction begins a transaction on repo.

func (Storage) TransactionQ ¶

func (s Storage) TransactionQ() data.TransactionQ

TransactionQ - creates new instance of TransactionQ

func (TransactionQ) Delete ¶

func (q TransactionQ) Delete(t *data.Transaction) error

Delete deletes the Transaction from the database.

func (TransactionQ) DeleteCtx ¶

func (q TransactionQ) DeleteCtx(ctx context.Context, t *data.Transaction) error

DeleteCtx deletes the Transaction from the database.

func (TransactionQ) Insert ¶

func (q TransactionQ) Insert(t *data.Transaction) error

Insert insert a Transaction to the database.

func (TransactionQ) InsertCtx ¶

func (q TransactionQ) InsertCtx(ctx context.Context, t *data.Transaction) error

InsertCtx inserts a Transaction to the database.

func (TransactionQ) Select ¶

func (q TransactionQ) Select(ctx context.Context) ([]data.Transaction, error)

func (TransactionQ) SelectWithLimit ¶ added in v1.0.7

func (q TransactionQ) SelectWithLimit(ctx context.Context, limit uint64) ([]data.Transaction, error)

func (TransactionQ) TransactionByID ¶

func (q TransactionQ) TransactionByID(id int64, isForUpdate bool) (*data.Transaction, error)

TransactionByID retrieves a row from 'public.transactions' as a Transaction.

Generated from index 'transactions_pkey'.

func (TransactionQ) TransactionByIDCtx ¶

func (q TransactionQ) TransactionByIDCtx(ctx context.Context, id int64, isForUpdate bool) (*data.Transaction, error)

TransactionByIDCtx retrieves a row from 'public.transactions' as a Transaction.

Generated from index 'transactions_pkey'.

func (TransactionQ) Update ¶

func (q TransactionQ) Update(t *data.Transaction) error

Update updates a Transaction in the database.

func (TransactionQ) UpdateCtx ¶

func (q TransactionQ) UpdateCtx(ctx context.Context, t *data.Transaction) error

UpdateCtx updates a Transaction in the database.

func (TransactionQ) Upsert ¶

func (q TransactionQ) Upsert(t *data.Transaction) error

Upsert performs an upsert for Transaction.

func (TransactionQ) UpsertCtx ¶

func (q TransactionQ) UpsertCtx(ctx context.Context, t *data.Transaction) error

UpsertCtx performs an upsert for Transaction.