db

Documentation

Index

• func LoadSchemasForPool(ctx context.Context, pool *ConnectionPool) (map[string]*schema.Schema, error)
• type Connection
  • func NewConnection(cfg config.Database) *Connection
  • func NewOpenedConnection(db *sqlx.DB) (*Connection, error)
  • func (c *Connection) Close() error
  • func (c *Connection) Connect(ctx context.Context) (*sqlx.DB, error)
  • func (c *Connection) Database() config.Database
  • func (c *Connection) Transact(ctx context.Context, fn func(context.Context) error) error
• type ConnectionPool
  • func NewConnectionPool() *ConnectionPool
  • func (p *ConnectionPool) Close() error
  • func (p *ConnectionPool) Get(name string) (*Connection, bool)
  • func (p *ConnectionPool) Setup(ds map[string]config.Database)
• type DataLoader
  • func NewDataLoader() *DataLoader
  • func (l *DataLoader) Load(ctx context.Context, conn *Connection, table string) (TableData, error)
• type Inserter
  • func NewInserter() *Inserter
  • func (i *Inserter) Insert(ctx context.Context, conn *Connection, table string, ...) (int64, error)
  • func (i *Inserter) Upsert(ctx context.Context, conn *Connection, table *schema.Table, ...) (int64, error)
• type PGLoader
  • func NewPGLoader() *PGLoader
  • func (l *PGLoader) Load(ctx context.Context, conn *Connection) (*schema.Schema, error)
• type SchemaLoader
• type TableData
  • func (d *TableData) FilterColumns(filter func(col string) bool) TableData
• type Transactioner

Functions

func LoadSchemasForPool

func LoadSchemasForPool(ctx context.Context, pool *ConnectionPool) (map[string]*schema.Schema, error)

Types

type Connection

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

func NewConnection

func NewConnection(cfg config.Database) *Connection

func NewOpenedConnection

func NewOpenedConnection(db *sqlx.DB) (*Connection, error)

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Connect

func (c *Connection) Connect(ctx context.Context) (*sqlx.DB, error)

func (*Connection) Database

func (c *Connection) Database() config.Database

func (*Connection) Transact

func (c *Connection) Transact(ctx context.Context, fn func(context.Context) error) error

type ConnectionPool

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

func NewConnectionPool

func NewConnectionPool() *ConnectionPool

func (*ConnectionPool) Close

func (p *ConnectionPool) Close() error

func (*ConnectionPool) Get

func (p *ConnectionPool) Get(name string) (*Connection, bool)

func (*ConnectionPool) Setup

func (p *ConnectionPool) Setup(ds map[string]config.Database)

type DataLoader

type DataLoader struct{}

func NewDataLoader

func NewDataLoader() *DataLoader

func (*DataLoader) Load

func (l *DataLoader) Load(ctx context.Context, conn *Connection, table string) (TableData, error)

type Inserter

type Inserter struct {
}

func NewInserter

func NewInserter() *Inserter

func (*Inserter) Insert

func (i *Inserter) Insert(
	ctx context.Context,
	conn *Connection,
	table string,
	dataset []map[string]interface{},
) (int64, error)

func (*Inserter) Upsert

func (i *Inserter) Upsert(
	ctx context.Context,
	conn *Connection,
	table *schema.Table,
	dataset []map[string]interface{},
) (int64, error)

type PGLoader

type PGLoader struct{}

func NewPGLoader

func NewPGLoader() *PGLoader

func (*PGLoader) Load

func (l *PGLoader) Load(ctx context.Context, conn *Connection) (*schema.Schema, error)

type SchemaLoader

type SchemaLoader interface {
	// Load database schema
	Load(ctx context.Context, conn *Connection) (*schema.Schema, error)
}

type TableData

type TableData []map[string]interface{}

func (*TableData) FilterColumns

func (d *TableData) FilterColumns(filter func(col string) bool) TableData

type Transactioner

type Transactioner func(context.Context, func(ctx context.Context) error) error