db

Oct 30, 2024

Changes in this version

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

type Connection

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

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

+ type ConnectionPool struct

+ 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 TableData

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

Jul 15, 2024

Changes in this version

type Connection

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

+ type Inserter struct

+ func NewInserter(db *Connection) *Inserter

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

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

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

Apr 1, 2024

Changes in this version

+ type Connection struct

+ func NewConnection(driverName DriverName, dsn string) *Connection

+ func (c *Connection) Close() error

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

+ type DataLoader struct

+ func NewDataLoader(conn *Connection) *DataLoader

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

+ type DriverName int

+ const DriverNamePostgres

+ const DriverNameUndefined

+ func CreateDriverName(name string) (DriverName, error)

+ func (n DriverName) String() string

+ type PGLoader struct

+ func NewPGLoader(conn *Connection) *PGLoader

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

+ type SchemaLoader interface

+ Load func(ctx context.Context) (*schema.Schema, error)

+ func CreateSchemaLoader(conn *Connection) (SchemaLoader, error)

+ type TableData []map[string]interface