db

Documentation

Index

• func CommitPrepared(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error
• func Connect(ctx context.Context, conf *config.DB) (*sqlx.DB, error)
• func CreateUser(ctx context.Context, dbConn NamedExecutorContext, user *User) error
• func Disconnect(ctx context.Context, dbConn *sqlx.DB) error
• func PrepareTransaction(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error
• func RollbackPrepared(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error
• type NamedExecutorContext
• type User

Functions

func CommitPrepared

func CommitPrepared(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error

func Connect

func Connect(ctx context.Context, conf *config.DB) (*sqlx.DB, error)

Connect creates new db connection.

func CreateUser

func CreateUser(ctx context.Context, dbConn NamedExecutorContext, user *User) error

func Disconnect

func Disconnect(ctx context.Context, dbConn *sqlx.DB) error

Disconnect drops db connection.

func PrepareTransaction

func PrepareTransaction(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error

func RollbackPrepared

func RollbackPrepared(ctx context.Context, dbConn sqlx.ExecerContext, txID string) error

Types

type NamedExecutorContext

type NamedExecutorContext interface {
	NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
}

type User

type User struct {
	CreatedAt time.Time `db:"created_at"`
	Name      string    `db:"name"`
	ID        uuid.UUID `db:"id"`
}