database

Documentation

Index

• Variables
• func DoMigration(logger logging.Logger, dbURL, devDbURL *url.URL, DesiredURLs []*url.URL) error
• func GetDatabaseURL(env config.Env) (*url.URL, error)
• func GetDevDatabaseURL(env config.Env) (*url.URL, error)
• func GetSchemaURL() []*url.URL
• type Database
  • func NewDatabase(lx fx.Lifecycle, logger logging.Logger, env config.Env) (*Database, repository.DBTX)
  • func (db Database) Begin(ctx context.Context) (pgx.Tx, error)
  • func (db Database) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
  • func (db Database) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
  • func (db Database) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
• type Tx
  • func (tx *Tx) Begin(ctx context.Context) (pgx.Tx, error)
  • func (tx *Tx) Commit(ctx context.Context) error
  • func (tx *Tx) Conn() *pgx.Conn
  • func (tx *Tx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)
  • func (tx *Tx) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)
  • func (tx *Tx) LargeObjects() pgx.LargeObjects
  • func (tx *Tx) Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error)
  • func (tx *Tx) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
  • func (tx *Tx) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
  • func (tx *Tx) Rollback(ctx context.Context) error
  • func (tx *Tx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

Variables

var Module = fx.Provide(NewDatabase)

Functions

func DoMigration

func DoMigration(logger logging.Logger, dbURL, devDbURL *url.URL, DesiredURLs []*url.URL) error

func GetDatabaseURL

func GetDatabaseURL(env config.Env) (*url.URL, error)

func GetDevDatabaseURL

func GetDevDatabaseURL(env config.Env) (*url.URL, error)

func GetSchemaURL

func GetSchemaURL() []*url.URL

GetSchemaURL Add in v2, get value from ENV

Types

type Database

type Database struct {
	// contains filtered or unexported fields
}

Database structure

func NewDatabase

func NewDatabase(lx fx.Lifecycle, logger logging.Logger, env config.Env) (*Database, repository.DBTX)

NewDatabase Saves a new database instance

func (Database) Begin

func (db Database) Begin(ctx context.Context) (pgx.Tx, error)

func (Database) Exec

func (db Database) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

func (Database) Query

func (db Database) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

func (Database) QueryRow

func (db Database) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

type Tx

type Tx struct {
	// contains filtered or unexported fields
}

func (*Tx) Begin

func (tx *Tx) Begin(ctx context.Context) (pgx.Tx, error)

func (*Tx) Commit

func (tx *Tx) Commit(ctx context.Context) error

func (*Tx) Conn

func (tx *Tx) Conn() *pgx.Conn

func (*Tx) CopyFrom

func (tx *Tx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)

func (*Tx) Exec

func (tx *Tx) Exec(ctx context.Context, sql string, args ...interface{}) (pgconn.CommandTag, error)

func (*Tx) LargeObjects

func (tx *Tx) LargeObjects() pgx.LargeObjects

func (*Tx) Prepare

func (tx *Tx) Prepare(ctx context.Context, name string, sql string) (*pgconn.StatementDescription, error)

func (*Tx) Query

func (tx *Tx) Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)

func (*Tx) QueryRow

func (tx *Tx) QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row

func (*Tx) Rollback

func (tx *Tx) Rollback(ctx context.Context) error

func (*Tx) SendBatch

func (tx *Tx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults